regattapb

package

Go to main page

Versions in this module

v0

v0.4.3

Jun 11, 2024

v0.4.2

May 6, 2024

v0.4.1

May 6, 2024

v0.4.0

Apr 15, 2024

Changes in this version

+ const Tables_Create_FullMethodName

+ const Tables_Delete_FullMethodName

+ const Tables_List_FullMethodName

+ var Tables_ServiceDesc = grpc.ServiceDesc

+ func RegisterTablesServer(s grpc.ServiceRegistrar, srv TablesServer)

type BackupRequest

+ func (m *BackupRequest) UnmarshalVTUnsafe(dAtA []byte) error

type Command

+ func (m *Command) UnmarshalVTUnsafe(dAtA []byte) error

type CommandResult

+ func (m *CommandResult) UnmarshalVTUnsafe(dAtA []byte) error

type Compare

+ func (m *Compare) UnmarshalVTUnsafe(dAtA []byte) error

+ type CreateTableRequest struct

+ Config *structpb.Struct

+ Name string

+ func (*CreateTableRequest) Descriptor() ([]byte, []int)

+ func (*CreateTableRequest) ProtoMessage()

+ func (m *CreateTableRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CreateTableRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CreateTableRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *CreateTableRequest) SizeVT() (n int)

+ func (m *CreateTableRequest) UnmarshalVT(dAtA []byte) error

+ func (m *CreateTableRequest) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *CreateTableRequest) GetConfig() *structpb.Struct

+ func (x *CreateTableRequest) GetName() string

+ func (x *CreateTableRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateTableRequest) Reset()

+ func (x *CreateTableRequest) String() string

+ type CreateTableResponse struct

+ Id string

+ func (*CreateTableResponse) Descriptor() ([]byte, []int)

+ func (*CreateTableResponse) ProtoMessage()

+ func (m *CreateTableResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CreateTableResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CreateTableResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *CreateTableResponse) SizeVT() (n int)

+ func (m *CreateTableResponse) UnmarshalVT(dAtA []byte) error

+ func (m *CreateTableResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *CreateTableResponse) GetId() string

+ func (x *CreateTableResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateTableResponse) Reset()

+ func (x *CreateTableResponse) String() string

type DeleteRangeRequest

+ func (m *DeleteRangeRequest) UnmarshalVTUnsafe(dAtA []byte) error

type DeleteRangeResponse

+ func (m *DeleteRangeResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ type DeleteTableRequest struct

+ Name string

+ func (*DeleteTableRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTableRequest) ProtoMessage()

+ func (m *DeleteTableRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DeleteTableRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DeleteTableRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *DeleteTableRequest) SizeVT() (n int)

+ func (m *DeleteTableRequest) UnmarshalVT(dAtA []byte) error

+ func (m *DeleteTableRequest) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *DeleteTableRequest) GetName() string

+ func (x *DeleteTableRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteTableRequest) Reset()

+ func (x *DeleteTableRequest) String() string

+ type DeleteTableResponse struct

+ func (*DeleteTableResponse) Descriptor() ([]byte, []int)

+ func (*DeleteTableResponse) ProtoMessage()

+ func (m *DeleteTableResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DeleteTableResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DeleteTableResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *DeleteTableResponse) SizeVT() (n int)

+ func (m *DeleteTableResponse) UnmarshalVT(dAtA []byte) error

+ func (m *DeleteTableResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *DeleteTableResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteTableResponse) Reset()

+ func (x *DeleteTableResponse) String() string

type KeyValue

+ func (m *KeyValue) UnmarshalVTUnsafe(dAtA []byte) error

+ type ListTablesRequest struct

+ func (*ListTablesRequest) Descriptor() ([]byte, []int)

+ func (*ListTablesRequest) ProtoMessage()

+ func (m *ListTablesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ListTablesRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ListTablesRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ListTablesRequest) SizeVT() (n int)

+ func (m *ListTablesRequest) UnmarshalVT(dAtA []byte) error

+ func (m *ListTablesRequest) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *ListTablesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListTablesRequest) Reset()

+ func (x *ListTablesRequest) String() string

+ type ListTablesResponse struct

+ Tables []*TableInfo

+ func (*ListTablesResponse) Descriptor() ([]byte, []int)

+ func (*ListTablesResponse) ProtoMessage()

+ func (m *ListTablesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ListTablesResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ListTablesResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ListTablesResponse) SizeVT() (n int)

+ func (m *ListTablesResponse) UnmarshalVT(dAtA []byte) error

+ func (m *ListTablesResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *ListTablesResponse) GetTables() []*TableInfo

+ func (x *ListTablesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListTablesResponse) Reset()

+ func (x *ListTablesResponse) String() string

type Member

+ func (m *Member) UnmarshalVTUnsafe(dAtA []byte) error

type MemberListRequest

+ func (m *MemberListRequest) UnmarshalVTUnsafe(dAtA []byte) error

type MemberListResponse

+ func (m *MemberListResponse) UnmarshalVTUnsafe(dAtA []byte) error

type MetadataRequest

+ func (m *MetadataRequest) UnmarshalVTUnsafe(dAtA []byte) error

type MetadataResponse

+ func (m *MetadataResponse) UnmarshalVTUnsafe(dAtA []byte) error

type PutRequest

+ func (m *PutRequest) UnmarshalVTUnsafe(dAtA []byte) error

type PutResponse

+ func (m *PutResponse) UnmarshalVTUnsafe(dAtA []byte) error

type RangeRequest

+ func (m *RangeRequest) UnmarshalVTUnsafe(dAtA []byte) error

type RangeResponse

+ func (m *RangeResponse) UnmarshalVTUnsafe(dAtA []byte) error

type ReplicateCommand

+ func (m *ReplicateCommand) UnmarshalVTUnsafe(dAtA []byte) error

type ReplicateCommandsResponse

+ func (m *ReplicateCommandsResponse) UnmarshalVTUnsafe(dAtA []byte) error

type ReplicateErrResponse

+ func (m *ReplicateErrResponse) UnmarshalVTUnsafe(dAtA []byte) error

type ReplicateRequest

+ func (m *ReplicateRequest) UnmarshalVTUnsafe(dAtA []byte) error

type ReplicateResponse

+ func (m *ReplicateResponse) UnmarshalVTUnsafe(dAtA []byte) error

type RequestOp

+ func (m *RequestOp) UnmarshalVTUnsafe(dAtA []byte) error

type RequestOp_DeleteRange

+ func (m *RequestOp_DeleteRange) UnmarshalVTUnsafe(dAtA []byte) error

type RequestOp_Put

+ func (m *RequestOp_Put) UnmarshalVTUnsafe(dAtA []byte) error

type RequestOp_Range

+ func (m *RequestOp_Range) UnmarshalVTUnsafe(dAtA []byte) error

type ResetRequest

+ func (m *ResetRequest) UnmarshalVTUnsafe(dAtA []byte) error

type ResetResponse

+ func (m *ResetResponse) UnmarshalVTUnsafe(dAtA []byte) error

type ResponseHeader

+ func (m *ResponseHeader) UnmarshalVTUnsafe(dAtA []byte) error

type ResponseOp

+ func (m *ResponseOp) UnmarshalVTUnsafe(dAtA []byte) error

type ResponseOp_DeleteRange

+ func (m *ResponseOp_DeleteRange) UnmarshalVTUnsafe(dAtA []byte) error

type ResponseOp_Put

+ func (m *ResponseOp_Put) UnmarshalVTUnsafe(dAtA []byte) error

type ResponseOp_Range

+ func (m *ResponseOp_Range) UnmarshalVTUnsafe(dAtA []byte) error

type RestoreInfo

+ func (m *RestoreInfo) UnmarshalVTUnsafe(dAtA []byte) error

type RestoreMessage

