cleanup virtual kubelet old reflection

Remove code related to virtual kubelet reflection because superseeded by
new work queue based reflection.

Author: fprojetto

cmd/virtual-kubelet/root/flag.go

@@ -37,8 +37,6 @@ func InstallFlags(flags *pflag.FlagSet, c *Opts) {
 
 	flags.DurationVar(&c.InformerResyncPeriod, "full-resync-period", c.InformerResyncPeriod,
 		"how often to perform a full resync of pods between kubernetes and the provider")
-	flags.DurationVar(&c.LiqoInformerResyncPeriod, "liqo-resync-period", c.LiqoInformerResyncPeriod,
-		"how often to perform a full resync of Liqo resources informers")
 	flags.DurationVar(&c.StartupTimeout, "startup-timeout", c.StartupTimeout, "How long to wait for the virtual-kubelet to start")
 
 	flags.StringVar(&c.ForeignClusterID, "foreign-cluster-id", c.ForeignClusterID, "The Id of the foreign cluster")

cmd/virtual-kubelet/root/opts.go

@@ -28,11 +28,10 @@ import (
 
 // Defaults for root command options.
 const (
-	DefaultNodeName                               = "virtual-kubelet"
-	DefaultInformerResyncPeriod                   = 1 * time.Minute
-	DefaultLiqoInformerResyncPeriod time.Duration = 0
-	DefaultMetricsAddr                            = ":10255"
-	DefaultListenPort                             = 10250
+	DefaultNodeName             = "virtual-kubelet"
+	DefaultInformerResyncPeriod = 10 * time.Hour
+	DefaultMetricsAddr          = ":10255"
+	DefaultListenPort           = 10250
 
 	DefaultPodWorkers                  = 10
 	DefaultServiceWorkers              = 3
@@ -69,8 +68,7 @@ type Opts struct {
 	SecretWorkers               uint
 	PersistenVolumeClaimWorkers uint
 
-	InformerResyncPeriod     time.Duration
-	LiqoInformerResyncPeriod time.Duration
+	InformerResyncPeriod time.Duration
 
 	// Startup Timeout is how long to wait for the kubelet to start
 	StartupTimeout time.Duration
@@ -98,10 +96,6 @@ func SetDefaultOpts(c *Opts) error {
 		c.InformerResyncPeriod = DefaultInformerResyncPeriod
 	}
 
-	if c.LiqoInformerResyncPeriod == 0 {
-		c.InformerResyncPeriod = DefaultLiqoInformerResyncPeriod
-	}
-
 	if c.MetricsAddr == "" {
 		c.MetricsAddr = DefaultMetricsAddr
 	}

cmd/virtual-kubelet/root/root.go

@@ -109,9 +109,6 @@ func runRootCommand(ctx context.Context, c *Opts) error {
 		return err
 	}
 
-	podProviderStopper := make(chan struct{})
-	podProvider.SetProviderStopper(podProviderStopper)
-
 	// Initialize the node provider
 	nodecfg := nodeprovider.InitConfig{
 		HomeConfig:      config,
@@ -126,8 +123,7 @@ func runRootCommand(ctx context.Context, c *Opts) error {
 		ExtraLabels:      c.NodeExtraLabels.StringMap,
 		ExtraAnnotations: c.NodeExtraAnnotations.StringMap,
 
-		PodProviderStopper:   podProviderStopper,
-		InformerResyncPeriod: c.LiqoInformerResyncPeriod,
+		InformerResyncPeriod: c.InformerResyncPeriod,
 	}
 
 	nodeProvider := nodeprovider.NewLiqoNodeProvider(&nodecfg)