enginepb

package
v0.1.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEnginepb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEnginepb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEnginepb = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterEngineServer 

func RegisterEngineServer(s *grpc.Server, srv EngineServer)

Types

type CommandRequest 

type CommandRequest struct {
	Header *CommandRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// kv put / delete
	Requests []*raft_cmdpb.Request `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	// region metadata manipulation command.
	AdminRequest *raft_cmdpb.AdminRequest `protobuf:"bytes,3,opt,name=admin_request,json=adminRequest,proto3" json:"admin_request,omitempty"`
	// region metadata manipulation result.
	AdminResponse        *raft_cmdpb.AdminResponse `protobuf:"bytes,4,opt,name=admin_response,json=adminResponse,proto3" json:"admin_response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*CommandRequest) Descriptor 

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

func (*CommandRequest) GetAdminRequest 

func (m *CommandRequest) GetAdminRequest() *raft_cmdpb.AdminRequest

func (*CommandRequest) GetAdminResponse 

func (m *CommandRequest) GetAdminResponse() *raft_cmdpb.AdminResponse

func (*CommandRequest) GetHeader 

func (m *CommandRequest) GetHeader() *CommandRequestHeader

func (*CommandRequest) GetRequests 

func (m *CommandRequest) GetRequests() []*raft_cmdpb.Request

func (*CommandRequest) Marshal 

func (m *CommandRequest) Marshal() (dAtA []byte, err error)

func (*CommandRequest) MarshalTo 

func (m *CommandRequest) MarshalTo(dAtA []byte) (int, error)

func (*CommandRequest) MarshalToSizedBuffer 

func (m *CommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandRequest) ProtoMessage 

func (*CommandRequest) ProtoMessage()

func (*CommandRequest) Reset 

func (m *CommandRequest) Reset()

func (*CommandRequest) Size 

func (m *CommandRequest) Size() (n int)

func (*CommandRequest) String 

func (m *CommandRequest) String() string

func (*CommandRequest) Unmarshal 

func (m *CommandRequest) Unmarshal(dAtA []byte) error

func (*CommandRequest) XXX_DiscardUnknown 

func (m *CommandRequest) XXX_DiscardUnknown()

func (*CommandRequest) XXX_Marshal 

func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandRequest) XXX_Merge 

func (m *CommandRequest) XXX_Merge(src proto.Message)

func (*CommandRequest) XXX_Size 

func (m *CommandRequest) XXX_Size() int

func (*CommandRequest) XXX_Unmarshal 

func (m *CommandRequest) XXX_Unmarshal(b []byte) error

type CommandRequestBatch 

type CommandRequestBatch struct {
	Requests             []*CommandRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CommandRequestBatch) Descriptor 

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

func (*CommandRequestBatch) GetRequests 

func (m *CommandRequestBatch) GetRequests() []*CommandRequest

func (*CommandRequestBatch) Marshal 

func (m *CommandRequestBatch) Marshal() (dAtA []byte, err error)

func (*CommandRequestBatch) MarshalTo 

func (m *CommandRequestBatch) MarshalTo(dAtA []byte) (int, error)

func (*CommandRequestBatch) MarshalToSizedBuffer 

func (m *CommandRequestBatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandRequestBatch) ProtoMessage 

func (*CommandRequestBatch) ProtoMessage()

func (*CommandRequestBatch) Reset 

func (m *CommandRequestBatch) Reset()

func (*CommandRequestBatch) Size 

func (m *CommandRequestBatch) Size() (n int)

func (*CommandRequestBatch) String 

func (m *CommandRequestBatch) String() string

func (*CommandRequestBatch) Unmarshal 

func (m *CommandRequestBatch) Unmarshal(dAtA []byte) error

func (*CommandRequestBatch) XXX_DiscardUnknown 

func (m *CommandRequestBatch) XXX_DiscardUnknown()

func (*CommandRequestBatch) XXX_Marshal 

func (m *CommandRequestBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandRequestBatch) XXX_Merge 

func (m *CommandRequestBatch) XXX_Merge(src proto.Message)

func (*CommandRequestBatch) XXX_Size 

func (m *CommandRequestBatch) XXX_Size() int

func (*CommandRequestBatch) XXX_Unmarshal 

func (m *CommandRequestBatch) XXX_Unmarshal(b []byte) error

type CommandRequestHeader 