+ func (m *RestoreMessage) UnmarshalVTUnsafe(dAtA []byte) error

type RestoreResponse

+ func (m *RestoreResponse) UnmarshalVTUnsafe(dAtA []byte) error

type SnapshotChunk

+ func (m *SnapshotChunk) UnmarshalVTUnsafe(dAtA []byte) error

type SnapshotRequest

+ func (m *SnapshotRequest) UnmarshalVTUnsafe(dAtA []byte) error

type StatusRequest

+ func (m *StatusRequest) UnmarshalVTUnsafe(dAtA []byte) error

type StatusResponse

+ func (m *StatusResponse) UnmarshalVTUnsafe(dAtA []byte) error

type Table

+ func (m *Table) UnmarshalVTUnsafe(dAtA []byte) error

+ type TableInfo struct

+ Config *structpb.Struct

+ Id string

+ Name string

+ func (*TableInfo) Descriptor() ([]byte, []int)

+ func (*TableInfo) ProtoMessage()

+ func (m *TableInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TableInfo) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TableInfo) MarshalVT() (dAtA []byte, err error)

+ func (m *TableInfo) SizeVT() (n int)

+ func (m *TableInfo) UnmarshalVT(dAtA []byte) error

+ func (m *TableInfo) UnmarshalVTUnsafe(dAtA []byte) error

+ func (x *TableInfo) GetConfig() *structpb.Struct

+ func (x *TableInfo) GetId() string

+ func (x *TableInfo) GetName() string

+ func (x *TableInfo) ProtoReflect() protoreflect.Message

+ func (x *TableInfo) Reset()

+ func (x *TableInfo) String() string

type TableStatus

+ func (m *TableStatus) UnmarshalVTUnsafe(dAtA []byte) error

+ type TablesClient interface

+ Create func(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*CreateTableResponse, error)

+ Delete func(ctx context.Context, in *DeleteTableRequest, opts ...grpc.CallOption) (*DeleteTableResponse, error)

+ List func(ctx context.Context, in *ListTablesRequest, opts ...grpc.CallOption) (*ListTablesResponse, error)

+ func NewTablesClient(cc grpc.ClientConnInterface) TablesClient

+ type TablesServer interface

+ Create func(context.Context, *CreateTableRequest) (*CreateTableResponse, error)

+ Delete func(context.Context, *DeleteTableRequest) (*DeleteTableResponse, error)

+ List func(context.Context, *ListTablesRequest) (*ListTablesResponse, error)

type Txn

+ func (m *Txn) UnmarshalVTUnsafe(dAtA []byte) error

type TxnRequest

+ func (m *TxnRequest) UnmarshalVTUnsafe(dAtA []byte) error

type TxnResponse

+ func (m *TxnResponse) UnmarshalVTUnsafe(dAtA []byte) error

+ type UnimplementedTablesServer struct

+ func (UnimplementedTablesServer) Create(context.Context, *CreateTableRequest) (*CreateTableResponse, error)

+ func (UnimplementedTablesServer) Delete(context.Context, *DeleteTableRequest) (*DeleteTableResponse, error)

+ func (UnimplementedTablesServer) List(context.Context, *ListTablesRequest) (*ListTablesResponse, error)

+ type UnsafeTablesServer interface

v0.3.1

Jan 16, 2024

v0.3.0

Jan 16, 2024

Changes in this version

+ const KV_IterateRange_FullMethodName

type KVClient

+ IterateRange func(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (KV_IterateRangeClient, error)

type KVServer

+ IterateRange func(*RangeRequest, KV_IterateRangeServer) error

+ type KV_IterateRangeClient interface

+ Recv func() (*RangeResponse, error)

+ type KV_IterateRangeServer interface

+ Send func(*RangeResponse) error

type MemberListResponse

+ Cluster string

+ func (x *MemberListResponse) GetCluster() string

type StatusRequest

+ Config bool

+ func (x *StatusRequest) GetConfig() bool

type StatusResponse

+ Config *structpb.Struct

+ func (x *StatusResponse) GetConfig() *structpb.Struct

type UnimplementedKVServer

+ func (UnimplementedKVServer) IterateRange(*RangeRequest, KV_IterateRangeServer) error

v0.2.2

Dec 23, 2023

v0.2.1

Dec 13, 2023

v0.2.0

Dec 7, 2023

Changes in this version

type Member

+ Id string

+ func (x *Member) GetId() string

type StatusResponse

+ Id string

+ Info string

+ Tables map[string]*TableStatus

+ func (x *StatusResponse) GetId() string

+ func (x *StatusResponse) GetInfo() string

+ func (x *StatusResponse) GetTables() map[string]*TableStatus

+ type TableStatus struct

+ DbSize int64

+ Leader string

+ LogSize int64

+ RaftAppliedIndex uint64

+ RaftIndex uint64

+ RaftTerm uint64

+ func (*TableStatus) Descriptor() ([]byte, []int)

+ func (*TableStatus) ProtoMessage()

+ func (m *TableStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TableStatus) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TableStatus) MarshalVT() (dAtA []byte, err error)

+ func (m *TableStatus) SizeVT() (n int)

+ func (m *TableStatus) UnmarshalVT(dAtA []byte) error

+ func (x *TableStatus) GetDbSize() int64

+ func (x *TableStatus) GetLeader() string

+ func (x *TableStatus) GetLogSize() int64

+ func (x *TableStatus) GetRaftAppliedIndex() uint64

+ func (x *TableStatus) GetRaftIndex() uint64

+ func (x *TableStatus) GetRaftTerm() uint64

+ func (x *TableStatus) ProtoReflect() protoreflect.Message

+ func (x *TableStatus) Reset()

+ func (x *TableStatus) String() string

v0.1.5

Dec 5, 2023

v0.1.4

Nov 23, 2023

v0.1.3

Nov 23, 2023

v0.1.2

Nov 23, 2023

v0.1.1

Nov 23, 2023

v0.1.0

Nov 23, 2023

v0.0.3

Nov 14, 2023

v0.0.2

Nov 13, 2023

v0.0.1

Oct 27, 2023

Changes in this version

+ const Cluster_MemberList_FullMethodName

+ const Cluster_Status_FullMethodName

+ const KV_DeleteRange_FullMethodName

+ const KV_Put_FullMethodName

+ const KV_Range_FullMethodName

+ const KV_Txn_FullMethodName

+ const Log_Replicate_FullMethodName

+ const Maintenance_Backup_FullMethodName

+ const Maintenance_Reset_FullMethodName

+ const Maintenance_Restore_FullMethodName

+ const Metadata_Get_FullMethodName

+ const Snapshot_Stream_FullMethodName

+ var Cluster_ServiceDesc = grpc.ServiceDesc

+ var Command_CommandType_name = map[int32]string

+ var Command_CommandType_value = map[string]int32

+ var Compare_CompareResult_name = map[int32]string

+ var Compare_CompareResult_value = map[string]int32

+ var Compare_CompareTarget_name = map[int32]string

+ var Compare_CompareTarget_value = map[string]int32

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_maintenance_proto protoreflect.FileDescriptor

+ var File_mvcc_proto protoreflect.FileDescriptor

+ var File_regatta_proto protoreflect.FileDescriptor

+ var File_replication_proto protoreflect.FileDescriptor

+ var KV_ServiceDesc = grpc.ServiceDesc

+ var Log_ServiceDesc = grpc.ServiceDesc

+ var Maintenance_ServiceDesc = grpc.ServiceDesc

+ var Metadata_ServiceDesc = grpc.ServiceDesc

+ var ReplicateError_name = map[int32]string

+ var ReplicateError_value = map[string]int32

+ var Snapshot_ServiceDesc = grpc.ServiceDesc

+ var Table_Type_name = map[int32]string

+ var Table_Type_value = map[string]int32

+ func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)

