controllers

Documentation

Index

• Constants
• type ClusterPairController
  • func NewClusterPair(mgr manager.Manager, d volume.Driver, r record.EventRecorder) *ClusterPairController
  • func (c *ClusterPairController) Init(mgr manager.Manager) error
  • func (c *ClusterPairController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type MigrationController
  • func NewMigration(mgr manager.Manager, d volume.Driver, r record.EventRecorder, ...) *MigrationController
  • func (m *MigrationController) Init(mgr manager.Manager, migrationAdminNamespace string, migrationMaxThreads int) error
  • func (m *MigrationController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type MigrationScheduleController
  • func NewMigrationSchedule(mgr manager.Manager, d volume.Driver, r record.EventRecorder) *MigrationScheduleController
  • func (m *MigrationScheduleController) Init(mgr manager.Manager) error
  • func (m *MigrationScheduleController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Constants

const (
	// StorkMigrationReplicasAnnotation is the annotation used to keep track of
	// the number of replicas for an application when it was migrated
	StorkMigrationReplicasAnnotation = "stork.libopenstorage.org/migrationReplicas"
	// StorkMigrationAnnotation is the annotation used to keep track of resources
	// migrated by stork
	StorkMigrationAnnotation = "stork.libopenstorage.org/migrated"
	// StorkMigrationName is the annotation used to identify resource migrated by
	// migration CRD name
	StorkMigrationName = "stork.libopenstorage.org/migrationName"
	// StorkMigrationTime is the annotation used to specify time of migration
	StorkMigrationTime = "stork.libopenstorage.org/migrationTime"
	// StorkMigrationCRDActivateAnnotation is the annotation used to keep track of
	// the value to be set for activating crds
	StorkMigrationCRDActivateAnnotation = "stork.libopenstorage.org/migrationCRDActivate"
	// StorkMigrationCRDDeactivateAnnotation is the annotation used to keep track of
	// the value to be set for deactivating crds
	StorkMigrationCRDDeactivateAnnotation = "stork.libopenstorage.org/migrationCRDDeactivate"
	// PVReclaimAnnotation for pvc's reclaim policy
	PVReclaimAnnotation = "stork.libopenstorage.org/reclaimPolicy"
	// StorkAnnotationPrefix for resources created/managed by stork
	StorkAnnotationPrefix = "stork.libopenstorage.org/"
)

const (

	// StorkMigrationScheduleCopied indicating migrated migrationscheduleobject
	StorkMigrationScheduleCopied = "stork.libopenstorage.org/static-copy"
	// StorkMigrationScheduleName is the annotation to keep track of child migration
	// objects triggered by migration schedule
	StorkMigrationScheduleName = "stork.libopenstorage.org/migration-schedule-name"
)

Types

type ClusterPairController

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

ClusterPairController controller to watch over ClusterPair

func NewClusterPair

func NewClusterPair(mgr manager.Manager, d volume.Driver, r record.EventRecorder) *ClusterPairController

NewClusterPair creates a new instance of ClusterPairController.

func (*ClusterPairController) Init

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

Init initialize the cluster pair controller

func (*ClusterPairController) Reconcile

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

Reconcile manages ClusterPair resources.

type MigrationController

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

MigrationController reconciles migration objects

func NewMigration

func NewMigration(mgr manager.Manager, d volume.Driver, r record.EventRecorder, rc resourcecollector.ResourceCollector) *MigrationController

NewMigration creates a new instance of MigrationController.

func (*MigrationController) Init

func (m *MigrationController) Init(mgr manager.Manager, migrationAdminNamespace string, migrationMaxThreads int) error

Init Initialize the migration controller

func (*MigrationController) Reconcile

func (m *MigrationController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile manages Migration resources.

type MigrationScheduleController

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

MigrationScheduleController reconciles MigrationSchedule objects

func NewMigrationSchedule

func NewMigrationSchedule(mgr manager.Manager, d volume.Driver, r record.EventRecorder) *MigrationScheduleController

NewMigrationSchedule creates a new instance of MigrationScheduleController.

func (*MigrationScheduleController) Init

func (m *MigrationScheduleController) Init(mgr manager.Manager) error

Init Initialize the migration schedule controller

func (*MigrationScheduleController) Reconcile

func (m *MigrationScheduleController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile manages MigrationSchedule resources.