diff --git a/pkg/agent/controller/controller_suite_test.go b/pkg/agent/controller/controller_suite_test.go index 844b6d6e..8d261e19 100644 --- a/pkg/agent/controller/controller_suite_test.go +++ b/pkg/agent/controller/controller_suite_test.go @@ -109,8 +109,6 @@ func init() { if err != nil { panic(err) } - - controller.BrokerResyncPeriod = time.Millisecond * 100 } func TestController(t *testing.T) { 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 1293486e..5af7fdbb 100644 --- a/pkg/agent/controller/service_import.go +++ b/pkg/agent/controller/service_import.go @@ -98,7 +98,6 @@ func newServiceImportController(spec *AgentSpecification, syncerMetricNames Agen Transform: controller.onRemoteServiceImport, OnSuccessfulSync: controller.serviceImportMigrator.onSuccessfulSyncFromBroker, Scheme: syncerConfig.Scheme, - ResyncPeriod: BrokerResyncPeriod, SyncCounterOpts: &prometheus.GaugeOpts{ Name: syncerMetricNames.ServiceImportCounterName, Help: "Count of imported services", diff --git a/pkg/agent/controller/types.go b/pkg/agent/controller/types.go index acd242aa..e87ebcb5 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" @@ -40,8 +39,6 @@ const ( portConflictReason = "ConflictingPorts" ) -var BrokerResyncPeriod = time.Minute * 2 - type EndpointSliceListerFn func(selector k8slabels.Selector) []runtime.Object type converter struct {