mongodb: Index | Files

package controller

import ""


Package Files

appbinding.go certificate.go config.go configsource.go controller.go deployment.go dormant_database.go job.go mongodb.go monitor.go rbac.go replicaset.go secret.go service.go snapshot.go statefulset.go workqueue.go


const (
    KeyMongoDBUser     = "username"
    KeyMongoDBPassword = "password"
    KeyForKeyFile      = "key.txt"

    DatabaseSecretSuffix    = "-auth"
    CertificateSecretSuffix = "-cert"
const (
    InitInstallContainerName   = "copy-config"
    InitBootstrapContainerName = "bootstrap"
const (
    MongoDBPort = 27017

type Controller Uses

type Controller struct {
    // contains filtered or unexported fields

func New Uses

func New(
    clientConfig *rest.Config,
    client kubernetes.Interface,
    apiExtKubeClient crd_cs.ApiextensionsV1beta1Interface,
    extClient cs.Interface,
    stashClient scs.Interface,
    dc dynamic.Interface,
    appCatalogClient appcat_cs.Interface,
    promClient pcm.MonitoringV1Interface,
    cronController snapc.CronControllerInterface,
    opt amc.Config,
    recorder record.EventRecorder,
) *Controller

func (*Controller) EnsureCustomResourceDefinitions Uses

func (c *Controller) EnsureCustomResourceDefinitions() error

EnsureCustomResourceDefinitions ensures CRD for MongoDB, DormantDatabase and Snapshot

func (*Controller) GetDatabase Uses

func (c *Controller) GetDatabase(meta metav1.ObjectMeta) (runtime.Object, error)

func (*Controller) GetSnapshotter Uses

func (c *Controller) GetSnapshotter(snapshot *api.Snapshot) (*batch.Job, error)

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) RunControllers Uses

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

RunControllers runs queue.worker

func (*Controller) SetDatabaseStatus Uses

func (c *Controller) SetDatabaseStatus(meta metav1.ObjectMeta, phase api.DatabasePhase, reason string) error

func (*Controller) StartAndRunControllers Uses

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

StartAndRunControllers starts InformetFactory and runs queue.worker

func (*Controller) UpsertDatabaseAnnotation Uses

func (c *Controller) UpsertDatabaseAnnotation(meta metav1.ObjectMeta, annotation map[string]string) error

func (*Controller) ValidateSnapshot Uses

func (c *Controller) ValidateSnapshot(snapshot *api.Snapshot) error

func (*Controller) WaitUntilPaused Uses

func (c *Controller) WaitUntilPaused(drmn *api.DormantDatabase) error

func (*Controller) WipeOutDatabase Uses

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.

func (*Controller) WipeOutSnapshot Uses

func (c *Controller) WipeOutSnapshot(snapshot *api.Snapshot) error

type OperatorConfig Uses

type OperatorConfig struct {

    ClientConfig     *rest.Config
    KubeClient       kubernetes.Interface
    APIExtKubeClient crd_cs.ApiextensionsV1beta1Interface
    DBClient         cs.Interface
    DynamicClient    dynamic.Interface
    StashClient      scs.Interface
    AppCatalogClient appcat_cs.Interface
    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 72 packages (graph) and is imported by 8 packages. Updated 2019-10-16. Refresh now. Tools for package owners.