replication

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2021 License: Apache-2.0 Imports: 10 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,
		},
	},
	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 (
	// 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]
)

Extension fields to descriptorpb.FieldOptions.

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)
}

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)
	// 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][]byte `` /* 155-byte string literal not displayed */
	// 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) GetSecrets 

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

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][]byte `` /* 155-byte string literal not displayed */
	// 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) GetSecrets 

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

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"`
	// 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][]byte `` /* 155-byte string literal not displayed */
	// 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) GetSecrets 

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

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 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][]byte `` /* 155-byte string literal not displayed */
	// 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) GetSecrets 

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

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 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][]byte `` /* 155-byte string literal not displayed */
	// 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) GetSecrets 

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

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) 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.