+ func RegisterKVServer(s grpc.ServiceRegistrar, srv KVServer)

+ func RegisterLogServer(s grpc.ServiceRegistrar, srv LogServer)

+ func RegisterMaintenanceServer(s grpc.ServiceRegistrar, srv MaintenanceServer)

+ func RegisterMetadataServer(s grpc.ServiceRegistrar, srv MetadataServer)

+ func RegisterSnapshotServer(s grpc.ServiceRegistrar, srv SnapshotServer)

+ type BackupRequest struct

+ Table []byte

+ func (*BackupRequest) Descriptor() ([]byte, []int)

+ func (*BackupRequest) ProtoMessage()

+ func (m *BackupRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *BackupRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *BackupRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *BackupRequest) SizeVT() (n int)

+ func (m *BackupRequest) UnmarshalVT(dAtA []byte) error

+ func (x *BackupRequest) GetTable() []byte

+ func (x *BackupRequest) ProtoReflect() protoreflect.Message

+ func (x *BackupRequest) Reset()

+ func (x *BackupRequest) String() string

+ type ClusterClient interface

+ MemberList func(ctx context.Context, in *MemberListRequest, opts ...grpc.CallOption) (*MemberListResponse, error)

+ Status func(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)

+ func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

+ type ClusterServer interface

+ MemberList func(context.Context, *MemberListRequest) (*MemberListResponse, error)

+ Status func(context.Context, *StatusRequest) (*StatusResponse, error)

+ type Command struct

+ Batch []*KeyValue

+ Count bool

+ Kv *KeyValue

+ LeaderIndex *uint64

+ PrevKvs bool

+ RangeEnd []byte

+ Sequence []*Command

+ Table []byte

+ Txn *Txn

+ Type Command_CommandType

+ func CommandFromVTPool() *Command

+ func (*Command) Descriptor() ([]byte, []int)

+ func (*Command) ProtoMessage()

+ func (m *Command) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Command) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Command) MarshalVT() (dAtA []byte, err error)

+ func (m *Command) ResetVT()

+ func (m *Command) ReturnToVTPool()

+ func (m *Command) SizeVT() (n int)

+ func (m *Command) UnmarshalVT(dAtA []byte) error

+ func (x *Command) GetBatch() []*KeyValue

+ func (x *Command) GetCount() bool

+ func (x *Command) GetKv() *KeyValue

+ func (x *Command) GetLeaderIndex() uint64

+ func (x *Command) GetPrevKvs() bool

+ func (x *Command) GetRangeEnd() []byte

+ func (x *Command) GetSequence() []*Command

+ func (x *Command) GetTable() []byte

+ func (x *Command) GetTxn() *Txn

+ func (x *Command) GetType() Command_CommandType

+ func (x *Command) ProtoReflect() protoreflect.Message

+ func (x *Command) Reset()

+ func (x *Command) String() string

+ type CommandResult struct

+ Responses []*ResponseOp

+ Revision uint64

+ func (*CommandResult) Descriptor() ([]byte, []int)

+ func (*CommandResult) ProtoMessage()

+ func (m *CommandResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CommandResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CommandResult) MarshalVT() (dAtA []byte, err error)

+ func (m *CommandResult) SizeVT() (n int)

+ func (m *CommandResult) UnmarshalVT(dAtA []byte) error

+ func (x *CommandResult) GetResponses() []*ResponseOp

+ func (x *CommandResult) GetRevision() uint64

+ func (x *CommandResult) ProtoReflect() protoreflect.Message

+ func (x *CommandResult) Reset()

+ func (x *CommandResult) String() string

+ type Command_CommandType int32

+ const Command_DELETE

+ const Command_DELETE_BATCH

+ const Command_DUMMY

+ const Command_PUT

+ const Command_PUT_BATCH

+ const Command_SEQUENCE

+ const Command_TXN

+ func (Command_CommandType) Descriptor() protoreflect.EnumDescriptor

+ func (Command_CommandType) EnumDescriptor() ([]byte, []int)

+ func (Command_CommandType) Type() protoreflect.EnumType

+ func (x Command_CommandType) Enum() *Command_CommandType

+ func (x Command_CommandType) Number() protoreflect.EnumNumber

+ func (x Command_CommandType) String() string

+ type Compare struct

+ Key []byte

+ RangeEnd []byte

+ Result Compare_CompareResult

+ Target Compare_CompareTarget

+ TargetUnion isCompare_TargetUnion

+ func (*Compare) Descriptor() ([]byte, []int)

+ func (*Compare) ProtoMessage()

+ func (m *Compare) GetTargetUnion() isCompare_TargetUnion

+ func (m *Compare) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Compare) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Compare) MarshalVT() (dAtA []byte, err error)

+ func (m *Compare) SizeVT() (n int)

+ func (m *Compare) UnmarshalVT(dAtA []byte) error

+ func (x *Compare) GetKey() []byte

+ func (x *Compare) GetRangeEnd() []byte

+ func (x *Compare) GetResult() Compare_CompareResult

+ func (x *Compare) GetTarget() Compare_CompareTarget

+ func (x *Compare) GetValue() []byte

+ func (x *Compare) ProtoReflect() protoreflect.Message

+ func (x *Compare) Reset()

+ func (x *Compare) String() string

+ type Compare_CompareResult int32

+ const Compare_EQUAL

+ const Compare_GREATER

+ const Compare_LESS

+ const Compare_NOT_EQUAL

+ func (Compare_CompareResult) Descriptor() protoreflect.EnumDescriptor

+ func (Compare_CompareResult) EnumDescriptor() ([]byte, []int)

+ func (Compare_CompareResult) Type() protoreflect.EnumType

+ func (x Compare_CompareResult) Enum() *Compare_CompareResult

+ func (x Compare_CompareResult) Number() protoreflect.EnumNumber

+ func (x Compare_CompareResult) String() string

+ type Compare_CompareTarget int32

+ const Compare_VALUE

+ func (Compare_CompareTarget) Descriptor() protoreflect.EnumDescriptor

+ func (Compare_CompareTarget) EnumDescriptor() ([]byte, []int)

+ func (Compare_CompareTarget) Type() protoreflect.EnumType

+ func (x Compare_CompareTarget) Enum() *Compare_CompareTarget

+ func (x Compare_CompareTarget) Number() protoreflect.EnumNumber

+ func (x Compare_CompareTarget) String() string

+ type Compare_Value struct

+ Value []byte

+ func (m *Compare_Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Compare_Value) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Compare_Value) SizeVT() (n int)

+ type DeleteRangeRequest struct

+ Count bool

+ Key []byte

+ PrevKv bool

+ RangeEnd []byte

+ Table []byte

+ func (*DeleteRangeRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRangeRequest) ProtoMessage()

+ func (m *DeleteRangeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DeleteRangeRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DeleteRangeRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *DeleteRangeRequest) SizeVT() (n int)

+ func (m *DeleteRangeRequest) UnmarshalVT(dAtA []byte) error

+ func (x *DeleteRangeRequest) GetCount() bool

+ func (x *DeleteRangeRequest) GetKey() []byte

+ func (x *DeleteRangeRequest) GetPrevKv() bool

+ func (x *DeleteRangeRequest) GetRangeEnd() []byte

+ func (x *DeleteRangeRequest) GetTable() []byte

+ func (x *DeleteRangeRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteRangeRequest) Reset()

+ func (x *DeleteRangeRequest) String() string

+ type DeleteRangeResponse struct

+ Deleted int64

+ Header *ResponseHeader

+ PrevKvs []*KeyValue

+ func (*DeleteRangeResponse) Descriptor() ([]byte, []int)

+ func (*DeleteRangeResponse) ProtoMessage()

+ func (m *DeleteRangeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *DeleteRangeResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *DeleteRangeResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *DeleteRangeResponse) SizeVT() (n int)

