raftcmdpb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 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")
)
View Source 
var AdminCmdType_name = map[int32]string{
	0: "InvalidAdmin",
	1: "ChangePeer",
	2: "CompactLog",
	3: "TransferLeader",
	4: "ComputeHash",
	5: "VerifyHash",
	6: "BatchSplit",
	7: "ChangePeerV2",
}
View Source 
var AdminCmdType_value = map[string]int32{
	"InvalidAdmin":   0,
	"ChangePeer":     1,
	"CompactLog":     2,
	"TransferLeader": 3,
	"ComputeHash":    4,
	"VerifyHash":     5,
	"BatchSplit":     6,
	"ChangePeerV2":   7,
}
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,
}

Functions

This section is empty.

Types

type AdminCmdType 

type AdminCmdType int32

AdminCmdType admin cmd type 

const (
	AdminCmdType_InvalidAdmin   AdminCmdType = 0
	AdminCmdType_ChangePeer     AdminCmdType = 1
	AdminCmdType_CompactLog     AdminCmdType = 2
	AdminCmdType_TransferLeader AdminCmdType = 3
	AdminCmdType_ComputeHash    AdminCmdType = 4
	AdminCmdType_VerifyHash     AdminCmdType = 5
	AdminCmdType_BatchSplit     AdminCmdType = 6
	AdminCmdType_ChangePeerV2   AdminCmdType = 7
)

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"`
	CompactLog           *CompactLogRequest     `protobuf:"bytes,3,opt,name=compactLog,proto3" json:"compactLog,omitempty"`
	TransferLeader       *TransferLeaderRequest `protobuf:"bytes,4,opt,name=transferLeader,proto3" json:"transferLeader,omitempty"`
	VerifyHash           *VerifyHashRequest     `protobuf:"bytes,5,opt,name=verifyHash,proto3" json:"verifyHash,omitempty"`
	Splits               *BatchSplitRequest     `protobuf:"bytes,6,opt,name=splits,proto3" json:"splits,omitempty"`
	ChangePeerV2         *ChangePeerV2Request   `protobuf:"bytes,7,opt,name=changePeerV2,proto3" json:"changePeerV2,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

AdminRequest admin request

func (*AdminRequest) Descriptor 

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

func (*AdminRequest) GetChangePeer 

func (m *AdminRequest) GetChangePeer() *ChangePeerRequest

func (*AdminRequest) GetChangePeerV2 

func (m *AdminRequest) GetChangePeerV2() *ChangePeerV2Request

func (*AdminRequest) GetCmdType 

func (m *AdminRequest) GetCmdType() AdminCmdType

func (*AdminRequest) GetCompactLog 

func (m *AdminRequest) GetCompactLog() *CompactLogRequest

func (*AdminRequest) GetSplits 

func (m *AdminRequest) GetSplits() *BatchSplitRequest

func (*AdminRequest) GetTransferLeader 

func (m *AdminRequest) GetTransferLeader() *TransferLeaderRequest

func (*AdminRequest) GetVerifyHash 

func (m *AdminRequest) GetVerifyHash() *VerifyHashRequest

func (*AdminRequest) Marshal 

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

func (*AdminRequest) MarshalTo 

func (m *AdminRequest) MarshalTo(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 {
	CmdType              AdminCmdType            `protobuf:"varint,1,opt,name=cmdType,proto3,enum=raftcmdpb.AdminCmdType" json:"cmdType,omitempty"`
	ChangePeer           *ChangePeerResponse     `protobuf:"bytes,2,opt,name=changePeer,proto3" json:"changePeer,omitempty"`
	CompactLog           *CompactLogResponse     `protobuf:"bytes,3,opt,name=compactLog,proto3" json:"compactLog,omitempty"`
	TransferLeader       *TransferLeaderResponse `protobuf:"bytes,4,opt,name=transferLeader,proto3" json:"transferLeader,omitempty"`
	VerifyHash           *VerifyHashResponse     `protobuf:"bytes,5,opt,name=verifyHash,proto3" json:"verifyHash,omitempty"`
	Splits               *BatchSplitResponse     `protobuf:"bytes,9,opt,name=splits,proto3" json:"splits,omitempty"`
	ChangePeerV2         *ChangePeerV2Response   `protobuf:"bytes,10,opt,name=changePeerV2,proto3" json:"changePeerV2,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

AdminResponse admin response

func (*AdminResponse) Descriptor 

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

func (*AdminResponse) GetChangePeer 

func (m *AdminResponse) GetChangePeer() *ChangePeerResponse

func (*AdminResponse) GetChangePeerV2 

func (m *AdminResponse) GetChangePeerV2() *ChangePeerV2Response