type CommandRequestHeader struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Index    uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Term     uint64 `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	// Flush in-memory data to disk.
	SyncLog bool `protobuf:"varint,4,opt,name=sync_log,json=syncLog,proto3" json:"sync_log,omitempty"`
	// Destroy the region.
	Destroy bool `protobuf:"varint,5,opt,name=destroy,proto3" json:"destroy,omitempty"`
	// Additional information for the request.
	Context              []byte   `protobuf:"bytes,6,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandRequestHeader) Descriptor 

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

func (*CommandRequestHeader) GetContext 

func (m *CommandRequestHeader) GetContext() []byte

func (*CommandRequestHeader) GetDestroy 

func (m *CommandRequestHeader) GetDestroy() bool

func (*CommandRequestHeader) GetIndex 

func (m *CommandRequestHeader) GetIndex() uint64

func (*CommandRequestHeader) GetRegionId 

func (m *CommandRequestHeader) GetRegionId() uint64

func (*CommandRequestHeader) GetSyncLog 

func (m *CommandRequestHeader) GetSyncLog() bool

func (*CommandRequestHeader) GetTerm 

func (m *CommandRequestHeader) GetTerm() uint64

func (*CommandRequestHeader) Marshal 

func (m *CommandRequestHeader) Marshal() (dAtA []byte, err error)

func (*CommandRequestHeader) MarshalTo 

func (m *CommandRequestHeader) MarshalTo(dAtA []byte) (int, error)

func (*CommandRequestHeader) MarshalToSizedBuffer 

func (m *CommandRequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandRequestHeader) ProtoMessage 

func (*CommandRequestHeader) ProtoMessage()

func (*CommandRequestHeader) Reset 

func (m *CommandRequestHeader) Reset()

func (*CommandRequestHeader) Size 

func (m *CommandRequestHeader) Size() (n int)

func (*CommandRequestHeader) String 

func (m *CommandRequestHeader) String() string

func (*CommandRequestHeader) Unmarshal 

func (m *CommandRequestHeader) Unmarshal(dAtA []byte) error

func (*CommandRequestHeader) XXX_DiscardUnknown 

func (m *CommandRequestHeader) XXX_DiscardUnknown()

func (*CommandRequestHeader) XXX_Marshal 

func (m *CommandRequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandRequestHeader) XXX_Merge 

func (m *CommandRequestHeader) XXX_Merge(src proto.Message)

func (*CommandRequestHeader) XXX_Size 

func (m *CommandRequestHeader) XXX_Size() int

func (*CommandRequestHeader) XXX_Unmarshal 

func (m *CommandRequestHeader) XXX_Unmarshal(b []byte) error

type CommandResponse 

