- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for podresourcesv1 (0.34 sec)
-
pkg/kubelet/apis/podresources/server_v1.go
} } for _, container := range pod.Spec.Containers { podResources.Containers = append(podResources.Containers, p.getContainerResources(pod, &container)) } response := &podresourcesv1.GetPodResourcesResponse{ PodResources: podResources, } return response, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 13:00:09 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1alpha1_test.go
limitations under the License. */ package podresources import ( "context" "testing" "go.uber.org/mock/gomock" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" podresourcesv1 "k8s.io/kubelet/pkg/apis/podresources/v1" "k8s.io/kubelet/pkg/apis/podresources/v1alpha1" podresourcetest "k8s.io/kubernetes/pkg/kubelet/apis/podresources/testing" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1_test.go
}) } } func equalListResponse(respA, respB *podresourcesapi.ListPodResourcesResponse) bool { if len(respA.PodResources) != len(respB.PodResources) { return false } for idx := 0; idx < len(respA.PodResources); idx++ { podResA := respA.PodResources[idx] podResB := respB.PodResources[idx] if podResA.Name != podResB.Name { return false } if podResA.Namespace != podResB.Namespace {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1alpha1.go
See the License for the specific language governing permissions and limitations under the License. */ package podresources import ( "context" "k8s.io/kubernetes/pkg/kubelet/metrics" "k8s.io/kubelet/pkg/apis/podresources/v1" "k8s.io/kubelet/pkg/apis/podresources/v1alpha1" ) // v1alpha1PodResourcesServer implements PodResourcesListerServer type v1alpha1PodResourcesServer struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:01 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/api/v1/resource/helpers_test.go
}{ { pod: getPod("foo", podResources{cpuRequest: "9"}), resourceName: v1.ResourceCPU, expectedValue: 9000, }, { pod: getPod("foo", podResources{memoryRequest: "90Mi"}), resourceName: v1.ResourceMemory, expectedValue: 94371840, }, { cName: "just-overhead for cpu", pod: getPod("foo", podResources{cpuOverhead: "5", memoryOverhead: "5"}),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:13 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/constants.go
limitations under the License. */ package podresources const ( // Socket is the name of the podresources server socket Socket = "kubelet" // DefaultQPS is determined by empirically reviewing known consumers of the API. // It's at least unlikely that there is a legitimate need to query podresources // more than 100 times per second, the other subsystems are not guaranteed to react
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 07:22:23 UTC 2023 - 1.1K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager.go
// might need to unprepare resources. PodMightNeedToUnprepareResources(UID types.UID) bool // Implements the PodResources Provider API podresources.CPUsProvider podresources.DevicesProvider podresources.MemoryProvider podresources.DynamicResourcesProvider } type NodeConfig struct { NodeName types.NodeName RuntimeCgroupsName string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:13 UTC 2024 - 9K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/client.go
limitations under the License. */ package podresources import ( "context" "fmt" "time" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" "k8s.io/cri-client/pkg/util" "k8s.io/kubelet/pkg/apis/podresources/v1" "k8s.io/kubelet/pkg/apis/podresources/v1alpha1" ) // Note: Consumers of the pod resources API should not be importing this package.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 2.5K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/types.go
*/ //go:generate mockgen -source=types.go -destination=testing/provider_mock.go -package=testing DevicesProvider,PodsProvider,CPUsProvider,MemoryProvider package podresources import ( v1 "k8s.io/api/core/v1" podresourcesapi "k8s.io/kubelet/pkg/apis/podresources/v1" ) // DevicesProvider knows how to provide the devices used by the given container type DevicesProvider interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:04 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/kubelet/server/server.go
// ListenAndServePodResources initializes a gRPC server to serve the PodResources service func ListenAndServePodResources(endpoint string, providers podresources.PodResourcesProviders) { server := grpc.NewServer(apisgrpc.WithRateLimiter("podresources", podresources.DefaultQPS, podresources.DefaultBurstTokens)) podresourcesapiv1alpha1.RegisterPodResourcesListerServer(server, podresources.NewV1alpha1PodResourcesServer(providers))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0)