func (*AdminResponse) GetCmdType 

func (m *AdminResponse) GetCmdType() AdminCmdType

func (*AdminResponse) GetCompactLog 

func (m *AdminResponse) GetCompactLog() *CompactLogResponse

func (*AdminResponse) GetSplits 

func (m *AdminResponse) GetSplits() *BatchSplitResponse

func (*AdminResponse) GetTransferLeader 

func (m *AdminResponse) GetTransferLeader() *TransferLeaderResponse

func (*AdminResponse) GetVerifyHash 

func (m *AdminResponse) GetVerifyHash() *VerifyHashResponse

func (*AdminResponse) Marshal 

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

func (*AdminResponse) MarshalTo 

func (m *AdminResponse) MarshalTo(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 BatchSplitRequest 

type BatchSplitRequest struct {
	Requests []SplitRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests"`
	// If true, the last shard derive the origin shard_id,
	// other shards use new ids.
	RightDerive          bool     `protobuf:"varint,2,opt,name=rightDerive,proto3" json:"rightDerive,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchSplitRequest) Descriptor 

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

func (*BatchSplitRequest) GetRequests 

func (m *BatchSplitRequest) GetRequests() []SplitRequest

func (*BatchSplitRequest) GetRightDerive 

func (m *BatchSplitRequest) GetRightDerive() bool

func (*BatchSplitRequest) Marshal 

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

func (*BatchSplitRequest) MarshalTo 

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

func (*BatchSplitRequest) ProtoMessage 

func (*BatchSplitRequest) ProtoMessage()

func (*BatchSplitRequest) Reset 

func (m *BatchSplitRequest) Reset()

func (*BatchSplitRequest) Size 

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

func (*BatchSplitRequest) String 

func (m *BatchSplitRequest) String() string

func (*BatchSplitRequest) Unmarshal 

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

func (*BatchSplitRequest) XXX_DiscardUnknown 

func (m *BatchSplitRequest) XXX_DiscardUnknown()

func (*BatchSplitRequest) XXX_Marshal 

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

func (*BatchSplitRequest) XXX_Merge 

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

func (*BatchSplitRequest) XXX_Size 

func (m *BatchSplitRequest) XXX_Size() int

func (*BatchSplitRequest) XXX_Unmarshal 

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

type BatchSplitResponse 

type BatchSplitResponse struct {
	Shards               []bhmetapb.Shard `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*BatchSplitResponse) Descriptor 

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

func (*BatchSplitResponse) GetShards 

func (m *BatchSplitResponse) GetShards() []bhmetapb.Shard

func (*BatchSplitResponse) Marshal 

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

func (*BatchSplitResponse) MarshalTo 

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

func (*BatchSplitResponse) ProtoMessage 

func (*BatchSplitResponse) ProtoMessage()

func (*BatchSplitResponse) Reset 

func (m *BatchSplitResponse) Reset()

func (*BatchSplitResponse) Size 

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

func (*BatchSplitResponse) String 

func (m *BatchSplitResponse) String() string

func (*BatchSplitResponse) Unmarshal 

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

func (*BatchSplitResponse) XXX_DiscardUnknown 

func (m *BatchSplitResponse) XXX_DiscardUnknown()

func (*BatchSplitResponse) XXX_Marshal 

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

func (*BatchSplitResponse) XXX_Merge 

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

func (*BatchSplitResponse) XXX_Size 

func (m *BatchSplitResponse) XXX_Size() int

func (*BatchSplitResponse) XXX_Unmarshal 

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

type CMDType 

type CMDType int32
const (
	CMDType_Invalid   CMDType = 0
	CMDType_RaftError CMDType = 1
	CMDType_Snap      CMDType = 2
	CMDType_Write     CMDType = 3
	CMDType_Read      CMDType = 4
)

func (CMDType) EnumDescriptor 

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

func (CMDType) String 

func (x CMDType) String() string

type ChangePeerRequest 

type ChangePeerRequest struct {
	// This can be only called in internal RaftStore now.
	ChangeType           metapb.ChangePeerType `protobuf:"varint,1,opt,name=changeType,proto3,enum=metapb.ChangePeerType" json:"changeType,omitempty"`
	Peer                 metapb.Peer           `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ChangePeerRequest) Descriptor 

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

func (*ChangePeerRequest) GetChangeType 

func (m *ChangePeerRequest) GetChangeType() metapb.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) 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                bhmetapb.Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

ChangePeerResponse change peer response

func (*ChangePeerResponse) Descriptor 

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

func (*ChangePeerResponse) GetShard 

func (m *ChangePeerResponse) GetShard() bhmetapb.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) 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 ChangePeerV2Request 

type ChangePeerV2Request struct {
	Changes              []ChangePeerRequest `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ChangePeerV2Request) Descriptor 

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

func (*ChangePeerV2Request) GetChanges 

func (m *ChangePeerV2Request) GetChanges() []ChangePeerRequest

func (*ChangePeerV2Request) Marshal 

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

func (*ChangePeerV2Request) MarshalTo 

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

func (*ChangePeerV2Request) ProtoMessage 

func (*ChangePeerV2Request) ProtoMessage()

func (*ChangePeerV2Request) Reset 

func (m *ChangePeerV2Request) Reset()

func (*ChangePeerV2Request) Size 

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

func (*ChangePeerV2Request) String 

func (m *ChangePeerV2Request) String() string

func (*ChangePeerV2Request) Unmarshal 

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

func (*ChangePeerV2Request) XXX_DiscardUnknown 

func (m *ChangePeerV2Request) XXX_DiscardUnknown()

func (*ChangePeerV2Request) XXX_Marshal 

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

func (*ChangePeerV2Request) XXX_Merge 

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

func (*ChangePeerV2Request) XXX_Size 

func (m *ChangePeerV2Request) XXX_Size() int

func (*ChangePeerV2Request) XXX_Unmarshal 

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

type ChangePeerV2Response 

type ChangePeerV2Response struct {
	Shard                *bhmetapb.Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ChangePeerV2Response) Descriptor 

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

func (*ChangePeerV2Response) GetShard 

func (m *ChangePeerV2Response) GetShard() *bhmetapb.Shard

func (*ChangePeerV2Response) Marshal 

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

func (*ChangePeerV2Response) MarshalTo 

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

func (*ChangePeerV2Response) ProtoMessage 

func (*ChangePeerV2Response) ProtoMessage()

func (*ChangePeerV2Response) Reset 

func (m *ChangePeerV2Response) Reset()

func (*ChangePeerV2Response) Size 

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

func (*ChangePeerV2Response) String 

func (m *ChangePeerV2Response) String() string

func (*ChangePeerV2Response) Unmarshal 

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

func (*ChangePeerV2Response) XXX_DiscardUnknown 

func (m *ChangePeerV2Response) XXX_DiscardUnknown()

func (*ChangePeerV2Response) XXX_Marshal 

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

func (*ChangePeerV2Response) XXX_Merge 

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

func (*ChangePeerV2Response) XXX_Size 

func (m *ChangePeerV2Response) XXX_Size() int

func (*ChangePeerV2Response) XXX_Unmarshal 

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

type CompactLogRequest 

type CompactLogRequest 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CompactLogRequest compact raft log

func (*CompactLogRequest) Descriptor 

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

func (*CompactLogRequest) GetCompactIndex 

func (m *CompactLogRequest) GetCompactIndex() uint64

func (*CompactLogRequest) GetCompactTerm 

func (m *CompactLogRequest) GetCompactTerm() uint64

func (*CompactLogRequest) Marshal 

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

func (*CompactLogRequest) MarshalTo 

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

func (*CompactLogRequest) ProtoMessage 

func (*CompactLogRequest) ProtoMessage()

func (*CompactLogRequest) Reset 

func (m *CompactLogRequest) Reset()

func (*CompactLogRequest) Size 

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

func (*CompactLogRequest) String 

func (m *CompactLogRequest) String() string

func (*CompactLogRequest) Unmarshal 

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

func (*CompactLogRequest) XXX_DiscardUnknown 

func (m *CompactLogRequest) XXX_DiscardUnknown()

func (*CompactLogRequest) XXX_Marshal 

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

func (*CompactLogRequest) XXX_Merge 

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

func (*CompactLogRequest) XXX_Size 

func (m *CompactLogRequest) XXX_Size() int

func (*CompactLogRequest) XXX_Unmarshal 

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

type CompactLogResponse 

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

CompactLogResponse compact raft log

func (*CompactLogResponse) Descriptor 

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

func (*CompactLogResponse) Marshal 

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

func (*CompactLogResponse) MarshalTo 

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

func (*CompactLogResponse) ProtoMessage 

func (*CompactLogResponse) ProtoMessage()

func (*CompactLogResponse) Reset 

func (m *CompactLogResponse) Reset()

func (*CompactLogResponse) Size 

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

func (*CompactLogResponse) String 

func (m *CompactLogResponse) String() string

func (*CompactLogResponse) Unmarshal 

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

func (*CompactLogResponse) XXX_DiscardUnknown 

func (m *CompactLogResponse) XXX_DiscardUnknown()

func (*CompactLogResponse) XXX_Marshal 

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

func (*CompactLogResponse) XXX_Merge 

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

func (*CompactLogResponse) XXX_Size 

func (m *CompactLogResponse) XXX_Size() int

func (*CompactLogResponse) XXX_Unmarshal 

func (m *CompactLogResponse) 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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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) 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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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) 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"`
	Epoch                metapb.ResourceEpoch `protobuf:"bytes,5,opt,name=epoch,proto3" json:"epoch"`
	Term                 uint64               `protobuf:"varint,6,opt,name=term,proto3" json:"term,omitempty"`
	IgnoreEpochCheck     bool                 `protobuf:"varint,7,opt,name=ignoreEpochCheck,proto3" json:"ignoreEpochCheck,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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

func (*RaftRequestHeader) Descriptor 

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

func (*RaftRequestHeader) GetEpoch 

func (m *RaftRequestHeader) GetEpoch() metapb.ResourceEpoch

func (*RaftRequestHeader) GetID 

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

func (*RaftRequestHeader) GetIgnoreEpochCheck 

func (m *RaftRequestHeader) GetIgnoreEpochCheck() bool

func (*RaftRequestHeader) GetPeer 

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

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) 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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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) 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"`
	IgnoreEpochCheck     bool     `protobuf:"varint,13,opt,name=ignoreEpochCheck,proto3" json:"ignoreEpochCheck,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) GetIgnoreEpochCheck 

func (m *Request) GetIgnoreEpochCheck() bool

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) 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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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) 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 split_key must be in the been splitting region.
	SplitKey []byte `protobuf:"bytes,1,opt,name=splitKey,proto3" json:"splitKey,omitempty"`
	// We split the region into two, first uses the origin
	// parent region id, and the second uses the new_region_id.
	// We must guarantee that the new_region_id is global unique.
	NewShardID uint64 `protobuf:"varint,2,opt,name=newShardID,proto3" json:"newShardID,omitempty"`
	// The peer ids for the new split region.
	NewPeerIDs           []uint64 `protobuf:"varint,3,rep,packed,name=newPeerIDs,proto3" json:"newPeerIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) 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) 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 TransferLeaderRequest 