+ func (m *DeleteRangeResponse) UnmarshalVT(dAtA []byte) error

+ func (x *DeleteRangeResponse) GetDeleted() int64

+ func (x *DeleteRangeResponse) GetHeader() *ResponseHeader

+ func (x *DeleteRangeResponse) GetPrevKvs() []*KeyValue

+ func (x *DeleteRangeResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteRangeResponse) Reset()

+ func (x *DeleteRangeResponse) String() string

+ type KVClient interface

+ DeleteRange func(ctx context.Context, in *DeleteRangeRequest, opts ...grpc.CallOption) (*DeleteRangeResponse, error)

+ Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)

+ Range func(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)

+ Txn func(ctx context.Context, in *TxnRequest, opts ...grpc.CallOption) (*TxnResponse, error)

+ func NewKVClient(cc grpc.ClientConnInterface) KVClient

+ type KVServer interface

+ DeleteRange func(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error)

+ Put func(context.Context, *PutRequest) (*PutResponse, error)

+ Range func(context.Context, *RangeRequest) (*RangeResponse, error)

+ Txn func(context.Context, *TxnRequest) (*TxnResponse, error)

+ type KeyValue struct

+ CreateRevision int64

+ Key []byte

+ ModRevision int64

+ Value []byte

+ func (*KeyValue) Descriptor() ([]byte, []int)

+ func (*KeyValue) ProtoMessage()

+ func (m *KeyValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *KeyValue) MarshalToVT(dAtA []byte) (int, error)

+ func (m *KeyValue) MarshalVT() (dAtA []byte, err error)

+ func (m *KeyValue) SizeVT() (n int)

+ func (m *KeyValue) UnmarshalVT(dAtA []byte) error

+ func (x *KeyValue) GetCreateRevision() int64

+ func (x *KeyValue) GetKey() []byte

+ func (x *KeyValue) GetModRevision() int64

+ func (x *KeyValue) GetValue() []byte

+ func (x *KeyValue) ProtoReflect() protoreflect.Message

+ func (x *KeyValue) Reset()

+ func (x *KeyValue) String() string

+ type LogClient interface

+ Replicate func(ctx context.Context, in *ReplicateRequest, opts ...grpc.CallOption) (Log_ReplicateClient, error)

+ func NewLogClient(cc grpc.ClientConnInterface) LogClient

+ type LogServer interface

+ Replicate func(*ReplicateRequest, Log_ReplicateServer) error

+ type Log_ReplicateClient interface

+ Recv func() (*ReplicateResponse, error)

+ type Log_ReplicateServer interface

+ Send func(*ReplicateResponse) error

+ type MaintenanceClient interface

+ Backup func(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (Maintenance_BackupClient, error)

+ Reset func(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (*ResetResponse, error)

+ Restore func(ctx context.Context, opts ...grpc.CallOption) (Maintenance_RestoreClient, error)

+ func NewMaintenanceClient(cc grpc.ClientConnInterface) MaintenanceClient

+ type MaintenanceServer interface

+ Backup func(*BackupRequest, Maintenance_BackupServer) error

+ Reset func(context.Context, *ResetRequest) (*ResetResponse, error)

+ Restore func(Maintenance_RestoreServer) error

+ type Maintenance_BackupClient interface

+ Recv func() (*SnapshotChunk, error)

+ type Maintenance_BackupServer interface

+ Send func(*SnapshotChunk) error

+ type Maintenance_RestoreClient interface

+ CloseAndRecv func() (*RestoreResponse, error)

+ Send func(*RestoreMessage) error

+ type Maintenance_RestoreServer interface

+ Recv func() (*RestoreMessage, error)

+ SendAndClose func(*RestoreResponse) error

+ type Member struct

+ ClientURLs []string

+ ID uint64

+ Name string

+ PeerURLs []string

+ func (*Member) Descriptor() ([]byte, []int)

+ func (*Member) ProtoMessage()

+ func (m *Member) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Member) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Member) MarshalVT() (dAtA []byte, err error)

+ func (m *Member) SizeVT() (n int)

+ func (m *Member) UnmarshalVT(dAtA []byte) error

+ func (x *Member) GetClientURLs() []string

+ func (x *Member) GetID() uint64

+ func (x *Member) GetName() string

+ func (x *Member) GetPeerURLs() []string

+ func (x *Member) ProtoReflect() protoreflect.Message

+ func (x *Member) Reset()

+ func (x *Member) String() string

+ type MemberListRequest struct

+ Linearizable bool

+ func (*MemberListRequest) Descriptor() ([]byte, []int)

+ func (*MemberListRequest) ProtoMessage()

+ func (m *MemberListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *MemberListRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *MemberListRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *MemberListRequest) SizeVT() (n int)

+ func (m *MemberListRequest) UnmarshalVT(dAtA []byte) error

+ func (x *MemberListRequest) GetLinearizable() bool

+ func (x *MemberListRequest) ProtoReflect() protoreflect.Message

+ func (x *MemberListRequest) Reset()

+ func (x *MemberListRequest) String() string

+ type MemberListResponse struct

+ Header *ResponseHeader

+ Members []*Member

+ func (*MemberListResponse) Descriptor() ([]byte, []int)

+ func (*MemberListResponse) ProtoMessage()

+ func (m *MemberListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *MemberListResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *MemberListResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *MemberListResponse) SizeVT() (n int)

+ func (m *MemberListResponse) UnmarshalVT(dAtA []byte) error

+ func (x *MemberListResponse) GetHeader() *ResponseHeader

+ func (x *MemberListResponse) GetMembers() []*Member

+ func (x *MemberListResponse) ProtoReflect() protoreflect.Message

+ func (x *MemberListResponse) Reset()

+ func (x *MemberListResponse) String() string

+ type MetadataClient interface

