replication

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// Indicates that a field MAY contain information that is sensitive
	// and MUST be treated as such (e.g. not logged).
	//
	// optional bool replication_secret = 1099;
	E_ReplicationSecret = &file_replication_proto_extTypes[0]
	// 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_proto_extTypes[1]
)

Extension fields to descriptorpb.FieldOptions.

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.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 File_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 added in v0.1.1 

func (x *DemoteVolumeRequest) GetReplicationId() string

func (*DemoteVolumeRequest) GetReplicationSource added in v0.1.3 

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 added in v0.1.1 

func (x *DisableVolumeReplicationRequest) GetReplicationId() string

func (*DisableVolumeReplicationRequest) GetReplicationSource added in v0.1.3 

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 added in v0.1.1 

func (x *EnableVolumeReplicationRequest) GetReplicationId() string

func (*EnableVolumeReplicationRequest) GetReplicationSource added in v0.1.3 

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 added in v0.1.2 

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 added in v0.1.2 

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

Deprecated: Use GetVolumeReplicationInfoRequest.ProtoReflect.Descriptor instead.

func (*GetVolumeReplicationInfoRequest) GetReplicationId added in v0.1.2 

func (x *GetVolumeReplicationInfoRequest) GetReplicationId() string

func (*GetVolumeReplicationInfoRequest) GetReplicationSource added in v0.1.3 

func (x *GetVolumeReplicationInfoRequest) GetReplicationSource() *ReplicationSource

func (*GetVolumeReplicationInfoRequest) GetSecrets added in v0.1.2 

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

func (*GetVolumeReplicationInfoRequest) GetVolumeId added in v0.1.2 

func (x *GetVolumeReplicationInfoRequest) GetVolumeId() string

func (*GetVolumeReplicationInfoRequest) ProtoMessage added in v0.1.2 

func (*GetVolumeReplicationInfoRequest) ProtoMessage()

func (*GetVolumeReplicationInfoRequest) ProtoReflect added in v0.1.2 

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

func (*GetVolumeReplicationInfoRequest) Reset added in v0.1.2 

func (x *GetVolumeReplicationInfoRequest) Reset()

func (*GetVolumeReplicationInfoRequest) String added in v0.1.2 

func (x *GetVolumeReplicationInfoRequest) String() string

type GetVolumeReplicationInfoResponse added in v0.1.2 

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"`
	// contains filtered or unexported fields
}

GetVolumeReplicationInfoResponse holds the information to send the volume replication information.

func (*GetVolumeReplicationInfoResponse) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use GetVolumeReplicationInfoResponse.ProtoReflect.Descriptor instead.

func (*GetVolumeReplicationInfoResponse) GetLastSyncTime added in v0.1.2 

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

func (*GetVolumeReplicationInfoResponse) ProtoMessage added in v0.1.2 

func (*GetVolumeReplicationInfoResponse) ProtoMessage()

func (*GetVolumeReplicationInfoResponse) ProtoReflect added in v0.1.2 

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

func (*GetVolumeReplicationInfoResponse) Reset added in v0.1.2 

func (x *GetVolumeReplicationInfoResponse) Reset()

func (*GetVolumeReplicationInfoResponse) String added in v0.1.2 

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 added in v0.1.1 

func (x *PromoteVolumeRequest) GetReplicationId() string

func (*PromoteVolumeRequest) GetReplicationSource added in v0.1.3 

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 added in v0.1.3 

type ReplicationSource struct {

	// Types that are assignable to Type:
	//	*ReplicationSource_Volumegroup
	//	*ReplicationSource_Volume
	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 added in v0.1.3 

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

Deprecated: Use ReplicationSource.ProtoReflect.Descriptor instead.

func (*ReplicationSource) GetType added in v0.1.3 

func (m *ReplicationSource) GetType() isReplicationSource_Type

func (*ReplicationSource) GetVolume added in v0.1.3 

func (x *ReplicationSource) GetVolume() *ReplicationSource_VolumeSource

func (*ReplicationSource) GetVolumegroup added in v0.1.3 

func (x *ReplicationSource) GetVolumegroup() *ReplicationSource_VolumeGroupSource

func (*ReplicationSource) ProtoMessage added in v0.1.3 

func (*ReplicationSource) ProtoMessage()

func (*ReplicationSource) ProtoReflect added in v0.1.3 

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

func (*ReplicationSource) Reset added in v0.1.3 

func (x *ReplicationSource) Reset()

func (*ReplicationSource) String added in v0.1.3 

func (x *ReplicationSource) String() string

type ReplicationSource_Volume added in v0.1.3 

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

type ReplicationSource_VolumeGroupSource added in v0.1.3 

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
}

func (*ReplicationSource_VolumeGroupSource) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use ReplicationSource_VolumeGroupSource.ProtoReflect.Descriptor instead.

func (*ReplicationSource_VolumeGroupSource) GetVolumeGroupId added in v0.1.3 

func (x *ReplicationSource_VolumeGroupSource) GetVolumeGroupId() string

func (*ReplicationSource_VolumeGroupSource) ProtoMessage added in v0.1.3 

func (*ReplicationSource_VolumeGroupSource) ProtoMessage()

func (*ReplicationSource_VolumeGroupSource) ProtoReflect added in v0.1.3 

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

func (*ReplicationSource_VolumeGroupSource) Reset added in v0.1.3 

func (x *ReplicationSource_VolumeGroupSource) Reset()

func (*ReplicationSource_VolumeGroupSource) String added in v0.1.3 

func (x *ReplicationSource_VolumeGroupSource) String() string

type ReplicationSource_VolumeSource added in v0.1.3 

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
}

func (*ReplicationSource_VolumeSource) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use ReplicationSource_VolumeSource.ProtoReflect.Descriptor instead.

func (*ReplicationSource_VolumeSource) GetVolumeId added in v0.1.3 

func (x *ReplicationSource_VolumeSource) GetVolumeId() string

func (*ReplicationSource_VolumeSource) ProtoMessage added in v0.1.3 

func (*ReplicationSource_VolumeSource) ProtoMessage()

func (*ReplicationSource_VolumeSource) ProtoReflect added in v0.1.3 

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

func (*ReplicationSource_VolumeSource) Reset added in v0.1.3 

func (x *ReplicationSource_VolumeSource) Reset()

func (*ReplicationSource_VolumeSource) String added in v0.1.3 

func (x *ReplicationSource_VolumeSource) String() string

type ReplicationSource_Volumegroup added in v0.1.3 

type ReplicationSource_Volumegroup struct {
	// Volume group source type
	Volumegroup *ReplicationSource_VolumeGroupSource `protobuf:"bytes,1,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 added in v0.1.1 

func (x *ResyncVolumeRequest) GetReplicationId() string

func (*ResyncVolumeRequest) GetReplicationSource added in v0.1.3 

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 added in v0.1.2 

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.