migration

Documentation

Index

• type Migration
  • func New(conn *grpc.ClientConn, log logr.Logger, timeout time.Duration) Migration
• type MockMigration
  • func NewFakeMigrationClient(contextPrefix string) MockMigration
  • func (m *MockMigration) ArrayMigrate(_ context.Context, migrateAction *csiext.ArrayMigrateRequest_Action, ...) (*csiext.ArrayMigrateResponse, error)
  • func (m *MockMigration) ClearError(force bool)
  • func (m *MockMigration) InjectError(err error)
  • func (m *MockMigration) VolumeMigrate(_ context.Context, _ string, _ string, _ *csiext.VolumeMigrateRequest_Type, ...) (*csiext.VolumeMigrateResponse, error)

Types

type Migration

type Migration interface {
	VolumeMigrate(context.Context, string, string, *csiext.VolumeMigrateRequest_Type, map[string]string, map[string]string, bool) (*csiext.VolumeMigrateResponse, error)
	ArrayMigrate(context.Context, *csiext.ArrayMigrateRequest_Action, map[string]string) (*csiext.ArrayMigrateResponse, error)
}

Migration is an interface that defines calls used for querying migration management calls to the driver

func New

func New(conn *grpc.ClientConn, log logr.Logger, timeout time.Duration) Migration

New returns new implementation of Replication interface

type MockMigration

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

MockMigration is dummy implementation of Migration interface

func NewFakeMigrationClient

func NewFakeMigrationClient(contextPrefix string) MockMigration

NewFakeMigrationClient returns mock implementation of Migration interface

func (*MockMigration) ArrayMigrate

func (m *MockMigration) ArrayMigrate(_ context.Context, migrateAction *csiext.ArrayMigrateRequest_Action, _ map[string]string) (*csiext.ArrayMigrateResponse, error)

ArrayMigrate migrates volume from source array to target

func (*MockMigration) ClearError

func (m *MockMigration) ClearError(force bool)

ClearError clears injected error

func (*MockMigration) InjectError

func (m *MockMigration) InjectError(err error)

InjectError injects error

func (*MockMigration) VolumeMigrate

func (m *MockMigration) VolumeMigrate(_ context.Context, _ string, _ string, _ *csiext.VolumeMigrateRequest_Type,
	_ map[string]string, _ map[string]string, _ bool,
) (*csiext.VolumeMigrateResponse, error)

VolumeMigrate migrates volume