Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowEnginepb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEnginepb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupEnginepb = fmt.Errorf("proto: unexpected end of group") + func RegisterEngineServer(s *grpc.Server, srv EngineServer) + type CommandRequest struct + AdminRequest *raft_cmdpb.AdminRequest + AdminResponse *raft_cmdpb.AdminResponse + Header *CommandRequestHeader + Requests []*raft_cmdpb.Request + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandRequest) Descriptor() ([]byte, []int) + func (*CommandRequest) ProtoMessage() + func (m *CommandRequest) GetAdminRequest() *raft_cmdpb.AdminRequest + func (m *CommandRequest) GetAdminResponse() *raft_cmdpb.AdminResponse + func (m *CommandRequest) GetHeader() *CommandRequestHeader + func (m *CommandRequest) GetRequests() []*raft_cmdpb.Request + func (m *CommandRequest) Marshal() (dAtA []byte, err error) + func (m *CommandRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandRequest) Reset() + func (m *CommandRequest) Size() (n int) + func (m *CommandRequest) String() string + func (m *CommandRequest) Unmarshal(dAtA []byte) error + func (m *CommandRequest) XXX_DiscardUnknown() + func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandRequest) XXX_Merge(src proto.Message) + func (m *CommandRequest) XXX_Size() int + func (m *CommandRequest) XXX_Unmarshal(b []byte) error + type CommandRequestBatch struct + Requests []*CommandRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandRequestBatch) Descriptor() ([]byte, []int) + func (*CommandRequestBatch) ProtoMessage() + func (m *CommandRequestBatch) GetRequests() []*CommandRequest + func (m *CommandRequestBatch) Marshal() (dAtA []byte, err error) + func (m *CommandRequestBatch) MarshalTo(dAtA []byte) (int, error) + func (m *CommandRequestBatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandRequestBatch) Reset() + func (m *CommandRequestBatch) Size() (n int) + func (m *CommandRequestBatch) String() string + func (m *CommandRequestBatch) Unmarshal(dAtA []byte) error + func (m *CommandRequestBatch) XXX_DiscardUnknown() + func (m *CommandRequestBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandRequestBatch) XXX_Merge(src proto.Message) + func (m *CommandRequestBatch) XXX_Size() int + func (m *CommandRequestBatch) XXX_Unmarshal(b []byte) error + type CommandRequestHeader struct + Context []byte + Destroy bool + Index uint64 + RegionId uint64 + SyncLog bool + Term uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandRequestHeader) Descriptor() ([]byte, []int) + func (*CommandRequestHeader) ProtoMessage() + func (m *CommandRequestHeader) GetContext() []byte + func (m *CommandRequestHeader) GetDestroy() bool + func (m *CommandRequestHeader) GetIndex() uint64 + func (m *CommandRequestHeader) GetRegionId() uint64 + func (m *CommandRequestHeader) GetSyncLog() bool + func (m *CommandRequestHeader) GetTerm() uint64 + func (m *CommandRequestHeader) Marshal() (dAtA []byte, err error) + func (m *CommandRequestHeader) MarshalTo(dAtA []byte) (int, error) + func (m *CommandRequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandRequestHeader) Reset() + func (m *CommandRequestHeader) Size() (n int) + func (m *CommandRequestHeader) String() string + func (m *CommandRequestHeader) Unmarshal(dAtA []byte) error + func (m *CommandRequestHeader) XXX_DiscardUnknown() + func (m *CommandRequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandRequestHeader) XXX_Merge(src proto.Message) + func (m *CommandRequestHeader) XXX_Size() int + func (m *CommandRequestHeader) XXX_Unmarshal(b []byte) error + type CommandResponse struct + AppliedTerm uint64 + ApplyState *raft_serverpb.RaftApplyState + Header *CommandResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandResponse) Descriptor() ([]byte, []int) + func (*CommandResponse) ProtoMessage() + func (m *CommandResponse) GetAppliedTerm() uint64 + func (m *CommandResponse) GetApplyState() *raft_serverpb.RaftApplyState + func (m *CommandResponse) GetHeader() *CommandResponseHeader + func (m *CommandResponse) Marshal() (dAtA []byte, err error) + func (m *CommandResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandResponse) Reset() + func (m *CommandResponse) Size() (n int) + func (m *CommandResponse) String() string + func (m *CommandResponse) Unmarshal(dAtA []byte) error + func (m *CommandResponse) XXX_DiscardUnknown() + func (m *CommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandResponse) XXX_Merge(src proto.Message) + func (m *CommandResponse) XXX_Size() int + func (m *CommandResponse) XXX_Unmarshal(b []byte) error + type CommandResponseBatch struct + Responses []*CommandResponse + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandResponseBatch) Descriptor() ([]byte, []int) + func (*CommandResponseBatch) ProtoMessage() + func (m *CommandResponseBatch) GetResponses() []*CommandResponse + func (m *CommandResponseBatch) Marshal() (dAtA []byte, err error) + func (m *CommandResponseBatch) MarshalTo(dAtA []byte) (int, error) + func (m *CommandResponseBatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandResponseBatch) Reset() + func (m *CommandResponseBatch) Size() (n int) + func (m *CommandResponseBatch) String() string + func (m *CommandResponseBatch) Unmarshal(dAtA []byte) error + func (m *CommandResponseBatch) XXX_DiscardUnknown() + func (m *CommandResponseBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandResponseBatch) XXX_Merge(src proto.Message) + func (m *CommandResponseBatch) XXX_Size() int + func (m *CommandResponseBatch) XXX_Unmarshal(b []byte) error + type CommandResponseHeader struct + Destroyed bool + RegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommandResponseHeader) Descriptor() ([]byte, []int) + func (*CommandResponseHeader) ProtoMessage() + func (m *CommandResponseHeader) GetDestroyed() bool + func (m *CommandResponseHeader) GetRegionId() uint64 + func (m *CommandResponseHeader) Marshal() (dAtA []byte, err error) + func (m *CommandResponseHeader) MarshalTo(dAtA []byte) (int, error) + func (m *CommandResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CommandResponseHeader) Reset() + func (m *CommandResponseHeader) Size() (n int) + func (m *CommandResponseHeader) String() string + func (m *CommandResponseHeader) Unmarshal(dAtA []byte) error + func (m *CommandResponseHeader) XXX_DiscardUnknown() + func (m *CommandResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommandResponseHeader) XXX_Merge(src proto.Message) + func (m *CommandResponseHeader) XXX_Size() int + func (m *CommandResponseHeader) XXX_Unmarshal(b []byte) error + type EngineClient interface + ApplyCommandBatch func(ctx context.Context, opts ...grpc.CallOption) (Engine_ApplyCommandBatchClient, error) + ApplySnapshot func(ctx context.Context, opts ...grpc.CallOption) (Engine_ApplySnapshotClient, error) + func NewEngineClient(cc *grpc.ClientConn) EngineClient + type EngineServer interface + ApplyCommandBatch func(Engine_ApplyCommandBatchServer) error + ApplySnapshot func(Engine_ApplySnapshotServer) error + type Engine_ApplyCommandBatchClient interface + Recv func() (*CommandResponseBatch, error) + Send func(*CommandRequestBatch) error + type Engine_ApplyCommandBatchServer interface + Recv func() (*CommandRequestBatch, error) + Send func(*CommandResponseBatch) error + type Engine_ApplySnapshotClient interface + CloseAndRecv func() (*SnapshotDone, error) + Send func(*SnapshotRequest) error + type Engine_ApplySnapshotServer interface + Recv func() (*SnapshotRequest, error) + SendAndClose func(*SnapshotDone) error + type SnapshotData struct + Cf string + Checksum uint32 + Data []*raft_serverpb.KeyValue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotData) Descriptor() ([]byte, []int) + func (*SnapshotData) ProtoMessage() + func (m *SnapshotData) GetCf() string + func (m *SnapshotData) GetChecksum() uint32 + func (m *SnapshotData) GetData() []*raft_serverpb.KeyValue + func (m *SnapshotData) Marshal() (dAtA []byte, err error) + func (m *SnapshotData) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotData) Reset() + func (m *SnapshotData) Size() (n int) + func (m *SnapshotData) String() string + func (m *SnapshotData) Unmarshal(dAtA []byte) error + func (m *SnapshotData) XXX_DiscardUnknown() + func (m *SnapshotData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotData) XXX_Merge(src proto.Message) + func (m *SnapshotData) XXX_Size() int + func (m *SnapshotData) XXX_Unmarshal(b []byte) error + type SnapshotDone struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotDone) Descriptor() ([]byte, []int) + func (*SnapshotDone) ProtoMessage() + func (m *SnapshotDone) Marshal() (dAtA []byte, err error) + func (m *SnapshotDone) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotDone) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotDone) Reset() + func (m *SnapshotDone) Size() (n int) + func (m *SnapshotDone) String() string + func (m *SnapshotDone) Unmarshal(dAtA []byte) error + func (m *SnapshotDone) XXX_DiscardUnknown() + func (m *SnapshotDone) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotDone) XXX_Merge(src proto.Message) + func (m *SnapshotDone) XXX_Size() int + func (m *SnapshotDone) XXX_Unmarshal(b []byte) error + type SnapshotRequest struct + Chunk isSnapshotRequest_Chunk + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotRequest) Descriptor() ([]byte, []int) + func (*SnapshotRequest) ProtoMessage() + func (*SnapshotRequest) XXX_OneofWrappers() []interface{} + func (m *SnapshotRequest) GetChunk() isSnapshotRequest_Chunk + func (m *SnapshotRequest) GetData() *SnapshotData + func (m *SnapshotRequest) GetState() *SnapshotState + func (m *SnapshotRequest) Marshal() (dAtA []byte, err error) + func (m *SnapshotRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotRequest) Reset() + func (m *SnapshotRequest) Size() (n int) + func (m *SnapshotRequest) String() string + func (m *SnapshotRequest) Unmarshal(dAtA []byte) error + func (m *SnapshotRequest) XXX_DiscardUnknown() + func (m *SnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotRequest) XXX_Merge(src proto.Message) + func (m *SnapshotRequest) XXX_Size() int + func (m *SnapshotRequest) XXX_Unmarshal(b []byte) error + type SnapshotRequest_Data struct + Data *SnapshotData + func (m *SnapshotRequest_Data) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotRequest_Data) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotRequest_Data) Size() (n int) + type SnapshotRequest_State struct + State *SnapshotState + func (m *SnapshotRequest_State) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotRequest_State) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotRequest_State) Size() (n int) + type SnapshotState struct + ApplyState *raft_serverpb.RaftApplyState + Peer *metapb.Peer + Region *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotState) Descriptor() ([]byte, []int) + func (*SnapshotState) ProtoMessage() + func (m *SnapshotState) GetApplyState() *raft_serverpb.RaftApplyState + func (m *SnapshotState) GetPeer() *metapb.Peer + func (m *SnapshotState) GetRegion() *metapb.Region + func (m *SnapshotState) Marshal() (dAtA []byte, err error) + func (m *SnapshotState) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotState) Reset() + func (m *SnapshotState) Size() (n int) + func (m *SnapshotState) String() string + func (m *SnapshotState) Unmarshal(dAtA []byte) error + func (m *SnapshotState) XXX_DiscardUnknown() + func (m *SnapshotState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotState) XXX_Merge(src proto.Message) + func (m *SnapshotState) XXX_Size() int + func (m *SnapshotState) XXX_Unmarshal(b []byte) error + type UnimplementedEngineServer struct + func (*UnimplementedEngineServer) ApplyCommandBatch(srv Engine_ApplyCommandBatchServer) error + func (*UnimplementedEngineServer) ApplySnapshot(srv Engine_ApplySnapshotServer) error