migration

package module
v1.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 13, 2025 License: Apache-2.0 Imports: 9 Imported by: 7

Documentation

Index

Constants

View Source 
const (
	Migration_ProbeController_FullMethodName          = "/migration.v1.Migration/ProbeController"
	Migration_VolumeMigrate_FullMethodName            = "/migration.v1.Migration/VolumeMigrate"
	Migration_ArrayMigrate_FullMethodName             = "/migration.v1.Migration/ArrayMigrate"
	Migration_GetMigrationCapabilities_FullMethodName = "/migration.v1.Migration/GetMigrationCapabilities"
)

Variables

View Source 
var (
	MigrateTypes_name = map[int32]string{
		0: "UNKNOWN_MIGRATE",
		1: "NON_REPL_TO_REPL",
		2: "REPL_TO_NON_REPL",
		3: "VERSION_UPGRADE",
	}
	MigrateTypes_value = map[string]int32{
		"UNKNOWN_MIGRATE":  0,
		"NON_REPL_TO_REPL": 1,
		"REPL_TO_NON_REPL": 2,
		"VERSION_UPGRADE":  3,
	}
)

Enum value maps for MigrateTypes.

View Source 
var (
	ActionTypes_name = map[int32]string{
		0: "UNKNOWN_ACTION",
		1: "MG_MIGRATE",
		2: "MG_RESCAN",
		3: "MG_COMMIT",
	}
	ActionTypes_value = map[string]int32{
		"UNKNOWN_ACTION": 0,
		"MG_MIGRATE":     1,
		"MG_RESCAN":      2,
		"MG_COMMIT":      3,
	}
)

Enum value maps for ActionTypes.

View Source 
var File_migration_proto protoreflect.FileDescriptor
View Source 
var Migration_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "migration.v1.Migration",
	HandlerType: (*MigrationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProbeController",
			Handler:    _Migration_ProbeController_Handler,
		},
		{
			MethodName: "VolumeMigrate",
			Handler:    _Migration_VolumeMigrate_Handler,
		},
		{
			MethodName: "ArrayMigrate",
			Handler:    _Migration_ArrayMigrate_Handler,
		},
		{
			MethodName: "GetMigrationCapabilities",
			Handler:    _Migration_GetMigrationCapabilities_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "migration.proto",
}

Migration_ServiceDesc is the grpc.ServiceDesc for Migration service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMigrationServer 

func RegisterMigrationServer(s grpc.ServiceRegistrar, srv MigrationServer)

Types

type Action added in v1.1.0 

type Action struct {
	ActionTypes ActionTypes `protobuf:"varint,1,opt,name=action_types,json=actionTypes,proto3,enum=migration.v1.ActionTypes" json:"action_types,omitempty"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetActionTypes added in v1.1.0 

func (x *Action) GetActionTypes() ActionTypes

func (*Action) ProtoMessage added in v1.1.0 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect added in v1.1.0 

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

func (*Action) Reset added in v1.1.0 

func (x *Action) Reset()

func (*Action) String added in v1.1.0 

func (x *Action) String() string

type ActionTypes added in v1.1.0 

type ActionTypes int32

ActionTypes are the exhaustive set of actions which can be performed on the migration group 

const (
	// Site-Aware actions
	ActionTypes_UNKNOWN_ACTION ActionTypes = 0
	// Migrate
	ActionTypes_MG_MIGRATE ActionTypes = 1
	// Rescan
	ActionTypes_MG_RESCAN ActionTypes = 2
	// Commit
	ActionTypes_MG_COMMIT ActionTypes = 3
)

func (ActionTypes) Descriptor added in v1.1.0 

func (ActionTypes) Descriptor() protoreflect.EnumDescriptor

func (ActionTypes) Enum added in v1.1.0 

func (x ActionTypes) Enum() *ActionTypes

func (ActionTypes) EnumDescriptor deprecated added in v1.1.0 

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

Deprecated: Use ActionTypes.Descriptor instead.

func (ActionTypes) Number added in v1.1.0 

func (x ActionTypes) Number() protoreflect.EnumNumber

func (ActionTypes) String added in v1.1.0 

func (x ActionTypes) String() string

func (ActionTypes) Type added in v1.1.0 

func (ActionTypes) Type() protoreflect.EnumType

type ArrayMigrateRequest added in v1.1.0 

type ArrayMigrateRequest struct {

	// Types that are assignable to ActionTypes:
	//
	//	*ArrayMigrateRequest_Action
	ActionTypes isArrayMigrateRequest_ActionTypes `protobuf_oneof:"action_types"`
	Parameters  map[string]string                 `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ArrayMigrateRequest) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use ArrayMigrateRequest.ProtoReflect.Descriptor instead.

