migration

May 27, 2024

Changes in this version

+ const Migration_ArrayMigrate_FullMethodName

+ const Migration_GetMigrationCapabilities_FullMethodName

+ const Migration_ProbeController_FullMethodName

+ const Migration_VolumeMigrate_FullMethodName

Feb 23, 2023

Changes in this version

+ var ActionTypes_name = map[int32]string

+ var ActionTypes_value = map[string]int32

+ type Action struct

+ ActionTypes ActionTypes

+ func (*Action) Descriptor() ([]byte, []int)

+ func (*Action) ProtoMessage()

+ func (x *Action) GetActionTypes() ActionTypes

+ func (x *Action) ProtoReflect() protoreflect.Message

+ func (x *Action) Reset()

+ func (x *Action) String() string

+ type ActionTypes int32

+ const ActionTypes_MG_COMMIT

+ const ActionTypes_MG_MIGRATE

+ const ActionTypes_MG_RESCAN

+ const ActionTypes_UNKNOWN_ACTION

+ func (ActionTypes) Descriptor() protoreflect.EnumDescriptor

+ func (ActionTypes) EnumDescriptor() ([]byte, []int)

+ func (ActionTypes) Type() protoreflect.EnumType

+ func (x ActionTypes) Enum() *ActionTypes

+ func (x ActionTypes) Number() protoreflect.EnumNumber

+ func (x ActionTypes) String() string

+ type ArrayMigrateRequest struct

+ ActionTypes isArrayMigrateRequest_ActionTypes

+ Parameters map[string]string

+ func (*ArrayMigrateRequest) Descriptor() ([]byte, []int)

+ func (*ArrayMigrateRequest) ProtoMessage()

+ func (m *ArrayMigrateRequest) GetActionTypes() isArrayMigrateRequest_ActionTypes

+ func (x *ArrayMigrateRequest) GetAction() *Action

+ func (x *ArrayMigrateRequest) GetParameters() map[string]string

+ func (x *ArrayMigrateRequest) ProtoReflect() protoreflect.Message

+ func (x *ArrayMigrateRequest) Reset()

+ func (x *ArrayMigrateRequest) String() string

+ type ArrayMigrateRequest_Action struct

+ Action *Action

+ type ArrayMigrateResponse struct

+ ActionTypes isArrayMigrateResponse_ActionTypes

+ Success bool

+ func (*ArrayMigrateResponse) Descriptor() ([]byte, []int)

+ func (*ArrayMigrateResponse) ProtoMessage()

+ func (m *ArrayMigrateResponse) GetActionTypes() isArrayMigrateResponse_ActionTypes

+ func (x *ArrayMigrateResponse) GetAction() *Action

+ func (x *ArrayMigrateResponse) GetSuccess() bool

+ func (x *ArrayMigrateResponse) ProtoReflect() protoreflect.Message

+ func (x *ArrayMigrateResponse) Reset()

+ func (x *ArrayMigrateResponse) String() string

+ type ArrayMigrateResponse_Action struct

+ Action *Action

type MigrationClient

+ ArrayMigrate func(ctx context.Context, in *ArrayMigrateRequest, opts ...grpc.CallOption) (*ArrayMigrateResponse, error)

type MigrationServer

+ ArrayMigrate func(context.Context, *ArrayMigrateRequest) (*ArrayMigrateResponse, error)

+ type SupportedActions struct

+ Actions isSupportedActions_Actions

+ func (*SupportedActions) Descriptor() ([]byte, []int)

+ func (*SupportedActions) ProtoMessage()

+ func (m *SupportedActions) GetActions() isSupportedActions_Actions

+ func (x *SupportedActions) GetType() ActionTypes

+ func (x *SupportedActions) ProtoReflect() protoreflect.Message

+ func (x *SupportedActions) Reset()

+ func (x *SupportedActions) String() string

+ type SupportedActions_Type struct

+ Type ActionTypes

type UnimplementedMigrationServer

+ func (UnimplementedMigrationServer) ArrayMigrate(context.Context, *ArrayMigrateRequest) (*ArrayMigrateResponse, error)

May 31, 2022

Changes in this version

type VolumeMigrateRequest

+ ScSourceParameters map[string]string

+ func (x *VolumeMigrateRequest) GetScSourceParameters() map[string]string

May 17, 2022

Changes in this version

+ var File_migration_proto protoreflect.FileDescriptor

+ var MigrateTypes_name = map[int32]string

+ var MigrateTypes_value = map[string]int32

+ var Migration_ServiceDesc = grpc.ServiceDesc

+ func RegisterMigrationServer(s grpc.ServiceRegistrar, srv MigrationServer)

+ type GetMigrationCapabilityRequest struct

+ func (*GetMigrationCapabilityRequest) Descriptor() ([]byte, []int)

+ func (*GetMigrationCapabilityRequest) ProtoMessage()

+ func (x *GetMigrationCapabilityRequest) ProtoReflect() protoreflect.Message

+ func (x *GetMigrationCapabilityRequest) Reset()

+ func (x *GetMigrationCapabilityRequest) String() string

+ type GetMigrationCapabilityResponse struct

+ Capabilities []*MigrationCapability

+ func (*GetMigrationCapabilityResponse) Descriptor() ([]byte, []int)

+ func (*GetMigrationCapabilityResponse) ProtoMessage()

+ func (x *GetMigrationCapabilityResponse) GetCapabilities() []*MigrationCapability

+ func (x *GetMigrationCapabilityResponse) ProtoReflect() protoreflect.Message

+ func (x *GetMigrationCapabilityResponse) Reset()

+ func (x *GetMigrationCapabilityResponse) String() string

+ type MigrateTypes int32

+ const MigrateTypes_NON_REPL_TO_REPL

+ const MigrateTypes_REPL_TO_NON_REPL

+ const MigrateTypes_UNKNOWN_MIGRATE

+ const MigrateTypes_VERSION_UPGRADE

+ func (MigrateTypes) Descriptor() protoreflect.EnumDescriptor

+ func (MigrateTypes) EnumDescriptor() ([]byte, []int)

+ func (MigrateTypes) Type() protoreflect.EnumType

+ func (x MigrateTypes) Enum() *MigrateTypes

+ func (x MigrateTypes) Number() protoreflect.EnumNumber

+ func (x MigrateTypes) String() string

+ type MigrationCapability struct

+ Type isMigrationCapability_Type

+ func (*MigrationCapability) Descriptor() ([]byte, []int)

+ func (*MigrationCapability) ProtoMessage()

+ func (m *MigrationCapability) GetType() isMigrationCapability_Type

+ func (x *MigrationCapability) GetRpc() *MigrationCapability_RPC

+ func (x *MigrationCapability) ProtoReflect() protoreflect.Message

+ func (x *MigrationCapability) Reset()

+ func (x *MigrationCapability) String() string

+ type MigrationCapability_RPC struct

+ Type MigrateTypes

+ func (*MigrationCapability_RPC) Descriptor() ([]byte, []int)

+ func (*MigrationCapability_RPC) ProtoMessage()

+ func (x *MigrationCapability_RPC) GetType() MigrateTypes

+ func (x *MigrationCapability_RPC) ProtoReflect() protoreflect.Message

+ func (x *MigrationCapability_RPC) Reset()

+ func (x *MigrationCapability_RPC) String() string

+ type MigrationCapability_Rpc struct

+ Rpc *MigrationCapability_RPC

+ type MigrationClient interface

+ GetMigrationCapabilities func(ctx context.Context, in *GetMigrationCapabilityRequest, ...) (*GetMigrationCapabilityResponse, error)

+ ProbeController func(ctx context.Context, in *common.ProbeControllerRequest, ...) (*common.ProbeControllerResponse, error)

+ VolumeMigrate func(ctx context.Context, in *VolumeMigrateRequest, opts ...grpc.CallOption) (*VolumeMigrateResponse, error)

+ func NewMigrationClient(cc grpc.ClientConnInterface) MigrationClient

+ type MigrationServer interface

+ GetMigrationCapabilities func(context.Context, *GetMigrationCapabilityRequest) (*GetMigrationCapabilityResponse, error)

+ ProbeController func(context.Context, *common.ProbeControllerRequest) (*common.ProbeControllerResponse, error)

+ VolumeMigrate func(context.Context, *VolumeMigrateRequest) (*VolumeMigrateResponse, error)

+ type UnimplementedMigrationServer struct

+ func (UnimplementedMigrationServer) GetMigrationCapabilities(context.Context, *GetMigrationCapabilityRequest) (*GetMigrationCapabilityResponse, error)

+ func (UnimplementedMigrationServer) ProbeController(context.Context, *common.ProbeControllerRequest) (*common.ProbeControllerResponse, error)

+ func (UnimplementedMigrationServer) VolumeMigrate(context.Context, *VolumeMigrateRequest) (*VolumeMigrateResponse, error)

+ type UnsafeMigrationServer interface

+ type Volume struct

+ CapacityBytes int64

+ FsType string

+ VolumeContext map[string]string

+ VolumeId string

+ func (*Volume) Descriptor() ([]byte, []int)

+ func (*Volume) ProtoMessage()

+ func (x *Volume) GetCapacityBytes() int64

+ func (x *Volume) GetFsType() string

+ func (x *Volume) GetVolumeContext() map[string]string

+ func (x *Volume) GetVolumeId() string

+ func (x *Volume) ProtoReflect() protoreflect.Message

+ func (x *Volume) Reset()

+ func (x *Volume) String() string

+ type VolumeMigrateRequest struct

+ MigrateTypes isVolumeMigrateRequest_MigrateTypes

+ ScParameters map[string]string

+ ShouldClone bool

+ StorageClass string

+ VolumeHandle string

+ func (*VolumeMigrateRequest) Descriptor() ([]byte, []int)

+ func (*VolumeMigrateRequest) ProtoMessage()

+ func (m *VolumeMigrateRequest) GetMigrateTypes() isVolumeMigrateRequest_MigrateTypes

+ func (x *VolumeMigrateRequest) GetScParameters() map[string]string

+ func (x *VolumeMigrateRequest) GetShouldClone() bool

+ func (x *VolumeMigrateRequest) GetStorageClass() string

+ func (x *VolumeMigrateRequest) GetType() MigrateTypes

+ func (x *VolumeMigrateRequest) GetVolumeHandle() string

+ func (x *VolumeMigrateRequest) ProtoReflect() protoreflect.Message

+ func (x *VolumeMigrateRequest) Reset()

+ func (x *VolumeMigrateRequest) String() string

+ type VolumeMigrateRequest_Type struct

+ Type MigrateTypes

+ type VolumeMigrateResponse struct

+ MigratedVolume *Volume

+ func (*VolumeMigrateResponse) Descriptor() ([]byte, []int)

+ func (*VolumeMigrateResponse) ProtoMessage()

+ func (x *VolumeMigrateResponse) GetMigratedVolume() *Volume

+ func (x *VolumeMigrateResponse) ProtoReflect() protoreflect.Message

+ func (x *VolumeMigrateResponse) Reset()

+ func (x *VolumeMigrateResponse) String() string