raftcmdpb

package
v0.0.0-...-01d9b8a Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRaftcmdpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftcmdpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRaftcmdpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AdminCmdType_name = map[int32]string{
	0: "InvalidAdmin",
	1: "ChangePeer",
	2: "Split",
	3: "CompactRaftLog",
	4: "TransferLeader",
	5: "ComputeHash",
	6: "VerifyHash",
}
View Source 
var AdminCmdType_value = map[string]int32{
	"InvalidAdmin":   0,
	"ChangePeer":     1,
	"Split":          2,
	"CompactRaftLog": 3,
	"TransferLeader": 4,
	"ComputeHash":    5,
	"VerifyHash":     6,
}
View Source 
var CMDType_name = map[int32]string{
	0: "Invalid",
	1: "RaftError",
	2: "Snap",
	3: "Write",
	4: "Read",
}
View Source 
var CMDType_value = map[string]int32{
	"Invalid":   0,
	"RaftError": 1,
	"Snap":      2,
	"Write":     3,
	"Read":      4,
}
View Source 
var ChangePeerType_name = map[int32]string{
	0: "AddNode",
	1: "RemoveNode",
}
View Source 
var ChangePeerType_value = map[string]int32{
	"AddNode":    0,
	"RemoveNode": 1,
}

Functions

This section is empty.

Types

type AdminCmdType 

type AdminCmdType int32
const (
	InvalidAdmin   AdminCmdType = 0
	ChangePeer     AdminCmdType = 1
	Split          AdminCmdType = 2
	CompactRaftLog AdminCmdType = 3
	TransferLeader AdminCmdType = 4
	ComputeHash    AdminCmdType = 5
	VerifyHash     AdminCmdType = 6
)

func (AdminCmdType) EnumDescriptor 

func (AdminCmdType) EnumDescriptor() ([]byte, []int)

func (AdminCmdType) String 

func (x AdminCmdType) String() string

type AdminRequest 

type AdminRequest struct {
	CmdType    AdminCmdType           `protobuf:"varint,1,opt,name=cmdType,proto3,enum=raftcmdpb.AdminCmdType" json:"cmdType,omitempty"`
	ChangePeer *ChangePeerRequest     `protobuf:"bytes,2,opt,name=changePeer,proto3" json:"changePeer,omitempty"`
	Split      *SplitRequest          `protobuf:"bytes,3,opt,name=split,proto3" json:"split,omitempty"`
	Transfer   *TransferLeaderRequest `protobuf:"bytes,4,opt,name=transfer,proto3" json:"transfer,omitempty"`
	Compact    *CompactRaftLogRequest `protobuf:"bytes,5,opt,name=compact,proto3" json:"compact,omitempty"`
}

AdminRequest admin request

func (*AdminRequest) Descriptor 

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

func (*AdminRequest) GetChangePeer 

func (m *AdminRequest) GetChangePeer() *ChangePeerRequest

func (*AdminRequest) GetCmdType 

func (m *AdminRequest) GetCmdType() AdminCmdType

func (*AdminRequest) GetCompact 

func (m *AdminRequest) GetCompact() *CompactRaftLogRequest

func (*AdminRequest) GetSplit 

func (m *AdminRequest) GetSplit() *SplitRequest

func (*AdminRequest) GetTransfer 

func (m *AdminRequest) GetTransfer() *TransferLeaderRequest

func (*AdminRequest) Marshal 

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

func (*AdminRequest) MarshalTo 

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

func (*AdminRequest) MarshalToSizedBuffer 

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

func (*AdminRequest) ProtoMessage 

func (*AdminRequest) ProtoMessage()

func (*AdminRequest) Reset 

func (m *AdminRequest) Reset()

func (*AdminRequest) Size 

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

func (*AdminRequest) String 

func (m *AdminRequest) String() string

func (*AdminRequest) Unmarshal 

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

func (*AdminRequest) XXX_DiscardUnknown 

