replication

package
v0.0.0-...-6323886 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Controller_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "replication.Controller",
	HandlerType: (*ControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EnableVolumeReplication",
			Handler:    _Controller_EnableVolumeReplication_Handler,
		},
		{
			MethodName: "DisableVolumeReplication",
			Handler:    _Controller_DisableVolumeReplication_Handler,
		},
		{
			MethodName: "PromoteVolume",
			Handler:    _Controller_PromoteVolume_Handler,
		},
		{
			MethodName: "DemoteVolume",
			Handler:    _Controller_DemoteVolume_Handler,
		},
		{
			MethodName: "ResyncVolume",
			Handler:    _Controller_ResyncVolume_Handler,
		},
		{
			MethodName: "GetVolumeReplicationInfo",
			Handler:    _Controller_GetVolumeReplicationInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "replication/replication.proto",
}

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

View Source 
var (
	// Indicates that this field is OPTIONAL and part of an experimental
	// API that may be deprecated and eventually removed between minor
	// releases.
	//
	// optional bool alpha_field = 1100;
	E_AlphaField = &file_replication_replication_proto_extTypes[0]
)

Extension fields to descriptorpb.FieldOptions.

View Source 
var File_replication_replication_proto protoreflect.FileDescriptor

Functions

func RegisterControllerServer 

func RegisterControllerServer(s grpc.ServiceRegistrar, srv ControllerServer)

Types

type ControllerClient 

type ControllerClient interface {
	// EnableVolumeReplication RPC call to enable the volume replication.
	EnableVolumeReplication(ctx context.Context, in *EnableVolumeReplicationRequest, opts ...grpc.CallOption) (*EnableVolumeReplicationResponse, error)
	// DisableVolumeReplication RPC call to disable the volume replication.
	DisableVolumeReplication(ctx context.Context, in *DisableVolumeReplicationRequest, opts ...grpc.CallOption) (*DisableVolumeReplicationResponse, error)
	// PromoteVolume RPC call to promote the volume.
	PromoteVolume(ctx context.Context, in *PromoteVolumeRequest, opts ...grpc.CallOption) (*PromoteVolumeResponse, error)
	// DemoteVolume RPC call to demote the volume.
	DemoteVolume(ctx context.Context, in *DemoteVolumeRequest, opts ...grpc.CallOption) (*DemoteVolumeResponse, error)
	// ResyncVolume RPC call to resync the volume.
	ResyncVolume(ctx context.Context, in *ResyncVolumeRequest, opts ...grpc.CallOption) (*ResyncVolumeResponse, error)
	// GetVolumeReplicationInfo RPC call to get the volume replication
	// information.
	GetVolumeReplicationInfo(ctx context.Context, in *GetVolumeReplicationInfoRequest, opts ...grpc.CallOption) (*GetVolumeReplicationInfoResponse, error)
}

ControllerClient is the client API for Controller 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 NewControllerClient 

func NewControllerClient(cc grpc.ClientConnInterface) ControllerClient

type ControllerServer 

type ControllerServer interface {
	// EnableVolumeReplication RPC call to enable the volume replication.
	EnableVolumeReplication(context.Context, *EnableVolumeReplicationRequest) (*EnableVolumeReplicationResponse, error)
	// DisableVolumeReplication RPC call to disable the volume replication.
	DisableVolumeReplication(context.Context, *DisableVolumeReplicationRequest) (*DisableVolumeReplicationResponse, error)
	// PromoteVolume RPC call to promote the volume.
	PromoteVolume(context.Context, *PromoteVolumeRequest) (*PromoteVolumeResponse, error)
	// DemoteVolume RPC call to demote the volume.
	DemoteVolume(context.Context, *DemoteVolumeRequest) (*DemoteVolumeResponse, error)
	// ResyncVolume RPC call to resync the volume.
	ResyncVolume(context.Context, *ResyncVolumeRequest) (*ResyncVolumeResponse, error)
	// GetVolumeReplicationInfo RPC call to get the volume replication
	// information.
	GetVolumeReplicationInfo(context.Context, *GetVolumeReplicationInfoRequest) (*GetVolumeReplicationInfoResponse, error)
	// contains filtered or unexported methods
}

ControllerServer is the server API for Controller service. All implementations must embed UnimplementedControllerServer for forward compatibility

type DemoteVolumeRequest 

type DemoteVolumeRequest struct {

	// The identifier for this volume, generated by the plugin during
	// CreateVolume CSI RPC call.
	// This field is REQUIRED.
	// This field MUST contain enough information to uniquely identify
	// this specific volume vs all other volumes supported by this plugin.
	// This field SHALL be used by the CO in subsequent calls to refer to
	// this volume.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// This field is optional.
	// Default value is false, force option to Demote the volume.
	Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// Plugin specific parameters passed in as opaque key-value pairs.
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// Secrets required by the plugin to complete the request.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// The identifier for the replication.
	// This field is OPTIONAL.
	// This field MUST contain enough information, together with volume_id,
	// to uniquely identify this specific replication
	// vs all other replications supported by this plugin.
	ReplicationId string `protobuf:"bytes,5,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// If specified, this field will contain volume or volume group id
	// for replication.
	ReplicationSource *ReplicationSource `protobuf:"bytes,6,opt,name=replication_source,json=replicationSource,proto3" json:"replication_source,omitempty"`
	// contains filtered or unexported fields
}

DemoteVolumeRequest holds the required information to demote volume on local cluster.

func (*DemoteVolumeRequest) Descriptor deprecated 

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

Deprecated: Use DemoteVolumeRequest.ProtoReflect.Descriptor instead.

func (*DemoteVolumeRequest) GetForce 

func (x *DemoteVolumeRequest) GetForce() bool

func (*DemoteVolumeRequest) GetParameters 

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

func (*DemoteVolumeRequest) GetReplicationId 

func (x *DemoteVolumeRequest) GetReplicationId() string

func (*DemoteVolumeRequest) GetReplicationSource 

func (x *DemoteVolumeRequest) GetReplicationSource() *ReplicationSource

func (*DemoteVolumeRequest) GetSecrets 

func (x *DemoteVolumeRequest) GetSecrets() map[string]string

func (*DemoteVolumeRequest) GetVolumeId 

func (x *DemoteVolumeRequest) GetVolumeId() string

func (*DemoteVolumeRequest) ProtoMessage 

func (*DemoteVolumeRequest) ProtoMessage()

func (*DemoteVolumeRequest) ProtoReflect 

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

func (*DemoteVolumeRequest) Reset 

func (x *DemoteVolumeRequest) Reset()

func (*DemoteVolumeRequest) String 

func (x *DemoteVolumeRequest) String() string

type DemoteVolumeResponse 

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

DemoteVolumeResponse holds the information to send when volume is successfully demoted.

func (*DemoteVolumeResponse) Descriptor deprecated 

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

Deprecated: Use DemoteVolumeResponse.ProtoReflect.Descriptor instead.

func (*DemoteVolumeResponse) ProtoMessage 

func (*DemoteVolumeResponse) ProtoMessage()

func (*DemoteVolumeResponse) ProtoReflect 

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

func (*DemoteVolumeResponse) Reset 

func (x *DemoteVolumeResponse) Reset()

func (*DemoteVolumeResponse) String 

func (x *DemoteVolumeResponse) String() string

type DisableVolumeReplicationRequest 

type DisableVolumeReplicationRequest struct {

	// The identifier for this volume, generated by the plugin during
	// CreateVolume CSI RPC call.
	// This field is REQUIRED.
	// This field MUST contain enough information to uniquely identify
	// this specific volume vs all other volumes supported by this plugin.
	// This field SHALL be used by the CO in subsequent calls to refer to
	// this volume.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// Plugin specific parameters passed in as opaque key-value pairs.
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// Secrets required by the plugin to complete the request.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// The identifier for the replication.
	// This field is OPTIONAL.
	// This field MUST contain enough information, together with volume_id,
	// to uniquely identify this specific replication
	// vs all other replications supported by this plugin.
	ReplicationId string `protobuf:"bytes,4,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// If specified, this field will contain volume or volume group id
	// for replication.
	ReplicationSource *ReplicationSource `protobuf:"bytes,5,opt,name=replication_source,json=replicationSource,proto3" json:"replication_source,omitempty"`
	// contains filtered or unexported fields
}

DisableVolumeReplicationRequest holds the required information to disable replication on a volume.

func (*DisableVolumeReplicationRequest) Descriptor deprecated 

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

Deprecated: Use DisableVolumeReplicationRequest.ProtoReflect.Descriptor instead.

func (*DisableVolumeReplicationRequest) GetParameters 

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

func (*DisableVolumeReplicationRequest) GetReplicationId 

func (x *DisableVolumeReplicationRequest) GetReplicationId() string

func (*DisableVolumeReplicationRequest) GetReplicationSource 

func (x *DisableVolumeReplicationRequest) GetReplicationSource() *ReplicationSource

func (*DisableVolumeReplicationRequest) GetSecrets 

func (x *DisableVolumeReplicationRequest) GetSecrets() map[string]string

func (*DisableVolumeReplicationRequest) GetVolumeId 

func (x *DisableVolumeReplicationRequest) GetVolumeId() string

func (*DisableVolumeReplicationRequest) ProtoMessage 

func (*DisableVolumeReplicationRequest) ProtoMessage()

func (*DisableVolumeReplicationRequest) ProtoReflect 

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

func (*DisableVolumeReplicationRequest) Reset 

func (x *DisableVolumeReplicationRequest) Reset()

func (*DisableVolumeReplicationRequest) String 

func (x *DisableVolumeReplicationRequest) String() string

type DisableVolumeReplicationResponse 

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

DisableVolumeReplicationResponse holds the information to send when replication is successfully disabled on a volume.

func (*DisableVolumeReplicationResponse) Descriptor deprecated 

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

Deprecated: Use DisableVolumeReplicationResponse.ProtoReflect.Descriptor instead.

func (*DisableVolumeReplicationResponse) ProtoMessage 

func (*DisableVolumeReplicationResponse) ProtoMessage()

func (*DisableVolumeReplicationResponse) ProtoReflect 

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

func (*DisableVolumeReplicationResponse) Reset 

func (x *DisableVolumeReplicationResponse) Reset()

func (*DisableVolumeReplicationResponse) String 

func (x *DisableVolumeReplicationResponse) String() string

type EnableVolumeReplicationRequest 

type EnableVolumeReplicationRequest struct {

	// The identifier for this volume, generated by the plugin during
	// CreateVolume CSI RPC call.
	// This field is REQUIRED.
	// This field MUST contain enough information to uniquely identify
	// this specific volume vs all other volumes supported by this plugin.
	// This field SHALL be used by the CO in subsequent calls to refer to
	// this volume.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// The identifier for the replication.
	// Plugin specific parameters passed in as opaque key-value pairs.
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// Secrets required by the plugin to complete the request.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// This field is OPTIONAL.
	// This field MUST contain enough information, together with volume_id,
	// to uniquely identify this specific replication
	// vs all other replications supported by this plugin.
	ReplicationId string `protobuf:"bytes,4,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// If specified, this field will contain volume or volume group id
	// for replication.
	ReplicationSource *ReplicationSource `protobuf:"bytes,5,opt,name=replication_source,json=replicationSource,proto3" json:"replication_source,omitempty"`
	// contains filtered or unexported fields
}

EnableVolumeReplicationRequest holds the required information to enable replication on a volume.

func (*EnableVolumeReplicationRequest) Descriptor deprecated 

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

Deprecated: Use EnableVolumeReplicationRequest.ProtoReflect.Descriptor instead.

func (*EnableVolumeReplicationRequest) GetParameters 

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

func (*EnableVolumeReplicationRequest) GetReplicationId 

func (x *EnableVolumeReplicationRequest) GetReplicationId() string

func (*EnableVolumeReplicationRequest) GetReplicationSource 

func (x *EnableVolumeReplicationRequest) GetReplicationSource() *ReplicationSource

func (*EnableVolumeReplicationRequest) GetSecrets 

func (x *EnableVolumeReplicationRequest) GetSecrets() map[string]string

func (*EnableVolumeReplicationRequest) GetVolumeId 

func (x *EnableVolumeReplicationRequest) GetVolumeId() string

func (*EnableVolumeReplicationRequest) ProtoMessage 

func (*EnableVolumeReplicationRequest) ProtoMessage()

func (*EnableVolumeReplicationRequest) ProtoReflect 

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

func (*EnableVolumeReplicationRequest) Reset 

func (x *EnableVolumeReplicationRequest) Reset()

func (*EnableVolumeReplicationRequest) String 

func (x *EnableVolumeReplicationRequest) String() string

type EnableVolumeReplicationResponse 

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

EnableVolumeReplicationResponse holds the information to send when replication is successfully enabled on a volume.

func (*EnableVolumeReplicationResponse) Descriptor deprecated 

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

Deprecated: Use EnableVolumeReplicationResponse.ProtoReflect.Descriptor instead.

func (*EnableVolumeReplicationResponse) ProtoMessage 

func (*EnableVolumeReplicationResponse) ProtoMessage()

func (*EnableVolumeReplicationResponse) ProtoReflect 

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

func (*EnableVolumeReplicationResponse) Reset 

func (x *EnableVolumeReplicationResponse) Reset()

func (*EnableVolumeReplicationResponse) String 

func (x *EnableVolumeReplicationResponse) String() string

type GetVolumeReplicationInfoRequest 

type GetVolumeReplicationInfoRequest struct {

	// The identifier for this volume, generated by the plugin during
	// CreateVolume CSI RPC call.
	// This field is REQUIRED.
	// This field MUST contain enough information to uniquely identify
	// this specific volume vs all other volumes supported by this plugin.
	// This field SHALL be used by the CO in subsequent calls to refer to
	// this volume.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// Secrets required by the plugin to complete the request.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// The identifier for the replication.
	// This field is OPTIONAL.
	// This field MUST contain enough information, together with volume_id,
	// to uniquely identify this specific replication
	// vs all other replications supported by this plugin.
	ReplicationId string `protobuf:"bytes,3,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// If specified, this field will contain volume or volume group id
	// for replication.
	ReplicationSource *ReplicationSource `protobuf:"bytes,4,opt,name=replication_source,json=replicationSource,proto3" json:"replication_source,omitempty"`
	// contains filtered or unexported fields
}

GetVolumeReplicationInfoRequest holds the required information to get the Volume replication information.

func (*GetVolumeReplicationInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetVolumeReplicationInfoRequest.ProtoReflect.Descriptor instead.

func (*GetVolumeReplicationInfoRequest) GetReplicationId 

func (x *GetVolumeReplicationInfoRequest) GetReplicationId() string

func (*GetVolumeReplicationInfoRequest) GetReplicationSource 

func (x *GetVolumeReplicationInfoRequest) GetReplicationSource() *ReplicationSource

func (*GetVolumeReplicationInfoRequest) GetSecrets 

func (x *GetVolumeReplicationInfoRequest) GetSecrets() map[string]string

func (*GetVolumeReplicationInfoRequest) GetVolumeId 

func (x *GetVolumeReplicationInfoRequest) GetVolumeId() string

func (*GetVolumeReplicationInfoRequest) ProtoMessage 

func (*GetVolumeReplicationInfoRequest) ProtoMessage()

func (*GetVolumeReplicationInfoRequest) ProtoReflect 

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

func (*GetVolumeReplicationInfoRequest) Reset 

func (x *GetVolumeReplicationInfoRequest) Reset()

func (*GetVolumeReplicationInfoRequest) String 

func (x *GetVolumeReplicationInfoRequest) String() string

type GetVolumeReplicationInfoResponse 

type GetVolumeReplicationInfoResponse struct {

	// Holds the last sync time.
	// This field is REQUIRED.
	LastSyncTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_sync_time,json=lastSyncTime,proto3" json:"last_sync_time,omitempty"`
	// Holds the last sync duration.
	// last_sync_duration states the time taken to sync
	// to execute the last sync operation.
	// This field is OPTIONAL.
	LastSyncDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=last_sync_duration,json=lastSyncDuration,proto3" json:"last_sync_duration,omitempty"`
	// Holds the last sync bytes.
	// Represents number of bytes transferred
	// with the last synchronization.
	// This field is OPTIONAL.
	// The value of this field MUST NOT be negative.
	LastSyncBytes int64 `protobuf:"varint,3,opt,name=last_sync_bytes,json=lastSyncBytes,proto3" json:"last_sync_bytes,omitempty"`
	// contains filtered or unexported fields
}

GetVolumeReplicationInfoResponse holds the information to send the volume replication information.

func (*GetVolumeReplicationInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetVolumeReplicationInfoResponse.ProtoReflect.Descriptor instead.

func (*GetVolumeReplicationInfoResponse) GetLastSyncBytes 

func (x *GetVolumeReplicationInfoResponse) GetLastSyncBytes() int64

func (*GetVolumeReplicationInfoResponse) GetLastSyncDuration 

func (x *GetVolumeReplicationInfoResponse) GetLastSyncDuration() *durationpb.Duration

func (*GetVolumeReplicationInfoResponse) GetLastSyncTime 

func (x *GetVolumeReplicationInfoResponse) GetLastSyncTime() *timestamppb.Timestamp

func (*GetVolumeReplicationInfoResponse) ProtoMessage 

func (*GetVolumeReplicationInfoResponse) ProtoMessage()

func (*GetVolumeReplicationInfoResponse) ProtoReflect 

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

func (*GetVolumeReplicationInfoResponse) Reset 

func (x *GetVolumeReplicationInfoResponse) Reset()

func (*GetVolumeReplicationInfoResponse) String 

func (x *GetVolumeReplicationInfoResponse) String() string

type PromoteVolumeRequest 

type PromoteVolumeRequest struct {

	// The identifier for this volume, generated by the plugin during
	// CreateVolume CSI RPC call.
	// This field is REQUIRED.
	// This field MUST contain enough information to uniquely identify
	// this specific volume vs all other volumes supported by this plugin.
	// This field SHALL be used by the CO in subsequent calls to refer to
	// this volume.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// This field is optional.
	// Default value is false, force option to Promote the volume.
	Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// Plugin specific parameters passed in as opaque key-value pairs.
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// Secrets required by the plugin to complete the request.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// The identifier for the replication.
	// This field is OPTIONAL.
	// This field MUST contain enough information, together with volume_id,
	// to uniquely identify this specific replication
	// vs all other replications supported by this plugin.
	ReplicationId string `protobuf:"bytes,5,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// If specified, this field will contain volume or volume group id
	// for replication.
	ReplicationSource *ReplicationSource `protobuf:"bytes,6,opt,name=replication_source,json=replicationSource,proto3" json:"replication_source,omitempty"`
	// contains filtered or unexported fields
}

PromoteVolumeRequest holds the required information to promote volume as a primary on local cluster.

func (*PromoteVolumeRequest) Descriptor deprecated 

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

Deprecated: Use PromoteVolumeRequest.ProtoReflect.Descriptor instead.

func (*PromoteVolumeRequest) GetForce 

func (x *PromoteVolumeRequest) GetForce() bool

func (*PromoteVolumeRequest) GetParameters 

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

func (*PromoteVolumeRequest) GetReplicationId 

func (x *PromoteVolumeRequest) GetReplicationId() string

func (*PromoteVolumeRequest) GetReplicationSource 

func (x *PromoteVolumeRequest) GetReplicationSource() *ReplicationSource

func (*PromoteVolumeRequest) GetSecrets 

func (x *PromoteVolumeRequest) GetSecrets() map[string]string

func (*PromoteVolumeRequest) GetVolumeId 

func (x *PromoteVolumeRequest) GetVolumeId() string

func (*PromoteVolumeRequest) ProtoMessage 

func (*PromoteVolumeRequest) ProtoMessage()

func (*PromoteVolumeRequest) ProtoReflect 

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

func (*PromoteVolumeRequest) Reset 

func (x *PromoteVolumeRequest) Reset()

func (*PromoteVolumeRequest) String 

func (x *PromoteVolumeRequest) String() string

type PromoteVolumeResponse 

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

PromoteVolumeResponse holds the information to send when volume is successfully promoted.

func (*PromoteVolumeResponse) Descriptor deprecated 

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

Deprecated: Use PromoteVolumeResponse.ProtoReflect.Descriptor instead.

func (*PromoteVolumeResponse) ProtoMessage 

func (*PromoteVolumeResponse) ProtoMessage()

func (*PromoteVolumeResponse) ProtoReflect 

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

func (*PromoteVolumeResponse) Reset 

func (x *PromoteVolumeResponse) Reset()

func (*PromoteVolumeResponse) String 

func (x *PromoteVolumeResponse) String() string

type ReplicationSource 

type ReplicationSource struct {

	// Types that are assignable to Type:
	//	*ReplicationSource_Volume
	//	*ReplicationSource_Volumegroup
	Type isReplicationSource_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

Specifies what source the replication will be created from. One of the type fields MUST be specified.

func (*ReplicationSource) Descriptor deprecated 

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

Deprecated: Use ReplicationSource.ProtoReflect.Descriptor instead.

func (*ReplicationSource) GetType 

func (m *ReplicationSource) GetType() isReplicationSource_Type

func (*ReplicationSource) GetVolume 

func (x *ReplicationSource) GetVolume() *ReplicationSource_VolumeSource

func (*ReplicationSource) GetVolumegroup 

func (x *ReplicationSource) GetVolumegroup() *ReplicationSource_VolumeGroupSource

func (*ReplicationSource) ProtoMessage 

func (*ReplicationSource) ProtoMessage()

func (*ReplicationSource) ProtoReflect 

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

func (*ReplicationSource) Reset 

func (x *ReplicationSource) Reset()

func (*ReplicationSource) String 

func (x *ReplicationSource) String() string

type ReplicationSource_Volume 

type ReplicationSource_Volume struct {
	// Volume source type
	Volume *ReplicationSource_VolumeSource `protobuf:"bytes,1,opt,name=volume,proto3,oneof"`
}

type ReplicationSource_VolumeGroupSource 

type ReplicationSource_VolumeGroupSource struct {

	// Contains identity information for the existing volume group.
	// This field is REQUIRED.
	VolumeGroupId string `protobuf:"bytes,1,opt,name=volume_group_id,json=volumeGroupId,proto3" json:"volume_group_id,omitempty"`
	// contains filtered or unexported fields
}

VolumeGroupSource contains the details about the volume group to be replication

func (*ReplicationSource_VolumeGroupSource) Descriptor deprecated 

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

Deprecated: Use ReplicationSource_VolumeGroupSource.ProtoReflect.Descriptor instead.

func (*ReplicationSource_VolumeGroupSource) GetVolumeGroupId 

func (x *ReplicationSource_VolumeGroupSource) GetVolumeGroupId() string

func (*ReplicationSource_VolumeGroupSource) ProtoMessage 

func (*ReplicationSource_VolumeGroupSource) ProtoMessage()

func (*ReplicationSource_VolumeGroupSource) ProtoReflect 

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

func (*ReplicationSource_VolumeGroupSource) Reset 

func (x *ReplicationSource_VolumeGroupSource) Reset()

func (*ReplicationSource_VolumeGroupSource) String 

func (x *ReplicationSource_VolumeGroupSource) String() string

type ReplicationSource_VolumeSource 

type ReplicationSource_VolumeSource struct {

	// Contains identity information for the existing volume.
	// This field is REQUIRED.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

VolumeSource contains the details about the volume to be replication

func (*ReplicationSource_VolumeSource) Descriptor deprecated 

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

Deprecated: Use ReplicationSource_VolumeSource.ProtoReflect.Descriptor instead.

func (*ReplicationSource_VolumeSource) GetVolumeId 

func (x *ReplicationSource_VolumeSource) GetVolumeId() string

func (*ReplicationSource_VolumeSource) ProtoMessage 

func (*ReplicationSource_VolumeSource) ProtoMessage()

func (*ReplicationSource_VolumeSource) ProtoReflect 

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

func (*ReplicationSource_VolumeSource) Reset 

func (x *ReplicationSource_VolumeSource) Reset()

func (*ReplicationSource_VolumeSource) String 

func (x *ReplicationSource_VolumeSource) String() string

type ReplicationSource_Volumegroup 

type ReplicationSource_Volumegroup struct {
	// Volume group source type
	Volumegroup *ReplicationSource_VolumeGroupSource `protobuf:"bytes,2,opt,name=volumegroup,proto3,oneof"`
}

type ResyncVolumeRequest 

type ResyncVolumeRequest struct {

	// The identifier for this volume, generated by the plugin during
	// CreateVolume CSI RPC call.
	// This field is REQUIRED.
	// This field MUST contain enough information to uniquely identify
	// this specific volume vs all other volumes supported by this plugin.
	// This field SHALL be used by the CO in subsequent calls to refer to
	// this volume.
	VolumeId string `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// This field is optional.
	// Default value is false, force option to Resync the volume.
	Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// Plugin specific parameters passed in as opaque key-value pairs.
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// Secrets required by the plugin to complete the request.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// The identifier for the replication.
	// This field is OPTIONAL.
	// This field MUST contain enough information, together with volume_id,
	// to uniquely identify this specific replication
	// vs all other replications supported by this plugin.
	ReplicationId string `protobuf:"bytes,5,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// If specified, this field will contain volume or volume group id
	// for replication.
	ReplicationSource *ReplicationSource `protobuf:"bytes,6,opt,name=replication_source,json=replicationSource,proto3" json:"replication_source,omitempty"`
	// contains filtered or unexported fields
}

ResyncVolumeRequest holds the required information to resync volume.

func (*ResyncVolumeRequest) Descriptor deprecated 

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

Deprecated: Use ResyncVolumeRequest.ProtoReflect.Descriptor instead.

func (*ResyncVolumeRequest) GetForce 

func (x *ResyncVolumeRequest) GetForce() bool

func (*ResyncVolumeRequest) GetParameters 

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

func (*ResyncVolumeRequest) GetReplicationId 

func (x *ResyncVolumeRequest) GetReplicationId() string

func (*ResyncVolumeRequest) GetReplicationSource 

func (x *ResyncVolumeRequest) GetReplicationSource() *ReplicationSource

func (*ResyncVolumeRequest) GetSecrets 

func (x *ResyncVolumeRequest) GetSecrets() map[string]string

func (*ResyncVolumeRequest) GetVolumeId 

func (x *ResyncVolumeRequest) GetVolumeId() string

func (*ResyncVolumeRequest) ProtoMessage 

func (*ResyncVolumeRequest) ProtoMessage()

func (*ResyncVolumeRequest) ProtoReflect 

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

func (*ResyncVolumeRequest) Reset 

func (x *ResyncVolumeRequest) Reset()

func (*ResyncVolumeRequest) String 

func (x *ResyncVolumeRequest) String() string

type ResyncVolumeResponse 

type ResyncVolumeResponse struct {

	// Indicates that the volume is ready to use.
	// The default value is false.
	// This field is REQUIRED.
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

ResyncVolumeResponse holds the information to send when volume is successfully resynced.

func (*ResyncVolumeResponse) Descriptor deprecated 

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

Deprecated: Use ResyncVolumeResponse.ProtoReflect.Descriptor instead.

func (*ResyncVolumeResponse) GetReady 

func (x *ResyncVolumeResponse) GetReady() bool

func (*ResyncVolumeResponse) ProtoMessage 

func (*ResyncVolumeResponse) ProtoMessage()

func (*ResyncVolumeResponse) ProtoReflect 

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

func (*ResyncVolumeResponse) Reset 

func (x *ResyncVolumeResponse) Reset()

func (*ResyncVolumeResponse) String 

func (x *ResyncVolumeResponse) String() string

type UnimplementedControllerServer 

type UnimplementedControllerServer struct {
}

UnimplementedControllerServer must be embedded to have forward compatible implementations.

func (UnimplementedControllerServer) DemoteVolume 

func (UnimplementedControllerServer) DemoteVolume(context.Context, *DemoteVolumeRequest) (*DemoteVolumeResponse, error)

func (UnimplementedControllerServer) DisableVolumeReplication 

func (UnimplementedControllerServer) DisableVolumeReplication(context.Context, *DisableVolumeReplicationRequest) (*DisableVolumeReplicationResponse, error)

func (UnimplementedControllerServer) EnableVolumeReplication 

func (UnimplementedControllerServer) EnableVolumeReplication(context.Context, *EnableVolumeReplicationRequest) (*EnableVolumeReplicationResponse, error)

func (UnimplementedControllerServer) GetVolumeReplicationInfo 

func (UnimplementedControllerServer) GetVolumeReplicationInfo(context.Context, *GetVolumeReplicationInfoRequest) (*GetVolumeReplicationInfoResponse, error)

func (UnimplementedControllerServer) PromoteVolume 

func (UnimplementedControllerServer) PromoteVolume(context.Context, *PromoteVolumeRequest) (*PromoteVolumeResponse, error)

func (UnimplementedControllerServer) ResyncVolume 

func (UnimplementedControllerServer) ResyncVolume(context.Context, *ResyncVolumeRequest) (*ResyncVolumeResponse, error)

type UnsafeControllerServer 

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

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

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.