controllers

Documentation

Index

• Constants
• func NewSnapshotProvisioner(client kubernetes.Interface, crdclient *rest.RESTClient, ...) controller.Provisioner
• type SnapshotRestoreController
  • func NewSnapshotRestoreController(mgr manager.Manager, d volume.Driver, r record.EventRecorder) *SnapshotRestoreController
  • func (c *SnapshotRestoreController) Init(mgr manager.Manager) error
  • func (c *SnapshotRestoreController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type SnapshotScheduleController
  • func NewSnapshotScheduleController(mgr manager.Manager, r record.EventRecorder) *SnapshotScheduleController
  • func (s *SnapshotScheduleController) Init(mgr manager.Manager) error
  • func (s *SnapshotScheduleController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type Snapshotter
  • func (s *Snapshotter) Start(stopChannel <-chan struct{}) error

Constants

const (
	// StorkSnapshotRestoreNamespacesAnnotation is annotation used to specify the
	// command separated list of namespaces to which the snapshot can be restored
	StorkSnapshotRestoreNamespacesAnnotation = "stork.libopenstorage.org/snapshot-restore-namespaces"
	// StorkSnapshotRestoreNamespacesAnnotationDeprecated deprecated version of StorkSnapshotRestoreNamespacesAnnotation
	StorkSnapshotRestoreNamespacesAnnotationDeprecated = "stork/snapshot-restore-namespaces"
	// StorkSnapshotSourceNamespaceAnnotation Annotation used to specify the
	// source of the snapshot when creating a PVC
	StorkSnapshotSourceNamespaceAnnotation = "stork.libopenstorage.org/snapshot-source-namespace"
	// StorkSnapshotSourceNamespaceAnnotationDeprecated deprecated version of StorkSnapshotSourceNamespaceAnnotation
	StorkSnapshotSourceNamespaceAnnotationDeprecated = "stork/snapshot-source-namespace"
)

const (

	// SnapshotScheduleNameAnnotation Annotation used to specify the name of schedule that
	// created the snapshot
	SnapshotScheduleNameAnnotation = "stork.libopenstorage.org/snapshotScheduleName"
	// SnapshotSchedulePolicyTypeAnnotation Annotation used to specify the type of the
	// policy that triggered the snapshot
	SnapshotSchedulePolicyTypeAnnotation = "stork.libopenstorage.org/snapshotSchedulePolicyType"
)

const (

	// RestoreAnnotation for pvc which has in-place restore in progress
	RestoreAnnotation = annotationPrefix + "restore-in-progress"
)

Functions

func NewSnapshotProvisioner

func NewSnapshotProvisioner(
	client kubernetes.Interface,
	crdclient *rest.RESTClient,
	volumePlugins map[string]volume.Plugin,
	id string,
) controller.Provisioner

NewSnapshotProvisioner Creates a new snapshot provisioner controller

Types

type SnapshotRestoreController

type SnapshotRestoreController struct {
	// contains filtered or unexported fields
}

SnapshotRestoreController controller to watch over In-Place snap restore CRD's

func NewSnapshotRestoreController

func NewSnapshotRestoreController(mgr manager.Manager, d volume.Driver, r record.EventRecorder) *SnapshotRestoreController

NewSnapshotRestoreController creates a new instance of SnapshotRestoreController.

func (*SnapshotRestoreController) Init

func (c *SnapshotRestoreController) Init(mgr manager.Manager) error

Init initialize the cluster pair controller

func (*SnapshotRestoreController) Reconcile

func (c *SnapshotRestoreController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile manages SnapShot resources.

type SnapshotScheduleController

type SnapshotScheduleController struct {
	// contains filtered or unexported fields
}

SnapshotScheduleController reconciles VolumeSnapshotSchedule objects

func NewSnapshotScheduleController

func NewSnapshotScheduleController(mgr manager.Manager, r record.EventRecorder) *SnapshotScheduleController

NewSnapshotScheduleController creates a new instance of SnapshotScheduleController.

func (*SnapshotScheduleController) Init

func (s *SnapshotScheduleController) Init(mgr manager.Manager) error

Init Initialize the snapshot schedule controller

func (*SnapshotScheduleController) Reconcile

func (s *SnapshotScheduleController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile manages SnapshotSchedule resources.

type Snapshotter

type Snapshotter struct {
	Driver volume.Driver
	// contains filtered or unexported fields
}

Snapshotter Snapshot Controller

func (*Snapshotter) Start

func (s *Snapshotter) Start(stopChannel <-chan struct{}) error

Start Starts the snapshot controller