func (m *AdminRequest) XXX_DiscardUnknown()

func (*AdminRequest) XXX_Marshal 

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

func (*AdminRequest) XXX_Merge 

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

func (*AdminRequest) XXX_Size 

func (m *AdminRequest) XXX_Size() int

func (*AdminRequest) XXX_Unmarshal 

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

type AdminResponse 

type AdminResponse struct {
	Type       AdminCmdType            `protobuf:"varint,1,opt,name=type,proto3,enum=raftcmdpb.AdminCmdType" json:"type,omitempty"`
	ChangePeer *ChangePeerResponse     `protobuf:"bytes,2,opt,name=changePeer,proto3" json:"changePeer,omitempty"`
	Split      *SplitResponse          `protobuf:"bytes,3,opt,name=split,proto3" json:"split,omitempty"`
	Transfer   *TransferLeaderResponse `protobuf:"bytes,4,opt,name=transfer,proto3" json:"transfer,omitempty"`
	Compact    *CompactRaftLogResponse `protobuf:"bytes,5,opt,name=compact,proto3" json:"compact,omitempty"`
}

AdminResponse admin response

func (*AdminResponse) Descriptor 

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

func (*AdminResponse) GetChangePeer 

func (m *AdminResponse) GetChangePeer() *ChangePeerResponse

func (*AdminResponse) GetCompact 

func (m *AdminResponse) GetCompact() *CompactRaftLogResponse

func (*AdminResponse) GetSplit 

func (m *AdminResponse) GetSplit() *SplitResponse

func (*AdminResponse) GetTransfer 

func (m *AdminResponse) GetTransfer() *TransferLeaderResponse

func (*AdminResponse) GetType 

func (m *AdminResponse) GetType() AdminCmdType

func (*AdminResponse) Marshal 

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

func (*AdminResponse) MarshalTo 

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

func (*AdminResponse) MarshalToSizedBuffer 

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

func (*AdminResponse) ProtoMessage 

func (*AdminResponse) ProtoMessage()

func (*AdminResponse) Reset 

func (m *AdminResponse) Reset()

func (*AdminResponse) Size 

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

func (*AdminResponse) String 

func (m *AdminResponse) String() string

func (*AdminResponse) Unmarshal 

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

func (*AdminResponse) XXX_DiscardUnknown 

func (m *AdminResponse) XXX_DiscardUnknown()

func (*AdminResponse) XXX_Marshal 

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

func (*AdminResponse) XXX_Merge 

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

func (*AdminResponse) XXX_Size 

func (m *AdminResponse) XXX_Size() int

func (*AdminResponse) XXX_Unmarshal 

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

type CMDType 

type CMDType int32
const (
	Invalid   CMDType = 0
	RaftError CMDType = 1
	Snap      CMDType = 2
	Write     CMDType = 3
	Read      CMDType = 4
)

func (CMDType) EnumDescriptor 

func (CMDType) EnumDescriptor() ([]byte, []int)

func (CMDType) String 

func (x CMDType) String() string

type ChangePeerRequest 

type ChangePeerRequest struct {
	ChangeType ChangePeerType `protobuf:"varint,1,opt,name=changeType,proto3,enum=raftcmdpb.ChangePeerType" json:"changeType,omitempty"`
	Peer       metapb.Peer    `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer"`
}

ChangePeerRequest change peer request

func (*ChangePeerRequest) Descriptor 

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

func (*ChangePeerRequest) GetChangeType 

func (m *ChangePeerRequest) GetChangeType() ChangePeerType

func (*ChangePeerRequest) GetPeer 

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

func (*ChangePeerRequest) Marshal 

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

func (*ChangePeerRequest) MarshalTo 

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

func (*ChangePeerRequest) MarshalToSizedBuffer 

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

func (*ChangePeerRequest) ProtoMessage 

func (*ChangePeerRequest) ProtoMessage()

func (*ChangePeerRequest) Reset 