func (*ArrayMigrateRequest) GetAction added in v1.1.0 

func (x *ArrayMigrateRequest) GetAction() *Action

func (*ArrayMigrateRequest) GetActionTypes added in v1.1.0 

func (m *ArrayMigrateRequest) GetActionTypes() isArrayMigrateRequest_ActionTypes

func (*ArrayMigrateRequest) GetParameters added in v1.1.0 

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

func (*ArrayMigrateRequest) ProtoMessage added in v1.1.0 

func (*ArrayMigrateRequest) ProtoMessage()

func (*ArrayMigrateRequest) ProtoReflect added in v1.1.0 

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

func (*ArrayMigrateRequest) Reset added in v1.1.0 

func (x *ArrayMigrateRequest) Reset()

func (*ArrayMigrateRequest) String added in v1.1.0 

func (x *ArrayMigrateRequest) String() string

type ArrayMigrateRequest_Action added in v1.1.0 

type ArrayMigrateRequest_Action struct {
	Action *Action `protobuf:"bytes,3,opt,name=action,proto3,oneof"`
}

type ArrayMigrateResponse added in v1.1.0 

type ArrayMigrateResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Types that are assignable to ActionTypes:
	//
	//	*ArrayMigrateResponse_Action
	ActionTypes isArrayMigrateResponse_ActionTypes `protobuf_oneof:"action_types"`
	// contains filtered or unexported fields
}

