- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 484 for podB (0.07 sec)
-
pkg/kube/kclient/index_test.go
c.Kube().CoreV1().Pods("ns").Create(context.Background(), pod2, metav1.CreateOptions{}) assertIndex(k1, pod1) // Original one must still persist assertIndex(k2, pod2) // New one should be there, eventually // Create another pod with the same SA; we ought to find multiple now. c.Kube().CoreV1().Pods("ns").Create(context.Background(), pod3, metav1.CreateOptions{}) assertIndex(k1, pod1, pod3) // Original one must still persist
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 5.7K bytes - Viewed (0) -
hack/testdata/sorted-pods/sorted-pod3.yaml
apiVersion: v1 kind: Pod metadata: name: sorted-pod3 creationTimestamp: "2018-08-30T14:10:53Z" labels: name: sorted-pod1-label spec: containers: - name: kubernetes-pause3
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 223 bytes - Viewed (0) -
hack/testdata/sorted-pods/sorted-pod1.yaml
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 355 bytes - Viewed (0) -
hack/testdata/sorted-pods/sorted-pod2.yaml
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 347 bytes - Viewed (0) -
pkg/scheduler/util/utils.go
func GetPodFullName(pod *v1.Pod) string { // Use underscore as the delimiter because it is not allowed in pod name // (DNS subdomain format). return pod.Name + "_" + pod.Namespace } // GetPodStartTime returns start time of the given pod or current timestamp // if it hasn't started yet. func GetPodStartTime(pod *v1.Pod) *metav1.Time { if pod.Status.StartTime != nil {
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/util/pod/pod.go
limitations under the License. */ package pod import ( "bytes" "context" "encoding/json" "fmt" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/strategicpatch" clientset "k8s.io/client-go/kubernetes" podutil "k8s.io/kubernetes/pkg/api/v1/pod" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 07 15:22:29 UTC 2022 - 3K bytes - Viewed (0) -
pkg/kube/krt/join_test.go
assert.EventuallyEqual(t, fetch, []SimpleEndpoint{ {pod.Name, se.Name, pod.Namespace, pod.Status.PodIP}, {pod2.Name, se.Name, pod2.Namespace, pod2.Status.PodIP}, {pod.Name, svc.Name, pod.Namespace, pod.Status.PodIP}, {pod2.Name, svc.Name, pod2.Namespace, pod2.Status.PodIP}, }) } func TestCollectionJoinSync(t *testing.T) { c := kube.NewFakeClient(&corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "name",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0) -
hack/testdata/pod-with-api-env.yaml
apiVersion: v1 kind: Pod metadata: name: env-test-pod spec: containers: - name: test-container image: registry.k8s.io/busybox command: [ "/bin/sh", "-c", "env" ] env: - name: TEST_CMD_1 valueFrom: secretKeyRef: name: test-secret key: key-1 - name: TEST_CMD_2 valueFrom: configMapKeyRef:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 593 bytes - Viewed (0) -
pkg/kube/krt/index_test.go
pod2 := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "name2", Namespace: "namespace", }, Status: corev1.PodStatus{PodIP: "1.2.3.5"}, } pc.CreateOrUpdateStatus(pod2) tt.WaitUnordered("add/namespace/name2") assert.Equal(t, Collection.Get(), ptr.Of("namespace/name,namespace/name2")) pc.Delete(pod.Name, pod.Namespace) pc.Delete(pod2.Name, pod2.Namespace)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 4.5K bytes - Viewed (0) -
hack/testdata/pod.yaml
apiVersion: v1 kind: Pod metadata: name: test-pod labels: name: test-pod-label spec: containers: - name: kubernetes-pause
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 172 bytes - Viewed (0)