func (m *ChangePeerRequest) Reset()

func (*ChangePeerRequest) Size 

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

func (*ChangePeerRequest) String 

func (m *ChangePeerRequest) String() string

func (*ChangePeerRequest) Unmarshal 

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

func (*ChangePeerRequest) XXX_DiscardUnknown 

func (m *ChangePeerRequest) XXX_DiscardUnknown()

func (*ChangePeerRequest) XXX_Marshal 

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

func (*ChangePeerRequest) XXX_Merge 

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

func (*ChangePeerRequest) XXX_Size 

func (m *ChangePeerRequest) XXX_Size() int

func (*ChangePeerRequest) XXX_Unmarshal 

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

type ChangePeerResponse 

type ChangePeerResponse struct {
	Shard metapb.Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard"`
}

ChangePeerResponse change peer response

func (*ChangePeerResponse) Descriptor 

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

func (*ChangePeerResponse) GetShard 

func (m *ChangePeerResponse) GetShard() metapb.Shard

func (*ChangePeerResponse) Marshal 

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

func (*ChangePeerResponse) MarshalTo 

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

func (*ChangePeerResponse) MarshalToSizedBuffer 

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

func (*ChangePeerResponse) ProtoMessage 

func (*ChangePeerResponse) ProtoMessage()

func (*ChangePeerResponse) Reset 

func (m *ChangePeerResponse) Reset()

func (*ChangePeerResponse) Size 

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

func (*ChangePeerResponse) String 

func (m *ChangePeerResponse) String() string

func (*ChangePeerResponse) Unmarshal 

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

func (*ChangePeerResponse) XXX_DiscardUnknown 

func (m *ChangePeerResponse) XXX_DiscardUnknown()

func (*ChangePeerResponse) XXX_Marshal 

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

func (*ChangePeerResponse) XXX_Merge 

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

func (*ChangePeerResponse) XXX_Size 

func (m *ChangePeerResponse) XXX_Size() int

func (*ChangePeerResponse) XXX_Unmarshal 

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

type ChangePeerType 

type ChangePeerType int32

ChangePeerType add or remove node 

const (
	AddNode    ChangePeerType = 0
	RemoveNode ChangePeerType = 1
)

func (ChangePeerType) EnumDescriptor 

func (ChangePeerType) EnumDescriptor() ([]byte, []int)

func (ChangePeerType) String 

func (x ChangePeerType) String() string

type CompactRaftLogRequest 

type CompactRaftLogRequest struct {
	CompactIndex uint64 `protobuf:"varint,1,opt,name=compactIndex,proto3" json:"compactIndex,omitempty"`
	CompactTerm  uint64 `protobuf:"varint,2,opt,name=compactTerm,proto3" json:"compactTerm,omitempty"`
}

CompactRaftLogRequest compact raft log request

func (*CompactRaftLogRequest) Descriptor 

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

func (*CompactRaftLogRequest) GetCompactIndex 

func (m *CompactRaftLogRequest) GetCompactIndex() uint64

func (*CompactRaftLogRequest) GetCompactTerm 

func (m *CompactRaftLogRequest) GetCompactTerm() uint64

func (*CompactRaftLogRequest) Marshal 

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

func (*CompactRaftLogRequest) MarshalTo 

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

func (*CompactRaftLogRequest) MarshalToSizedBuffer 

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

func (*CompactRaftLogRequest) ProtoMessage 

func (*CompactRaftLogRequest) ProtoMessage()

func (*CompactRaftLogRequest) Reset 

func (m *CompactRaftLogRequest) Reset()

func (*CompactRaftLogRequest) Size 

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

func (*CompactRaftLogRequest) String 

func (m *CompactRaftLogRequest) String() string

func (*CompactRaftLogRequest) Unmarshal 

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

func (*CompactRaftLogRequest) XXX_DiscardUnknown 

func (m *CompactRaftLogRequest) XXX_DiscardUnknown()

