Versions in this module Expand all Collapse all v1 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