- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for CreatePod (0.16 sec)
-
pilot/pkg/xds/workload_test.go
}) ads.ExpectEmptyResponse() // Create pod, due to wildcard subscribe we should receive it createPod(s, "pod", "sa", "127.0.0.1", "not-node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod") // A new pod should push only that one createPod(s, "pod2", "sa", "127.0.0.2", "node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod2")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
}) initTestEnv(t, c.client.Kube(), fx) createPod := func(ip, name string) { addPods(t, c, fx, generatePod(ip, name, "ns", "1", "", map[string]string{}, map[string]string{})) } createPod("128.0.0.1", "pod1") assert.Equal(t, c.pods.getPodKeys("128.0.0.1"), []types.NamespacedName{{Name: "pod1", Namespace: "ns"}}) events.WaitOrdered("pod1/add", "pod1/update") createPod("128.0.0.1", "pod2")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K 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
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
testContext := genericapirequest.WithNamespace(genericapirequest.NewContext(), "test") destroyFunc, registry := NewTestGenericStoreRegistry(t) registry.EnableGarbageCollection = true defer destroyFunc() createPod := func(i int, finalizers []string) *example.Pod { return &example.Pod{ ObjectMeta: metav1.ObjectMeta{Name: fmt.Sprintf("pod-%d", i), Finalizers: finalizers, Generation: initialGeneration},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
revisionInformer.Informer().GetIndexer(), newRequestTracker(0, nil, 0), newRequestTracker(0, nil, 0), newRequestTracker(0, nil, 0), } } func (om *fakeObjectManager) CreatePod(ctx context.Context, pod *v1.Pod) error { defer om.createPodTracker.trackParallelRequests() if err := om.createPodTracker.incWithOptionalError(); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)