- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 561 for Pods (0.04 sec)
-
pkg/kubelet/util/sliceutils/sliceutils_test.go
fooTests := []struct { pods PodsByCreationTime i int j int }{ {buildPodsByCreationTime(), 0, 1}, {buildPodsByCreationTime(), 2, 1}, } for _, fooTest := range fooTests { fooi := fooTest.pods[fooTest.i] fooj := fooTest.pods[fooTest.j] fooTest.pods.Swap(fooTest.i, fooTest.j) if fooi.GetName() != fooTest.pods[fooTest.j].GetName() || fooj.GetName() != fooTest.pods[fooTest.i].GetName() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 13 08:27:42 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/client/tests/fake_client_test.go
} wrongPod, err := tc.CoreV1().Pods("nsB").Get(context.TODO(), "pod-1", metav1.GetOptions{}) if err == nil { t.Fatalf("Pods.Get: expected nsB/pod-1 not to match, but it matched %s/%s", wrongPod.Namespace, wrongPod.Name) } allPods, err := tc.CoreV1().Pods(metav1.NamespaceAll).List(context.TODO(), metav1.ListOptions{}) if err != nil { t.Fatalf("Pods.List: %s", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 08 17:30:21 UTC 2020 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/api/policy/v1/generated.proto
// all pods within the namespace. // +patchStrategy=replace // +optional optional .k8s.io.apimachinery.pkg.apis.meta.v1.LabelSelector selector = 2; // An eviction is allowed if at most "maxUnavailable" pods selected by // "selector" are unavailable after the eviction, i.e. even in absence of // the evicted pod. For example, one can prevent all voluntary evictions
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 8K bytes - Viewed (0) -
samples/external/README.md
see errors such as 404s, HTTPS connection problems, and TCP connection problems. If ServiceEntries are misconfigured pods may see problems with server names. ## Try it out After an operator runs `kubectl create -f aptget.yaml` pods will be able to succeed with `apt-get update` and `apt-get install`. After an operator runs `kubectl create -f github.yaml` pods will be able to
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 27 18:28:55 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager_test.go
updates := append(expectedPods, mirrorPod) podManager, _ := newTestManager() podManager.SetPods(updates) // Tests that all regular pods are recorded correctly. actualPods := podManager.GetPods() if len(actualPods) != len(expectedPods) { t.Errorf("expected %d pods, got %d pods; expected pods %#v, got pods %#v", len(expectedPods), len(actualPods), expectedPods, actualPods) } for _, expected := range expectedPods { found := false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 12 16:57:27 UTC 2023 - 5.4K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
return pod.Status.StartTime } // Assumed pods and bound pods that haven't started don't have a StartTime yet. return &metav1.Time{Time: time.Now()} } // GetEarliestPodStartTime returns the earliest start time of all pods that // have the highest priority among all victims. func GetEarliestPodStartTime(victims *extenderv1.Victims) *metav1.Time { if len(victims.Pods) == 0 { // should not reach here.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/scheduler/internal/cache/debugger/comparer.go
} // ComparePods compares actual pods with cached pods. func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*framework.NodeInfo) (missed, redundant []string) { actual := []string{} for _, pod := range pods { actual = append(actual, string(pod.UID)) } cached := []string{} for _, nodeinfo := range nodeinfos { for _, p := range nodeinfo.Pods { cached = append(cached, string(p.Pod.UID))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1alpha1.go
} // List returns information about the resources assigned to pods on the node func (p *v1alpha1PodResourcesServer) List(ctx context.Context, req *v1alpha1.ListPodResourcesRequest) (*v1alpha1.ListPodResourcesResponse, error) { metrics.PodResourcesEndpointRequestsTotalCount.WithLabelValues("v1alpha1").Inc() pods := p.podsProvider.GetPods() podResources := make([]*v1alpha1.PodResources, len(pods)) p.devicesProvider.UpdateAllocatedDevices()
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/kubelet/apis/podresources/types.go
// DevicesProvider knows how to provide the devices used by the given container type DevicesProvider interface { // UpdateAllocatedDevices frees any Devices that are bound to terminated pods. UpdateAllocatedDevices() // GetDevices returns information about the devices assigned to pods and containers GetDevices(podUID, containerName string) []*podresourcesapi.ContainerDevices // GetAllocatableDevices returns information about all the devices known to the manager
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/config/http.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 07:19:44 UTC 2021 - 4.1K bytes - Viewed (0)