func (*CompactRaftLogRequest) XXX_Marshal 

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

func (*CompactRaftLogRequest) XXX_Merge 

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

func (*CompactRaftLogRequest) XXX_Size 

func (m *CompactRaftLogRequest) XXX_Size() int

func (*CompactRaftLogRequest) XXX_Unmarshal 

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

type CompactRaftLogResponse 

type CompactRaftLogResponse struct {
}

CompactRaftLogResponse compact raft log response

func (*CompactRaftLogResponse) Descriptor 

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

func (*CompactRaftLogResponse) Marshal 

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

func (*CompactRaftLogResponse) MarshalTo 

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

func (*CompactRaftLogResponse) MarshalToSizedBuffer 

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

func (*CompactRaftLogResponse) ProtoMessage 

func (*CompactRaftLogResponse) ProtoMessage()

func (*CompactRaftLogResponse) Reset 

func (m *CompactRaftLogResponse) Reset()

func (*CompactRaftLogResponse) Size 

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

func (*CompactRaftLogResponse) String 

func (m *CompactRaftLogResponse) String() string

func (*CompactRaftLogResponse) Unmarshal 

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

func (*CompactRaftLogResponse) XXX_DiscardUnknown 

func (m *CompactRaftLogResponse) XXX_DiscardUnknown()

func (*CompactRaftLogResponse) XXX_Marshal 

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

func (*CompactRaftLogResponse) XXX_Merge 

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

func (*CompactRaftLogResponse) XXX_Size 

func (m *CompactRaftLogResponse) XXX_Size() int

func (*CompactRaftLogResponse) XXX_Unmarshal 

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

type RaftCMDRequest 

