diff --git a/pkg/agent/controller/endpoint_slice.go b/pkg/agent/controller/endpoint_slice.go index d7374b6c..6d7f2433 100644 --- a/pkg/agent/controller/endpoint_slice.go +++ b/pkg/agent/controller/endpoint_slice.go @@ -70,7 +70,6 @@ func newEndpointSliceController(spec *AgentSpecification, syncerConfig broker.Sy c.enqueueForConflictCheck(context.TODO(), obj.(*discovery.EndpointSlice), op) return false }, - BrokerResyncPeriod: BrokerResyncPeriod, }, } diff --git a/pkg/agent/controller/service_import.go b/pkg/agent/controller/service_import.go index ce639e70..2f1f1176 100644 --- a/pkg/agent/controller/service_import.go +++ b/pkg/agent/controller/service_import.go @@ -99,7 +99,6 @@ func newServiceImportController(spec *AgentSpecification, syncerMetricNames Agen Transform: controller.onRemoteServiceImport, OnSuccessfulSync: controller.serviceImportMigrator.onSuccessfulSyncFromBroker, Scheme: syncerConfig.Scheme, - ResyncPeriod: BrokerResyncPeriod, NamespaceInformer: syncerConfig.NamespaceInformer, SyncCounterOpts: &prometheus.GaugeOpts{ Name: syncerMetricNames.ServiceImportCounterName, diff --git a/pkg/agent/controller/types.go b/pkg/agent/controller/types.go index 9e261144..fe054b7b 100644 --- a/pkg/agent/controller/types.go +++ b/pkg/agent/controller/types.go @@ -20,7 +20,6 @@ package controller import ( "sync" - "time" "github.com/submariner-io/admiral/pkg/federate" "github.com/submariner-io/admiral/pkg/syncer" @@ -42,8 +41,6 @@ const ( portConflictReason = "ConflictingPorts" ) -var BrokerResyncPeriod = time.Minute * 2 - type EndpointSliceListerFn func(selector k8slabels.Selector) []runtime.Object type converter struct {