Skip to content

Commit 2e0042e

Browse files
committed
Fixing the recent removal of unversioned client interfaces.
We need to reference explicitly versioned interfaces
1 parent 9fa11be commit 2e0042e

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Diff for: pkg/ipam/ipam.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ func updateDanmNetAllocation (danmClient danmclientset.Interface, netInfo danmty
7979
//Randomizing backoff time to decrease the possibility of conflicts
8080
randomBackoff := rand.Intn(backOffTimer)
8181
time.Sleep(time.Duration(randomBackoff) * time.Millisecond)
82-
newNetSpec, err := danmClient.Danm().DanmNets(netInfo.ObjectMeta.Namespace).Get(netInfo.Spec.NetworkID, meta_v1.GetOptions{})
82+
newNetSpec, err := danmClient.DanmV1().DanmNets(netInfo.ObjectMeta.Namespace).Get(netInfo.Spec.NetworkID, meta_v1.GetOptions{})
8383
if err != nil {
8484
return false, errors.New("After IP address reservation conflict, network cannot be read again!"), danmtypes.DanmNet{}
8585
}

Diff for: pkg/svcwatcher/controller.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -504,7 +504,7 @@ func (c *Controller) updatePod(old, new interface{}) {
504504
if deNew.Spec.Pod == podName && deNew.Namespace == podNs {
505505
deLabels := newPod.Labels
506506
deNew.SetLabels(deLabels)
507-
c.danmclient.Danm().DanmEps(deNew.Namespace).Update(deNew)
507+
c.danmclient.DanmV1().DanmEps(deNew.Namespace).Update(deNew)
508508
}
509509
}
510510
}

0 commit comments

Comments
 (0)