type RaftCMDRequest struct {
	Header       *RaftRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Requests     []*Request         `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	AdminRequest *AdminRequest      `protobuf:"bytes,3,opt,name=adminRequest,proto3" json:"adminRequest,omitempty"`
}

RaftCMDRequest we can't include both normal requests and administrator request at same time.

func (*RaftCMDRequest) Descriptor 

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

func (*RaftCMDRequest) GetAdminRequest 

func (m *RaftCMDRequest) GetAdminRequest() *AdminRequest

func (*RaftCMDRequest) GetHeader 

func (m *RaftCMDRequest) GetHeader() *RaftRequestHeader

func (*RaftCMDRequest) GetRequests 

func (m *RaftCMDRequest) GetRequests() []*Request

func (*RaftCMDRequest) Marshal 

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

func (*RaftCMDRequest) MarshalTo 

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

func (*RaftCMDRequest) MarshalToSizedBuffer 

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

func (*RaftCMDRequest) ProtoMessage 

func (*RaftCMDRequest) ProtoMessage()

func (*RaftCMDRequest) Reset 

func (m *RaftCMDRequest) Reset()

func (*RaftCMDRequest) Size 

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

func (*RaftCMDRequest) String 

func (m *RaftCMDRequest) String() string

func (*RaftCMDRequest) Unmarshal 

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

func (*RaftCMDRequest) XXX_DiscardUnknown 

func (m *RaftCMDRequest) XXX_DiscardUnknown()

func (*RaftCMDRequest) XXX_Marshal 

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

func (*RaftCMDRequest) XXX_Merge 

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

func (*RaftCMDRequest) XXX_Size 

func (m *RaftCMDRequest) XXX_Size() int

func (*RaftCMDRequest) XXX_Unmarshal 

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

type RaftCMDResponse 

type RaftCMDResponse struct {
	Header        *RaftResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Responses     []*Response         `protobuf:"bytes,2,rep,name=responses,proto3" json:"responses,omitempty"`
	AdminResponse *AdminResponse      `protobuf:"bytes,3,opt,name=adminResponse,proto3" json:"adminResponse,omitempty"`
}

func (*RaftCMDResponse) Descriptor 

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

func (*RaftCMDResponse) GetAdminResponse 

func (m *RaftCMDResponse) GetAdminResponse() *AdminResponse

func (*RaftCMDResponse) GetHeader 

func (m *RaftCMDResponse) GetHeader() *RaftResponseHeader

func (*RaftCMDResponse) GetResponses 

func (m *RaftCMDResponse) GetResponses() []*Response

func (*RaftCMDResponse) Marshal 

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

func (*RaftCMDResponse) MarshalTo 

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

func (*RaftCMDResponse) MarshalToSizedBuffer 

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

func (*RaftCMDResponse) ProtoMessage 

func (*RaftCMDResponse) ProtoMessage()

func (*RaftCMDResponse) Reset 

func (m *RaftCMDResponse) Reset()

func (*RaftCMDResponse) Size 

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

func (*RaftCMDResponse) String 

func (m *RaftCMDResponse) String() string

func (*RaftCMDResponse) Unmarshal 

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

func (*RaftCMDResponse) XXX_DiscardUnknown 

func (m *RaftCMDResponse) XXX_DiscardUnknown()

func (*RaftCMDResponse) XXX_Marshal 

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

func (*RaftCMDResponse) XXX_Merge 

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

func (*RaftCMDResponse) XXX_Size 

func (m *RaftCMDResponse) XXX_Size() int

func (*RaftCMDResponse) XXX_Unmarshal 

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

type RaftRequestHeader 

type RaftRequestHeader struct {
	ID         []byte            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ShardID    uint64            `protobuf:"varint,2,opt,name=shardID,proto3" json:"shardID,omitempty"`
	Peer       metapb.Peer       `protobuf:"bytes,3,opt,name=peer,proto3" json:"peer"`
	ShardEpoch metapb.ShardEpoch `protobuf:"bytes,5,opt,name=shardEpoch,proto3" json:"shardEpoch"`
	Term       uint64            `protobuf:"varint,6,opt,name=term,proto3" json:"term,omitempty"`
}

RaftRequestHeader raft request header, it contains the shard's metadata

func (*RaftRequestHeader) Descriptor 

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

func (*RaftRequestHeader) GetID 

func (m *RaftRequestHeader) GetID() []byte

func (*RaftRequestHeader) GetPeer 

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

func (*RaftRequestHeader) GetShardEpoch 

func (m *RaftRequestHeader) GetShardEpoch() metapb.ShardEpoch

func (*RaftRequestHeader) GetShardID 

func (m *RaftRequestHeader) GetShardID() uint64

func (*RaftRequestHeader) GetTerm 

func (m *RaftRequestHeader) GetTerm() uint64

func (*RaftRequestHeader) Marshal 

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

func (*RaftRequestHeader) MarshalTo 

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

func (*RaftRequestHeader) MarshalToSizedBuffer 

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

func (*RaftRequestHeader) ProtoMessage 

func (*RaftRequestHeader) ProtoMessage()

func (*RaftRequestHeader) Reset 

func (m *RaftRequestHeader) Reset()

func (*RaftRequestHeader) Size 

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

func (*RaftRequestHeader) String 

func (m *RaftRequestHeader) String() string

func (*RaftRequestHeader) Unmarshal 

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

func (*RaftRequestHeader) XXX_DiscardUnknown 

func (m *RaftRequestHeader) XXX_DiscardUnknown()

func (*RaftRequestHeader) XXX_Marshal 

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

func (*RaftRequestHeader) XXX_Merge 

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

func (*RaftRequestHeader) XXX_Size 

func (m *RaftRequestHeader) XXX_Size() int

func (*RaftRequestHeader) XXX_Unmarshal 

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

type RaftResponseHeader 

type RaftResponseHeader struct {
	ID          []byte        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Error       errorpb.Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error"`
	CurrentTerm uint64        `protobuf:"varint,3,opt,name=currentTerm,proto3" json:"currentTerm,omitempty"`
}

func (*RaftResponseHeader) Descriptor 

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

