Skip to content

Commit

Permalink
remove fip controller (#3684)
Browse files Browse the repository at this point in the history
Signed-off-by: bobz965 <zhangbingbing2_yewu@cmss.chinamobile.com>
  • Loading branch information
bobz965 committed Feb 2, 2024
1 parent 51a3c1e commit 8da2239
Show file tree
Hide file tree
Showing 6 changed files with 0 additions and 807 deletions.
21 changes: 0 additions & 21 deletions pkg/controller/controller.go
Expand Up @@ -708,21 +708,6 @@ func Run(ctx context.Context, config *Configuration) {
util.LogFatalAndExit(err, "failed to add ovn dnat rule event handler")
}

if _, err = podAnnotatedIptablesEipInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: controller.enqueueAddPodAnnotatedIptablesEip,
UpdateFunc: controller.enqueueUpdatePodAnnotatedIptablesEip,
DeleteFunc: controller.enqueueDeletePodAnnotatedIptablesEip,
}); err != nil {
util.LogFatalAndExit(err, "failed to add pod iptables eip event handler")
}
if _, err = podAnnotatedIptablesFipInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: controller.enqueueAddPodAnnotatedIptablesFip,
UpdateFunc: controller.enqueueUpdatePodAnnotatedIptablesFip,
DeleteFunc: controller.enqueueDeletePodAnnotatedIptablesFip,
}); err != nil {
util.LogFatalAndExit(err, "failed to add pod iptables fip event handler")
}

if _, err = qosPolicyInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: controller.enqueueAddQoSPolicy,
UpdateFunc: controller.enqueueUpdateQoSPolicy,
Expand Down Expand Up @@ -1109,12 +1094,6 @@ func (c *Controller) startWorkers(ctx context.Context) {
go wait.Until(c.runAddQoSPolicyWorker, time.Second, ctx.Done())
go wait.Until(c.runUpdateQoSPolicyWorker, time.Second, ctx.Done())
go wait.Until(c.runDelQoSPolicyWorker, time.Second, ctx.Done())

go wait.Until(c.runAddPodAnnotatedIptablesEipWorker, time.Second, ctx.Done())
go wait.Until(c.runDelPodAnnotatedIptablesEipWorker, time.Second, ctx.Done())

go wait.Until(c.runAddPodAnnotatedIptablesFipWorker, time.Second, ctx.Done())
go wait.Until(c.runDelPodAnnotatedIptablesFipWorker, time.Second, ctx.Done())
}

func (c *Controller) allSubnetReady(subnets ...string) (bool, error) {
Expand Down

0 comments on commit 8da2239

Please sign in to comment.