type TransferLeaderRequest struct {
	Peer                 metapb.Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

TransferLeaderRequest transfer leader

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) 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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) 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

type VerifyHashRequest 

type VerifyHashRequest struct {
	Index                uint64   `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Hash                 []byte   `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	Context              []byte   `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VerifyHashRequest) Descriptor 

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

func (*VerifyHashRequest) GetContext 

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

func (*VerifyHashRequest) GetHash 

func (m *VerifyHashRequest) GetHash() []byte

func (*VerifyHashRequest) GetIndex 

func (m *VerifyHashRequest) GetIndex() uint64

func (*VerifyHashRequest) Marshal 

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

func (*VerifyHashRequest) MarshalTo 

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

func (*VerifyHashRequest) ProtoMessage 

func (*VerifyHashRequest) ProtoMessage()

func (*VerifyHashRequest) Reset 

func (m *VerifyHashRequest) Reset()

func (*VerifyHashRequest) Size 

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

func (*VerifyHashRequest) String 

func (m *VerifyHashRequest) String() string

func (*VerifyHashRequest) Unmarshal 

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

func (*VerifyHashRequest) XXX_DiscardUnknown 

func (m *VerifyHashRequest) XXX_DiscardUnknown()

func (*VerifyHashRequest) XXX_Marshal 

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

func (*VerifyHashRequest) XXX_Merge 

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

func (*VerifyHashRequest) XXX_Size 

func (m *VerifyHashRequest) XXX_Size() int

func (*VerifyHashRequest) XXX_Unmarshal 

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

type VerifyHashResponse 

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

func (*VerifyHashResponse) Descriptor 

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

func (*VerifyHashResponse) Marshal 

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

func (*VerifyHashResponse) MarshalTo 

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

func (*VerifyHashResponse) ProtoMessage 

func (*VerifyHashResponse) ProtoMessage()

func (*VerifyHashResponse) Reset 

func (m *VerifyHashResponse) Reset()

func (*VerifyHashResponse) Size 

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

func (*VerifyHashResponse) String 

func (m *VerifyHashResponse) String() string

func (*VerifyHashResponse) Unmarshal 

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

func (*VerifyHashResponse) XXX_DiscardUnknown 

func (m *VerifyHashResponse) XXX_DiscardUnknown()

func (*VerifyHashResponse) XXX_Marshal 

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

func (*VerifyHashResponse) XXX_Merge 

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

func (*VerifyHashResponse) XXX_Size 

func (m *VerifyHashResponse) XXX_Size() int

func (*VerifyHashResponse) XXX_Unmarshal 

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