func (*RaftResponseHeader) GetCurrentTerm 

func (m *RaftResponseHeader) GetCurrentTerm() uint64

func (*RaftResponseHeader) GetError 

func (m *RaftResponseHeader) GetError() errorpb.Error

func (*RaftResponseHeader) GetID 

func (m *RaftResponseHeader) GetID() []byte

func (*RaftResponseHeader) Marshal 

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

func (*RaftResponseHeader) MarshalTo 

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

func (*RaftResponseHeader) MarshalToSizedBuffer 

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

func (*RaftResponseHeader) ProtoMessage 

func (*RaftResponseHeader) ProtoMessage()

func (*RaftResponseHeader) Reset 

func (m *RaftResponseHeader) Reset()

func (*RaftResponseHeader) Size 

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

func (*RaftResponseHeader) String 

func (m *RaftResponseHeader) String() string

func (*RaftResponseHeader) Unmarshal 

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

func (*RaftResponseHeader) XXX_DiscardUnknown 

func (m *RaftResponseHeader) XXX_DiscardUnknown()

func (*RaftResponseHeader) XXX_Marshal 

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

func (*RaftResponseHeader) XXX_Merge 

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

func (*RaftResponseHeader) XXX_Size 

func (m *RaftResponseHeader) XXX_Size() int

func (*RaftResponseHeader) XXX_Unmarshal 

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

type Request 

type Request struct {
	ID            []byte  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Group         uint64  `protobuf:"varint,2,opt,name=group,proto3" json:"group,omitempty"`
	Type          CMDType `protobuf:"varint,3,opt,name=type,proto3,enum=raftcmdpb.CMDType" json:"type,omitempty"`
	CustemType    uint64  `protobuf:"varint,4,opt,name=custemType,proto3" json:"custemType,omitempty"`
	Key           []byte  `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	Cmd           []byte  `protobuf:"bytes,6,opt,name=cmd,proto3" json:"cmd,omitempty"`
	SID           int64   `protobuf:"varint,7,opt,name=sid,proto3" json:"sid,omitempty"`
	PID           int64   `protobuf:"varint,8,opt,name=pid,proto3" json:"pid,omitempty"`
	StopAt        int64   `protobuf:"varint,9,opt,name=stopAt,proto3" json:"stopAt,omitempty"`
	ToShard       uint64  `protobuf:"varint,10,opt,name=toShard,proto3" json:"toShard,omitempty"`
	AllowFollower bool    `protobuf:"varint,11,opt,name=allowFollower,proto3" json:"allowFollower,omitempty"`
	LastBroadcast bool    `protobuf:"varint,12,opt,name=lastBroadcast,proto3" json:"lastBroadcast,omitempty"`
}

Request request

func (*Request) Descriptor 

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

func (*Request) GetAllowFollower 

func (m *Request) GetAllowFollower() bool

func (*Request) GetCmd 

func (m *Request) GetCmd() []byte

func (*Request) GetCustemType 

func (m *Request) GetCustemType() uint64

func (*Request) GetGroup 

func (m *Request) GetGroup() uint64

func (*Request) GetID 

func (m *Request) GetID() []byte

func (*Request) GetKey 

func (m *Request) GetKey() []byte

func (*Request) GetLastBroadcast 

func (m *Request) GetLastBroadcast() bool

func (*Request) GetPID 

func (m *Request) GetPID() int64

func (*Request) GetSID 

func (m *Request) GetSID() int64

func (*Request) GetStopAt 

func (m *Request) GetStopAt() int64

func (*Request) GetToShard 

func (m *Request) GetToShard() uint64

func (*Request) GetType 

func (m *Request) GetType() CMDType

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer 

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

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type Response 

type Response struct {
	ID                []byte        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type              CMDType       `protobuf:"varint,2,opt,name=type,proto3,enum=raftcmdpb.CMDType" json:"type,omitempty"`
	Value             []byte        `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	OriginRequest     *Request      `protobuf:"bytes,4,opt,name=originRequest,proto3" json:"originRequest,omitempty"`
	SID               int64         `protobuf:"varint,5,opt,name=sid,proto3" json:"sid,omitempty"`
	PID               int64         `protobuf:"varint,6,opt,name=pid,proto3" json:"pid,omitempty"`
	Error             errorpb.Error `protobuf:"bytes,7,opt,name=error,proto3" json:"error"`
	ContinueBroadcast bool          `protobuf:"varint,8,opt,name=continueBroadcast,proto3" json:"continueBroadcast,omitempty"`
	Stale             bool          `protobuf:"varint,9,opt,name=stale,proto3" json:"stale,omitempty"`
}

