mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-03 09:22:44 +00:00
Generate pod.Name when pod.Name == "" for both HTTP and file sources.
Fix #3584
This commit is contained in:
parent
a3eaef8a65
commit
ec77507915
@ -168,6 +168,12 @@ func extractFromFile(filename string) (api.BoundPod, error) {
|
|||||||
pod.UID = types.UID(hex.EncodeToString(hasher.Sum(nil)[0:]))
|
pod.UID = types.UID(hex.EncodeToString(hasher.Sum(nil)[0:]))
|
||||||
glog.V(5).Infof("Generated UID %q for pod %q from file %s", pod.UID, pod.Name, filename)
|
glog.V(5).Infof("Generated UID %q for pod %q from file %s", pod.UID, pod.Name, filename)
|
||||||
}
|
}
|
||||||
|
// This is required for backward compatibility, and should be removed once we
|
||||||
|
// completely deprecate ContainerManifest.
|
||||||
|
if len(pod.Name) == 0 {
|
||||||
|
pod.Name = string(pod.UID)
|
||||||
|
glog.V(5).Infof("Generated Name %q for UID %q from file %s", pod.Name, pod.UID, filename)
|
||||||
|
}
|
||||||
if len(pod.Namespace) == 0 {
|
if len(pod.Namespace) == 0 {
|
||||||
hasher := adler32.New()
|
hasher := adler32.New()
|
||||||
fmt.Fprint(hasher, filename)
|
fmt.Fprint(hasher, filename)
|
||||||
|
@ -151,6 +151,12 @@ func applyDefaults(pod *api.BoundPod, url string) {
|
|||||||
pod.UID = types.UID(hex.EncodeToString(hasher.Sum(nil)[0:]))
|
pod.UID = types.UID(hex.EncodeToString(hasher.Sum(nil)[0:]))
|
||||||
glog.V(5).Infof("Generated UID %q for pod %q from URL %s", pod.UID, pod.Name, url)
|
glog.V(5).Infof("Generated UID %q for pod %q from URL %s", pod.UID, pod.Name, url)
|
||||||
}
|
}
|
||||||
|
// This is required for backward compatibility, and should be removed once we
|
||||||
|
// completely deprecate ContainerManifest.
|
||||||
|
if len(pod.Name) == 0 {
|
||||||
|
pod.Name = string(pod.UID)
|
||||||
|
glog.V(5).Infof("Generate Name %q from UID %q from URL %s", pod.Name, pod.UID, url)
|
||||||
|
}
|
||||||
if len(pod.Namespace) == 0 {
|
if len(pod.Namespace) == 0 {
|
||||||
hasher := adler32.New()
|
hasher := adler32.New()
|
||||||
fmt.Fprint(hasher, url)
|
fmt.Fprint(hasher, url)
|
||||||
|
@ -138,6 +138,23 @@ func TestExtractFromHTTP(t *testing.T) {
|
|||||||
},
|
},
|
||||||
}),
|
}),
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
desc: "Single manifest without ID",
|
||||||
|
manifests: api.ContainerManifest{Version: "v1beta1", UUID: "111"},
|
||||||
|
expected: CreatePodUpdate(kubelet.SET,
|
||||||
|
kubelet.HTTPSource,
|
||||||
|
api.BoundPod{
|
||||||
|
ObjectMeta: api.ObjectMeta{
|
||||||
|
UID: "111",
|
||||||
|
Name: "111",
|
||||||
|
Namespace: "foobar",
|
||||||
|
},
|
||||||
|
Spec: api.PodSpec{
|
||||||
|
RestartPolicy: api.RestartPolicy{Always: &api.RestartPolicyAlways{}},
|
||||||
|
DNSPolicy: api.DNSClusterFirst,
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
},
|
||||||
{
|
{
|
||||||
desc: "Multiple manifests",
|
desc: "Multiple manifests",
|
||||||
manifests: []api.ContainerManifest{
|
manifests: []api.ContainerManifest{
|
||||||
|
Loading…
Reference in New Issue
Block a user