controllers

package

v2.3.3+incompatible Latest Latest Go to latest Published: Apr 3, 2020 License: Apache-2.0 Imports: 32 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/diptiranjanpx/stork

Links

Open Source Insights

Documentation ¶

Index ¶

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

View Source

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"
)

View Source

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"
)

View Source

const (

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

Variables ¶

This section is empty.

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 {
	Driver   volume.Driver
	Recorder record.EventRecorder
}

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

func (*SnapshotRestoreController) Handle ¶

func (c *SnapshotRestoreController) Handle(ctx context.Context, event sdk.Event) error

Handle updates for SnapshotRestore objects

func (*SnapshotRestoreController) Init ¶

func (c *SnapshotRestoreController) Init() error

Init initialize the cluster pair controller

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL