enginepb

package
v0.0.0-...-98b0a12 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2019 License: Apache-2.0 Imports: 9 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")
)

Functions

func RegisterEngineServer 

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

Types

type CommandRequest 

type CommandRequest struct {
	Header *CommandRequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// kv put / delete
	Requests []*raft_cmdpb.Request `protobuf:"bytes,2,rep,name=requests" json:"requests,omitempty"`
	// region metadata manipulation command.
	AdminRequest *raft_cmdpb.AdminRequest `protobuf:"bytes,3,opt,name=admin_request,json=adminRequest" json:"admin_request,omitempty"`
	// region metadata manipulation result.
	AdminResponse        *raft_cmdpb.AdminResponse `protobuf:"bytes,4,opt,name=admin_response,json=adminResponse" 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) 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 (dst *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" 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) 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 (dst *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) 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 (dst *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" json:"header,omitempty"`
	ApplyState           *raft_serverpb.RaftApplyState `protobuf:"bytes,2,opt,name=apply_state,json=applyState" 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) 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 (dst *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" 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) 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 (dst *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) 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 (dst *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)
}

func NewEngineClient 

func NewEngineClient(cc *grpc.ClientConn) EngineClient

type EngineServer 

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

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" 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) 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 (dst *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) 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 (dst *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) 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 (dst *SnapshotRequest) XXX_Merge(src proto.Message)

func (*SnapshotRequest) XXX_OneofFuncs 

func (*SnapshotRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs 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,oneof"`
}

func (*SnapshotRequest_Data) MarshalTo 

func (m *SnapshotRequest_Data) MarshalTo(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,oneof"`
}

func (*SnapshotRequest_State) MarshalTo 

func (m *SnapshotRequest_State) MarshalTo(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" json:"region,omitempty"`
	Peer                 *metapb.Peer                  `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
	ApplyState           *raft_serverpb.RaftApplyState `protobuf:"bytes,3,opt,name=apply_state,json=applyState" 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) 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 (dst *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

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.