replication

package module
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: May 31, 2022 License: Apache-2.0 Imports: 9 Imported by: 14

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ActionTypes_name = map[int32]string{
		0:  "UNKNOWN_ACTION",
		1:  "FAILOVER_LOCAL",
		2:  "FAILOVER_REMOTE",
		3:  "UNPLANNED_FAILOVER_LOCAL",
		4:  "UNPLANNED_FAILOVER_REMOTE",
		5:  "REPROTECT_LOCAL",
		6:  "REPROTECT_REMOTE",
		7:  "FAILOVER_WITHOUT_SWAP_LOCAL",
		8:  "FAILOVER_WITHOUT_SWAP_REMOTE",
		9:  "FAILBACK_LOCAL",
		10: "FAILBACK_REMOTE",
		11: "ACTION_FAILBACK_DISCARD_CHANGES_LOCAL",
		12: "ACTION_FAILBACK_DISCARD_CHANGES_REMOTE",
		13: "SWAP_LOCAL",
		14: "SWAP_REMOTE",
		15: "SUSPEND",
		16: "RESUME",
		17: "ESTABLISH",
		18: "SYNC",
		19: "TEST_FAILOVER",
		20: "TEST_FAILOVER_STOP",
	}
	ActionTypes_value = map[string]int32{
		"UNKNOWN_ACTION":                         0,
		"FAILOVER_LOCAL":                         1,
		"FAILOVER_REMOTE":                        2,
		"UNPLANNED_FAILOVER_LOCAL":               3,
		"UNPLANNED_FAILOVER_REMOTE":              4,
		"REPROTECT_LOCAL":                        5,
		"REPROTECT_REMOTE":                       6,
		"FAILOVER_WITHOUT_SWAP_LOCAL":            7,
		"FAILOVER_WITHOUT_SWAP_REMOTE":           8,
		"FAILBACK_LOCAL":                         9,
		"FAILBACK_REMOTE":                        10,
		"ACTION_FAILBACK_DISCARD_CHANGES_LOCAL":  11,
		"ACTION_FAILBACK_DISCARD_CHANGES_REMOTE": 12,
		"SWAP_LOCAL":                             13,
		"SWAP_REMOTE":                            14,
		"SUSPEND":                                15,
		"RESUME":                                 16,
		"ESTABLISH":                              17,
		"SYNC":                                   18,
		"TEST_FAILOVER":                          19,
		"TEST_FAILOVER_STOP":                     20,
	}
)

Enum value maps for ActionTypes.

View Source 
var (
	ReplicationCapability_RPC_Type_name = map[int32]string{
		0: "CREATE_REMOTE_VOLUME",
		1: "CREATE_PROTECTION_GROUP",
		2: "DELETE_PROTECTION_GROUP",
		3: "MONITOR_PROTECTION_GROUP",
		4: "REPLICATION_ACTION_EXECUTION",
	}
	ReplicationCapability_RPC_Type_value = map[string]int32{
		"CREATE_REMOTE_VOLUME":         0,
		"CREATE_PROTECTION_GROUP":      1,
		"DELETE_PROTECTION_GROUP":      2,
		"MONITOR_PROTECTION_GROUP":     3,
		"REPLICATION_ACTION_EXECUTION": 4,
	}
)

Enum value maps for ReplicationCapability_RPC_Type.

View Source 
var (
	StorageProtectionGroupStatus_State_name = map[int32]string{
		0: "SYNCHRONIZED",
		1: "SYNC_IN_PROGRESS",
		2: "SUSPENDED",
		3: "FAILEDOVER",
		4: "INVALID",
		5: "UNKNOWN",
		6: "EMPTY",
	}
	StorageProtectionGroupStatus_State_value = map[string]int32{
		"SYNCHRONIZED":     0,
		"SYNC_IN_PROGRESS": 1,
		"SUSPENDED":        2,
		"FAILEDOVER":       3,
		"INVALID":          4,
		"UNKNOWN":          5,
		"EMPTY":            6,
	}
)

Enum value maps for StorageProtectionGroupStatus_State.

View Source 
var File_replication_proto protoreflect.FileDescriptor
View Source 
var Replication_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "replication.v1alpha1.Replication",
	HandlerType: (*ReplicationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProbeController",
			Handler:    _Replication_ProbeController_Handler,
		},
		{
			MethodName: "GetReplicationCapabilities",
			Handler:    _Replication_GetReplicationCapabilities_Handler,
		},
		{
			MethodName: "CreateStorageProtectionGroup",
			Handler:    _Replication_CreateStorageProtectionGroup_Handler,
		},
		{
			MethodName: "CreateRemoteVolume",
			Handler:    _Replication_CreateRemoteVolume_Handler,
		},
		{
			MethodName: "DeleteStorageProtectionGroup",
			Handler:    _Replication_DeleteStorageProtectionGroup_Handler,
		},
		{
			MethodName: "ExecuteAction",
			Handler:    _Replication_ExecuteAction_Handler,
		},
		{
			MethodName: "GetStorageProtectionGroupStatus",
			Handler:    _Replication_GetStorageProtectionGroupStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "replication.proto",
}

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

Functions

func RegisterReplicationServer 

func RegisterReplicationServer(s grpc.ServiceRegistrar, srv ReplicationServer)

Types

type Action added in v0.2.0 

type Action struct {
	ActionTypes ActionTypes `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetActionTypes added in v0.2.0 

func (x *Action) GetActionTypes() ActionTypes

func (*Action) ProtoMessage added in v0.2.0 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect added in v0.2.0 

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

func (*Action) Reset added in v0.2.0 

func (x *Action) Reset()

func (*Action) String added in v0.2.0 

func (x *Action) String() string

type ActionTypes added in v1.0.0 

type ActionTypes int32

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

const (
	// Site-Aware actions
	ActionTypes_UNKNOWN_ACTION ActionTypes = 0
	// Failover - Write disable source device, suspend replication and make the target device ReadWrite
	// Swap personalities of source and target device
	// Failover to the local protection group (storage array)
	ActionTypes_FAILOVER_LOCAL ActionTypes = 1
	// Failover to the remote protection group (storage array)
	ActionTypes_FAILOVER_REMOTE ActionTypes = 2
	// Unplanned Failover
	// Same as Failover but used in case of disaster
	// Unplanned failover to the local storage array
	ActionTypes_UNPLANNED_FAILOVER_LOCAL ActionTypes = 3
	// Unplanned failover to the remote storage array
	ActionTypes_UNPLANNED_FAILOVER_REMOTE ActionTypes = 4
	// Reprotect
	// Restart the replication in reverse direction
	// Resume replication from local -> remote storage array
	ActionTypes_REPROTECT_LOCAL ActionTypes = 5
	// Resume replication from remote -> local storage array
	ActionTypes_REPROTECT_REMOTE ActionTypes = 6
	// Same as Failover but don't swap source & target devices
	ActionTypes_FAILOVER_WITHOUT_SWAP_LOCAL  ActionTypes = 7
	ActionTypes_FAILOVER_WITHOUT_SWAP_REMOTE ActionTypes = 8
	// Failback to the source device while keeping all writes done at target device
	ActionTypes_FAILBACK_LOCAL  ActionTypes = 9
	ActionTypes_FAILBACK_REMOTE ActionTypes = 10
	// Same as Failback but keep data from source (discard any writes at target)
	ActionTypes_ACTION_FAILBACK_DISCARD_CHANGES_LOCAL  ActionTypes = 11
	ActionTypes_ACTION_FAILBACK_DISCARD_CHANGES_REMOTE ActionTypes = 12
	// Swap personalities of source and target devices
	ActionTypes_SWAP_LOCAL  ActionTypes = 13
	ActionTypes_SWAP_REMOTE ActionTypes = 14
	// Suspend the replication link
	ActionTypes_SUSPEND ActionTypes = 15
	// Resume the replication link
	ActionTypes_RESUME ActionTypes = 16
	// Copy pending tracks from source to target
	ActionTypes_ESTABLISH ActionTypes = 17
	// Same as ESTABLISH
	ActionTypes_SYNC               ActionTypes = 18
	ActionTypes_TEST_FAILOVER      ActionTypes = 19
	ActionTypes_TEST_FAILOVER_STOP ActionTypes = 20
)

func (ActionTypes) Descriptor added in v1.0.0 

func (ActionTypes) Descriptor() protoreflect.EnumDescriptor

func (ActionTypes) Enum added in v1.0.0 

func (x ActionTypes) Enum() *ActionTypes

func (ActionTypes) EnumDescriptor deprecated added in v1.0.0 

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

Deprecated: Use ActionTypes.Descriptor instead.

func (ActionTypes) Number added in v1.0.0 

func (x ActionTypes) Number() protoreflect.EnumNumber

func (ActionTypes) String added in v1.0.0 

func (x ActionTypes) String() string

func (ActionTypes) Type added in v1.0.0 

func (ActionTypes) Type() protoreflect.EnumType

type CreateRemoteVolumeRequest added in v0.2.0 

type CreateRemoteVolumeRequest struct {

	// Handle of the local volume, whose remote replica is being requested
	VolumeHandle string `protobuf:"bytes,1,opt,name=volume_handle,json=volumeHandle,proto3" json:"volume_handle,omitempty"`
	// Optional information about the local volume
	// will be supplied if the driver returned this information
	// in the CSI CreateVolumeResponse
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateRemoteVolumeRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CreateRemoteVolumeRequest.ProtoReflect.Descriptor instead.

func (*CreateRemoteVolumeRequest) GetParameters added in v0.2.0 

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

func (*CreateRemoteVolumeRequest) GetVolumeHandle added in v0.2.0 

func (x *CreateRemoteVolumeRequest) GetVolumeHandle() string

func (*CreateRemoteVolumeRequest) ProtoMessage added in v0.2.0 

func (*CreateRemoteVolumeRequest) ProtoMessage()

func (*CreateRemoteVolumeRequest) ProtoReflect added in v0.2.0 

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

func (*CreateRemoteVolumeRequest) Reset added in v0.2.0 

func (x *CreateRemoteVolumeRequest) Reset()

func (*CreateRemoteVolumeRequest) String added in v0.2.0 

func (x *CreateRemoteVolumeRequest) String() string

type CreateRemoteVolumeResponse added in v0.2.0 

type CreateRemoteVolumeResponse struct {

	// Remote Volume
	RemoteVolume *Volume `protobuf:"bytes,1,opt,name=remote_volume,json=remoteVolume,proto3" json:"remote_volume,omitempty"`
	// contains filtered or unexported fields
}

Information about the remote replica of a local volume

func (*CreateRemoteVolumeResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CreateRemoteVolumeResponse.ProtoReflect.Descriptor instead.

func (*CreateRemoteVolumeResponse) GetRemoteVolume added in v0.2.0 

func (x *CreateRemoteVolumeResponse) GetRemoteVolume() *Volume

func (*CreateRemoteVolumeResponse) ProtoMessage added in v0.2.0 

func (*CreateRemoteVolumeResponse) ProtoMessage()

func (*CreateRemoteVolumeResponse) ProtoReflect added in v0.2.0 

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

func (*CreateRemoteVolumeResponse) Reset added in v0.2.0 

func (x *CreateRemoteVolumeResponse) Reset()

func (*CreateRemoteVolumeResponse) String added in v0.2.0 

func (x *CreateRemoteVolumeResponse) String() string

type CreateStorageProtectionGroupRequest added in v0.2.0 

type CreateStorageProtectionGroupRequest struct {

	// Handle of the volume, whose storage protection group is being requested,
	VolumeHandle string `protobuf:"bytes,1,opt,name=volume_handle,json=volumeHandle,proto3" json:"volume_handle,omitempty"`
	// Optional information about the Volume
	// will be supplied if the driver returned this information
	// in the CSI CreateVolumeResponse
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateStorageProtectionGroupRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CreateStorageProtectionGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateStorageProtectionGroupRequest) GetParameters added in v0.2.0 

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

func (*CreateStorageProtectionGroupRequest) GetVolumeHandle added in v0.2.0 

func (x *CreateStorageProtectionGroupRequest) GetVolumeHandle() string

func (*CreateStorageProtectionGroupRequest) ProtoMessage added in v0.2.0 

func (*CreateStorageProtectionGroupRequest) ProtoMessage()

func (*CreateStorageProtectionGroupRequest) ProtoReflect added in v0.2.0 

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

func (*CreateStorageProtectionGroupRequest) Reset added in v0.2.0 

func (x *CreateStorageProtectionGroupRequest) Reset()

func (*CreateStorageProtectionGroupRequest) String added in v0.2.0 

func (x *CreateStorageProtectionGroupRequest) String() string

type CreateStorageProtectionGroupResponse added in v0.2.0 

type CreateStorageProtectionGroupResponse struct {

	// Identifier for the local storage protection group
	// This should be unique for one CSI driver
	LocalProtectionGroupId string `` /* 131-byte string literal not displayed */
	// Identifier for the remote storage protection group
	// This should be unique for one CSI driver
	RemoteProtectionGroupId string `` /* 134-byte string literal not displayed */
	// Attributes for the local storage protection group
	LocalProtectionGroupAttributes map[string]string `` /* 243-byte string literal not displayed */
	// Attributes for the remote storage protection group
	RemoteProtectionGroupAttributes map[string]string `` /* 246-byte string literal not displayed */
	// status of the protection group
	Status *StorageProtectionGroupStatus `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStorageProtectionGroupResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CreateStorageProtectionGroupResponse.ProtoReflect.Descriptor instead.

func (*CreateStorageProtectionGroupResponse) GetLocalProtectionGroupAttributes added in v0.2.0 

func (x *CreateStorageProtectionGroupResponse) GetLocalProtectionGroupAttributes() map[string]string

func (*CreateStorageProtectionGroupResponse) GetLocalProtectionGroupId added in v0.2.0 

func (x *CreateStorageProtectionGroupResponse) GetLocalProtectionGroupId() string

func (*CreateStorageProtectionGroupResponse) GetRemoteProtectionGroupAttributes added in v0.2.0 

func (x *CreateStorageProtectionGroupResponse) GetRemoteProtectionGroupAttributes() map[string]string

func (*CreateStorageProtectionGroupResponse) GetRemoteProtectionGroupId added in v0.2.0 

func (x *CreateStorageProtectionGroupResponse) GetRemoteProtectionGroupId() string

func (*CreateStorageProtectionGroupResponse) GetStatus added in v1.0.0 

func (x *CreateStorageProtectionGroupResponse) GetStatus() *StorageProtectionGroupStatus

func (*CreateStorageProtectionGroupResponse) ProtoMessage added in v0.2.0 

func (*CreateStorageProtectionGroupResponse) ProtoMessage()

func (*CreateStorageProtectionGroupResponse) ProtoReflect added in v0.2.0 

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

func (*CreateStorageProtectionGroupResponse) Reset added in v0.2.0 

func (x *CreateStorageProtectionGroupResponse) Reset()

func (*CreateStorageProtectionGroupResponse) String added in v0.2.0 

func (x *CreateStorageProtectionGroupResponse) String() string

type DeleteStorageProtectionGroupRequest 

type DeleteStorageProtectionGroupRequest struct {

	// Unique identifier, representing the storage protection group
	ProtectionGroupId string `protobuf:"bytes,1,opt,name=protection_group_id,json=protectionGroupId,proto3" json:"protection_group_id,omitempty"`
	// Attributes of the storage protection group (optional)
	ProtectionGroupAttributes map[string]string `` /* 226-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeleteStorageProtectionGroupRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStorageProtectionGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteStorageProtectionGroupRequest) GetProtectionGroupAttributes 

func (x *DeleteStorageProtectionGroupRequest) GetProtectionGroupAttributes() map[string]string

func (*DeleteStorageProtectionGroupRequest) GetProtectionGroupId 

func (x *DeleteStorageProtectionGroupRequest) GetProtectionGroupId() string

func (*DeleteStorageProtectionGroupRequest) ProtoMessage 

func (*DeleteStorageProtectionGroupRequest) ProtoMessage()

func (*DeleteStorageProtectionGroupRequest) ProtoReflect 

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

func (*DeleteStorageProtectionGroupRequest) Reset 

func (x *DeleteStorageProtectionGroupRequest) Reset()

func (*DeleteStorageProtectionGroupRequest) String 

func (x *DeleteStorageProtectionGroupRequest) String() string

type DeleteStorageProtectionGroupResponse 

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

func (*DeleteStorageProtectionGroupResponse) Descriptor deprecated 

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

Deprecated: Use DeleteStorageProtectionGroupResponse.ProtoReflect.Descriptor instead.

func (*DeleteStorageProtectionGroupResponse) ProtoMessage 

func (*DeleteStorageProtectionGroupResponse) ProtoMessage()

func (*DeleteStorageProtectionGroupResponse) ProtoReflect 

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

func (*DeleteStorageProtectionGroupResponse) Reset 

func (x *DeleteStorageProtectionGroupResponse) Reset()

func (*DeleteStorageProtectionGroupResponse) String 

func (x *DeleteStorageProtectionGroupResponse) String() string

type ExecuteActionRequest added in v0.2.0 

type ExecuteActionRequest struct {
	ActionId          string `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	ProtectionGroupId string `protobuf:"bytes,2,opt,name=protection_group_id,json=protectionGroupId,proto3" json:"protection_group_id,omitempty"`
	// Types that are assignable to ActionTypes:
	//	*ExecuteActionRequest_Action
	ActionTypes                     isExecuteActionRequest_ActionTypes `protobuf_oneof:"action_types"`
	ProtectionGroupAttributes       map[string]string                  `` /* 226-byte string literal not displayed */
	RemoteProtectionGroupId         string                             `` /* 134-byte string literal not displayed */
	RemoteProtectionGroupAttributes map[string]string                  `` /* 246-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteActionRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ExecuteActionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteActionRequest) GetAction added in v0.2.0 

func (x *ExecuteActionRequest) GetAction() *Action

func (*ExecuteActionRequest) GetActionId added in v1.0.0 

func (x *ExecuteActionRequest) GetActionId() string

func (*ExecuteActionRequest) GetActionTypes added in v0.2.0 

func (m *ExecuteActionRequest) GetActionTypes() isExecuteActionRequest_ActionTypes

func (*ExecuteActionRequest) GetProtectionGroupAttributes added in v0.2.0 

func (x *ExecuteActionRequest) GetProtectionGroupAttributes() map[string]string

func (*ExecuteActionRequest) GetProtectionGroupId added in v0.2.0 

func (x *ExecuteActionRequest) GetProtectionGroupId() string

func (*ExecuteActionRequest) GetRemoteProtectionGroupAttributes added in v1.0.0 

func (x *ExecuteActionRequest) GetRemoteProtectionGroupAttributes() map[string]string

func (*ExecuteActionRequest) GetRemoteProtectionGroupId added in v1.0.0 

func (x *ExecuteActionRequest) GetRemoteProtectionGroupId() string

func (*ExecuteActionRequest) ProtoMessage added in v0.2.0 

func (*ExecuteActionRequest) ProtoMessage()

func (*ExecuteActionRequest) ProtoReflect added in v0.2.0 

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

func (*ExecuteActionRequest) Reset added in v0.2.0 

func (x *ExecuteActionRequest) Reset()

func (*ExecuteActionRequest) String added in v0.2.0 

func (x *ExecuteActionRequest) String() string

type ExecuteActionRequest_Action added in v0.2.0 

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

type ExecuteActionResponse added in v0.2.0 

type ExecuteActionResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Types that are assignable to ActionTypes:
	//	*ExecuteActionResponse_Action
	ActionTypes isExecuteActionResponse_ActionTypes `protobuf_oneof:"action_types"`
	// status of the protection group
	Status *StorageProtectionGroupStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteActionResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ExecuteActionResponse.ProtoReflect.Descriptor instead.

func (*ExecuteActionResponse) GetAction added in v0.2.0 

func (x *ExecuteActionResponse) GetAction() *Action

func (*ExecuteActionResponse) GetActionTypes added in v0.2.0 

func (m *ExecuteActionResponse) GetActionTypes() isExecuteActionResponse_ActionTypes

func (*ExecuteActionResponse) GetStatus added in v1.0.0 

func (x *ExecuteActionResponse) GetStatus() *StorageProtectionGroupStatus

func (*ExecuteActionResponse) GetSuccess added in v0.2.0 

func (x *ExecuteActionResponse) GetSuccess() bool

func (*ExecuteActionResponse) ProtoMessage added in v0.2.0 

func (*ExecuteActionResponse) ProtoMessage()

func (*ExecuteActionResponse) ProtoReflect added in v0.2.0 

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

func (*ExecuteActionResponse) Reset added in v0.2.0 

func (x *ExecuteActionResponse) Reset()

func (*ExecuteActionResponse) String added in v0.2.0 

func (x *ExecuteActionResponse) String() string

type ExecuteActionResponse_Action added in v0.2.0 

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

type GetReplicationCapabilityRequest 

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

Input request used in GetReplicationCapabilities API

func (*GetReplicationCapabilityRequest) Descriptor deprecated 

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

Deprecated: Use GetReplicationCapabilityRequest.ProtoReflect.Descriptor instead.

func (*GetReplicationCapabilityRequest) ProtoMessage 

func (*GetReplicationCapabilityRequest) ProtoMessage()

func (*GetReplicationCapabilityRequest) ProtoReflect 

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

func (*GetReplicationCapabilityRequest) Reset 

func (x *GetReplicationCapabilityRequest) Reset()

func (*GetReplicationCapabilityRequest) String 

func (x *GetReplicationCapabilityRequest) String() string

type GetReplicationCapabilityResponse 

type GetReplicationCapabilityResponse struct {
	Capabilities []*ReplicationCapability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	Actions      []*SupportedActions      `protobuf:"bytes,2,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

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

func (*GetReplicationCapabilityResponse) Descriptor deprecated 

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

Deprecated: Use GetReplicationCapabilityResponse.ProtoReflect.Descriptor instead.

func (*GetReplicationCapabilityResponse) GetActions added in v1.0.0 

func (x *GetReplicationCapabilityResponse) GetActions() []*SupportedActions

func (*GetReplicationCapabilityResponse) GetCapabilities 

func (x *GetReplicationCapabilityResponse) GetCapabilities() []*ReplicationCapability

func (*GetReplicationCapabilityResponse) ProtoMessage 

func (*GetReplicationCapabilityResponse) ProtoMessage()

func (*GetReplicationCapabilityResponse) ProtoReflect 

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

func (*GetReplicationCapabilityResponse) Reset 

func (x *GetReplicationCapabilityResponse) Reset()

func (*GetReplicationCapabilityResponse) String 

func (x *GetReplicationCapabilityResponse) String() string

type GetStorageProtectionGroupStatusRequest added in v0.2.0 

type GetStorageProtectionGroupStatusRequest struct {

	// Protection group to be monitored
	ProtectionGroupId         string            `protobuf:"bytes,1,opt,name=protection_group_id,json=protectionGroupId,proto3" json:"protection_group_id,omitempty"`
	ProtectionGroupAttributes map[string]string `` /* 226-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetStorageProtectionGroupStatusRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetStorageProtectionGroupStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStorageProtectionGroupStatusRequest) GetProtectionGroupAttributes added in v1.0.0 

func (x *GetStorageProtectionGroupStatusRequest) GetProtectionGroupAttributes() map[string]string

func (*GetStorageProtectionGroupStatusRequest) GetProtectionGroupId added in v0.2.0 

func (x *GetStorageProtectionGroupStatusRequest) GetProtectionGroupId() string

func (*GetStorageProtectionGroupStatusRequest) ProtoMessage added in v0.2.0 

func (*GetStorageProtectionGroupStatusRequest) ProtoMessage()

func (*GetStorageProtectionGroupStatusRequest) ProtoReflect added in v0.2.0 

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

func (*GetStorageProtectionGroupStatusRequest) Reset added in v0.2.0 

func (x *GetStorageProtectionGroupStatusRequest) Reset()

func (*GetStorageProtectionGroupStatusRequest) String added in v0.2.0 

func (x *GetStorageProtectionGroupStatusRequest) String() string

type GetStorageProtectionGroupStatusResponse added in v0.2.0 

type GetStorageProtectionGroupStatusResponse struct {

	// Returns status of the protection group
	Status *StorageProtectionGroupStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStorageProtectionGroupStatusResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetStorageProtectionGroupStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStorageProtectionGroupStatusResponse) GetStatus added in v0.2.0 

func (x *GetStorageProtectionGroupStatusResponse) GetStatus() *StorageProtectionGroupStatus

func (*GetStorageProtectionGroupStatusResponse) ProtoMessage added in v0.2.0 

func (*GetStorageProtectionGroupStatusResponse) ProtoMessage()

func (*GetStorageProtectionGroupStatusResponse) ProtoReflect added in v0.2.0 

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

func (*GetStorageProtectionGroupStatusResponse) Reset added in v0.2.0 

func (x *GetStorageProtectionGroupStatusResponse) Reset()

func (*GetStorageProtectionGroupStatusResponse) String added in v0.2.0 

func (x *GetStorageProtectionGroupStatusResponse) String() string

type ReplicationCapability 

type ReplicationCapability struct {

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

ReplicationCapability is the set of replication capabilities which can be advertised by a CSI driver. For e.g. if a driver supports discovery of remote volume characteristics via the extensions API, then it needs to include DISCOVER_REMOTE_VOLUME in its list of replication capabilities

func (*ReplicationCapability) Descriptor deprecated 

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

Deprecated: Use ReplicationCapability.ProtoReflect.Descriptor instead.

func (*ReplicationCapability) GetRpc 

func (x *ReplicationCapability) GetRpc() *ReplicationCapability_RPC

func (*ReplicationCapability) GetType 

func (m *ReplicationCapability) GetType() isReplicationCapability_Type

func (*ReplicationCapability) ProtoMessage 

func (*ReplicationCapability) ProtoMessage()

func (*ReplicationCapability) ProtoReflect 

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

func (*ReplicationCapability) Reset 

func (x *ReplicationCapability) Reset()

func (*ReplicationCapability) String 

func (x *ReplicationCapability) String() string

type ReplicationCapability_RPC 

type ReplicationCapability_RPC struct {
	Type ReplicationCapability_RPC_Type `protobuf:"varint,1,opt,name=type,proto3,enum=replication.v1alpha1.ReplicationCapability_RPC_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationCapability_RPC) Descriptor deprecated 

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

Deprecated: Use ReplicationCapability_RPC.ProtoReflect.Descriptor instead.

func (*ReplicationCapability_RPC) GetType 

func (x *ReplicationCapability_RPC) GetType() ReplicationCapability_RPC_Type

func (*ReplicationCapability_RPC) ProtoMessage 

func (*ReplicationCapability_RPC) ProtoMessage()

func (*ReplicationCapability_RPC) ProtoReflect 

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

func (*ReplicationCapability_RPC) Reset 

func (x *ReplicationCapability_RPC) Reset()

func (*ReplicationCapability_RPC) String 

func (x *ReplicationCapability_RPC) String() string

type ReplicationCapability_RPC_Type 

type ReplicationCapability_RPC_Type int32
const (
	ReplicationCapability_RPC_CREATE_REMOTE_VOLUME         ReplicationCapability_RPC_Type = 0
	ReplicationCapability_RPC_CREATE_PROTECTION_GROUP      ReplicationCapability_RPC_Type = 1
	ReplicationCapability_RPC_DELETE_PROTECTION_GROUP      ReplicationCapability_RPC_Type = 2
	ReplicationCapability_RPC_MONITOR_PROTECTION_GROUP     ReplicationCapability_RPC_Type = 3
	ReplicationCapability_RPC_REPLICATION_ACTION_EXECUTION ReplicationCapability_RPC_Type = 4
)

func (ReplicationCapability_RPC_Type) Descriptor 

func (ReplicationCapability_RPC_Type) Descriptor() protoreflect.EnumDescriptor

func (ReplicationCapability_RPC_Type) Enum 

func (x ReplicationCapability_RPC_Type) Enum() *ReplicationCapability_RPC_Type

func (ReplicationCapability_RPC_Type) EnumDescriptor deprecated 

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

Deprecated: Use ReplicationCapability_RPC_Type.Descriptor instead.

func (ReplicationCapability_RPC_Type) Number 

func (x ReplicationCapability_RPC_Type) Number() protoreflect.EnumNumber

func (ReplicationCapability_RPC_Type) String 

func (x ReplicationCapability_RPC_Type) String() string

func (ReplicationCapability_RPC_Type) Type 

func (ReplicationCapability_RPC_Type) Type() protoreflect.EnumType

type ReplicationCapability_Rpc 

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

type ReplicationClient 

type ReplicationClient 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)
	// GetReplicationCapabilities is used to query CSI drivers for their supported replication capabilities
	GetReplicationCapabilities(ctx context.Context, in *GetReplicationCapabilityRequest, opts ...grpc.CallOption) (*GetReplicationCapabilityResponse, error)
	// CreateStorageProtectionGroup is used to create Storage Protection Group on array
	CreateStorageProtectionGroup(ctx context.Context, in *CreateStorageProtectionGroupRequest, opts ...grpc.CallOption) (*CreateStorageProtectionGroupResponse, error)
	// CreateRemoteVolume is used to create volume on remote array
	CreateRemoteVolume(ctx context.Context, in *CreateRemoteVolumeRequest, opts ...grpc.CallOption) (*CreateRemoteVolumeResponse, error)
	// DeleteStorageProtectionGroup is used to delete a Storage Protection group
	DeleteStorageProtectionGroup(ctx context.Context, in *DeleteStorageProtectionGroupRequest, opts ...grpc.CallOption) (*DeleteStorageProtectionGroupResponse, error)
	// ExecuteAction is used to update the action to failover, testfailover, failback, suspend, etc.
	ExecuteAction(ctx context.Context, in *ExecuteActionRequest, opts ...grpc.CallOption) (*ExecuteActionResponse, error)
	// GetStorageProtectionGroupStatus is used to monitor the status of Storage Protection groups
	GetStorageProtectionGroupStatus(ctx context.Context, in *GetStorageProtectionGroupStatusRequest, opts ...grpc.CallOption) (*GetStorageProtectionGroupStatusResponse, error)
}

ReplicationClient is the client API for Replication 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 NewReplicationClient 

func NewReplicationClient(cc grpc.ClientConnInterface) ReplicationClient

type ReplicationServer 

type ReplicationServer 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)
	// GetReplicationCapabilities is used to query CSI drivers for their supported replication capabilities
	GetReplicationCapabilities(context.Context, *GetReplicationCapabilityRequest) (*GetReplicationCapabilityResponse, error)
	// CreateStorageProtectionGroup is used to create Storage Protection Group on array
	CreateStorageProtectionGroup(context.Context, *CreateStorageProtectionGroupRequest) (*CreateStorageProtectionGroupResponse, error)
	// CreateRemoteVolume is used to create volume on remote array
	CreateRemoteVolume(context.Context, *CreateRemoteVolumeRequest) (*CreateRemoteVolumeResponse, error)
	// DeleteStorageProtectionGroup is used to delete a Storage Protection group
	DeleteStorageProtectionGroup(context.Context, *DeleteStorageProtectionGroupRequest) (*DeleteStorageProtectionGroupResponse, error)
	// ExecuteAction is used to update the action to failover, testfailover, failback, suspend, etc.
	ExecuteAction(context.Context, *ExecuteActionRequest) (*ExecuteActionResponse, error)
	// GetStorageProtectionGroupStatus is used to monitor the status of Storage Protection groups
	GetStorageProtectionGroupStatus(context.Context, *GetStorageProtectionGroupStatusRequest) (*GetStorageProtectionGroupStatusResponse, error)
}

ReplicationServer is the server API for Replication service. All implementations should embed UnimplementedReplicationServer for forward compatibility

type StorageProtectionGroupStatus added in v0.2.0 

type StorageProtectionGroupStatus struct {

	// The state of the protection group
	State    StorageProtectionGroupStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=replication.v1alpha1.StorageProtectionGroupStatus_State" json:"state,omitempty"`
	IsSource bool                               `protobuf:"varint,2,opt,name=isSource,proto3" json:"isSource,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageProtectionGroupStatus) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use StorageProtectionGroupStatus.ProtoReflect.Descriptor instead.

func (*StorageProtectionGroupStatus) GetIsSource added in v1.0.0 

func (x *StorageProtectionGroupStatus) GetIsSource() bool

func (*StorageProtectionGroupStatus) GetState added in v0.2.0 

func (x *StorageProtectionGroupStatus) GetState() StorageProtectionGroupStatus_State

func (*StorageProtectionGroupStatus) ProtoMessage added in v0.2.0 

func (*StorageProtectionGroupStatus) ProtoMessage()

func (*StorageProtectionGroupStatus) ProtoReflect added in v0.2.0 

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

func (*StorageProtectionGroupStatus) Reset added in v0.2.0 

func (x *StorageProtectionGroupStatus) Reset()

func (*StorageProtectionGroupStatus) String added in v0.2.0 

func (x *StorageProtectionGroupStatus) String() string

type StorageProtectionGroupStatus_State added in v0.2.0 

type StorageProtectionGroupStatus_State int32
const (
	StorageProtectionGroupStatus_SYNCHRONIZED     StorageProtectionGroupStatus_State = 0
	StorageProtectionGroupStatus_SYNC_IN_PROGRESS StorageProtectionGroupStatus_State = 1
	StorageProtectionGroupStatus_SUSPENDED        StorageProtectionGroupStatus_State = 2
	StorageProtectionGroupStatus_FAILEDOVER       StorageProtectionGroupStatus_State = 3
	StorageProtectionGroupStatus_INVALID          StorageProtectionGroupStatus_State = 4
	StorageProtectionGroupStatus_UNKNOWN          StorageProtectionGroupStatus_State = 5
	StorageProtectionGroupStatus_EMPTY            StorageProtectionGroupStatus_State = 6
)

func (StorageProtectionGroupStatus_State) Descriptor added in v0.2.0 

func (StorageProtectionGroupStatus_State) Descriptor() protoreflect.EnumDescriptor

func (StorageProtectionGroupStatus_State) Enum added in v0.2.0 

func (x StorageProtectionGroupStatus_State) Enum() *StorageProtectionGroupStatus_State

func (StorageProtectionGroupStatus_State) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use StorageProtectionGroupStatus_State.Descriptor instead.

func (StorageProtectionGroupStatus_State) Number added in v0.2.0 

func (x StorageProtectionGroupStatus_State) Number() protoreflect.EnumNumber

func (StorageProtectionGroupStatus_State) String added in v0.2.0 

func (x StorageProtectionGroupStatus_State) String() string

func (StorageProtectionGroupStatus_State) Type added in v0.2.0 

func (StorageProtectionGroupStatus_State) Type() protoreflect.EnumType

type SupportedActions added in v1.0.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.0.0 

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

Deprecated: Use SupportedActions.ProtoReflect.Descriptor instead.

func (*SupportedActions) GetActions added in v1.0.0 

func (m *SupportedActions) GetActions() isSupportedActions_Actions

func (*SupportedActions) GetType added in v1.0.0 

func (x *SupportedActions) GetType() ActionTypes

func (*SupportedActions) ProtoMessage added in v1.0.0 

func (*SupportedActions) ProtoMessage()

func (*SupportedActions) ProtoReflect added in v1.0.0 

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

func (*SupportedActions) Reset added in v1.0.0 

func (x *SupportedActions) Reset()

func (*SupportedActions) String added in v1.0.0 

func (x *SupportedActions) String() string

type SupportedActions_Type added in v1.0.0 

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

type UnimplementedReplicationServer 

type UnimplementedReplicationServer struct {
}

UnimplementedReplicationServer should be embedded to have forward compatible implementations.

func (UnimplementedReplicationServer) CreateRemoteVolume added in v0.2.0 

func (UnimplementedReplicationServer) CreateRemoteVolume(context.Context, *CreateRemoteVolumeRequest) (*CreateRemoteVolumeResponse, error)

func (UnimplementedReplicationServer) CreateStorageProtectionGroup added in v0.2.0 

func (UnimplementedReplicationServer) CreateStorageProtectionGroup(context.Context, *CreateStorageProtectionGroupRequest) (*CreateStorageProtectionGroupResponse, error)

func (UnimplementedReplicationServer) DeleteStorageProtectionGroup 

func (UnimplementedReplicationServer) DeleteStorageProtectionGroup(context.Context, *DeleteStorageProtectionGroupRequest) (*DeleteStorageProtectionGroupResponse, error)

func (UnimplementedReplicationServer) ExecuteAction added in v0.2.0 

func (UnimplementedReplicationServer) ExecuteAction(context.Context, *ExecuteActionRequest) (*ExecuteActionResponse, error)

func (UnimplementedReplicationServer) GetReplicationCapabilities 

func (UnimplementedReplicationServer) GetReplicationCapabilities(context.Context, *GetReplicationCapabilityRequest) (*GetReplicationCapabilityResponse, error)

func (UnimplementedReplicationServer) GetStorageProtectionGroupStatus added in v0.2.0 

func (UnimplementedReplicationServer) GetStorageProtectionGroupStatus(context.Context, *GetStorageProtectionGroupStatusRequest) (*GetStorageProtectionGroupStatusResponse, error)

func (UnimplementedReplicationServer) ProbeController 

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

type UnsafeReplicationServer added in v1.0.0 

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

UnsafeReplicationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReplicationServer 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
	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) 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

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.