reviewable/pr2421/r2
devinyan 9 years ago
parent de2bf35526
commit 4cedb9d118

@ -173,7 +173,7 @@ func (c *Client) Get(namespace string, reader io.Reader) (string, error) {
if gvk.Kind != "Pod" { if gvk.Kind != "Pod" {
objs[vk] = append(objs[vk], info.Object) objs[vk] = append(objs[vk], info.Object)
} else { } else {
if !IsFoundPodInfo(objPods[vk], info) { if !isFoundPodInfo(objPods[vk], info) {
objs[vk] = append(objs[vk], info.Object) objs[vk] = append(objs[vk], info.Object)
} }
} }
@ -670,7 +670,7 @@ func (c *Client) getSelectRelationPod(info *resource.Info,objPods map[string][]a
vk := pod.GroupVersionKind().Version + "/" + pod.GroupVersionKind().Kind vk := pod.GroupVersionKind().Version + "/" + pod.GroupVersionKind().Kind
if !IsFoundPod(objPods[vk], pod) { if !isFoundPod(objPods[vk], pod) {
objPods[vk] = append(objPods[vk], pod) objPods[vk] = append(objPods[vk], pod)
} }
} }
@ -678,7 +678,7 @@ func (c *Client) getSelectRelationPod(info *resource.Info,objPods map[string][]a
return objPods,nil return objPods,nil
} }
func IsFoundPod(podItem []api.Pod,pod api.Pod) bool { func isFoundPod(podItem []api.Pod,pod api.Pod) bool {
for _,value := range podItem { for _,value := range podItem {
if (value.Namespace == pod.Namespace) && (value.Name==pod.Name) { if (value.Namespace == pod.Namespace) && (value.Name==pod.Name) {
return true return true
@ -687,7 +687,7 @@ func IsFoundPod(podItem []api.Pod,pod api.Pod) bool {
return false return false
} }
func IsFoundPodInfo(podItem []api.Pod,podInfo *resource.Info) bool { func isFoundPodInfo(podItem []api.Pod,podInfo *resource.Info) bool {
if podInfo == nil { if podInfo == nil {
return false return false
} }

Loading…
Cancel
Save