/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/util/endpoint/ |
H A D | trigger_time_tracker_test.go | 52 pod1 := createPod(ttNamespace, "pod1", t0) 53 pod2 := createPod(ttNamespace, "pod2", t1) 54 pod3 := createPod(ttNamespace, "pod3", t5) 66 pod1 := createPod(ttNamespace, "pod1", t2) 67 pod2 := createPod(ttNamespace, "pod2", t1) 75 pod1 := createPod(ttNamespace, "pod1", t1) 76 pod2 := createPod(ttNamespace, "pod2", t2) 77 pod3 := createPod(ttNamespace, "pod3", t3) 80 pod1 = createPod(ttNamespace, "pod1", t5) 81 pod2 = createPod(ttNamespace, "pod2", t4) [all …]
|
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/volume/util/recyclerclient/ |
H A D | recycler_client_test.go | 34 createPod *v1.Pod member 86 createPod: newPod("podRecyclerSuccess", v1.PodPending, ""), 110 createPod: newPod("podRecyclerFailure", v1.PodPending, ""), 130 createPod: newPod("podRecyclerDeleted", v1.PodPending, ""), 146 createPod: newPod("podNewRecycler", v1.PodFailed, "mock message"), 158 …err := internalRecycleVolumeByWatchingPodUntilCompletion(test.createPod.Name, test.createPod, clie…
|
/dports/sysutils/istio/istio-1.6.7/pilot/pkg/serviceregistry/kube/controller/ |
H A D | pod_test.go | 121 createPod(t, c, "128.0.0.1", "pod") 127 createPod(t, c, "128.0.0.2", "pod") 136 createPod(t, c, "128.0.0.1", "new-pod") 142 createPod(t, c, "128.0.0.1", "another-pod") 161 func createPod(t *testing.T, c *Controller, ip, name string) { func
|
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/upgrades/auth/ |
H A D | serviceaccount_admission_controller_migration.go | 53 t.pod = createPod(f, podBeforeMigrationName) 76 podAfterMigration := createPod(f, podAfterMigrationName) 116 func createPod(f *framework.Framework, podName string) *v1.Pod { func
|
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/pod-security-admission/test/ |
H A D | run.go | 220 …createPod := func(t *testing.T, i int, pod *corev1.Pod, expectSuccess bool, expectErrorSubstring s… 304 createPod(t, 0, minimalValidPod.DeepCopy(), true, "") 323 createPod(t, i, pod, true, "") 340 createPod(t, i, pod, false, checkData.expectErrorSubstring)
|
/dports/sysutils/istio/istio-1.6.7/vendor/sigs.k8s.io/controller-runtime/pkg/cache/ |
H A D | cache_test.go | 45 func createPod(name, namespace string, restartPolicy kcorev1.RestartPolicy) runtime.Object { func 108 knownPod1 = createPod("test-pod-1", testNamespaceOne, kcorev1.RestartPolicyNever) 109 knownPod2 = createPod("test-pod-2", testNamespaceTwo, kcorev1.RestartPolicyAlways) 110 knownPod3 = createPod("test-pod-3", testNamespaceTwo, kcorev1.RestartPolicyOnFailure) 111 knownPod4 = createPod("test-pod-4", testNamespaceThree, kcorev1.RestartPolicyNever) 192 anotherPod := createPod("test-pod-2", testNamespaceOne, kcorev1.RestartPolicyAlways) 349 anotherPod := createPod("test-pod-2", testNamespaceOne, kcorev1.RestartPolicyAlways)
|
/dports/sysutils/kubectl/kubernetes-1.22.2/test/integration/disruption/ |
H A D | disruption_test.go | 147 …createPod(t, fmt.Sprintf("pod-%d", i), nsName, map[string]string{"app": "test-crd"}, clientSet, ow… 247 createPod(t, fmt.Sprintf("pod-%d", j), nsName, map[string]string{"app": "test-crd"}, 368 createPod(t, "pod", nsName, map[string]string{}, clientSet, []metav1.OwnerReference{}) 386 func createPod(t *testing.T, name, namespace string, labels map[string]string, clientSet clientset.… func
|
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/test/fake/ |
H A D | kube.py | 32 def createPod(self, namespace, spec): member in KubeClientService
|
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/storage/ |
H A D | csi_mock_volume.go | 344 _, claim, pod := createPod(false) 501 _, _, pod := createPod(test.expectEphemeral) 543 _, _, pod1 := createPod(false) 549 _, _, pod2 := createPod(false) 555 _, _, pod3 := createPod(false) 607 sc, pvc, pod := createPod(false) 700 sc, pvc, pod := createPod(false) 841 _, claim, pod := createPod(false) 979 _, claim, pod := createPod(false) 1125 sc, claim, pod := createPod(false) [all …]
|
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/security/podsecuritypolicy/ |
H A D | provider_test.go | 48 createPod := func() *api.Pod { 87 pod := createPod() 97 if !reflect.DeepEqual(createPod(), pod) { 98 diffs := diff.ObjectDiff(createPod(), pod) 119 createPod := func() *api.Pod { 165 pod := createPod() 175 if !reflect.DeepEqual(createPod(), pod) { 176 diffs := diff.ObjectDiff(createPod(), pod)
|
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/network/netpol/ |
H A D | kubemanager.go | 66 kubePod, err := k.createPod(pod.KubePod()) 186 func (k *kubeManager) createPod(pod *v1.Pod) (*v1.Pod, error) { func
|
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/worker/ |
H A D | kubernetes.py | 110 yield self._kube.createPod(self.namespace, pod_spec)
|
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/framework/network/ |
H A D | utils.go | 719 config.createPod(testContainerPod) 721 config.createPod(hostTestContainerPod) 851 createdPod := config.createPod(pod) 886 func (config *NetworkingTestConfig) createPod(pod *v1.Pod) *v1.Pod { func
|
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/framework/service/ |
H A D | jig.go | 194 func (j *TestJig) CreateOnlyLocalNodePortService(createPod bool) (*v1.Service, error) { 205 if createPod { 219 func (j *TestJig) CreateOnlyLocalLoadBalancerService(timeout time.Duration, createPod bool, 232 if createPod {
|
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/util/ |
H A D | kubeclientservice.py | 238 def createPod(self, namespace, spec): member in KubeClientService
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/Microsoft/hcsshim/cmd/containerd-shim-runhcs-v1/ |
H A D | pod.go | 58 func createPod(ctx context.Context, events publisher, req *task.CreateTaskRequest, s *specs.Spec) (… func
|
H A D | service_internal.go | 166 pod, err = createPod(ctx, s.events, req, &spec)
|
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/Microsoft/hcsshim/cmd/containerd-shim-runhcs-v1/ |
H A D | pod.go | 56 func createPod(ctx context.Context, events publisher, req *task.CreateTaskRequest, s *specs.Spec) (… func
|
H A D | service_internal.go | 166 pod, err = createPod(ctx, s.events, req, &spec)
|
/dports/security/vault/vault-1.8.2/vendor/github.com/Microsoft/hcsshim/cmd/containerd-shim-runhcs-v1/ |
H A D | pod.go | 56 func createPod(ctx context.Context, events publisher, req *task.CreateTaskRequest, s *specs.Spec) (… func
|
H A D | service_internal.go | 166 pod, err = createPod(ctx, s.events, req, &spec)
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/Microsoft/hcsshim/cmd/containerd-shim-runhcs-v1/ |
H A D | pod.go | 56 func createPod(ctx context.Context, events publisher, req *task.CreateTaskRequest, s *specs.Spec) (… func
|
H A D | service_internal.go | 166 pod, err = createPod(ctx, s.events, req, &spec)
|
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/scheduling/ |
H A D | preemption.go | 632 preemptorPod := createPod(f, preemptorPodConf) 803 func createPod(f *framework.Framework, conf pausePodConfig) *v1.Pod { func
|
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apiserver/pkg/storage/tests/ |
H A D | cacher_test.go | 141 func createPod(s storage.Interface, obj *example.Pod) error { func 902 err := createPod(etcdStorage, makeTestPod(pod))
|