- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,071 for GetPod (0.2 sec)
-
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
// correctness and security. // // Note: this is only used by endpointslice controller func getPod(c *Controller, ip string, ep *metav1.ObjectMeta, targetRef *corev1.ObjectReference, host host.Name) (*corev1.Pod, bool) { var expectPod bool pod := c.getPod(ip, ep.Namespace, targetRef) if targetRef != nil && targetRef.Kind == "Pod" { expectPod = true if pod == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
// with a clientset for writes and listers for reads; for tests we provide stubs. type StatefulPodControlObjectManager interface { CreatePod(ctx context.Context, pod *v1.Pod) error GetPod(namespace, podName string) (*v1.Pod, error) UpdatePod(pod *v1.Pod) error DeletePod(pod *v1.Pod) error CreateClaim(claim *v1.PersistentVolumeClaim) error GetClaim(namespace, claimName string) (*v1.PersistentVolumeClaim, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/registry/core/pod/strategy.go
} // ResourceGetter is an interface for retrieving resources by ResourceLocation. type ResourceGetter interface { Get(context.Context, string, *metav1.GetOptions) (runtime.Object, error) } func getPod(ctx context.Context, getter ResourceGetter, name string) (*api.Pod, error) { obj, err := getter.Get(ctx, name, &metav1.GetOptions{}) if err != nil { return nil, err } pod := obj.(*api.Pod) if pod == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 17:51:48 UTC 2024 - 29.8K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
sched.updatePodInCache(tt.oldObj, tt.newObj) if tt.oldObj.(*v1.Pod).UID != tt.newObj.(*v1.Pod).UID { if pod, err := sched.Cache.GetPod(tt.oldObj.(*v1.Pod)); err == nil { t.Errorf("Get pod UID %v from cache but it should not happen", pod.UID) } } pod, err := sched.Cache.GetPod(tt.newObj.(*v1.Pod)) if err != nil { t.Errorf("Failed to get pod from scheduler: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/serviceaccount/jwt.go
) // ServiceAccountTokenGetter defines functions to retrieve a named service account and secret type ServiceAccountTokenGetter interface { GetServiceAccount(namespace, name string) (*v1.ServiceAccount, error) GetPod(namespace, name string) (*v1.Pod, error) GetSecret(namespace, name string) (*v1.Secret, error) GetNode(name string) (*v1.Node, error) } type TokenGenerator interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 22:16:08 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
return nil } return &Status{ code: Error, err: err, } } // WaitingPod represents a pod currently waiting in the permit phase. type WaitingPod interface { // GetPod returns a reference to the waiting pod. GetPod() *v1.Pod // GetPendingPlugins returns a list of pending Permit plugin's name. GetPendingPlugins() []string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/serviceaccount/claims_test.go
if f.serviceAccount == nil { return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "serviceaccounts"}, name) } return f.serviceAccount, nil } func (f fakeGetter) GetPod(namespace, name string) (*v1.Pod, error) { if f.pod == nil { return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "pods"}, name) } return f.pod, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
for _, fwk := range scheduler.Profiles { actualPodNamesInWaitingPods := sets.NewString() fwk.IterateOverWaitingPods(func(pod framework.WaitingPod) { actualPodNamesInWaitingPods.Insert(pod.GetPod().Name) }) // Validate the name of pods in waitingPods matches expectations. if actualPodNamesInWaitingPods.Len() != len(tc.expectPodNamesInWaitingPods) ||
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
assertTrue(desc, isBoolean(method)); assertFalse(desc, isInterruptible(method)); } else if (isWaitFor(method)) { assertTrue(desc, isGuarded(method)); assertEquals(desc, isTimed(method), isBoolean(method)); } else { // any other enterXxx method assertEquals(desc, isTimed(method), isBoolean(method)); } } /** Generates all test cases appropriate for the given method. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 25.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
assertFalse(desc, isInterruptible(method)); } else if (isWaitFor(method)) { assertTrue(desc, isGuarded(method)); assertEquals(desc, isTimed(method), isBoolean(method)); } else { // any other enterXxx method assertEquals(desc, isTimed(method), isBoolean(method)); } } /** Generates all test cases appropriate for the given method. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 27.1K bytes - Viewed (0)