Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct { amc.Config *amc.Controller // contains filtered or unexported fields }
func New ¶
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 ¶
func (c *Controller) EnsureCustomResourceDefinitions() error
EnsureCustomResourceDefinitions ensures CRD for MySQl, DormantDatabase and Snapshot
func (*Controller) Init ¶
func (c *Controller) Init() error
InitInformer initializes MongoDB, DormantDB amd Snapshot watcher
func (*Controller) Run ¶
func (c *Controller) Run(stopCh <-chan struct{})
Blocks caller. Intended to be called as a Go routine.
func (*Controller) StartAndRunControllers ¶
func (c *Controller) StartAndRunControllers(stopCh <-chan struct{})
StartAndRunControllers starts InformetFactory and runs queue.worker
type OperatorConfig ¶
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 ¶
func NewOperatorConfig(clientConfig *rest.Config) *OperatorConfig
func (*OperatorConfig) New ¶
func (c *OperatorConfig) New() (*Controller, error)
Click to show internal directories.
Click to hide internal directories.