type CommandResponse struct {
	Header               *CommandResponseHeader        `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ApplyState           *raft_serverpb.RaftApplyState `protobuf:"bytes,2,opt,name=apply_state,json=applyState,proto3" json:"apply_state,omitempty"`
	AppliedTerm          uint64                        `protobuf:"varint,3,opt,name=applied_term,json=appliedTerm,proto3" json:"applied_term,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*CommandResponse) Descriptor 

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

func (*CommandResponse) GetAppliedTerm 

func (m *CommandResponse) GetAppliedTerm() uint64

func (*CommandResponse) GetApplyState 

func (m *CommandResponse) GetApplyState() *raft_serverpb.RaftApplyState

func (*CommandResponse) GetHeader 

func (m *CommandResponse) GetHeader() *CommandResponseHeader

func (*CommandResponse) Marshal 

func (m *CommandResponse) Marshal() (dAtA []byte, err error)

func (*CommandResponse) MarshalTo 

func (m *CommandResponse) MarshalTo(dAtA []byte) (int, error)

func (*CommandResponse) MarshalToSizedBuffer 

func (m *CommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandResponse) ProtoMessage 

func (*CommandResponse) ProtoMessage()

func (*CommandResponse) Reset 

func (m *CommandResponse) Reset()

func (*CommandResponse) Size 

func (m *CommandResponse) Size() (n int)

func (*CommandResponse) String 

func (m *CommandResponse) String() string

func (*CommandResponse) Unmarshal 

func (m *CommandResponse) Unmarshal(dAtA []byte) error

func (*CommandResponse) XXX_DiscardUnknown 

func (m *CommandResponse) XXX_DiscardUnknown()

func (*CommandResponse) XXX_Marshal 

func (m *CommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandResponse) XXX_Merge 

func (m *CommandResponse) XXX_Merge(src proto.Message)

func (*CommandResponse) XXX_Size 

func (m *CommandResponse) XXX_Size() int

func (*CommandResponse) XXX_Unmarshal 

func (m *CommandResponse) XXX_Unmarshal(b []byte) error

type CommandResponseBatch 

type CommandResponseBatch struct {
	Responses            []*CommandResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*CommandResponseBatch) Descriptor 

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

func (*CommandResponseBatch) GetResponses 

func (m *CommandResponseBatch) GetResponses() []*CommandResponse

func (*CommandResponseBatch) Marshal 

func (m *CommandResponseBatch) Marshal() (dAtA []byte, err error)

func (*CommandResponseBatch) MarshalTo 

func (m *CommandResponseBatch) MarshalTo(dAtA []byte) (int, error)

func (*CommandResponseBatch) MarshalToSizedBuffer 

func (m *CommandResponseBatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandResponseBatch) ProtoMessage 

func (*CommandResponseBatch) ProtoMessage()

func (*CommandResponseBatch) Reset 

func (m *CommandResponseBatch) Reset()

func (*CommandResponseBatch) Size 

func (m *CommandResponseBatch) Size() (n int)

func (*CommandResponseBatch) String 

func (m *CommandResponseBatch) String() string

func (*CommandResponseBatch) Unmarshal 

func (m *CommandResponseBatch) Unmarshal(dAtA []byte) error

func (*CommandResponseBatch) XXX_DiscardUnknown 

func (m *CommandResponseBatch) XXX_DiscardUnknown()

func (*CommandResponseBatch) XXX_Marshal 

func (m *CommandResponseBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandResponseBatch) XXX_Merge 

func (m *CommandResponseBatch) XXX_Merge(src proto.Message)

func (*CommandResponseBatch) XXX_Size 

func (m *CommandResponseBatch) XXX_Size() int

func (*CommandResponseBatch) XXX_Unmarshal 

func (m *CommandResponseBatch) XXX_Unmarshal(b []byte) error

type CommandResponseHeader 

type CommandResponseHeader struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// Region is destroyed.
	Destroyed            bool     `protobuf:"varint,2,opt,name=destroyed,proto3" json:"destroyed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandResponseHeader) Descriptor 

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

func (*CommandResponseHeader) GetDestroyed 

func (m *CommandResponseHeader) GetDestroyed() bool

func (*CommandResponseHeader) GetRegionId 

func (m *CommandResponseHeader) GetRegionId() uint64

func (*CommandResponseHeader) Marshal 

func (m *CommandResponseHeader) Marshal() (dAtA []byte, err error)

func (*CommandResponseHeader) MarshalTo 

func (m *CommandResponseHeader) MarshalTo(dAtA []byte) (int, error)

func (*CommandResponseHeader) MarshalToSizedBuffer 

func (m *CommandResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommandResponseHeader) ProtoMessage 

func (*CommandResponseHeader) ProtoMessage()

func (*CommandResponseHeader) Reset 

func (m *CommandResponseHeader) Reset()

func (*CommandResponseHeader) Size 

func (m *CommandResponseHeader) Size() (n int)

func (*CommandResponseHeader) String 

func (m *CommandResponseHeader) String() string

func (*CommandResponseHeader) Unmarshal 

func (m *CommandResponseHeader) Unmarshal(dAtA []byte) error

func (*CommandResponseHeader) XXX_DiscardUnknown 

func (m *CommandResponseHeader) XXX_DiscardUnknown()

func (*CommandResponseHeader) XXX_Marshal 

func (m *CommandResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommandResponseHeader) XXX_Merge 

func (m *CommandResponseHeader) XXX_Merge(src proto.Message)

func (*CommandResponseHeader) XXX_Size 

func (m *CommandResponseHeader) XXX_Size() int

func (*CommandResponseHeader) XXX_Unmarshal 

func (m *CommandResponseHeader) XXX_Unmarshal(b []byte) error

type EngineClient 

type EngineClient interface {
	ApplyCommandBatch(ctx context.Context, opts ...grpc.CallOption) (Engine_ApplyCommandBatchClient, error)
	ApplySnapshot(ctx context.Context, opts ...grpc.CallOption) (Engine_ApplySnapshotClient, error)
}

EngineClient is the client API for Engine service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEngineClient 

func NewEngineClient(cc *grpc.ClientConn) EngineClient

type EngineServer 

type EngineServer interface {
	ApplyCommandBatch(Engine_ApplyCommandBatchServer) error
	ApplySnapshot(Engine_ApplySnapshotServer) error
}

EngineServer is the server API for Engine service.

type Engine_ApplyCommandBatchClient 

type Engine_ApplyCommandBatchClient interface {
	Send(*CommandRequestBatch) error
	Recv() (*CommandResponseBatch, error)
	grpc.ClientStream
}

type Engine_ApplyCommandBatchServer 

type Engine_ApplyCommandBatchServer interface {
	Send(*CommandResponseBatch) error
	Recv() (*CommandRequestBatch, error)
	grpc.ServerStream
}

type Engine_ApplySnapshotClient 

type Engine_ApplySnapshotClient interface {
	Send(*SnapshotRequest) error
	CloseAndRecv() (*SnapshotDone, error)
	grpc.ClientStream
}

type Engine_ApplySnapshotServer 

type Engine_ApplySnapshotServer interface {
	SendAndClose(*SnapshotDone) error
	Recv() (*SnapshotRequest, error)
	grpc.ServerStream
}

type SnapshotData 

type SnapshotData struct {
	Cf                   string                    `protobuf:"bytes,1,opt,name=cf,proto3" json:"cf,omitempty"`
	Checksum             uint32                    `protobuf:"varint,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	Data                 []*raft_serverpb.KeyValue `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*SnapshotData) Descriptor 

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

func (*SnapshotData) GetCf 

func (m *SnapshotData) GetCf() string

func (*SnapshotData) GetChecksum 

func (m *SnapshotData) GetChecksum() uint32

func (*SnapshotData) GetData 

func (m *SnapshotData) GetData() []*raft_serverpb.KeyValue

func (*SnapshotData) Marshal 

func (m *SnapshotData) Marshal() (dAtA []byte, err error)

func (*SnapshotData) MarshalTo 

func (m *SnapshotData) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotData) MarshalToSizedBuffer 

func (m *SnapshotData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SnapshotData) ProtoMessage 

func (*SnapshotData) ProtoMessage()

func (*SnapshotData) Reset 

func (m *SnapshotData) Reset()

func (*SnapshotData) Size 

func (m *SnapshotData) Size() (n int)

func (*SnapshotData) String 

func (m *SnapshotData) String() string

func (*SnapshotData) Unmarshal 

func (m *SnapshotData) Unmarshal(dAtA []byte) error

func (*SnapshotData) XXX_DiscardUnknown 

func (m *SnapshotData) XXX_DiscardUnknown()

func (*SnapshotData) XXX_Marshal 

func (m *SnapshotData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SnapshotData) XXX_Merge 

func (m *SnapshotData) XXX_Merge(src proto.Message)

func (*SnapshotData) XXX_Size 

func (m *SnapshotData) XXX_Size() int

func (*SnapshotData) XXX_Unmarshal 

func (m *SnapshotData) XXX_Unmarshal(b []byte) error

type SnapshotDone 

type SnapshotDone struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SnapshotDone) Descriptor 

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

func (*SnapshotDone) Marshal 

func (m *SnapshotDone) Marshal() (dAtA []byte, err error)

func (*SnapshotDone) MarshalTo 

func (m *SnapshotDone) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotDone) MarshalToSizedBuffer 

func (m *SnapshotDone) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SnapshotDone) ProtoMessage 

func (*SnapshotDone) ProtoMessage()

func (*SnapshotDone) Reset 

func (m *SnapshotDone) Reset()

func (*SnapshotDone) Size 

func (m *SnapshotDone) Size() (n int)

func (*SnapshotDone) String 

func (m *SnapshotDone) String() string

func (*SnapshotDone) Unmarshal 

func (m *SnapshotDone) Unmarshal(dAtA []byte) error

func (*SnapshotDone) XXX_DiscardUnknown 

func (m *SnapshotDone) XXX_DiscardUnknown()

func (*SnapshotDone) XXX_Marshal 

func (m *SnapshotDone) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SnapshotDone) XXX_Merge 

func (m *SnapshotDone) XXX_Merge(src proto.Message)

func (*SnapshotDone) XXX_Size 

func (m *SnapshotDone) XXX_Size() int

func (*SnapshotDone) XXX_Unmarshal 

func (m *SnapshotDone) XXX_Unmarshal(b []byte) error

type SnapshotRequest 

