diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go index f89ccb7a47bcbc7fba3ec043e31b19d0c20d4c46..468387a005f31008c1e170d6471ab0edf8b34ee4 100644 --- a/pkg/controller/controller.go +++ b/pkg/controller/controller.go @@ -31,7 +31,7 @@ type Controller struct { logger *logrus.Entry clustersMu sync.RWMutex - clusters map[types.NamespacedName]types.Cluster + clusters map[types.NamespacedName]types.OperatorCluster stopChs map[types.NamespacedName]chan struct{} postgresqlInformer cache.SharedIndexInformer @@ -56,7 +56,7 @@ func New(controllerConfig *Config, operatorConfig *config.Config) *Controller { Config: *controllerConfig, opConfig: operatorConfig, logger: logger.WithField("pkg", "controller"), - clusters: make(map[types.NamespacedName]types.Cluster), + clusters: make(map[types.NamespacedName]types.OperatorCluster), stopChs: make(map[types.NamespacedName]chan struct{}), podCh: make(chan types.PodEvent), } diff --git a/pkg/types/types.go b/pkg/types/types.go index bd314cd0a53e74fc377dcca43c3a67fcec065a45..9438ad655b3c7473bd5df35fb1c1bb41317cec9f 100644 --- a/pkg/types/types.go +++ b/pkg/types/types.go @@ -70,7 +70,7 @@ type UserSyncer interface { ExecuteSyncRequests(req []PgSyncUserRequest, db *sql.DB) error } -type Cluster interface { +type OperatorCluster interface { Create() error Delete() error ExecCommand(podName *NamespacedName, command ...string) (string, error)