Versions in this module Expand all Collapse all v1 v1.1.0 Feb 20, 2019 Changes in this version + type ClusterEvent struct + EventTime time.Time + EventType EventType + NewSpec *acidv1.Postgresql + OldSpec *acidv1.Postgresql + UID types.UID + WorkerID uint32 + type EventType string + const EventAdd + const EventDelete + const EventRepair + const EventSync + const EventUpdate v1.0.0 Aug 8, 2018 Changes in this version + type Controller struct + KubeClient k8sutil.KubernetesClient + PodServiceAccount *v1.ServiceAccount + PodServiceAccountRoleBinding *rbacv1beta1.RoleBinding + func NewController(controllerConfig *spec.ControllerConfig) *Controller + func (c *Controller) ClusterDatabasesMap() map[string][]string + func (c *Controller) ClusterHistory(team, namespace, name string) ([]*spec.Diff, error) + func (c *Controller) ClusterLogs(team, namespace, name string) ([]*spec.LogEntry, error) + func (c *Controller) ClusterStatus(team, namespace, cluster string) (*spec.ClusterStatus, error) + func (c *Controller) Fire(e *logrus.Entry) error + func (c *Controller) GetConfig() *spec.ControllerConfig + func (c *Controller) GetOperatorConfig() *config.Config + func (c *Controller) GetStatus() *spec.ControllerStatus + func (c *Controller) GetWorkersCnt() uint32 + func (c *Controller) Levels() []logrus.Level + func (c *Controller) ListQueue(workerID uint32) (*spec.QueueDump, error) + func (c *Controller) Run(stopCh <-chan struct{}, wg *sync.WaitGroup) + func (c *Controller) TeamClusterList() map[string][]spec.NamespacedName + func (c *Controller) WorkerLogs(workerID uint32) ([]*spec.LogEntry, error) + func (c *Controller) WorkerStatus(workerID uint32) (*spec.WorkerStatus, error)
Go to main page