feat: refactor subnet and allow cidr change

kubeovn · May 11, 2020 · 13283da · 13283da
1 parent 9f2e718
commit 13283da
Show file tree

Hide file tree

Showing 9 changed files with 209 additions and 427 deletions.
diff --git a/dist/images/.dockerignore b/dist/images/.dockerignore
@@ -0,0 +1,4 @@
+install.sh
+cleanup.sh
+kubectl-ko
+*.yaml
diff --git a/dist/images/install.sh b/dist/images/install.sh
@@ -1051,7 +1051,9 @@ diagnose(){
   case $type in
     all)
       echo "### kube-ovn-controller recent log"
+      set +e
       kubectl logs -n $KUBE_OVN_NS -l app=kube-ovn-controller --tail=100 | grep E$(date +%m%d)
+      set -e
       echo ""
       pingers=$(kubectl get pod -n $KUBE_OVN_NS | grep kube-ovn-pinger | awk '{print $1}')
       for pinger in $pingers

diff --git a/dist/images/kubectl-ko b/dist/images/kubectl-ko
@@ -143,7 +143,9 @@ diagnose(){
   case $type in
     all)
       echo "### kube-ovn-controller recent log"
+      set +e
       kubectl logs -n $KUBE_OVN_NS -l app=kube-ovn-controller --tail=100 | grep E$(date +%m%d)
+      set -e
       echo ""
       pingers=$(kubectl get pod -n $KUBE_OVN_NS | grep kube-ovn-pinger | awk '{print $1}')
       for pinger in $pingers

diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -45,10 +45,9 @@ type Controller struct {
 
 	subnetsLister           kubeovnlister.SubnetLister
 	subnetSynced            cache.InformerSynced
-	addSubnetQueue          workqueue.RateLimitingInterface
+	addOrUpdateSubnetQueue  workqueue.RateLimitingInterface
 	deleteSubnetQueue       workqueue.RateLimitingInterface
 	deleteRouteQueue        workqueue.RateLimitingInterface
-	updateSubnetQueue       workqueue.RateLimitingInterface
 	updateSubnetStatusQueue workqueue.RateLimitingInterface
 
 	ipsLister kubeovnlister.IPLister
@@ -127,10 +126,9 @@ func NewController(config *Configuration) *Controller {
 
 		subnetsLister:           subnetInformer.Lister(),
 		subnetSynced:            subnetInformer.Informer().HasSynced,
-		addSubnetQueue:          workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "AddSubnet"),
+		addOrUpdateSubnetQueue:  workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "AddSubnet"),
 		deleteSubnetQueue:       workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "DeleteSubnet"),
 		deleteRouteQueue:        workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "DeleteRoute"),
-		updateSubnetQueue:       workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "UpdateSubnet"),
 		updateSubnetStatusQueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "UpdateSubnetStatus"),
 
 		ipsLister: ipInformer.Lister(),
@@ -282,8 +280,7 @@ func (c *Controller) shutdown() {
 
 	c.addNamespaceQueue.ShutDown()
 
-	c.addSubnetQueue.ShutDown()
-	c.updateSubnetQueue.ShutDown()
+	c.addOrUpdateSubnetQueue.ShutDown()
 	c.deleteSubnetQueue.ShutDown()
 	c.deleteRouteQueue.ShutDown()
 	c.updateSubnetStatusQueue.ShutDown()
@@ -356,7 +353,6 @@ func (c *Controller) startWorkers(stopCh <-chan struct{}) {
 		go wait.Until(c.runUpdatePodWorker, time.Second, stopCh)
 
 		go wait.Until(c.runDeleteSubnetWorker, time.Second, stopCh)
-		go wait.Until(c.runUpdateSubnetWorker, time.Second, stopCh)
 		go wait.Until(c.runDeleteRouteWorker, time.Second, stopCh)
 		go wait.Until(c.runUpdateSubnetStatusWorker, time.Second, stopCh)