controller

Documentation

Index

• Constants
• type Controller
  • func New(client kubernetes.Interface, ...) *Controller
  • func (c *Controller) Exists(om *metav1.ObjectMeta) (bool, error)
  • func (c *Controller) GetDatabase(snapshot *api.Snapshot) (runtime.Object, error)
  • func (c *Controller) GetSnapshotter(snapshot *api.Snapshot) (*batch.Job, error)
  • func (c *Controller) PauseDatabase(dormantDb *api.DormantDatabase) error
  • func (c *Controller) ResumeDatabase(dormantDb *api.DormantDatabase) error
  • func (c *Controller) Run()
  • func (c *Controller) RunAndHold()
  • func (c *Controller) ValidateSnapshot(snapshot *api.Snapshot) error
  • func (c *Controller) WipeOutDatabase(dormantDb *api.DormantDatabase) error
  • func (c *Controller) WipeOutSnapshot(snapshot *api.Snapshot) error
• type Options

Constants

const (
	SnapshotProcess_Backup = "backup"
)

const (
	SnapshotProcess_Restore = "restore"
)

Types

type Controller

type Controller struct {
	*amc.Controller
	// Api Extension Client
	ApiExtKubeClient apiextensionsclient.ApiextensionsV1beta1Interface
	// contains filtered or unexported fields
}

func New

func New(
	client kubernetes.Interface,
	apiExtKubeClient apiextensionsclient.ApiextensionsV1beta1Interface,
	extClient cs.KubedbV1alpha1Interface,
	promClient pcm.MonitoringV1Interface,
	cronController amc.CronControllerInterface,
	opt Options,
) *Controller

func (*Controller) Exists

func (c *Controller) Exists(om *metav1.ObjectMeta) (bool, error)

func (*Controller) GetDatabase

func (c *Controller) GetDatabase(snapshot *api.Snapshot) (runtime.Object, error)

func (*Controller) GetSnapshotter

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

func (*Controller) PauseDatabase

func (c *Controller) PauseDatabase(dormantDb *api.DormantDatabase) error

func (*Controller) ResumeDatabase

func (c *Controller) ResumeDatabase(dormantDb *api.DormantDatabase) error

func (*Controller) Run

func (c *Controller) Run()

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

func (*Controller) RunAndHold

func (c *Controller) RunAndHold()

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

func (*Controller) ValidateSnapshot

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

func (*Controller) WipeOutDatabase

func (c *Controller) WipeOutDatabase(dormantDb *api.DormantDatabase) error

func (*Controller) WipeOutSnapshot

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

type Options

type Options struct {
	// Operator namespace
	OperatorNamespace string
	// Exporter tag
	ExporterTag string
	// Governing service
	GoverningService string
	// Address to listen on for web interface and telemetry.
	Address string
	// Enable RBAC for database workloads
	EnableRbac bool
}