Skip to content
Snippets Groups Projects
Commit 903e16ac authored by Murat Kabilov's avatar Murat Kabilov
Browse files

move cluster interface to a different package

parent 8f8d3d51
No related branches found
No related tags found
No related merge requests found
...@@ -31,7 +31,7 @@ type Controller struct { ...@@ -31,7 +31,7 @@ type Controller struct {
logger *logrus.Entry logger *logrus.Entry
clustersMu sync.RWMutex clustersMu sync.RWMutex
clusters map[types.NamespacedName]types.Cluster clusters map[types.NamespacedName]types.OperatorCluster
stopChs map[types.NamespacedName]chan struct{} stopChs map[types.NamespacedName]chan struct{}
postgresqlInformer cache.SharedIndexInformer postgresqlInformer cache.SharedIndexInformer
...@@ -56,7 +56,7 @@ func New(controllerConfig *Config, operatorConfig *config.Config) *Controller { ...@@ -56,7 +56,7 @@ func New(controllerConfig *Config, operatorConfig *config.Config) *Controller {
Config: *controllerConfig, Config: *controllerConfig,
opConfig: operatorConfig, opConfig: operatorConfig,
logger: logger.WithField("pkg", "controller"), 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{}), stopChs: make(map[types.NamespacedName]chan struct{}),
podCh: make(chan types.PodEvent), podCh: make(chan types.PodEvent),
} }
......
...@@ -70,7 +70,7 @@ type UserSyncer interface { ...@@ -70,7 +70,7 @@ type UserSyncer interface {
ExecuteSyncRequests(req []PgSyncUserRequest, db *sql.DB) error ExecuteSyncRequests(req []PgSyncUserRequest, db *sql.DB) error
} }
type Cluster interface { type OperatorCluster interface {
Create() error Create() error
Delete() error Delete() error
ExecCommand(podName *NamespacedName, command ...string) (string, error) ExecCommand(podName *NamespacedName, command ...string) (string, error)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment