operator: kubedb.dev/operator/pkg/controller Index | Files

package controller

import "kubedb.dev/operator/pkg/controller"

Index

Package Files

config.go controller.go run.go

type Controller Uses

type Controller struct {
    amc.Config
    *amc.Controller
    // contains filtered or unexported fields
}

func New Uses

func New(
    clientConfig *rest.Config,
    client kubernetes.Interface,
    apiExtKubeClient crd_cs.ApiextensionsV1beta1Interface,
    dbClient cs.Interface,
    stashClient scs.Interface,
    dynamicClient dynamic.Interface,
    appCatalogClient appcat_cs.AppcatalogV1alpha1Interface,
    promClient pcm.MonitoringV1Interface,
    cronController snapc.CronControllerInterface,
    opt amc.Config,
) *Controller

func (*Controller) EnsureCustomResourceDefinitions Uses

func (c *Controller) EnsureCustomResourceDefinitions() error

EnsureCustomResourceDefinitions ensures CRD for MySQl, DormantDatabase and Snapshot

func (*Controller) Init Uses

func (c *Controller) Init() error

InitInformer initializes MongoDB, DormantDB amd Snapshot watcher

func (*Controller) Run Uses

func (c *Controller) Run(stopCh <-chan struct{})

Blocks caller. Intended to be called as a Go routine.

func (*Controller) StartAndRunControllers Uses

func (c *Controller) StartAndRunControllers(stopCh <-chan struct{})

StartAndRunControllers starts InformetFactory and runs queue.worker

type OperatorConfig Uses

type OperatorConfig struct {
    amc.Config

    ClientConfig     *rest.Config
    KubeClient       kubernetes.Interface
    APIExtKubeClient crd_cs.ApiextensionsV1beta1Interface
    DBClient         cs.Interface
    StashClient      scs.Interface
    DynamicClient    dynamic.Interface
    AppCatalogClient appcat_cs.AppcatalogV1alpha1Interface
    PromClient       pcm.MonitoringV1Interface
    CronController   snapc.CronControllerInterface
}

func NewOperatorConfig Uses

func NewOperatorConfig(clientConfig *rest.Config) *OperatorConfig

func (*OperatorConfig) New Uses

func (c *OperatorConfig) New() (*Controller, error)

Package controller imports 28 packages (graph) and is imported by 4 packages. Updated 2019-07-28. Refresh now. Tools for package owners.