- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for GetPodFullName (0.34 sec)
-
pkg/kubelet/pod/pod_manager.go
pm.lock.RLock() defer pm.lock.RUnlock() mirrorPod, ok := pm.mirrorPodByFullName[kubecontainer.GetPodFullName(pod)] return mirrorPod, ok } func (pm *basicManager) GetPodByMirrorPod(mirrorPod *v1.Pod) (*v1.Pod, bool) { pm.lock.RLock() defer pm.lock.RUnlock() pod, ok := pm.podByFullName[kubecontainer.GetPodFullName(mirrorPod)] return pod, ok }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/kubelet/server/server.go
return } fw := flushwriter.Wrap(response.ResponseWriter) response.Header().Set("Transfer-Encoding", "chunked") if err := s.host.GetKubeletContainerLogs(ctx, kubecontainer.GetPodFullName(pod), containerName, logOptions, fw, fw); err != nil { response.WriteError(http.StatusBadRequest, err) return } } // encodePods creates an v1.PodList object from pods and returns the encoded
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
pkg/scheduler/util/utils_test.go
extenderv1 "k8s.io/kube-scheduler/extender/v1" ) func TestGetPodFullName(t *testing.T) { pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Namespace: "test", Name: "pod", }, } got := GetPodFullName(pod) expected := fmt.Sprintf("%s_%s", pod.Name, pod.Namespace) if got != expected { t.Errorf("Got wrong full name, got: %s, expected: %s", got, expected) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 14.5K bytes - Viewed (0) -
pkg/kubelet/container/runtime.go
} return &pod } // IsEmpty returns true if the pod is empty. func (p *Pod) IsEmpty() bool { return reflect.DeepEqual(p, &Pod{}) } // GetPodFullName returns a name that uniquely identifies a pod. func GetPodFullName(pod *v1.Pod) string { // Use underscore as the delimiter because it is not allowed in pod name // (DNS subdomain format), while allowed in the container name format.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0) -
pkg/kubelet/config/config.go
for i, pod := range pods { // Pods from each source are assumed to have passed validation individually. // This function only checks if there is any naming conflict. name := kubecontainer.GetPodFullName(pod) if names.Has(name) { klog.InfoS("Pod failed validation due to duplicate pod name, ignoring", "index", i, "pod", klog.KObj(pod), "source", source)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0)