+ Get func(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (*MetadataResponse, error)

+ func NewMetadataClient(cc grpc.ClientConnInterface) MetadataClient

+ type MetadataRequest struct

+ func (*MetadataRequest) Descriptor() ([]byte, []int)

+ func (*MetadataRequest) ProtoMessage()

+ func (m *MetadataRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *MetadataRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *MetadataRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *MetadataRequest) SizeVT() (n int)

+ func (m *MetadataRequest) UnmarshalVT(dAtA []byte) error

+ func (x *MetadataRequest) ProtoReflect() protoreflect.Message

+ func (x *MetadataRequest) Reset()

+ func (x *MetadataRequest) String() string

+ type MetadataResponse struct

+ Tables []*Table

+ func (*MetadataResponse) Descriptor() ([]byte, []int)

+ func (*MetadataResponse) ProtoMessage()

+ func (m *MetadataResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *MetadataResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *MetadataResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *MetadataResponse) SizeVT() (n int)

+ func (m *MetadataResponse) UnmarshalVT(dAtA []byte) error

+ func (x *MetadataResponse) GetTables() []*Table

+ func (x *MetadataResponse) ProtoReflect() protoreflect.Message

+ func (x *MetadataResponse) Reset()

+ func (x *MetadataResponse) String() string

+ type MetadataServer interface

+ Get func(context.Context, *MetadataRequest) (*MetadataResponse, error)

+ type PutRequest struct

+ Key []byte

+ PrevKv bool

+ Table []byte

+ Value []byte

+ func (*PutRequest) Descriptor() ([]byte, []int)

+ func (*PutRequest) ProtoMessage()

+ func (m *PutRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PutRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PutRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *PutRequest) SizeVT() (n int)

+ func (m *PutRequest) UnmarshalVT(dAtA []byte) error

+ func (x *PutRequest) GetKey() []byte

+ func (x *PutRequest) GetPrevKv() bool

+ func (x *PutRequest) GetTable() []byte

+ func (x *PutRequest) GetValue() []byte

+ func (x *PutRequest) ProtoReflect() protoreflect.Message

+ func (x *PutRequest) Reset()

+ func (x *PutRequest) String() string

+ type PutResponse struct

+ Header *ResponseHeader

+ PrevKv *KeyValue

+ func (*PutResponse) Descriptor() ([]byte, []int)

+ func (*PutResponse) ProtoMessage()

+ func (m *PutResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PutResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PutResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *PutResponse) SizeVT() (n int)

+ func (m *PutResponse) UnmarshalVT(dAtA []byte) error

+ func (x *PutResponse) GetHeader() *ResponseHeader

+ func (x *PutResponse) GetPrevKv() *KeyValue

+ func (x *PutResponse) ProtoReflect() protoreflect.Message

+ func (x *PutResponse) Reset()

+ func (x *PutResponse) String() string

+ type RangeRequest struct

+ CountOnly bool

+ Key []byte

+ KeysOnly bool

+ Limit int64

+ Linearizable bool

+ MaxCreateRevision int64

+ MaxModRevision int64

+ MinCreateRevision int64

+ MinModRevision int64

+ RangeEnd []byte

+ Table []byte

+ func (*RangeRequest) Descriptor() ([]byte, []int)

+ func (*RangeRequest) ProtoMessage()

+ func (m *RangeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RangeRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RangeRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *RangeRequest) SizeVT() (n int)

+ func (m *RangeRequest) UnmarshalVT(dAtA []byte) error

+ func (x *RangeRequest) GetCountOnly() bool

+ func (x *RangeRequest) GetKey() []byte

+ func (x *RangeRequest) GetKeysOnly() bool

+ func (x *RangeRequest) GetLimit() int64

+ func (x *RangeRequest) GetLinearizable() bool

+ func (x *RangeRequest) GetMaxCreateRevision() int64

+ func (x *RangeRequest) GetMaxModRevision() int64

+ func (x *RangeRequest) GetMinCreateRevision() int64

+ func (x *RangeRequest) GetMinModRevision() int64

+ func (x *RangeRequest) GetRangeEnd() []byte

+ func (x *RangeRequest) GetTable() []byte

+ func (x *RangeRequest) ProtoReflect() protoreflect.Message

+ func (x *RangeRequest) Reset()

+ func (x *RangeRequest) String() string

+ type RangeResponse struct

+ Count int64

+ Header *ResponseHeader

+ Kvs []*KeyValue

+ More bool

+ func (*RangeResponse) Descriptor() ([]byte, []int)

+ func (*RangeResponse) ProtoMessage()

+ func (m *RangeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RangeResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RangeResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *RangeResponse) SizeVT() (n int)

+ func (m *RangeResponse) UnmarshalVT(dAtA []byte) error

+ func (x *RangeResponse) GetCount() int64

+ func (x *RangeResponse) GetHeader() *ResponseHeader

+ func (x *RangeResponse) GetKvs() []*KeyValue

+ func (x *RangeResponse) GetMore() bool

+ func (x *RangeResponse) ProtoReflect() protoreflect.Message

+ func (x *RangeResponse) Reset()

+ func (x *RangeResponse) String() string

+ type ReplicateCommand struct

+ Command *Command

+ LeaderIndex uint64

+ func (*ReplicateCommand) Descriptor() ([]byte, []int)

+ func (*ReplicateCommand) ProtoMessage()

+ func (m *ReplicateCommand) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReplicateCommand) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReplicateCommand) MarshalVT() (dAtA []byte, err error)

+ func (m *ReplicateCommand) SizeVT() (n int)

+ func (m *ReplicateCommand) UnmarshalVT(dAtA []byte) error

+ func (x *ReplicateCommand) GetCommand() *Command

+ func (x *ReplicateCommand) GetLeaderIndex() uint64

+ func (x *ReplicateCommand) ProtoReflect() protoreflect.Message

+ func (x *ReplicateCommand) Reset()

+ func (x *ReplicateCommand) String() string

+ type ReplicateCommandsResponse struct

+ Commands []*ReplicateCommand

+ func (*ReplicateCommandsResponse) Descriptor() ([]byte, []int)

+ func (*ReplicateCommandsResponse) ProtoMessage()

+ func (m *ReplicateCommandsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReplicateCommandsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReplicateCommandsResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ReplicateCommandsResponse) SizeVT() (n int)

+ func (m *ReplicateCommandsResponse) UnmarshalVT(dAtA []byte) error

+ func (x *ReplicateCommandsResponse) GetCommands() []*ReplicateCommand

+ func (x *ReplicateCommandsResponse) ProtoReflect() protoreflect.Message

+ func (x *ReplicateCommandsResponse) Reset()

+ func (x *ReplicateCommandsResponse) String() string

+ type ReplicateErrResponse struct

+ Error ReplicateError

+ func (*ReplicateErrResponse) Descriptor() ([]byte, []int)

+ func (*ReplicateErrResponse) ProtoMessage()

+ func (m *ReplicateErrResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReplicateErrResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReplicateErrResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ReplicateErrResponse) SizeVT() (n int)

+ func (m *ReplicateErrResponse) UnmarshalVT(dAtA []byte) error

+ func (x *ReplicateErrResponse) GetError() ReplicateError

+ func (x *ReplicateErrResponse) ProtoReflect() protoreflect.Message

+ func (x *ReplicateErrResponse) Reset()

+ func (x *ReplicateErrResponse) String() string

+ type ReplicateError int32

+ const ReplicateError_LEADER_BEHIND

+ const ReplicateError_USE_SNAPSHOT

+ func (ReplicateError) Descriptor() protoreflect.EnumDescriptor

+ func (ReplicateError) EnumDescriptor() ([]byte, []int)

+ func (ReplicateError) Type() protoreflect.EnumType

+ func (x ReplicateError) Enum() *ReplicateError

+ func (x ReplicateError) Number() protoreflect.EnumNumber

+ func (x ReplicateError) String() string

+ type ReplicateRequest struct

+ LeaderIndex uint64

+ Table []byte

+ func (*ReplicateRequest) Descriptor() ([]byte, []int)

+ func (*ReplicateRequest) ProtoMessage()

+ func (m *ReplicateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReplicateRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReplicateRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ReplicateRequest) SizeVT() (n int)

+ func (m *ReplicateRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ReplicateRequest) GetLeaderIndex() uint64

+ func (x *ReplicateRequest) GetTable() []byte

+ func (x *ReplicateRequest) ProtoReflect() protoreflect.Message

+ func (x *ReplicateRequest) Reset()

+ func (x *ReplicateRequest) String() string

+ type ReplicateResponse struct

+ LeaderIndex uint64

+ Response isReplicateResponse_Response

+ func (*ReplicateResponse) Descriptor() ([]byte, []int)

+ func (*ReplicateResponse) ProtoMessage()

+ func (m *ReplicateResponse) GetResponse() isReplicateResponse_Response

+ func (m *ReplicateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReplicateResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReplicateResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ReplicateResponse) SizeVT() (n int)

+ func (m *ReplicateResponse) UnmarshalVT(dAtA []byte) error

+ func (x *ReplicateResponse) GetCommandsResponse() *ReplicateCommandsResponse

+ func (x *ReplicateResponse) GetErrorResponse() *ReplicateErrResponse

+ func (x *ReplicateResponse) GetLeaderIndex() uint64

+ func (x *ReplicateResponse) ProtoReflect() protoreflect.Message

+ func (x *ReplicateResponse) Reset()

+ func (x *ReplicateResponse) String() string

+ type ReplicateResponse_CommandsResponse struct

+ CommandsResponse *ReplicateCommandsResponse

+ func (m *ReplicateResponse_CommandsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReplicateResponse_CommandsResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReplicateResponse_CommandsResponse) SizeVT() (n int)

+ type ReplicateResponse_ErrorResponse struct

+ ErrorResponse *ReplicateErrResponse

