- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 3,571 for GetPod (0.21 sec)
-
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/serviceaccount/claims.go
} } var podName, podUID string if podref != nil { // Make sure token hasn't been invalidated by deletion of the pod pod, err := v.getter.GetPod(namespace, podref.Name) if err != nil { klog.V(4).Infof("Could not retrieve bound pod %s/%s for service account %s/%s: %v", namespace, podref.Name, namespace, saref.Name, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 21:15:10 UTC 2023 - 11.3K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache.go
} cache.mu.RLock() defer cache.mu.RUnlock() return cache.assumedPods.Has(key), nil } // GetPod might return a pod for which its node has already been deleted from // the main cache. This is useful to properly process pod update events. func (cache *cacheImpl) GetPod(pod *v1.Pod) (*v1.Pod, error) { key, err := framework.GetPodKey(pod) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
} // fakeAction records information about requests to aid in testing. type fakeAction struct { method string path string query string } // String returns method=path to aid in testing func (f *fakeAction) String() string { return strings.Join([]string{f.method, f.path}, "=") } type FakeResponse struct { statusCode int content []byte }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K 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) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test_cases/invalid/httproute/invalid-method.yaml
apiVersion: gateway.networking.k8s.io/v1beta1 kind: HTTPRoute metadata: name: invalid-method spec: rules: - matches:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 17:15:18 UTC 2023 - 145 bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test_cases/valid/multicluster/httproute-method.yaml
#$ Used in: #$ - geps/gep-1748.md kind: HTTPRoute apiVersion: gateway.networking.k8s.io/v1beta1 metadata: name: api spec: parentRefs: - name: api-gw rules: - matches: - method: POST - method: PUT - method: DELETE backendRefs: - group: multicluster.x-k8s.io kind: ServiceImport name: api-primary port: 8080 - backendRefs: - group: multicluster.x-k8s.io
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 17:15:18 UTC 2023 - 474 bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
if err := om.createPodTracker.incWithOptionalError(); err != nil { return err } pod.SetUID(types.UID(pod.Name + "-uid")) return om.podsIndexer.Update(pod) } func (om *fakeObjectManager) GetPod(namespace, podName string) (*v1.Pod, error) { return om.podsLister.Pods(namespace).Get(podName) } func (om *fakeObjectManager) UpdatePod(pod *v1.Pod) error { defer om.updatePodTracker.trackParallelRequests()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)