func (*ArrayMigrateResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use ArrayMigrateResponse.ProtoReflect.Descriptor instead.

func (*ArrayMigrateResponse) GetAction added in v1.1.0 

func (x *ArrayMigrateResponse) GetAction() *Action

func (*ArrayMigrateResponse) GetActionTypes added in v1.1.0 

func (m *ArrayMigrateResponse) GetActionTypes() isArrayMigrateResponse_ActionTypes

func (*ArrayMigrateResponse) GetSuccess added in v1.1.0 

func (x *ArrayMigrateResponse) GetSuccess() bool

func (*ArrayMigrateResponse) ProtoMessage added in v1.1.0 

func (*ArrayMigrateResponse) ProtoMessage()

func (*ArrayMigrateResponse) ProtoReflect added in v1.1.0 

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

func (*ArrayMigrateResponse) Reset added in v1.1.0 

func (x *ArrayMigrateResponse) Reset()

func (*ArrayMigrateResponse) String added in v1.1.0 

func (x *ArrayMigrateResponse) String() string

type ArrayMigrateResponse_Action added in v1.1.0 

type ArrayMigrateResponse_Action struct {
	Action *Action `protobuf:"bytes,2,opt,name=action,proto3,oneof"`
}

type GetMigrationCapabilityRequest 

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

Input request used in GetMigrationCapabilities API

func (*GetMigrationCapabilityRequest) Descriptor deprecated 

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

Deprecated: Use GetMigrationCapabilityRequest.ProtoReflect.Descriptor instead.

func (*GetMigrationCapabilityRequest) ProtoMessage 

func (*GetMigrationCapabilityRequest) ProtoMessage()

func (*GetMigrationCapabilityRequest) ProtoReflect 

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

func (*GetMigrationCapabilityRequest) Reset 

func (x *GetMigrationCapabilityRequest) Reset()

func (*GetMigrationCapabilityRequest) String 

func (x *GetMigrationCapabilityRequest) String() string

type GetMigrationCapabilityResponse 

type GetMigrationCapabilityResponse struct {
	Capabilities []*MigrationCapability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

Capabilities of the driver, in terms of the RPC calls it supports

func (*GetMigrationCapabilityResponse) Descriptor deprecated 

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

Deprecated: Use GetMigrationCapabilityResponse.ProtoReflect.Descriptor instead.

func (*GetMigrationCapabilityResponse) GetCapabilities 

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

func (*GetMigrationCapabilityResponse) ProtoMessage 

func (*GetMigrationCapabilityResponse) ProtoMessage()

func (*GetMigrationCapabilityResponse) ProtoReflect 

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

func (*GetMigrationCapabilityResponse) Reset 

func (x *GetMigrationCapabilityResponse) Reset()

func (*GetMigrationCapabilityResponse) String 

func (x *GetMigrationCapabilityResponse) String() string

type MigrateTypes 

type MigrateTypes int32
const (
	MigrateTypes_UNKNOWN_MIGRATE  MigrateTypes = 0
	MigrateTypes_NON_REPL_TO_REPL MigrateTypes = 1
	MigrateTypes_REPL_TO_NON_REPL MigrateTypes = 2
	MigrateTypes_VERSION_UPGRADE  MigrateTypes = 3
)

func (MigrateTypes) Descriptor 

func (MigrateTypes) Descriptor() protoreflect.EnumDescriptor

func (MigrateTypes) Enum 

func (x MigrateTypes) Enum() *MigrateTypes

func (MigrateTypes) EnumDescriptor deprecated 

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

Deprecated: Use MigrateTypes.Descriptor instead.

func (MigrateTypes) Number 

func (x MigrateTypes) Number() protoreflect.EnumNumber

func (MigrateTypes) String 

func (x MigrateTypes) String() string

func (MigrateTypes) Type 

func (MigrateTypes) Type() protoreflect.EnumType

type MigrationCapability 

type MigrationCapability struct {

	// Types that are assignable to Type:
	//
	//	*MigrationCapability_Rpc
	Type isMigrationCapability_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*MigrationCapability) Descriptor deprecated 

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

Deprecated: Use MigrationCapability.ProtoReflect.Descriptor instead.

func (*MigrationCapability) GetRpc 

func (x *MigrationCapability) GetRpc() *MigrationCapability_RPC

func (*MigrationCapability) GetType 

func (m *MigrationCapability) GetType() isMigrationCapability_Type

func (*MigrationCapability) ProtoMessage 

func (*MigrationCapability) ProtoMessage()

func (*MigrationCapability) ProtoReflect 

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

func (*MigrationCapability) Reset 

func (x *MigrationCapability) Reset()

func (*MigrationCapability) String 

func (x *MigrationCapability) String() string

type MigrationCapability_RPC 

type MigrationCapability_RPC struct {
	Type MigrateTypes `protobuf:"varint,1,opt,name=type,proto3,enum=migration.v1.MigrateTypes" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*MigrationCapability_RPC) Descriptor deprecated 

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

Deprecated: Use MigrationCapability_RPC.ProtoReflect.Descriptor instead.

func (*MigrationCapability_RPC) GetType 

func (x *MigrationCapability_RPC) GetType() MigrateTypes

func (*MigrationCapability_RPC) ProtoMessage 

func (*MigrationCapability_RPC) ProtoMessage()

func (*MigrationCapability_RPC) ProtoReflect 

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

func (*MigrationCapability_RPC) Reset 

func (x *MigrationCapability_RPC) Reset()

func (*MigrationCapability_RPC) String 

func (x *MigrationCapability_RPC) String() string

type MigrationCapability_Rpc 

type MigrationCapability_Rpc struct {
	Rpc *MigrationCapability_RPC `protobuf:"bytes,1,opt,name=rpc,proto3,oneof"`
}

type MigrationClient 

type MigrationClient interface {
	// ProbeController is used to verify if the CSI driver controller plugin is ready to service Replication APIs
	ProbeController(ctx context.Context, in *common.ProbeControllerRequest, opts ...grpc.CallOption) (*common.ProbeControllerResponse, error)
	// VolumeMigrate is used to migrate volume on storage array to different location/protection group
	VolumeMigrate(ctx context.Context, in *VolumeMigrateRequest, opts ...grpc.CallOption) (*VolumeMigrateResponse, error)
	// ArrayMigrate is to migrate all volumes from one storage array to a newer storay array
	ArrayMigrate(ctx context.Context, in *ArrayMigrateRequest, opts ...grpc.CallOption) (*ArrayMigrateResponse, error)
	// GetMigrationCapabilities is used to query CSI drivers for their supported migration capabilities
	GetMigrationCapabilities(ctx context.Context, in *GetMigrationCapabilityRequest, opts ...grpc.CallOption) (*GetMigrationCapabilityResponse, error)
}

MigrationClient is the client API for Migration service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMigrationClient 

func NewMigrationClient(cc grpc.ClientConnInterface) MigrationClient

type MigrationServer 

type MigrationServer interface {
	// ProbeController is used to verify if the CSI driver controller plugin is ready to service Replication APIs
	ProbeController(context.Context, *common.ProbeControllerRequest) (*common.ProbeControllerResponse, error)
	// VolumeMigrate is used to migrate volume on storage array to different location/protection group
	VolumeMigrate(context.Context, *VolumeMigrateRequest) (*VolumeMigrateResponse, error)
	// ArrayMigrate is to migrate all volumes from one storage array to a newer storay array
	ArrayMigrate(context.Context, *ArrayMigrateRequest) (*ArrayMigrateResponse, error)
	// GetMigrationCapabilities is used to query CSI drivers for their supported migration capabilities
	GetMigrationCapabilities(context.Context, *GetMigrationCapabilityRequest) (*GetMigrationCapabilityResponse, error)
}

MigrationServer is the server API for Migration service. All implementations should embed UnimplementedMigrationServer for forward compatibility

type SupportedActions added in v1.1.0 

type SupportedActions struct {

	// Types that are assignable to Actions:
	//
	//	*SupportedActions_Type
	Actions isSupportedActions_Actions `protobuf_oneof:"Actions"`
	// contains filtered or unexported fields
}

SupportedActions is the set of action types which are supported by a specific CSI driver

func (*SupportedActions) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use SupportedActions.ProtoReflect.Descriptor instead.

func (*SupportedActions) GetActions added in v1.1.0 

func (m *SupportedActions) GetActions() isSupportedActions_Actions

func (*SupportedActions) GetType added in v1.1.0 

func (x *SupportedActions) GetType() ActionTypes

func (*SupportedActions) ProtoMessage added in v1.1.0 

func (*SupportedActions) ProtoMessage()

func (*SupportedActions) ProtoReflect added in v1.1.0 

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

func (*SupportedActions) Reset added in v1.1.0 

func (x *SupportedActions) Reset()

func (*SupportedActions) String added in v1.1.0 

func (x *SupportedActions) String() string

type SupportedActions_Type added in v1.1.0 

type SupportedActions_Type struct {
	Type ActionTypes `protobuf:"varint,1,opt,name=type,proto3,enum=migration.v1.ActionTypes,oneof"`
}

type UnimplementedMigrationServer 

type UnimplementedMigrationServer struct {
}

UnimplementedMigrationServer should be embedded to have forward compatible implementations.

func (UnimplementedMigrationServer) ArrayMigrate added in v1.1.0 

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

func (UnimplementedMigrationServer) GetMigrationCapabilities 

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

func (UnimplementedMigrationServer) ProbeController 

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

func (UnimplementedMigrationServer) VolumeMigrate 

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

type UnsafeMigrationServer 

type UnsafeMigrationServer interface {
	// contains filtered or unexported methods
}

UnsafeMigrationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MigrationServer will result in compilation errors.

type Volume 

type Volume struct {

	// Size of the volume in bytes
	CapacityBytes int64 `protobuf:"varint,1,opt,name=capacity_bytes,json=capacityBytes,proto3" json:"capacity_bytes,omitempty"`
	// Volume ID - should be the same as one
	// returned in the CSI CreateVolumeResponse
	VolumeId string `protobuf:"bytes,2,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// Optional context information about the volume
	// which can be passed down to the driver in future calls
	FsType        string            `protobuf:"bytes,3,opt,name=fs_type,json=fsType,proto3" json:"fs_type,omitempty"`
	VolumeContext map[string]string `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

Information about a specific volume

func (*Volume) Descriptor deprecated 

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

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetCapacityBytes 

func (x *Volume) GetCapacityBytes() int64

func (*Volume) GetFsType 

func (x *Volume) GetFsType() string

func (*Volume) GetVolumeContext 

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

func (*Volume) GetVolumeId 

func (x *Volume) GetVolumeId() string

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect 

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

func (*Volume) Reset 

func (x *Volume) Reset()

func (*Volume) String 

func (x *Volume) String() string

type VolumeMigrateRequest 

type VolumeMigrateRequest struct {
	VolumeHandle string `protobuf:"bytes,1,opt,name=volume_handle,json=volumeHandle,proto3" json:"volume_handle,omitempty"`
	StorageClass string `protobuf:"bytes,2,opt,name=storage_class,json=storageClass,proto3" json:"storage_class,omitempty"`
	// Types that are assignable to MigrateTypes:
	//
	//	*VolumeMigrateRequest_Type
	MigrateTypes       isVolumeMigrateRequest_MigrateTypes `protobuf_oneof:"migrate_types"`
	ScParameters       map[string]string                   `` /* 185-byte string literal not displayed */
	ScSourceParameters map[string]string                   `` /* 203-byte string literal not displayed */
	ShouldClone        bool                                `protobuf:"varint,6,opt,name=should_clone,json=shouldClone,proto3" json:"should_clone,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMigrateRequest) Descriptor deprecated 

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

Deprecated: Use VolumeMigrateRequest.ProtoReflect.Descriptor instead.

func (*VolumeMigrateRequest) GetMigrateTypes 

func (m *VolumeMigrateRequest) GetMigrateTypes() isVolumeMigrateRequest_MigrateTypes

func (*VolumeMigrateRequest) GetScParameters 

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

func (*VolumeMigrateRequest) GetScSourceParameters added in v1.0.1 

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

func (*VolumeMigrateRequest) GetShouldClone 

func (x *VolumeMigrateRequest) GetShouldClone() bool

func (*VolumeMigrateRequest) GetStorageClass 

func (x *VolumeMigrateRequest) GetStorageClass() string

func (*VolumeMigrateRequest) GetType 

func (x *VolumeMigrateRequest) GetType() MigrateTypes

func (*VolumeMigrateRequest) GetVolumeHandle 

func (x *VolumeMigrateRequest) GetVolumeHandle() string

func (*VolumeMigrateRequest) ProtoMessage 

func (*VolumeMigrateRequest) ProtoMessage()

func (*VolumeMigrateRequest) ProtoReflect 

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

func (*VolumeMigrateRequest) Reset 

func (x *VolumeMigrateRequest) Reset()

func (*VolumeMigrateRequest) String 

func (x *VolumeMigrateRequest) String() string

type VolumeMigrateRequest_Type 

type VolumeMigrateRequest_Type struct {
	Type MigrateTypes `protobuf:"varint,3,opt,name=type,proto3,enum=migration.v1.MigrateTypes,oneof"`
}

type VolumeMigrateResponse 

type VolumeMigrateResponse struct {
	MigratedVolume *Volume `protobuf:"bytes,1,opt,name=migrated_volume,json=migratedVolume,proto3" json:"migrated_volume,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMigrateResponse) Descriptor deprecated 

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

Deprecated: Use VolumeMigrateResponse.ProtoReflect.Descriptor instead.

func (*VolumeMigrateResponse) GetMigratedVolume 

func (x *VolumeMigrateResponse) GetMigratedVolume() *Volume

func (*VolumeMigrateResponse) ProtoMessage 

func (*VolumeMigrateResponse) ProtoMessage()

func (*VolumeMigrateResponse) ProtoReflect 

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

func (*VolumeMigrateResponse) Reset 

func (x *VolumeMigrateResponse) Reset()

func (*VolumeMigrateResponse) String 

func (x *VolumeMigrateResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.