+ func (m *ReplicateResponse_ErrorResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ReplicateResponse_ErrorResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ReplicateResponse_ErrorResponse) SizeVT() (n int)

+ type RequestOp struct

+ Request isRequestOp_Request

+ func (*RequestOp) Descriptor() ([]byte, []int)

+ func (*RequestOp) ProtoMessage()

+ func (m *RequestOp) GetRequest() isRequestOp_Request

+ func (m *RequestOp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RequestOp) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RequestOp) MarshalVT() (dAtA []byte, err error)

+ func (m *RequestOp) SizeVT() (n int)

+ func (m *RequestOp) UnmarshalVT(dAtA []byte) error

+ func (x *RequestOp) GetRequestDeleteRange() *RequestOp_DeleteRange

+ func (x *RequestOp) GetRequestPut() *RequestOp_Put

+ func (x *RequestOp) GetRequestRange() *RequestOp_Range

+ func (x *RequestOp) ProtoReflect() protoreflect.Message

+ func (x *RequestOp) Reset()

+ func (x *RequestOp) String() string

+ type RequestOp_DeleteRange struct

+ Count bool

+ Key []byte

+ PrevKv bool

+ RangeEnd []byte

+ func (*RequestOp_DeleteRange) Descriptor() ([]byte, []int)

+ func (*RequestOp_DeleteRange) ProtoMessage()

+ func (m *RequestOp_DeleteRange) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RequestOp_DeleteRange) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RequestOp_DeleteRange) MarshalVT() (dAtA []byte, err error)

+ func (m *RequestOp_DeleteRange) SizeVT() (n int)

+ func (m *RequestOp_DeleteRange) UnmarshalVT(dAtA []byte) error

+ func (x *RequestOp_DeleteRange) GetCount() bool

+ func (x *RequestOp_DeleteRange) GetKey() []byte

+ func (x *RequestOp_DeleteRange) GetPrevKv() bool

+ func (x *RequestOp_DeleteRange) GetRangeEnd() []byte

+ func (x *RequestOp_DeleteRange) ProtoReflect() protoreflect.Message

+ func (x *RequestOp_DeleteRange) Reset()

+ func (x *RequestOp_DeleteRange) String() string

+ type RequestOp_Put struct

+ Key []byte

+ PrevKv bool

+ Value []byte

+ func (*RequestOp_Put) Descriptor() ([]byte, []int)

+ func (*RequestOp_Put) ProtoMessage()

+ func (m *RequestOp_Put) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RequestOp_Put) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RequestOp_Put) MarshalVT() (dAtA []byte, err error)

+ func (m *RequestOp_Put) SizeVT() (n int)

+ func (m *RequestOp_Put) UnmarshalVT(dAtA []byte) error

+ func (x *RequestOp_Put) GetKey() []byte

+ func (x *RequestOp_Put) GetPrevKv() bool

+ func (x *RequestOp_Put) GetValue() []byte

+ func (x *RequestOp_Put) ProtoReflect() protoreflect.Message

+ func (x *RequestOp_Put) Reset()

+ func (x *RequestOp_Put) String() string

+ type RequestOp_Range struct

+ CountOnly bool

+ Key []byte

+ KeysOnly bool

+ Limit int64

+ RangeEnd []byte

+ func (*RequestOp_Range) Descriptor() ([]byte, []int)

+ func (*RequestOp_Range) ProtoMessage()

+ func (m *RequestOp_Range) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RequestOp_Range) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RequestOp_Range) MarshalVT() (dAtA []byte, err error)

+ func (m *RequestOp_Range) SizeVT() (n int)

+ func (m *RequestOp_Range) UnmarshalVT(dAtA []byte) error

+ func (x *RequestOp_Range) GetCountOnly() bool

+ func (x *RequestOp_Range) GetKey() []byte

+ func (x *RequestOp_Range) GetKeysOnly() bool

+ func (x *RequestOp_Range) GetLimit() int64

+ func (x *RequestOp_Range) GetRangeEnd() []byte

+ func (x *RequestOp_Range) ProtoReflect() protoreflect.Message

+ func (x *RequestOp_Range) Reset()

+ func (x *RequestOp_Range) String() string

+ type RequestOp_RequestDeleteRange struct

+ RequestDeleteRange *RequestOp_DeleteRange

+ func (m *RequestOp_RequestDeleteRange) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RequestOp_RequestDeleteRange) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RequestOp_RequestDeleteRange) SizeVT() (n int)

+ type RequestOp_RequestPut struct

+ RequestPut *RequestOp_Put

+ func (m *RequestOp_RequestPut) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RequestOp_RequestPut) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RequestOp_RequestPut) SizeVT() (n int)

+ type RequestOp_RequestRange struct

+ RequestRange *RequestOp_Range

+ func (m *RequestOp_RequestRange) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RequestOp_RequestRange) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RequestOp_RequestRange) SizeVT() (n int)

+ type ResetRequest struct

+ ResetAll bool

+ Table []byte

+ func (*ResetRequest) Descriptor() ([]byte, []int)

+ func (*ResetRequest) ProtoMessage()

+ func (m *ResetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResetRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResetRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ResetRequest) SizeVT() (n int)

+ func (m *ResetRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ResetRequest) GetResetAll() bool

+ func (x *ResetRequest) GetTable() []byte

+ func (x *ResetRequest) ProtoReflect() protoreflect.Message

+ func (x *ResetRequest) Reset()

+ func (x *ResetRequest) String() string

+ type ResetResponse struct

+ func (*ResetResponse) Descriptor() ([]byte, []int)

+ func (*ResetResponse) ProtoMessage()

+ func (m *ResetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResetResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResetResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ResetResponse) SizeVT() (n int)

+ func (m *ResetResponse) UnmarshalVT(dAtA []byte) error

+ func (x *ResetResponse) ProtoReflect() protoreflect.Message

+ func (x *ResetResponse) Reset()

+ func (x *ResetResponse) String() string

+ type ResponseHeader struct

+ RaftLeaderId uint64

+ RaftTerm uint64

+ ReplicaId uint64

+ Revision uint64

+ ShardId uint64

+ func (*ResponseHeader) Descriptor() ([]byte, []int)

+ func (*ResponseHeader) ProtoMessage()

+ func (m *ResponseHeader) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResponseHeader) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResponseHeader) MarshalVT() (dAtA []byte, err error)

+ func (m *ResponseHeader) SizeVT() (n int)

+ func (m *ResponseHeader) UnmarshalVT(dAtA []byte) error

+ func (x *ResponseHeader) GetRaftLeaderId() uint64

+ func (x *ResponseHeader) GetRaftTerm() uint64

+ func (x *ResponseHeader) GetReplicaId() uint64

+ func (x *ResponseHeader) GetRevision() uint64

+ func (x *ResponseHeader) GetShardId() uint64

+ func (x *ResponseHeader) ProtoReflect() protoreflect.Message

+ func (x *ResponseHeader) Reset()

+ func (x *ResponseHeader) String() string

+ type ResponseOp struct

+ Response isResponseOp_Response

+ func (*ResponseOp) Descriptor() ([]byte, []int)

+ func (*ResponseOp) ProtoMessage()

+ func (m *ResponseOp) GetResponse() isResponseOp_Response

+ func (m *ResponseOp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResponseOp) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResponseOp) MarshalVT() (dAtA []byte, err error)

+ func (m *ResponseOp) SizeVT() (n int)

+ func (m *ResponseOp) UnmarshalVT(dAtA []byte) error

+ func (x *ResponseOp) GetResponseDeleteRange() *ResponseOp_DeleteRange

+ func (x *ResponseOp) GetResponsePut() *ResponseOp_Put

+ func (x *ResponseOp) GetResponseRange() *ResponseOp_Range

+ func (x *ResponseOp) ProtoReflect() protoreflect.Message

