Documentation
¶
Index ¶
- Constants
- type Controller
- func (c *Controller) EnsureCustomResourceDefinitions() error
- func (c *Controller) Init() error
- func (c *Controller) Run(stopCh <-chan struct{})
- func (c *Controller) RunControllers(stopCh <-chan struct{})
- func (c *Controller) StartAndRunControllers(stopCh <-chan struct{})
- func (c *Controller) WaitUntilPaused(drmn *api.DormantDatabase) error
- func (c *Controller) WipeOutDatabase(drmn *api.DormantDatabase) error
- type OperatorConfig
Constants ¶
View Source
const ( RedisConfigKey = "redis.conf" RedisConfigRelativePath = "redis.conf" )
View Source
const (
CONFIG_MOUNT_PATH = "/usr/local/etc/redis/"
)
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, extClient cs.Interface, dynamicClient dynamic.Interface, appCatalogClient appcat_cs.AppcatalogV1alpha1Interface, promClient pcm.MonitoringV1Interface, opt amc.Config, recorder record.EventRecorder, ) *Controller
func (*Controller) EnsureCustomResourceDefinitions ¶
func (c *Controller) EnsureCustomResourceDefinitions() error
EnsureCustomResourceDefinitions ensures CRD for MySQl, DormantDatabase
func (*Controller) Init ¶
func (c *Controller) Init() error
InitInformer initializes Redis, 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) RunControllers ¶
func (c *Controller) RunControllers(stopCh <-chan struct{})
RunControllers runs queue.worker
func (*Controller) StartAndRunControllers ¶
func (c *Controller) StartAndRunControllers(stopCh <-chan struct{})
StartAndRunControllers starts InformetFactory and runs queue.worker
func (*Controller) WaitUntilPaused ¶
func (c *Controller) WaitUntilPaused(drmn *api.DormantDatabase) error
func (*Controller) WipeOutDatabase ¶
func (c *Controller) WipeOutDatabase(drmn *api.DormantDatabase) error
WipeOutDatabase is an Interface of *amc.Controller. It verifies and deletes secrets and other left overs of DBs except Snapshot and PVC.
type OperatorConfig ¶
type OperatorConfig struct {
amc.Config
ClientConfig *rest.Config
KubeClient kubernetes.Interface
APIExtKubeClient crd_cs.ApiextensionsV1beta1Interface
DBClient cs.Interface
DynamicClient dynamic.Interface
AppCatalogClient appcat_cs.AppcatalogV1alpha1Interface
PromClient pcm.MonitoringV1Interface
}
func NewOperatorConfig ¶
func NewOperatorConfig(clientConfig *rest.Config) *OperatorConfig
func (*OperatorConfig) New ¶
func (c *OperatorConfig) New() (*Controller, error)
Source Files
Click to show internal directories.
Click to hide internal directories.