controllers

Documentation

Index

• Constants
• func NewSnapshotProvisioner(client kubernetes.Interface, crdclient *rest.RESTClient, ...) controller.Provisioner
• type SnapshotScheduleController
  • func (s *SnapshotScheduleController) Handle(ctx context.Context, event sdk.Event) error
  • func (s *SnapshotScheduleController) Init() 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 (

	// SnapshotScheduleNameLabel Label used to specify the name of schedule that
	// created the snapshot
	SnapshotScheduleNameLabel = "stork.libopenstorage.org/snapshotScheduleName"
	// SnapshotSchedulePolicyTypeLabel Label used to specify the type of the
	// policy that triggered the snapshot
	SnapshotSchedulePolicyTypeLabel = "stork.libopenstorage.org/snapshotSchedulePolicyType"
)

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 SnapshotScheduleController

type SnapshotScheduleController struct {
	Recorder record.EventRecorder
}

SnapshotScheduleController reconciles VolumeSnapshotSchedule objects

func (*SnapshotScheduleController) Handle

func (s *SnapshotScheduleController) Handle(ctx context.Context, event sdk.Event) error

Handle updates for VolumeSnapshotSchedule objects

func (*SnapshotScheduleController) Init

func (s *SnapshotScheduleController) Init() error

Init Initialize the snapshot schedule controller

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