controllers

Documentation

Index

• Constants
• type ClusterPairController
  • func (c *ClusterPairController) Handle(ctx context.Context, event sdk.Event) error
  • func (c *ClusterPairController) Init() error
• type MigrationController
  • func (m *MigrationController) Handle(ctx context.Context, event sdk.Event) error
  • func (m *MigrationController) Init(migrationAdminNamespace string) error
• type MigrationScheduleController
  • func (m *MigrationScheduleController) Handle(ctx context.Context, event sdk.Event) error
  • func (m *MigrationScheduleController) Init() 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"
)

Types

type ClusterPairController

type ClusterPairController struct {
	Driver   volume.Driver
	Recorder record.EventRecorder
}

ClusterPairController controller to watch over ClusterPair

func (*ClusterPairController) Handle

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

Handle updates for ClusterPair objects

func (*ClusterPairController) Init

func (c *ClusterPairController) Init() error

Init initialize the cluster pair controller

type MigrationController

type MigrationController struct {
	Driver            volume.Driver
	Recorder          record.EventRecorder
	ResourceCollector resourcecollector.ResourceCollector
	// contains filtered or unexported fields
}

MigrationController reconciles migration objects

func (*MigrationController) Handle

func (m *MigrationController) Handle(ctx context.Context, event sdk.Event) error

Handle updates for Migration objects

func (*MigrationController) Init

func (m *MigrationController) Init(migrationAdminNamespace string) error

Init Initialize the migration controller

type MigrationScheduleController

type MigrationScheduleController struct {
	Driver   volume.Driver
	Recorder record.EventRecorder
}

MigrationScheduleController reconciles MigrationSchedule objects

func (*MigrationScheduleController) Handle

func (m *MigrationScheduleController) Handle(ctx context.Context, event sdk.Event) error

Handle updates for MigrationSchedule objects

func (*MigrationScheduleController) Init

func (m *MigrationScheduleController) Init() error

Init Initialize the migration schedule controller