+ func (x *ResponseOp) Reset()

+ func (x *ResponseOp) String() string

+ type ResponseOp_DeleteRange struct

+ Deleted int64

+ PrevKvs []*KeyValue

+ func (*ResponseOp_DeleteRange) Descriptor() ([]byte, []int)

+ func (*ResponseOp_DeleteRange) ProtoMessage()

+ func (m *ResponseOp_DeleteRange) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_DeleteRange) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_DeleteRange) MarshalVT() (dAtA []byte, err error)

+ func (m *ResponseOp_DeleteRange) SizeVT() (n int)

+ func (m *ResponseOp_DeleteRange) UnmarshalVT(dAtA []byte) error

+ func (x *ResponseOp_DeleteRange) GetDeleted() int64

+ func (x *ResponseOp_DeleteRange) GetPrevKvs() []*KeyValue

+ func (x *ResponseOp_DeleteRange) ProtoReflect() protoreflect.Message

+ func (x *ResponseOp_DeleteRange) Reset()

+ func (x *ResponseOp_DeleteRange) String() string

+ type ResponseOp_Put struct

+ PrevKv *KeyValue

+ func (*ResponseOp_Put) Descriptor() ([]byte, []int)

+ func (*ResponseOp_Put) ProtoMessage()

+ func (m *ResponseOp_Put) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_Put) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_Put) MarshalVT() (dAtA []byte, err error)

+ func (m *ResponseOp_Put) SizeVT() (n int)

+ func (m *ResponseOp_Put) UnmarshalVT(dAtA []byte) error

+ func (x *ResponseOp_Put) GetPrevKv() *KeyValue

+ func (x *ResponseOp_Put) ProtoReflect() protoreflect.Message

+ func (x *ResponseOp_Put) Reset()

+ func (x *ResponseOp_Put) String() string

+ type ResponseOp_Range struct

+ Count int64

+ Kvs []*KeyValue

+ More bool

+ func (*ResponseOp_Range) Descriptor() ([]byte, []int)

+ func (*ResponseOp_Range) ProtoMessage()

+ func (m *ResponseOp_Range) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_Range) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_Range) MarshalVT() (dAtA []byte, err error)

+ func (m *ResponseOp_Range) SizeVT() (n int)

+ func (m *ResponseOp_Range) UnmarshalVT(dAtA []byte) error

+ func (x *ResponseOp_Range) GetCount() int64

+ func (x *ResponseOp_Range) GetKvs() []*KeyValue

+ func (x *ResponseOp_Range) GetMore() bool

+ func (x *ResponseOp_Range) ProtoReflect() protoreflect.Message

+ func (x *ResponseOp_Range) Reset()

+ func (x *ResponseOp_Range) String() string

+ type ResponseOp_ResponseDeleteRange struct

+ ResponseDeleteRange *ResponseOp_DeleteRange

+ func (m *ResponseOp_ResponseDeleteRange) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_ResponseDeleteRange) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_ResponseDeleteRange) SizeVT() (n int)

+ type ResponseOp_ResponsePut struct

+ ResponsePut *ResponseOp_Put

+ func (m *ResponseOp_ResponsePut) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_ResponsePut) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_ResponsePut) SizeVT() (n int)

+ type ResponseOp_ResponseRange struct

+ ResponseRange *ResponseOp_Range

+ func (m *ResponseOp_ResponseRange) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_ResponseRange) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ResponseOp_ResponseRange) SizeVT() (n int)

+ type RestoreInfo struct

+ Table []byte

+ func (*RestoreInfo) Descriptor() ([]byte, []int)

+ func (*RestoreInfo) ProtoMessage()

+ func (m *RestoreInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RestoreInfo) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RestoreInfo) MarshalVT() (dAtA []byte, err error)

+ func (m *RestoreInfo) SizeVT() (n int)

+ func (m *RestoreInfo) UnmarshalVT(dAtA []byte) error

+ func (x *RestoreInfo) GetTable() []byte

+ func (x *RestoreInfo) ProtoReflect() protoreflect.Message

+ func (x *RestoreInfo) Reset()

+ func (x *RestoreInfo) String() string

+ type RestoreMessage struct

+ Data isRestoreMessage_Data

+ func (*RestoreMessage) Descriptor() ([]byte, []int)

+ func (*RestoreMessage) ProtoMessage()

+ func (m *RestoreMessage) GetData() isRestoreMessage_Data

+ func (m *RestoreMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RestoreMessage) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RestoreMessage) MarshalVT() (dAtA []byte, err error)

+ func (m *RestoreMessage) SizeVT() (n int)

+ func (m *RestoreMessage) UnmarshalVT(dAtA []byte) error

+ func (x *RestoreMessage) GetChunk() *SnapshotChunk

+ func (x *RestoreMessage) GetInfo() *RestoreInfo

+ func (x *RestoreMessage) ProtoReflect() protoreflect.Message

+ func (x *RestoreMessage) Reset()

+ func (x *RestoreMessage) String() string

+ type RestoreMessage_Chunk struct

+ Chunk *SnapshotChunk

+ func (m *RestoreMessage_Chunk) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RestoreMessage_Chunk) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RestoreMessage_Chunk) SizeVT() (n int)

+ type RestoreMessage_Info struct

+ Info *RestoreInfo

+ func (m *RestoreMessage_Info) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RestoreMessage_Info) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RestoreMessage_Info) SizeVT() (n int)

+ type RestoreResponse struct

+ func (*RestoreResponse) Descriptor() ([]byte, []int)

+ func (*RestoreResponse) ProtoMessage()

+ func (m *RestoreResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RestoreResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RestoreResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *RestoreResponse) SizeVT() (n int)

+ func (m *RestoreResponse) UnmarshalVT(dAtA []byte) error

+ func (x *RestoreResponse) ProtoReflect() protoreflect.Message

+ func (x *RestoreResponse) Reset()

+ func (x *RestoreResponse) String() string

+ type ShardStatus struct

+ DbSize int64

+ Id uint64

+ Leader uint64

+ RaftAppliedIndex uint64

+ RaftIndex uint64

+ RaftTerm uint64

+ Table []byte

+ func (*ShardStatus) Descriptor() ([]byte, []int)

+ func (*ShardStatus) ProtoMessage()

+ func (m *ShardStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ShardStatus) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ShardStatus) MarshalVT() (dAtA []byte, err error)

+ func (m *ShardStatus) SizeVT() (n int)

+ func (m *ShardStatus) UnmarshalVT(dAtA []byte) error

+ func (x *ShardStatus) GetDbSize() int64

+ func (x *ShardStatus) GetId() uint64

+ func (x *ShardStatus) GetLeader() uint64

+ func (x *ShardStatus) GetRaftAppliedIndex() uint64

+ func (x *ShardStatus) GetRaftIndex() uint64

+ func (x *ShardStatus) GetRaftTerm() uint64

+ func (x *ShardStatus) GetTable() []byte

+ func (x *ShardStatus) ProtoReflect() protoreflect.Message

+ func (x *ShardStatus) Reset()

+ func (x *ShardStatus) String() string

+ type SnapshotChunk struct

+ Data []byte

+ Index uint64

+ Len uint64

+ func SnapshotChunkFromVTPool() *SnapshotChunk

+ func (*SnapshotChunk) Descriptor() ([]byte, []int)

+ func (*SnapshotChunk) ProtoMessage()

+ func (m *SnapshotChunk) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SnapshotChunk) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SnapshotChunk) MarshalVT() (dAtA []byte, err error)

+ func (m *SnapshotChunk) ResetVT()

+ func (m *SnapshotChunk) ReturnToVTPool()

+ func (m *SnapshotChunk) SizeVT() (n int)

+ func (m *SnapshotChunk) UnmarshalVT(dAtA []byte) error

+ func (x *SnapshotChunk) GetData() []byte