type SnapshotRequest struct {
	// Types that are valid to be assigned to Chunk:
	//	*SnapshotRequest_State
	//	*SnapshotRequest_Data
	Chunk                isSnapshotRequest_Chunk `protobuf_oneof:"chunk"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*SnapshotRequest) Descriptor 

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

func (*SnapshotRequest) GetChunk 

func (m *SnapshotRequest) GetChunk() isSnapshotRequest_Chunk

func (*SnapshotRequest) GetData 

func (m *SnapshotRequest) GetData() *SnapshotData

func (*SnapshotRequest) GetState 

func (m *SnapshotRequest) GetState() *SnapshotState

func (*SnapshotRequest) Marshal 

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

func (*SnapshotRequest) MarshalTo 

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

func (*SnapshotRequest) MarshalToSizedBuffer 

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

func (*SnapshotRequest) ProtoMessage 

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) Reset 

func (m *SnapshotRequest) Reset()

func (*SnapshotRequest) Size 

func (m *SnapshotRequest) Size() (n int)

func (*SnapshotRequest) String 

func (m *SnapshotRequest) String() string

func (*SnapshotRequest) Unmarshal 

func (m *SnapshotRequest) Unmarshal(dAtA []byte) error

func (*SnapshotRequest) XXX_DiscardUnknown 

func (m *SnapshotRequest) XXX_DiscardUnknown()

func (*SnapshotRequest) XXX_Marshal 

func (m *SnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SnapshotRequest) XXX_Merge 

func (m *SnapshotRequest) XXX_Merge(src proto.Message)

func (*SnapshotRequest) XXX_OneofWrappers 

func (*SnapshotRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SnapshotRequest) XXX_Size 

func (m *SnapshotRequest) XXX_Size() int

func (*SnapshotRequest) XXX_Unmarshal 

func (m *SnapshotRequest) XXX_Unmarshal(b []byte) error

type SnapshotRequest_Data 

type SnapshotRequest_Data struct {
	Data *SnapshotData `protobuf:"bytes,2,opt,name=data,proto3,oneof" json:"data,omitempty"`
}

func (*SnapshotRequest_Data) MarshalTo 

func (m *SnapshotRequest_Data) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotRequest_Data) MarshalToSizedBuffer 

func (m *SnapshotRequest_Data) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SnapshotRequest_Data) Size 

func (m *SnapshotRequest_Data) Size() (n int)

type SnapshotRequest_State 

type SnapshotRequest_State struct {
	State *SnapshotState `protobuf:"bytes,1,opt,name=state,proto3,oneof" json:"state,omitempty"`
}

func (*SnapshotRequest_State) MarshalTo 

func (m *SnapshotRequest_State) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotRequest_State) MarshalToSizedBuffer 

func (m *SnapshotRequest_State) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SnapshotRequest_State) Size 

func (m *SnapshotRequest_State) Size() (n int)

type SnapshotState 

type SnapshotState struct {
	Region               *metapb.Region                `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	Peer                 *metapb.Peer                  `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	ApplyState           *raft_serverpb.RaftApplyState `protobuf:"bytes,3,opt,name=apply_state,json=applyState,proto3" json:"apply_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*SnapshotState) Descriptor 

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

func (*SnapshotState) GetApplyState 

func (m *SnapshotState) GetApplyState() *raft_serverpb.RaftApplyState

func (*SnapshotState) GetPeer 

func (m *SnapshotState) GetPeer() *metapb.Peer

func (*SnapshotState) GetRegion 

func (m *SnapshotState) GetRegion() *metapb.Region

func (*SnapshotState) Marshal 

func (m *SnapshotState) Marshal() (dAtA []byte, err error)

func (*SnapshotState) MarshalTo 

func (m *SnapshotState) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotState) MarshalToSizedBuffer 

func (m *SnapshotState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SnapshotState) ProtoMessage 

func (*SnapshotState) ProtoMessage()

func (*SnapshotState) Reset 

func (m *SnapshotState) Reset()

func (*SnapshotState) Size 

func (m *SnapshotState) Size() (n int)

func (*SnapshotState) String 

func (m *SnapshotState) String() string

func (*SnapshotState) Unmarshal 

func (m *SnapshotState) Unmarshal(dAtA []byte) error

func (*SnapshotState) XXX_DiscardUnknown 

func (m *SnapshotState) XXX_DiscardUnknown()

func (*SnapshotState) XXX_Marshal 

func (m *SnapshotState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SnapshotState) XXX_Merge 

func (m *SnapshotState) XXX_Merge(src proto.Message)

func (*SnapshotState) XXX_Size 

func (m *SnapshotState) XXX_Size() int

func (*SnapshotState) XXX_Unmarshal 

func (m *SnapshotState) XXX_Unmarshal(b []byte) error

type UnimplementedEngineServer 

type UnimplementedEngineServer struct {
}

UnimplementedEngineServer can be embedded to have forward compatible implementations.

func (*UnimplementedEngineServer) ApplyCommandBatch 

func (*UnimplementedEngineServer) ApplyCommandBatch(srv Engine_ApplyCommandBatchServer) error

func (*UnimplementedEngineServer) ApplySnapshot 

func (*UnimplementedEngineServer) ApplySnapshot(srv Engine_ApplySnapshotServer) error

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.