Fixing the recent removal of unversioned client interfaces.

We need to reference explicitly versioned interfaces
nokia · Feb 27, 2019 · 2e0042e · 2e0042e
1 parent 9fa11be
commit 2e0042e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/ipam/ipam.go b/pkg/ipam/ipam.go
@@ -79,7 +79,7 @@ func updateDanmNetAllocation (danmClient danmclientset.Interface, netInfo danmty
     //Randomizing backoff time to decrease the possibility of conflicts
     randomBackoff := rand.Intn(backOffTimer) 
     time.Sleep(time.Duration(randomBackoff) * time.Millisecond)
-    newNetSpec, err := danmClient.Danm().DanmNets(netInfo.ObjectMeta.Namespace).Get(netInfo.Spec.NetworkID, meta_v1.GetOptions{})
+    newNetSpec, err := danmClient.DanmV1().DanmNets(netInfo.ObjectMeta.Namespace).Get(netInfo.Spec.NetworkID, meta_v1.GetOptions{})
     if err != nil {
         return false, errors.New("After IP address reservation conflict, network cannot be read again!"), danmtypes.DanmNet{}
     }

diff --git a/pkg/svcwatcher/controller.go b/pkg/svcwatcher/controller.go
@@ -504,7 +504,7 @@ func (c *Controller) updatePod(old, new interface{}) {
 			if deNew.Spec.Pod == podName && deNew.Namespace == podNs {
 				deLabels := newPod.Labels
 				deNew.SetLabels(deLabels)
-				c.danmclient.Danm().DanmEps(deNew.Namespace).Update(deNew)
+				c.danmclient.DanmV1().DanmEps(deNew.Namespace).Update(deNew)
 			}
 		}
 	}