+ func (x *SnapshotChunk) GetIndex() uint64

+ func (x *SnapshotChunk) GetLen() uint64

+ func (x *SnapshotChunk) ProtoReflect() protoreflect.Message

+ func (x *SnapshotChunk) Reset()

+ func (x *SnapshotChunk) String() string

+ type SnapshotClient interface

+ Stream func(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (Snapshot_StreamClient, error)

+ func NewSnapshotClient(cc grpc.ClientConnInterface) SnapshotClient

+ type SnapshotRequest struct

+ Table []byte

+ func (*SnapshotRequest) Descriptor() ([]byte, []int)

+ func (*SnapshotRequest) ProtoMessage()

+ func (m *SnapshotRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SnapshotRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SnapshotRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *SnapshotRequest) SizeVT() (n int)

+ func (m *SnapshotRequest) UnmarshalVT(dAtA []byte) error

+ func (x *SnapshotRequest) GetTable() []byte

+ func (x *SnapshotRequest) ProtoReflect() protoreflect.Message

+ func (x *SnapshotRequest) Reset()

+ func (x *SnapshotRequest) String() string

+ type SnapshotServer interface

+ Stream func(*SnapshotRequest, Snapshot_StreamServer) error

+ type Snapshot_StreamClient interface

+ Recv func() (*SnapshotChunk, error)

+ type Snapshot_StreamServer interface

+ Send func(*SnapshotChunk) error

+ type StatusRequest struct

+ func (*StatusRequest) Descriptor() ([]byte, []int)

+ func (*StatusRequest) ProtoMessage()

+ func (m *StatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *StatusRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *StatusRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *StatusRequest) SizeVT() (n int)

+ func (m *StatusRequest) UnmarshalVT(dAtA []byte) error

+ func (x *StatusRequest) ProtoReflect() protoreflect.Message

+ func (x *StatusRequest) Reset()

+ func (x *StatusRequest) String() string

+ type StatusResponse struct

+ Errors []string

+ Shards []*ShardStatus

+ Version string

+ func (*StatusResponse) Descriptor() ([]byte, []int)

+ func (*StatusResponse) ProtoMessage()

+ func (m *StatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *StatusResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *StatusResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *StatusResponse) SizeVT() (n int)

+ func (m *StatusResponse) UnmarshalVT(dAtA []byte) error

+ func (x *StatusResponse) GetErrors() []string

+ func (x *StatusResponse) GetShards() []*ShardStatus

+ func (x *StatusResponse) GetVersion() string

+ func (x *StatusResponse) ProtoReflect() protoreflect.Message

+ func (x *StatusResponse) Reset()

+ func (x *StatusResponse) String() string

+ type Table struct

+ Name string

+ Type Table_Type

+ func (*Table) Descriptor() ([]byte, []int)

+ func (*Table) ProtoMessage()

+ func (m *Table) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Table) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Table) MarshalVT() (dAtA []byte, err error)

+ func (m *Table) SizeVT() (n int)

+ func (m *Table) UnmarshalVT(dAtA []byte) error

+ func (x *Table) GetName() string

+ func (x *Table) GetType() Table_Type

+ func (x *Table) ProtoReflect() protoreflect.Message

+ func (x *Table) Reset()

+ func (x *Table) String() string

+ type Table_Type int32

+ const Table_LOCAL

+ const Table_REPLICATED

+ func (Table_Type) Descriptor() protoreflect.EnumDescriptor

+ func (Table_Type) EnumDescriptor() ([]byte, []int)

+ func (Table_Type) Type() protoreflect.EnumType

+ func (x Table_Type) Enum() *Table_Type

+ func (x Table_Type) Number() protoreflect.EnumNumber

+ func (x Table_Type) String() string

+ type Txn struct

+ Compare []*Compare

+ Failure []*RequestOp

+ Success []*RequestOp

+ func (*Txn) Descriptor() ([]byte, []int)

+ func (*Txn) ProtoMessage()

+ func (m *Txn) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Txn) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Txn) MarshalVT() (dAtA []byte, err error)

+ func (m *Txn) SizeVT() (n int)

+ func (m *Txn) UnmarshalVT(dAtA []byte) error

+ func (x *Txn) GetCompare() []*Compare

+ func (x *Txn) GetFailure() []*RequestOp

+ func (x *Txn) GetSuccess() []*RequestOp

+ func (x *Txn) ProtoReflect() protoreflect.Message

+ func (x *Txn) Reset()

+ func (x *Txn) String() string

+ type TxnRequest struct

+ Compare []*Compare

+ Failure []*RequestOp

+ Success []*RequestOp

+ Table []byte

+ func (*TxnRequest) Descriptor() ([]byte, []int)

+ func (*TxnRequest) ProtoMessage()

+ func (m *TxnRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TxnRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TxnRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *TxnRequest) SizeVT() (n int)

+ func (m *TxnRequest) UnmarshalVT(dAtA []byte) error

+ func (x *TxnRequest) GetCompare() []*Compare

+ func (x *TxnRequest) GetFailure() []*RequestOp

+ func (x *TxnRequest) GetSuccess() []*RequestOp

+ func (x *TxnRequest) GetTable() []byte

+ func (x *TxnRequest) ProtoReflect() protoreflect.Message

+ func (x *TxnRequest) Reset()

+ func (x *TxnRequest) String() string

+ type TxnResponse struct

+ Header *ResponseHeader

+ Responses []*ResponseOp

+ Succeeded bool

+ func (*TxnResponse) Descriptor() ([]byte, []int)

+ func (*TxnResponse) ProtoMessage()

+ func (m *TxnResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TxnResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TxnResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *TxnResponse) SizeVT() (n int)

+ func (m *TxnResponse) UnmarshalVT(dAtA []byte) error

+ func (x *TxnResponse) GetHeader() *ResponseHeader

+ func (x *TxnResponse) GetResponses() []*ResponseOp

+ func (x *TxnResponse) GetSucceeded() bool

+ func (x *TxnResponse) ProtoReflect() protoreflect.Message

+ func (x *TxnResponse) Reset()

+ func (x *TxnResponse) String() string

+ type UnimplementedClusterServer struct

+ func (UnimplementedClusterServer) MemberList(context.Context, *MemberListRequest) (*MemberListResponse, error)

+ func (UnimplementedClusterServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

+ type UnimplementedKVServer struct

+ func (UnimplementedKVServer) DeleteRange(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error)

+ func (UnimplementedKVServer) Put(context.Context, *PutRequest) (*PutResponse, error)

+ func (UnimplementedKVServer) Range(context.Context, *RangeRequest) (*RangeResponse, error)

+ func (UnimplementedKVServer) Txn(context.Context, *TxnRequest) (*TxnResponse, error)

+ type UnimplementedLogServer struct

+ func (UnimplementedLogServer) Replicate(*ReplicateRequest, Log_ReplicateServer) error

+ type UnimplementedMaintenanceServer struct

+ func (UnimplementedMaintenanceServer) Backup(*BackupRequest, Maintenance_BackupServer) error

+ func (UnimplementedMaintenanceServer) Reset(context.Context, *ResetRequest) (*ResetResponse, error)

+ func (UnimplementedMaintenanceServer) Restore(Maintenance_RestoreServer) error

+ type UnimplementedMetadataServer struct

+ func (UnimplementedMetadataServer) Get(context.Context, *MetadataRequest) (*MetadataResponse, error)

+ type UnimplementedSnapshotServer struct

+ func (UnimplementedSnapshotServer) Stream(*SnapshotRequest, Snapshot_StreamServer) error

+ type UnsafeClusterServer interface

+ type UnsafeKVServer interface

+ type UnsafeLogServer interface

+ type UnsafeMaintenanceServer interface

+ type UnsafeMetadataServer interface

+ type UnsafeSnapshotServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL