controller

Documentation

Index

• type Controller
  • func (c *Controller) CreateGoverningService(name, namespace string) error
  • func (c *Controller) DeletePersistentVolumeClaims(namespace string, selector labels.Selector) error
  • func (c *Controller) DeleteSnapshotData(snapshot *api.Snapshot) error
  • func (c *Controller) DeleteSnapshots(namespace string, selector labels.Selector) error
  • func (c *Controller) SetJobOwnerReference(snapshot *api.Snapshot, job *batch.Job) error
• type Deleter
• type Snapshotter

Types

type Controller

type Controller struct {
	// Kubernetes client
	Client kubernetes.Interface
	// Api Extension Client
	ApiExtKubeClient crd_cs.ApiextensionsV1beta1Interface
	// ThirdPartyExtension client
	ExtClient cs.KubedbV1alpha1Interface
}

func (*Controller) CreateGoverningService

func (c *Controller) CreateGoverningService(name, namespace string) error

func (*Controller) DeletePersistentVolumeClaims

func (c *Controller) DeletePersistentVolumeClaims(namespace string, selector labels.Selector) error

func (*Controller) DeleteSnapshotData

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

func (*Controller) DeleteSnapshots

func (c *Controller) DeleteSnapshots(namespace string, selector labels.Selector) error

func (*Controller) SetJobOwnerReference

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

type Deleter

type Deleter interface {
	Exists(*metav1.ObjectMeta) (bool, error)
	PauseDatabase(*api.DormantDatabase) error
	WipeOutDatabase(*api.DormantDatabase) error
	ResumeDatabase(*api.DormantDatabase) error
}

type Snapshotter

type Snapshotter interface {
	ValidateSnapshot(*api.Snapshot) error
	GetDatabase(metav1.ObjectMeta) (runtime.Object, error)
	GetSnapshotter(*api.Snapshot) (*batch.Job, error)
	WipeOutSnapshot(*api.Snapshot) error
	SetDatabaseStatus(metav1.ObjectMeta, api.DatabasePhase, string) error
	UpsertDatabaseAnnotation(metav1.ObjectMeta, map[string]string) error
}