Response response

func (*Response) Descriptor 

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

func (*Response) GetContinueBroadcast 

func (m *Response) GetContinueBroadcast() bool

func (*Response) GetError 

func (m *Response) GetError() errorpb.Error

func (*Response) GetID 

func (m *Response) GetID() []byte

func (*Response) GetOriginRequest 

func (m *Response) GetOriginRequest() *Request

func (*Response) GetPID 

func (m *Response) GetPID() int64

func (*Response) GetSID 

func (m *Response) GetSID() int64

func (*Response) GetStale 

func (m *Response) GetStale() bool

func (*Response) GetType 

func (m *Response) GetType() CMDType

func (*Response) GetValue 

func (m *Response) GetValue() []byte

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type SplitRequest 

type SplitRequest struct {
	// This can be only called in internal RaftStore now.
	// The splitKey must be in the been splitting shard.
	SplitKey []byte `protobuf:"bytes,1,opt,name=splitKey,proto3" json:"splitKey,omitempty"`
	// We split the shard into two, first uses the shard
	// parent shard id, and the second uses the new_shard_id.
	// We must guarantee that the new_shard_id is global unique.
	NewShardID uint64 `protobuf:"varint,2,opt,name=newShardID,proto3" json:"newShardID,omitempty"`
	// The peer ids for the new split shard.
	NewPeerIDs []uint64 `protobuf:"varint,3,rep,packed,name=newPeerIDs,proto3" json:"newPeerIDs,omitempty"`
	// If true, right shard derive the origin shard_id,
	// left shard use new_shard_id.
	RightDerive bool `protobuf:"varint,4,opt,name=rightDerive,proto3" json:"rightDerive,omitempty"`
}

SplitRequest split shard request

func (*SplitRequest) Descriptor 

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

func (*SplitRequest) GetNewPeerIDs 

func (m *SplitRequest) GetNewPeerIDs() []uint64

func (*SplitRequest) GetNewShardID 

func (m *SplitRequest) GetNewShardID() uint64

func (*SplitRequest) GetRightDerive 

func (m *SplitRequest) GetRightDerive() bool

func (*SplitRequest) GetSplitKey 

func (m *SplitRequest) GetSplitKey() []byte

func (*SplitRequest) Marshal 

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

func (*SplitRequest) MarshalTo 

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

func (*SplitRequest) MarshalToSizedBuffer 

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

func (*SplitRequest) ProtoMessage 

func (*SplitRequest) ProtoMessage()

func (*SplitRequest) Reset 

func (m *SplitRequest) Reset()

func (*SplitRequest) Size 

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

func (*SplitRequest) String 

func (m *SplitRequest) String() string

func (*SplitRequest) Unmarshal 

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

func (*SplitRequest) XXX_DiscardUnknown 

func (m *SplitRequest) XXX_DiscardUnknown()

func (*SplitRequest) XXX_Marshal 

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

func (*SplitRequest) XXX_Merge 

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

func (*SplitRequest) XXX_Size 

func (m *SplitRequest) XXX_Size() int

func (*SplitRequest) XXX_Unmarshal 

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

type SplitResponse 

type SplitResponse struct {
	Left  metapb.Shard `protobuf:"bytes,1,opt,name=left,proto3" json:"left"`
	Right metapb.Shard `protobuf:"bytes,2,opt,name=right,proto3" json:"right"`
}

SplitResponse split shard response

func (*SplitResponse) Descriptor 

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

func (*SplitResponse) GetLeft 

func (m *SplitResponse) GetLeft() metapb.Shard

func (*SplitResponse) GetRight 

func (m *SplitResponse) GetRight() metapb.Shard

func (*SplitResponse) Marshal 

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

func (*SplitResponse) MarshalTo 

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

func (*SplitResponse) MarshalToSizedBuffer 

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

func (*SplitResponse) ProtoMessage 

func (*SplitResponse) ProtoMessage()

func (*SplitResponse) Reset 

func (m *SplitResponse) Reset()

func (*SplitResponse) Size 

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

func (*SplitResponse) String 

func (m *SplitResponse) String() string

func (*SplitResponse) Unmarshal 

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

func (*SplitResponse) XXX_DiscardUnknown 

func (m *SplitResponse) XXX_DiscardUnknown()

func (*SplitResponse) XXX_Marshal 

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

func (*SplitResponse) XXX_Merge 

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

func (*SplitResponse) XXX_Size 

func (m *SplitResponse) XXX_Size() int

func (*SplitResponse) XXX_Unmarshal 

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

type TransferLeaderRequest 

type TransferLeaderRequest struct {
	Peer metapb.Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer"`
}

TransferLeaderRequest transfer leader request

func (*TransferLeaderRequest) Descriptor 

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

func (*TransferLeaderRequest) GetPeer 

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

func (*TransferLeaderRequest) Marshal 

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

func (*TransferLeaderRequest) MarshalTo 

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

func (*TransferLeaderRequest) MarshalToSizedBuffer 

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

func (*TransferLeaderRequest) ProtoMessage 

func (*TransferLeaderRequest) ProtoMessage()

func (*TransferLeaderRequest) Reset 

func (m *TransferLeaderRequest) Reset()

func (*TransferLeaderRequest) Size 

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

func (*TransferLeaderRequest) String 

func (m *TransferLeaderRequest) String() string

func (*TransferLeaderRequest) Unmarshal 

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

func (*TransferLeaderRequest) XXX_DiscardUnknown 

func (m *TransferLeaderRequest) XXX_DiscardUnknown()

func (*TransferLeaderRequest) XXX_Marshal 

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

func (*TransferLeaderRequest) XXX_Merge 

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

func (*TransferLeaderRequest) XXX_Size 

func (m *TransferLeaderRequest) XXX_Size() int

func (*TransferLeaderRequest) XXX_Unmarshal 

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

type TransferLeaderResponse 

type TransferLeaderResponse struct {
}

TransferLeaderResponse transfer leader response

func (*TransferLeaderResponse) Descriptor 

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

func (*TransferLeaderResponse) Marshal 

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

func (*TransferLeaderResponse) MarshalTo 

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

func (*TransferLeaderResponse) MarshalToSizedBuffer 

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

func (*TransferLeaderResponse) ProtoMessage 

func (*TransferLeaderResponse) ProtoMessage()

func (*TransferLeaderResponse) Reset 

func (m *TransferLeaderResponse) Reset()

func (*TransferLeaderResponse) Size 

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

func (*TransferLeaderResponse) String 

func (m *TransferLeaderResponse) String() string

func (*TransferLeaderResponse) Unmarshal 

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

func (*TransferLeaderResponse) XXX_DiscardUnknown 

func (m *TransferLeaderResponse) XXX_DiscardUnknown()

func (*TransferLeaderResponse) XXX_Marshal 

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

func (*TransferLeaderResponse) XXX_Merge 

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

func (*TransferLeaderResponse) XXX_Size 

func (m *TransferLeaderResponse) XXX_Size() int

func (*TransferLeaderResponse) XXX_Unmarshal 

func (m *TransferLeaderResponse) 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.