- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 550 for pfds (0.28 sec)
-
pkg/kubelet/container/runtime_cache.go
return err } r.pods, r.cacheTime = pods, timestamp return nil } // getPodsWithTimestamp records a timestamp and retrieves pods from the getter. func (r *runtimeCache) getPodsWithTimestamp(ctx context.Context) ([]*Pod, time.Time, error) { // Always record the timestamp before getting the pods to avoid stale pods. timestamp := time.Now() pods, err := r.getter.GetPods(ctx, false) return pods, timestamp, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 09 04:03:51 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kube/kclient/index_test.go
NodeName: "node", }, } assertIndex := func(k SaNode, pods ...*corev1.Pod) { t.Helper() assert.EventuallyEqual(t, func() []*corev1.Pod { return index.Lookup(k) }, pods, retry.Timeout(time.Second*5)) } // When we create a pod, we should (eventually) see it in the index c.Kube().CoreV1().Pods("ns").Create(context.Background(), pod1, metav1.CreateOptions{}) assertIndex(k1, pod1)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/test/kube/util.go
func NewPodMustFetch(a istioKube.CLIClient, namespace string, selectors ...string) PodFetchFunc { return func() ([]corev1.Pod, error) { pods, err := a.PodsForSelector(context.TODO(), namespace, selectors...) if err != nil { return nil, err } if len(pods.Items) == 0 { return nil, fmt.Errorf("no pods found for %v", selectors) } return pods.Items, nil } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 9.4K bytes - Viewed (0) -
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) -
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)