diff options
| author |   Lvbo163 <lv.bo163@zte.com.cn> | 2018-03-08 15:05:36 +0800 |
|---|---|---|
| committer | Lvbo163 <lv.bo163@zte.com.cn> | 2018-03-08 15:05:36 +0800 |
| commit | d653f9feea831724457ae0812850a69977ff949c (patch) | |
| tree | ee20e1b4d1752a20ed9beea70609b7ff895c923e /src/kube2msb/kube_work.go | |
| parent | 708ce4cfd811fc72588d414e6c0720d3ee632a23 (diff) | |
add ut for bookkeeper
Issue-ID: MSB-167
Change-Id: Ic1e1d2e1ec0347e02369dd76ea1d2bf9a8d40d8e
Signed-off-by: Lvbo163 <lv.bo163@zte.com.cn>
Diffstat (limited to 'src/kube2msb/kube_work.go')
| -rw-r--r-- | src/kube2msb/kube_work.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/kube2msb/kube_work.go b/src/kube2msb/kube_work.go index b7965b5..8e15671 100644 --- a/src/kube2msb/kube_work.go +++ b/src/kube2msb/kube_work.go @@ -105,7 +105,7 @@ func (client *ClientBookKeeper) RemoveService(svc *kapi.Service) { client.msbQueue <- MSBWork{ Action: MSBWorkRemoveService, ServiceInfo: svc.ObjectMeta.Annotations[serviceKey], - IPAddress: svc.Spec.LoadBalancerIP, + IPAddress: svc.Spec.ClusterIP, } } else { log.Printf("Service Type:%s for Service:%s is not supported", svc.Spec.Type, svc.Name) @@ -152,7 +152,7 @@ func (client *ClientBookKeeper) AddPod(pod *kapi.Pod) { IPAddress: pod.Status.PodIP, } client.pods[pod.Name] = pod - log.Println("Queued Pod to be added: ", pod.Name) + log.Println("Queued Pod to be added: ", pod.Name, pod.Status.PodIP) } func (client *ClientBookKeeper) RemovePod(pod *kapi.Pod) { @@ -173,8 +173,8 @@ func (client *ClientBookKeeper) RemovePod(pod *kapi.Pod) { ServiceInfo: pod.Annotations[serviceKey], IPAddress: client.pods[pod.Name].Status.PodIP, } + log.Println("Queued Pod to be removed: ", pod.Name, client.pods[pod.Name].Status.PodIP) delete(client.pods, pod.Name) - log.Println("Queued Pod to be removed: ", pod.Name) } func (client *ClientBookKeeper) UpdatePod(pod *kapi.Pod) { |