Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

controller

package

Go to main page

Versions in this module

v1

v1.2.0

Jul 25, 2019

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)