raft_cmdpb

package
v0.0.0-...-4fa2b26 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2024 License: Apache-2.0 Imports: 11 Imported by: 30

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:  "CompactLog",
	4:  "TransferLeader",
	5:  "ComputeHash",
	6:  "VerifyHash",
	7:  "PrepareMerge",
	8:  "CommitMerge",
	9:  "RollbackMerge",
	10: "BatchSplit",
	11: "ChangePeerV2",
	12: "PrepareFlashback",
	13: "FinishFlashback",
	14: "BatchSwitchWitness",
	15: "UpdateGcPeer",
}
View Source 
var AdminCmdType_value = map[string]int32{
	"InvalidAdmin":       0,
	"ChangePeer":         1,
	"Split":              2,
	"CompactLog":         3,
	"TransferLeader":     4,
	"ComputeHash":        5,
	"VerifyHash":         6,
	"PrepareMerge":       7,
	"CommitMerge":        8,
	"RollbackMerge":      9,
	"BatchSplit":         10,
	"ChangePeerV2":       11,
	"PrepareFlashback":   12,
	"FinishFlashback":    13,
	"BatchSwitchWitness": 14,
	"UpdateGcPeer":       15,
}
View Source 
var CmdType_name = map[int32]string{
	0: "Invalid",
	1: "Get",
	3: "Put",
	4: "Delete",
	5: "Snap",
	6: "Prewrite",
	7: "DeleteRange",
	8: "IngestSST",
	9: "ReadIndex",
}
View Source 
var CmdType_value = map[string]int32{
	"Invalid":     0,
	"Get":         1,
	"Put":         3,
	"Delete":      4,
	"Snap":        5,
	"Prewrite":    6,
	"DeleteRange": 7,
	"IngestSST":   8,
	"ReadIndex":   9,
}
View Source 
var StatusCmdType_name = map[int32]string{
	0: "InvalidStatus",
	1: "RegionLeader",
	2: "RegionDetail",
}
View Source 
var StatusCmdType_value = map[string]int32{
	"InvalidStatus": 0,
	"RegionLeader":  1,
	"RegionDetail":  2,
}

Functions

This section is empty.

Types

type AdminCmdType 

type AdminCmdType int32
const (
	AdminCmdType_InvalidAdmin AdminCmdType = 0
	AdminCmdType_ChangePeer   AdminCmdType = 1
	// Use `BatchSplit` instead.
	AdminCmdType_Split              AdminCmdType = 2 // Deprecated: Do not use.
	AdminCmdType_CompactLog         AdminCmdType = 3
	AdminCmdType_TransferLeader     AdminCmdType = 4
	AdminCmdType_ComputeHash        AdminCmdType = 5
	AdminCmdType_VerifyHash         AdminCmdType = 6
	AdminCmdType_PrepareMerge       AdminCmdType = 7
	AdminCmdType_CommitMerge        AdminCmdType = 8
	AdminCmdType_RollbackMerge      AdminCmdType = 9
	AdminCmdType_BatchSplit         AdminCmdType = 10
	AdminCmdType_ChangePeerV2       AdminCmdType = 11
	AdminCmdType_PrepareFlashback   AdminCmdType = 12
	AdminCmdType_FinishFlashback    AdminCmdType = 13
	AdminCmdType_BatchSwitchWitness AdminCmdType = 14
	// Command that updates RegionLocalState.gc_peers
	AdminCmdType_UpdateGcPeer AdminCmdType = 15
)

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=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.AdminCmdType" json:"cmd_type,omitempty"`
	ChangePeer           *ChangePeerRequest         `protobuf:"bytes,2,opt,name=change_peer,json=changePeer,proto3" json:"change_peer,omitempty"`
	Split                *SplitRequest              `protobuf:"bytes,3,opt,name=split,proto3" json:"split,omitempty"` // Deprecated: Do not use.
	CompactLog           *CompactLogRequest         `protobuf:"bytes,4,opt,name=compact_log,json=compactLog,proto3" json:"compact_log,omitempty"`
	TransferLeader       *TransferLeaderRequest     `protobuf:"bytes,5,opt,name=transfer_leader,json=transferLeader,proto3" json:"transfer_leader,omitempty"`
	VerifyHash           *VerifyHashRequest         `protobuf:"bytes,6,opt,name=verify_hash,json=verifyHash,proto3" json:"verify_hash,omitempty"`
	PrepareMerge         *PrepareMergeRequest       `protobuf:"bytes,7,opt,name=prepare_merge,json=prepareMerge,proto3" json:"prepare_merge,omitempty"`
	CommitMerge          *CommitMergeRequest        `protobuf:"bytes,8,opt,name=commit_merge,json=commitMerge,proto3" json:"commit_merge,omitempty"`
	RollbackMerge        *RollbackMergeRequest      `protobuf:"bytes,9,opt,name=rollback_merge,json=rollbackMerge,proto3" json:"rollback_merge,omitempty"`
	Splits               *BatchSplitRequest         `protobuf:"bytes,10,opt,name=splits,proto3" json:"splits,omitempty"`
	ChangePeerV2         *ChangePeerV2Request       `protobuf:"bytes,11,opt,name=change_peer_v2,json=changePeerV2,proto3" json:"change_peer_v2,omitempty"`
	ComputeHash          *ComputeHashRequest        `protobuf:"bytes,12,opt,name=compute_hash,json=computeHash,proto3" json:"compute_hash,omitempty"`
	PrepareFlashback     *PrepareFlashbackRequest   `protobuf:"bytes,13,opt,name=prepare_flashback,json=prepareFlashback,proto3" json:"prepare_flashback,omitempty"`
	FinishFlashback      *FinishFlashbackRequest    `protobuf:"bytes,14,opt,name=finish_flashback,json=finishFlashback,proto3" json:"finish_flashback,omitempty"`
	SwitchWitnesses      *BatchSwitchWitnessRequest `protobuf:"bytes,15,opt,name=switch_witnesses,json=switchWitnesses,proto3" json:"switch_witnesses,omitempty"`
	UpdateGcPeers        *UpdateGcPeerRequest       `protobuf:"bytes,16,opt,name=update_gc_peers,json=updateGcPeers,proto3" json:"update_gc_peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

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

func (m *AdminRequest) GetCommitMerge() *CommitMergeRequest

func (*AdminRequest) GetCompactLog 

func (m *AdminRequest) GetCompactLog() *CompactLogRequest

func (*AdminRequest) GetComputeHash 

func (m *AdminRequest) GetComputeHash() *ComputeHashRequest

func (*AdminRequest) GetFinishFlashback 

func (m *AdminRequest) GetFinishFlashback() *FinishFlashbackRequest

func (*AdminRequest) GetPrepareFlashback 

func (m *AdminRequest) GetPrepareFlashback() *PrepareFlashbackRequest

func (*AdminRequest) GetPrepareMerge 

func (m *AdminRequest) GetPrepareMerge() *PrepareMergeRequest

func (*AdminRequest) GetRollbackMerge 

func (m *AdminRequest) GetRollbackMerge() *RollbackMergeRequest

func (*AdminRequest) GetSplit deprecated 

func (m *AdminRequest) GetSplit() *SplitRequest

Deprecated: Do not use.

func (*AdminRequest) GetSplits 

func (m *AdminRequest) GetSplits() *BatchSplitRequest

func (*AdminRequest) GetSwitchWitnesses 

func (m *AdminRequest) GetSwitchWitnesses() *BatchSwitchWitnessRequest

func (*AdminRequest) GetTransferLeader 

func (m *AdminRequest) GetTransferLeader() *TransferLeaderRequest

func (*AdminRequest) GetUpdateGcPeers 

func (m *AdminRequest) GetUpdateGcPeers() *UpdateGcPeerRequest

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) 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 {
	CmdType              AdminCmdType                `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.AdminCmdType" json:"cmd_type,omitempty"`
	ChangePeer           *ChangePeerResponse         `protobuf:"bytes,2,opt,name=change_peer,json=changePeer,proto3" json:"change_peer,omitempty"`
	Split                *SplitResponse              `protobuf:"bytes,3,opt,name=split,proto3" json:"split,omitempty"` // Deprecated: Do not use.
	CompactLog           *CompactLogResponse         `protobuf:"bytes,4,opt,name=compact_log,json=compactLog,proto3" json:"compact_log,omitempty"`
	TransferLeader       *TransferLeaderResponse     `protobuf:"bytes,5,opt,name=transfer_leader,json=transferLeader,proto3" json:"transfer_leader,omitempty"`
	VerifyHash           *VerifyHashResponse         `protobuf:"bytes,6,opt,name=verify_hash,json=verifyHash,proto3" json:"verify_hash,omitempty"`
	PrepareMerge         *PrepareMergeResponse       `protobuf:"bytes,7,opt,name=prepare_merge,json=prepareMerge,proto3" json:"prepare_merge,omitempty"`
	CommitMerge          *CommitMergeResponse        `protobuf:"bytes,8,opt,name=commit_merge,json=commitMerge,proto3" json:"commit_merge,omitempty"`
	RollbackMerge        *RollbackMergeResponse      `protobuf:"bytes,9,opt,name=rollback_merge,json=rollbackMerge,proto3" json:"rollback_merge,omitempty"`
	Splits               *BatchSplitResponse         `protobuf:"bytes,10,opt,name=splits,proto3" json:"splits,omitempty"`
	ChangePeerV2         *ChangePeerV2Response       `protobuf:"bytes,11,opt,name=change_peer_v2,json=changePeerV2,proto3" json:"change_peer_v2,omitempty"`
	PrepareFlashback     *PrepareFlashbackResponse   `protobuf:"bytes,12,opt,name=prepare_flashback,json=prepareFlashback,proto3" json:"prepare_flashback,omitempty"`
	FinishFlashback      *FinishFlashbackResponse    `protobuf:"bytes,13,opt,name=finish_flashback,json=finishFlashback,proto3" json:"finish_flashback,omitempty"`
	SwitchWitnesses      *BatchSwitchWitnessResponse `protobuf:"bytes,14,opt,name=switch_witnesses,json=switchWitnesses,proto3" json:"switch_witnesses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

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

func (m *AdminResponse) GetCommitMerge() *CommitMergeResponse

func (*AdminResponse) GetCompactLog 

func (m *AdminResponse) GetCompactLog() *CompactLogResponse

func (*AdminResponse) GetFinishFlashback 

func (m *AdminResponse) GetFinishFlashback() *FinishFlashbackResponse

func (*AdminResponse) GetPrepareFlashback 

func (m *AdminResponse) GetPrepareFlashback() *PrepareFlashbackResponse

func (*AdminResponse) GetPrepareMerge 

func (m *AdminResponse) GetPrepareMerge() *PrepareMergeResponse

func (*AdminResponse) GetRollbackMerge 

func (m *AdminResponse) GetRollbackMerge() *RollbackMergeResponse

func (*AdminResponse) GetSplit deprecated 

func (m *AdminResponse) GetSplit() *SplitResponse

Deprecated: Do not use.

func (*AdminResponse) GetSplits 

func (m *AdminResponse) GetSplits() *BatchSplitResponse

func (*AdminResponse) GetSwitchWitnesses 

func (m *AdminResponse) GetSwitchWitnesses() *BatchSwitchWitnessResponse

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

type BatchSplitRequest struct {
	Requests []*SplitRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// If true, the last region derive the origin region_id,
	// other regions use new ids.
	RightDerive bool `protobuf:"varint,2,opt,name=right_derive,json=rightDerive,proto3" json:"right_derive,omitempty"`
	// It should be false iff the region split by user key such as split table or create partion table etc,
	// the new region's will not share the source region size, so it's region size is zero.
	// It should be true iff the region's load reaches the threshold such as size, keys, load check etc,
	// the new region's size will share the origin region, so it's region size is half of the source region.
	ShareSourceRegionSize bool     `` /* 129-byte string literal not displayed */
	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) GetShareSourceRegionSize 

func (m *BatchSplitRequest) GetShareSourceRegionSize() 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) MarshalToSizedBuffer 

func (m *BatchSplitRequest) MarshalToSizedBuffer(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 {
	Regions              []*metapb.Region `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*BatchSplitResponse) Descriptor 

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

func (*BatchSplitResponse) GetRegions 

func (m *BatchSplitResponse) GetRegions() []*metapb.Region

func (*BatchSplitResponse) Marshal 

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

func (*BatchSplitResponse) MarshalTo 

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

func (*BatchSplitResponse) MarshalToSizedBuffer 

func (m *BatchSplitResponse) MarshalToSizedBuffer(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 BatchSwitchWitnessRequest 

type BatchSwitchWitnessRequest struct {
	SwitchWitnesses      []*SwitchWitnessRequest `protobuf:"bytes,1,rep,name=switch_witnesses,json=switchWitnesses,proto3" json:"switch_witnesses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*BatchSwitchWitnessRequest) Descriptor 

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

func (*BatchSwitchWitnessRequest) GetSwitchWitnesses 

func (m *BatchSwitchWitnessRequest) GetSwitchWitnesses() []*SwitchWitnessRequest

func (*BatchSwitchWitnessRequest) Marshal 

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

func (*BatchSwitchWitnessRequest) MarshalTo 

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

func (*BatchSwitchWitnessRequest) MarshalToSizedBuffer 

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

func (*BatchSwitchWitnessRequest) ProtoMessage 

func (*BatchSwitchWitnessRequest) ProtoMessage()

func (*BatchSwitchWitnessRequest) Reset 

func (m *BatchSwitchWitnessRequest) Reset()

func (*BatchSwitchWitnessRequest) Size 

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

func (*BatchSwitchWitnessRequest) String 

func (m *BatchSwitchWitnessRequest) String() string

func (*BatchSwitchWitnessRequest) Unmarshal 

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

func (*BatchSwitchWitnessRequest) XXX_DiscardUnknown 

func (m *BatchSwitchWitnessRequest) XXX_DiscardUnknown()

func (*BatchSwitchWitnessRequest) XXX_Marshal 

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

func (*BatchSwitchWitnessRequest) XXX_Merge 

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

func (*BatchSwitchWitnessRequest) XXX_Size 

func (m *BatchSwitchWitnessRequest) XXX_Size() int

func (*BatchSwitchWitnessRequest) XXX_Unmarshal 

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

type BatchSwitchWitnessResponse 

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

func (*BatchSwitchWitnessResponse) Descriptor 

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

func (*BatchSwitchWitnessResponse) Marshal 

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

func (*BatchSwitchWitnessResponse) MarshalTo 

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

func (*BatchSwitchWitnessResponse) MarshalToSizedBuffer 

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

func (*BatchSwitchWitnessResponse) ProtoMessage 

func (*BatchSwitchWitnessResponse) ProtoMessage()

func (*BatchSwitchWitnessResponse) Reset 

func (m *BatchSwitchWitnessResponse) Reset()

func (*BatchSwitchWitnessResponse) Size 

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

func (*BatchSwitchWitnessResponse) String 

func (m *BatchSwitchWitnessResponse) String() string

func (*BatchSwitchWitnessResponse) Unmarshal 

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

func (*BatchSwitchWitnessResponse) XXX_DiscardUnknown 

func (m *BatchSwitchWitnessResponse) XXX_DiscardUnknown()

func (*BatchSwitchWitnessResponse) XXX_Marshal 

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

func (*BatchSwitchWitnessResponse) XXX_Merge 

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

func (*BatchSwitchWitnessResponse) XXX_Size 

func (m *BatchSwitchWitnessResponse) XXX_Size() int

func (*BatchSwitchWitnessResponse) XXX_Unmarshal 

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

type ChangePeerRequest 

type ChangePeerRequest struct {
	// This can be only called in internal RaftStore now.
	ChangeType           eraftpb.ConfChangeType `protobuf:"varint,1,opt,name=change_type,json=changeType,proto3,enum=eraftpb.ConfChangeType" json:"change_type,omitempty"`
	Peer                 *metapb.Peer           `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	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() eraftpb.ConfChangeType

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 {
	Region               *metapb.Region `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ChangePeerResponse) Descriptor 

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

func (*ChangePeerResponse) GetRegion 

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

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 ChangePeerV2Request 

type ChangePeerV2Request struct {
	Changes              []*ChangePeerRequest `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes,omitempty"`
	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) MarshalToSizedBuffer 

func (m *ChangePeerV2Request) MarshalToSizedBuffer(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 {
	Region               *metapb.Region `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ChangePeerV2Response) Descriptor 

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

func (*ChangePeerV2Response) GetRegion 

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

func (*ChangePeerV2Response) Marshal 

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

func (*ChangePeerV2Response) MarshalTo 

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

func (*ChangePeerV2Response) MarshalToSizedBuffer 

func (m *ChangePeerV2Response) MarshalToSizedBuffer(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 CmdType 

type CmdType int32
const (
	CmdType_Invalid     CmdType = 0
	CmdType_Get         CmdType = 1
	CmdType_Put         CmdType = 3
	CmdType_Delete      CmdType = 4
	CmdType_Snap        CmdType = 5
	CmdType_Prewrite    CmdType = 6
	CmdType_DeleteRange CmdType = 7
	CmdType_IngestSST   CmdType = 8
	CmdType_ReadIndex   CmdType = 9
)

func (CmdType) EnumDescriptor 

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

func (CmdType) String 

func (x CmdType) String() string

type CommitMergeRequest 

type CommitMergeRequest struct {
	Source  *metapb.Region   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Commit  uint64           `protobuf:"varint,2,opt,name=commit,proto3" json:"commit,omitempty"`
	Entries []*eraftpb.Entry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	// Used in v2. When it's present, `source` and `commit` will not be set.
	SourceState          *raft_serverpb.RegionLocalState `protobuf:"bytes,4,opt,name=source_state,json=sourceState,proto3" json:"source_state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*CommitMergeRequest) Descriptor 

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

func (*CommitMergeRequest) GetCommit 

func (m *CommitMergeRequest) GetCommit() uint64

func (*CommitMergeRequest) GetEntries 

func (m *CommitMergeRequest) GetEntries() []*eraftpb.Entry

func (*CommitMergeRequest) GetSource 

func (m *CommitMergeRequest) GetSource() *metapb.Region

func (*CommitMergeRequest) GetSourceState 

func (m *CommitMergeRequest) GetSourceState() *raft_serverpb.RegionLocalState

func (*CommitMergeRequest) Marshal 

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

func (*CommitMergeRequest) MarshalTo 

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

func (*CommitMergeRequest) MarshalToSizedBuffer 

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

func (*CommitMergeRequest) ProtoMessage 

func (*CommitMergeRequest) ProtoMessage()

func (*CommitMergeRequest) Reset 

func (m *CommitMergeRequest) Reset()

func (*CommitMergeRequest) Size 

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

func (*CommitMergeRequest) String 

func (m *CommitMergeRequest) String() string

func (*CommitMergeRequest) Unmarshal 

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

func (*CommitMergeRequest) XXX_DiscardUnknown 

func (m *CommitMergeRequest) XXX_DiscardUnknown()

func (*CommitMergeRequest) XXX_Marshal 

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

func (*CommitMergeRequest) XXX_Merge 

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

func (*CommitMergeRequest) XXX_Size 

func (m *CommitMergeRequest) XXX_Size() int

func (*CommitMergeRequest) XXX_Unmarshal 

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

type CommitMergeResponse 

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

func (*CommitMergeResponse) Descriptor 

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

func (*CommitMergeResponse) Marshal 

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

func (*CommitMergeResponse) MarshalTo 

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

func (*CommitMergeResponse) MarshalToSizedBuffer 

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

func (*CommitMergeResponse) ProtoMessage 

func (*CommitMergeResponse) ProtoMessage()

func (*CommitMergeResponse) Reset 

func (m *CommitMergeResponse) Reset()

func (*CommitMergeResponse) Size 

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

func (*CommitMergeResponse) String 

func (m *CommitMergeResponse) String() string

func (*CommitMergeResponse) Unmarshal 

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

func (*CommitMergeResponse) XXX_DiscardUnknown 

func (m *CommitMergeResponse) XXX_DiscardUnknown()

func (*CommitMergeResponse) XXX_Marshal 

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

func (*CommitMergeResponse) XXX_Merge 

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

func (*CommitMergeResponse) XXX_Size 

func (m *CommitMergeResponse) XXX_Size() int

func (*CommitMergeResponse) XXX_Unmarshal 

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

type CompactLogRequest 

type CompactLogRequest struct {
	CompactIndex         uint64   `protobuf:"varint,1,opt,name=compact_index,json=compactIndex,proto3" json:"compact_index,omitempty"`
	CompactTerm          uint64   `protobuf:"varint,2,opt,name=compact_term,json=compactTerm,proto3" json:"compact_term,omitempty"`
	VoterReplicatedIndex uint64   `protobuf:"varint,3,opt,name=voter_replicated_index,json=voterReplicatedIndex,proto3" json:"voter_replicated_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (m *CompactLogRequest) GetVoterReplicatedIndex() 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) MarshalToSizedBuffer 

func (m *CompactLogRequest) MarshalToSizedBuffer(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:"-"`
}

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

func (m *CompactLogResponse) MarshalToSizedBuffer(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 ComputeHashRequest 

type ComputeHashRequest struct {
	Context              []byte   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ComputeHashRequest) Descriptor 

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

func (*ComputeHashRequest) GetContext 

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

func (*ComputeHashRequest) Marshal 

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

func (*ComputeHashRequest) MarshalTo 

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

func (*ComputeHashRequest) MarshalToSizedBuffer 

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

func (*ComputeHashRequest) ProtoMessage 

func (*ComputeHashRequest) ProtoMessage()

func (*ComputeHashRequest) Reset 

func (m *ComputeHashRequest) Reset()

func (*ComputeHashRequest) Size 

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

func (*ComputeHashRequest) String 

func (m *ComputeHashRequest) String() string

func (*ComputeHashRequest) Unmarshal 

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

func (*ComputeHashRequest) XXX_DiscardUnknown 

func (m *ComputeHashRequest) XXX_DiscardUnknown()

func (*ComputeHashRequest) XXX_Marshal 

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

func (*ComputeHashRequest) XXX_Merge 

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

func (*ComputeHashRequest) XXX_Size 

func (m *ComputeHashRequest) XXX_Size() int

func (*ComputeHashRequest) XXX_Unmarshal 

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

type DeleteRangeRequest 

type DeleteRangeRequest struct {
	Cf                   string   `protobuf:"bytes,1,opt,name=cf,proto3" json:"cf,omitempty"`
	StartKey             []byte   `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey               []byte   `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	NotifyOnly           bool     `protobuf:"varint,4,opt,name=notify_only,json=notifyOnly,proto3" json:"notify_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRangeRequest) Descriptor 

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

func (*DeleteRangeRequest) GetCf 

func (m *DeleteRangeRequest) GetCf() string

func (*DeleteRangeRequest) GetEndKey 

func (m *DeleteRangeRequest) GetEndKey() []byte

func (*DeleteRangeRequest) GetNotifyOnly 

func (m *DeleteRangeRequest) GetNotifyOnly() bool

func (*DeleteRangeRequest) GetStartKey 

func (m *DeleteRangeRequest) GetStartKey() []byte

func (*DeleteRangeRequest) Marshal 

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

func (*DeleteRangeRequest) MarshalTo 

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

func (*DeleteRangeRequest) MarshalToSizedBuffer 

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

func (*DeleteRangeRequest) ProtoMessage 

func (*DeleteRangeRequest) ProtoMessage()

func (*DeleteRangeRequest) Reset 

func (m *DeleteRangeRequest) Reset()

func (*DeleteRangeRequest) Size 

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

func (*DeleteRangeRequest) String 

func (m *DeleteRangeRequest) String() string

func (*DeleteRangeRequest) Unmarshal 

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

func (*DeleteRangeRequest) XXX_DiscardUnknown 

func (m *DeleteRangeRequest) XXX_DiscardUnknown()

func (*DeleteRangeRequest) XXX_Marshal 

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

func (*DeleteRangeRequest) XXX_Merge 

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

func (*DeleteRangeRequest) XXX_Size 

func (m *DeleteRangeRequest) XXX_Size() int

func (*DeleteRangeRequest) XXX_Unmarshal 

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

type DeleteRangeResponse 

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

func (*DeleteRangeResponse) Descriptor 

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

func (*DeleteRangeResponse) Marshal 

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

func (*DeleteRangeResponse) MarshalTo 

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

func (*DeleteRangeResponse) MarshalToSizedBuffer 

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

func (*DeleteRangeResponse) ProtoMessage 

func (*DeleteRangeResponse) ProtoMessage()

func (*DeleteRangeResponse) Reset 

func (m *DeleteRangeResponse) Reset()

func (*DeleteRangeResponse) Size 

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

func (*DeleteRangeResponse) String 

func (m *DeleteRangeResponse) String() string

func (*DeleteRangeResponse) Unmarshal 

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

func (*DeleteRangeResponse) XXX_DiscardUnknown 

func (m *DeleteRangeResponse) XXX_DiscardUnknown()

func (*DeleteRangeResponse) XXX_Marshal 

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

func (*DeleteRangeResponse) XXX_Merge 

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

func (*DeleteRangeResponse) XXX_Size 

func (m *DeleteRangeResponse) XXX_Size() int

func (*DeleteRangeResponse) XXX_Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	Cf                   string   `protobuf:"bytes,1,opt,name=cf,proto3" json:"cf,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetCf 

func (m *DeleteRequest) GetCf() string

func (*DeleteRequest) GetKey 

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

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) MarshalToSizedBuffer 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeleteResponse 

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

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) Marshal 

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

func (*DeleteResponse) MarshalTo 

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

func (*DeleteResponse) MarshalToSizedBuffer 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

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

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

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

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

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

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type FinishFlashbackRequest 

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

func (*FinishFlashbackRequest) Descriptor 

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

func (*FinishFlashbackRequest) Marshal 

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

func (*FinishFlashbackRequest) MarshalTo 

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

func (*FinishFlashbackRequest) MarshalToSizedBuffer 

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

func (*FinishFlashbackRequest) ProtoMessage 

func (*FinishFlashbackRequest) ProtoMessage()

func (*FinishFlashbackRequest) Reset 

func (m *FinishFlashbackRequest) Reset()

func (*FinishFlashbackRequest) Size 

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

func (*FinishFlashbackRequest) String 

func (m *FinishFlashbackRequest) String() string

func (*FinishFlashbackRequest) Unmarshal 

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

func (*FinishFlashbackRequest) XXX_DiscardUnknown 

func (m *FinishFlashbackRequest) XXX_DiscardUnknown()

func (*FinishFlashbackRequest) XXX_Marshal 

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

func (*FinishFlashbackRequest) XXX_Merge 

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

func (*FinishFlashbackRequest) XXX_Size 

func (m *FinishFlashbackRequest) XXX_Size() int

func (*FinishFlashbackRequest) XXX_Unmarshal 

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

type FinishFlashbackResponse 

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

func (*FinishFlashbackResponse) Descriptor 

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

func (*FinishFlashbackResponse) Marshal 

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

func (*FinishFlashbackResponse) MarshalTo 

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

func (*FinishFlashbackResponse) MarshalToSizedBuffer 

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

func (*FinishFlashbackResponse) ProtoMessage 

func (*FinishFlashbackResponse) ProtoMessage()

func (*FinishFlashbackResponse) Reset 

func (m *FinishFlashbackResponse) Reset()

func (*FinishFlashbackResponse) Size 

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

func (*FinishFlashbackResponse) String 

func (m *FinishFlashbackResponse) String() string

func (*FinishFlashbackResponse) Unmarshal 

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

func (*FinishFlashbackResponse) XXX_DiscardUnknown 

func (m *FinishFlashbackResponse) XXX_DiscardUnknown()

func (*FinishFlashbackResponse) XXX_Marshal 

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

func (*FinishFlashbackResponse) XXX_Merge 

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

func (*FinishFlashbackResponse) XXX_Size 

func (m *FinishFlashbackResponse) XXX_Size() int

func (*FinishFlashbackResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Cf                   string   `protobuf:"bytes,1,opt,name=cf,proto3" json:"cf,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetCf 

func (m *GetRequest) GetCf() string

func (*GetRequest) GetKey 

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

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetValue 

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

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type IngestSSTRequest 

type IngestSSTRequest struct {
	Sst                  *import_sstpb.SSTMeta `protobuf:"bytes,1,opt,name=sst,proto3" json:"sst,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*IngestSSTRequest) Descriptor 

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

func (*IngestSSTRequest) GetSst 

func (m *IngestSSTRequest) GetSst() *import_sstpb.SSTMeta

func (*IngestSSTRequest) Marshal 

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

func (*IngestSSTRequest) MarshalTo 

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

func (*IngestSSTRequest) MarshalToSizedBuffer 

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

func (*IngestSSTRequest) ProtoMessage 

func (*IngestSSTRequest) ProtoMessage()

func (*IngestSSTRequest) Reset 

func (m *IngestSSTRequest) Reset()

func (*IngestSSTRequest) Size 

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

func (*IngestSSTRequest) String 

func (m *IngestSSTRequest) String() string

func (*IngestSSTRequest) Unmarshal 

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

func (*IngestSSTRequest) XXX_DiscardUnknown 

func (m *IngestSSTRequest) XXX_DiscardUnknown()

func (*IngestSSTRequest) XXX_Marshal 

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

func (*IngestSSTRequest) XXX_Merge 

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

func (*IngestSSTRequest) XXX_Size 

func (m *IngestSSTRequest) XXX_Size() int

func (*IngestSSTRequest) XXX_Unmarshal 

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

type IngestSSTResponse 

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

func (*IngestSSTResponse) Descriptor 

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

func (*IngestSSTResponse) Marshal 

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

func (*IngestSSTResponse) MarshalTo 

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

func (*IngestSSTResponse) MarshalToSizedBuffer 

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

func (*IngestSSTResponse) ProtoMessage 

func (*IngestSSTResponse) ProtoMessage()

func (*IngestSSTResponse) Reset 

func (m *IngestSSTResponse) Reset()

func (*IngestSSTResponse) Size 

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

func (*IngestSSTResponse) String 

func (m *IngestSSTResponse) String() string

func (*IngestSSTResponse) Unmarshal 

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

func (*IngestSSTResponse) XXX_DiscardUnknown 

func (m *IngestSSTResponse) XXX_DiscardUnknown()

func (*IngestSSTResponse) XXX_Marshal 

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

func (*IngestSSTResponse) XXX_Merge 

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

func (*IngestSSTResponse) XXX_Size 

func (m *IngestSSTResponse) XXX_Size() int

func (*IngestSSTResponse) XXX_Unmarshal 

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

type PrepareFlashbackRequest 

type PrepareFlashbackRequest struct {
	// The start_ts that the current flashback progress is using.
	StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrepareFlashbackRequest) Descriptor 

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

func (*PrepareFlashbackRequest) GetStartTs 

func (m *PrepareFlashbackRequest) GetStartTs() uint64

func (*PrepareFlashbackRequest) Marshal 

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

func (*PrepareFlashbackRequest) MarshalTo 

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

func (*PrepareFlashbackRequest) MarshalToSizedBuffer 

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

func (*PrepareFlashbackRequest) ProtoMessage 

func (*PrepareFlashbackRequest) ProtoMessage()

func (*PrepareFlashbackRequest) Reset 

func (m *PrepareFlashbackRequest) Reset()

func (*PrepareFlashbackRequest) Size 

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

func (*PrepareFlashbackRequest) String 

func (m *PrepareFlashbackRequest) String() string

func (*PrepareFlashbackRequest) Unmarshal 

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

func (*PrepareFlashbackRequest) XXX_DiscardUnknown 

func (m *PrepareFlashbackRequest) XXX_DiscardUnknown()

func (*PrepareFlashbackRequest) XXX_Marshal 

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

func (*PrepareFlashbackRequest) XXX_Merge 

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

func (*PrepareFlashbackRequest) XXX_Size 

func (m *PrepareFlashbackRequest) XXX_Size() int

func (*PrepareFlashbackRequest) XXX_Unmarshal 

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

type PrepareFlashbackResponse 

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

func (*PrepareFlashbackResponse) Descriptor 

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

func (*PrepareFlashbackResponse) Marshal 

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

func (*PrepareFlashbackResponse) MarshalTo 

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

func (*PrepareFlashbackResponse) MarshalToSizedBuffer 

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

func (*PrepareFlashbackResponse) ProtoMessage 

func (*PrepareFlashbackResponse) ProtoMessage()

func (*PrepareFlashbackResponse) Reset 

func (m *PrepareFlashbackResponse) Reset()

func (*PrepareFlashbackResponse) Size 

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

func (*PrepareFlashbackResponse) String 

func (m *PrepareFlashbackResponse) String() string

func (*PrepareFlashbackResponse) Unmarshal 

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

func (*PrepareFlashbackResponse) XXX_DiscardUnknown 

func (m *PrepareFlashbackResponse) XXX_DiscardUnknown()

func (*PrepareFlashbackResponse) XXX_Marshal 

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

func (*PrepareFlashbackResponse) XXX_Merge 

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

func (*PrepareFlashbackResponse) XXX_Size 

func (m *PrepareFlashbackResponse) XXX_Size() int

func (*PrepareFlashbackResponse) XXX_Unmarshal 

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

type PrepareMergeRequest 

type PrepareMergeRequest struct {
	MinIndex             uint64         `protobuf:"varint,1,opt,name=min_index,json=minIndex,proto3" json:"min_index,omitempty"`
	Target               *metapb.Region `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*PrepareMergeRequest) Descriptor 

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

func (*PrepareMergeRequest) GetMinIndex 

func (m *PrepareMergeRequest) GetMinIndex() uint64

func (*PrepareMergeRequest) GetTarget 

func (m *PrepareMergeRequest) GetTarget() *metapb.Region

func (*PrepareMergeRequest) Marshal 

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

func (*PrepareMergeRequest) MarshalTo 

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

func (*PrepareMergeRequest) MarshalToSizedBuffer 

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

func (*PrepareMergeRequest) ProtoMessage 

func (*PrepareMergeRequest) ProtoMessage()

func (*PrepareMergeRequest) Reset 

func (m *PrepareMergeRequest) Reset()

func (*PrepareMergeRequest) Size 

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

func (*PrepareMergeRequest) String 

func (m *PrepareMergeRequest) String() string

func (*PrepareMergeRequest) Unmarshal 

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

func (*PrepareMergeRequest) XXX_DiscardUnknown 

func (m *PrepareMergeRequest) XXX_DiscardUnknown()

func (*PrepareMergeRequest) XXX_Marshal 

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

func (*PrepareMergeRequest) XXX_Merge 

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

func (*PrepareMergeRequest) XXX_Size 

func (m *PrepareMergeRequest) XXX_Size() int

func (*PrepareMergeRequest) XXX_Unmarshal 

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

type PrepareMergeResponse 

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

func (*PrepareMergeResponse) Descriptor 

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

func (*PrepareMergeResponse) Marshal 

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

func (*PrepareMergeResponse) MarshalTo 

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

func (*PrepareMergeResponse) MarshalToSizedBuffer 

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

func (*PrepareMergeResponse) ProtoMessage 

func (*PrepareMergeResponse) ProtoMessage()

func (*PrepareMergeResponse) Reset 

func (m *PrepareMergeResponse) Reset()

func (*PrepareMergeResponse) Size 

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

func (*PrepareMergeResponse) String 

func (m *PrepareMergeResponse) String() string

func (*PrepareMergeResponse) Unmarshal 

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

func (*PrepareMergeResponse) XXX_DiscardUnknown 

func (m *PrepareMergeResponse) XXX_DiscardUnknown()

func (*PrepareMergeResponse) XXX_Marshal 

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

func (*PrepareMergeResponse) XXX_Merge 

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

func (*PrepareMergeResponse) XXX_Size 

func (m *PrepareMergeResponse) XXX_Size() int

func (*PrepareMergeResponse) XXX_Unmarshal 

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

type PrewriteRequest 

type PrewriteRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Lock                 []byte   `protobuf:"bytes,3,opt,name=lock,proto3" json:"lock,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrewriteRequest) Descriptor 

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

func (*PrewriteRequest) GetKey 

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

func (*PrewriteRequest) GetLock 

func (m *PrewriteRequest) GetLock() []byte

func (*PrewriteRequest) GetValue 

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

func (*PrewriteRequest) Marshal 

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

func (*PrewriteRequest) MarshalTo 

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

func (*PrewriteRequest) MarshalToSizedBuffer 

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

func (*PrewriteRequest) ProtoMessage 

func (*PrewriteRequest) ProtoMessage()

func (*PrewriteRequest) Reset 

func (m *PrewriteRequest) Reset()

func (*PrewriteRequest) Size 

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

func (*PrewriteRequest) String 

func (m *PrewriteRequest) String() string

func (*PrewriteRequest) Unmarshal 

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

func (*PrewriteRequest) XXX_DiscardUnknown 

func (m *PrewriteRequest) XXX_DiscardUnknown()

func (*PrewriteRequest) XXX_Marshal 

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

func (*PrewriteRequest) XXX_Merge 

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

func (*PrewriteRequest) XXX_Size 

func (m *PrewriteRequest) XXX_Size() int

func (*PrewriteRequest) XXX_Unmarshal 

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

type PrewriteResponse 

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

func (*PrewriteResponse) Descriptor 

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

func (*PrewriteResponse) Marshal 

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

func (*PrewriteResponse) MarshalTo 

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

func (*PrewriteResponse) MarshalToSizedBuffer 

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

func (*PrewriteResponse) ProtoMessage 

func (*PrewriteResponse) ProtoMessage()

func (*PrewriteResponse) Reset 

func (m *PrewriteResponse) Reset()

func (*PrewriteResponse) Size 

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

func (*PrewriteResponse) String 

func (m *PrewriteResponse) String() string

func (*PrewriteResponse) Unmarshal 

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

func (*PrewriteResponse) XXX_DiscardUnknown 

func (m *PrewriteResponse) XXX_DiscardUnknown()

func (*PrewriteResponse) XXX_Marshal 

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

func (*PrewriteResponse) XXX_Merge 

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

func (*PrewriteResponse) XXX_Size 

func (m *PrewriteResponse) XXX_Size() int

func (*PrewriteResponse) XXX_Unmarshal 

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

type PutRequest 

type PutRequest struct {
	Cf                   string   `protobuf:"bytes,1,opt,name=cf,proto3" json:"cf,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetCf 

func (m *PutRequest) GetCf() string

func (*PutRequest) GetKey 

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

func (*PutRequest) GetValue 

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

func (*PutRequest) Marshal 

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

func (*PutRequest) MarshalTo 

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

func (*PutRequest) MarshalToSizedBuffer 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) Size 

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

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) Unmarshal 

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

func (*PutRequest) XXX_DiscardUnknown 

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal 

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

func (*PutRequest) XXX_Merge 

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

func (*PutRequest) XXX_Size 

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal 

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

type PutResponse 

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

func (*PutResponse) Descriptor 

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

func (*PutResponse) Marshal 

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

func (*PutResponse) MarshalTo 

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

func (*PutResponse) MarshalToSizedBuffer 

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

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) Size 

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

func (*PutResponse) String 

func (m *PutResponse) String() string

func (*PutResponse) Unmarshal 

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

func (*PutResponse) XXX_DiscardUnknown 

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal 

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

func (*PutResponse) XXX_Merge 

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

func (*PutResponse) XXX_Size 

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal 

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

type RaftCmdRequest 

type RaftCmdRequest struct {
	Header *RaftRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// We can't enclose normal requests and administrator request
	// at same time.
	Requests             []*Request     `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	AdminRequest         *AdminRequest  `protobuf:"bytes,3,opt,name=admin_request,json=adminRequest,proto3" json:"admin_request,omitempty"`
	StatusRequest        *StatusRequest `protobuf:"bytes,4,opt,name=status_request,json=statusRequest,proto3" json:"status_request,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (m *RaftCmdRequest) GetStatusRequest() *StatusRequest

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=admin_response,json=adminResponse,proto3" json:"admin_response,omitempty"`
	StatusResponse       *StatusResponse     `protobuf:"bytes,4,opt,name=status_response,json=statusResponse,proto3" json:"status_response,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) GetStatusResponse 

func (m *RaftCmdResponse) GetStatusResponse() *StatusResponse

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 {
	RegionId uint64       `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Peer     *metapb.Peer `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	// true for read linearization
	ReadQuorum bool `protobuf:"varint,3,opt,name=read_quorum,json=readQuorum,proto3" json:"read_quorum,omitempty"`
	// 16 bytes, to distinguish request.
	Uuid        []byte              `protobuf:"bytes,4,opt,name=uuid,proto3" json:"uuid,omitempty"`
	RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,5,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
	Term        uint64              `protobuf:"varint,6,opt,name=term,proto3" json:"term,omitempty"`
	SyncLog     bool                `protobuf:"varint,7,opt,name=sync_log,json=syncLog,proto3" json:"sync_log,omitempty"`
	ReplicaRead bool                `protobuf:"varint,8,opt,name=replica_read,json=replicaRead,proto3" json:"replica_read,omitempty"`
	// Read requests can be responsed directly after the Raft applys to `applied_index`.
	AppliedIndex uint64 `protobuf:"varint,9,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	// Custom flags for this raft request.
	Flags                uint64             `protobuf:"varint,10,opt,name=flags,proto3" json:"flags,omitempty"`
	FlagData             []byte             `protobuf:"bytes,11,opt,name=flag_data,json=flagData,proto3" json:"flag_data,omitempty"`
	Priority             kvrpcpb.CommandPri `protobuf:"varint,12,opt,name=priority,proto3,enum=kvrpcpb.CommandPri" json:"priority,omitempty"`
	ResourceGroupName    string             `protobuf:"bytes,13,opt,name=resource_group_name,json=resourceGroupName,proto3" json:"resource_group_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*RaftRequestHeader) Descriptor 

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

func (*RaftRequestHeader) GetAppliedIndex 

func (m *RaftRequestHeader) GetAppliedIndex() uint64

func (*RaftRequestHeader) GetFlagData 

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

func (*RaftRequestHeader) GetFlags 

func (m *RaftRequestHeader) GetFlags() uint64

func (*RaftRequestHeader) GetPeer 

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

func (*RaftRequestHeader) GetPriority 

func (m *RaftRequestHeader) GetPriority() kvrpcpb.CommandPri

func (*RaftRequestHeader) GetReadQuorum 

func (m *RaftRequestHeader) GetReadQuorum() bool

func (*RaftRequestHeader) GetRegionEpoch 

func (m *RaftRequestHeader) GetRegionEpoch() *metapb.RegionEpoch

func (*RaftRequestHeader) GetRegionId 

func (m *RaftRequestHeader) GetRegionId() uint64

func (*RaftRequestHeader) GetReplicaRead 

func (m *RaftRequestHeader) GetReplicaRead() bool

func (*RaftRequestHeader) GetResourceGroupName 

func (m *RaftRequestHeader) GetResourceGroupName() string

func (*RaftRequestHeader) GetSyncLog 

func (m *RaftRequestHeader) GetSyncLog() bool

func (*RaftRequestHeader) GetTerm 

func (m *RaftRequestHeader) GetTerm() uint64

func (*RaftRequestHeader) GetUuid 

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

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 {
	Error                *errorpb.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Uuid                 []byte         `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	CurrentTerm          uint64         `protobuf:"varint,3,opt,name=current_term,json=currentTerm,proto3" json:"current_term,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) GetUuid 

func (m *RaftResponseHeader) GetUuid() []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 ReadIndexRequest 

type ReadIndexRequest struct {
	// In replica read, leader uses start_ts and key_ranges to check memory locks.
	StartTs              uint64              `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	KeyRanges            []*kvrpcpb.KeyRange `protobuf:"bytes,2,rep,name=key_ranges,json=keyRanges,proto3" json:"key_ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ReadIndexRequest) Descriptor 

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

func (*ReadIndexRequest) GetKeyRanges 

func (m *ReadIndexRequest) GetKeyRanges() []*kvrpcpb.KeyRange

func (*ReadIndexRequest) GetStartTs 

func (m *ReadIndexRequest) GetStartTs() uint64

func (*ReadIndexRequest) Marshal 

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

func (*ReadIndexRequest) MarshalTo 

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

func (*ReadIndexRequest) MarshalToSizedBuffer 

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

func (*ReadIndexRequest) ProtoMessage 

func (*ReadIndexRequest) ProtoMessage()

func (*ReadIndexRequest) Reset 

func (m *ReadIndexRequest) Reset()

func (*ReadIndexRequest) Size 

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

func (*ReadIndexRequest) String 

func (m *ReadIndexRequest) String() string

func (*ReadIndexRequest) Unmarshal 

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

func (*ReadIndexRequest) XXX_DiscardUnknown 

func (m *ReadIndexRequest) XXX_DiscardUnknown()

func (*ReadIndexRequest) XXX_Marshal 

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

func (*ReadIndexRequest) XXX_Merge 

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

func (*ReadIndexRequest) XXX_Size 

func (m *ReadIndexRequest) XXX_Size() int

func (*ReadIndexRequest) XXX_Unmarshal 

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

type ReadIndexResponse 

type ReadIndexResponse struct {
	ReadIndex uint64 `protobuf:"varint,1,opt,name=read_index,json=readIndex,proto3" json:"read_index,omitempty"`
	// The memory lock blocking this read at the leader
	Locked               *kvrpcpb.LockInfo `protobuf:"bytes,2,opt,name=locked,proto3" json:"locked,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ReadIndexResponse) Descriptor 

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

func (*ReadIndexResponse) GetLocked 

func (m *ReadIndexResponse) GetLocked() *kvrpcpb.LockInfo

func (*ReadIndexResponse) GetReadIndex 

func (m *ReadIndexResponse) GetReadIndex() uint64

func (*ReadIndexResponse) Marshal 

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

func (*ReadIndexResponse) MarshalTo 

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

func (*ReadIndexResponse) MarshalToSizedBuffer 

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

func (*ReadIndexResponse) ProtoMessage 

func (*ReadIndexResponse) ProtoMessage()

func (*ReadIndexResponse) Reset 

func (m *ReadIndexResponse) Reset()

func (*ReadIndexResponse) Size 

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

func (*ReadIndexResponse) String 

func (m *ReadIndexResponse) String() string

func (*ReadIndexResponse) Unmarshal 

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

func (*ReadIndexResponse) XXX_DiscardUnknown 

func (m *ReadIndexResponse) XXX_DiscardUnknown()

func (*ReadIndexResponse) XXX_Marshal 

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

func (*ReadIndexResponse) XXX_Merge 

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

func (*ReadIndexResponse) XXX_Size 

func (m *ReadIndexResponse) XXX_Size() int

func (*ReadIndexResponse) XXX_Unmarshal 

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

type RegionDetailRequest 

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

For getting more information of the region. We add some admin operations (ChangePeer, Split...) into the pb job list, then pd server will peek the first one, handle it and then pop it from the job lib. But sometimes, the pd server may crash before popping. When another pd server starts and finds the job is running but not finished, it will first check whether the raft server already has handled this job. E,g, for ChangePeer, if we add Peer10 into region1 and find region1 has already had Peer10, we can think this ChangePeer is finished, and can pop this job from job list directly.

func (*RegionDetailRequest) Descriptor 

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

func (*RegionDetailRequest) Marshal 

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

func (*RegionDetailRequest) MarshalTo 

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

func (*RegionDetailRequest) MarshalToSizedBuffer 

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

func (*RegionDetailRequest) ProtoMessage 

func (*RegionDetailRequest) ProtoMessage()

func (*RegionDetailRequest) Reset 

func (m *RegionDetailRequest) Reset()

func (*RegionDetailRequest) Size 

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

func (*RegionDetailRequest) String 

func (m *RegionDetailRequest) String() string

func (*RegionDetailRequest) Unmarshal 

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

func (*RegionDetailRequest) XXX_DiscardUnknown 

func (m *RegionDetailRequest) XXX_DiscardUnknown()

func (*RegionDetailRequest) XXX_Marshal 

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

func (*RegionDetailRequest) XXX_Merge 

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

func (*RegionDetailRequest) XXX_Size 

func (m *RegionDetailRequest) XXX_Size() int

func (*RegionDetailRequest) XXX_Unmarshal 

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

type RegionDetailResponse 

type RegionDetailResponse struct {
	Region               *metapb.Region `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	Leader               *metapb.Peer   `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RegionDetailResponse) Descriptor 

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

func (*RegionDetailResponse) GetLeader 

func (m *RegionDetailResponse) GetLeader() *metapb.Peer

func (*RegionDetailResponse) GetRegion 

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

func (*RegionDetailResponse) Marshal 

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

func (*RegionDetailResponse) MarshalTo 

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

func (*RegionDetailResponse) MarshalToSizedBuffer 

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

func (*RegionDetailResponse) ProtoMessage 

func (*RegionDetailResponse) ProtoMessage()

func (*RegionDetailResponse) Reset 

func (m *RegionDetailResponse) Reset()

func (*RegionDetailResponse) Size 

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

func (*RegionDetailResponse) String 

func (m *RegionDetailResponse) String() string

func (*RegionDetailResponse) Unmarshal 

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

func (*RegionDetailResponse) XXX_DiscardUnknown 

func (m *RegionDetailResponse) XXX_DiscardUnknown()

func (*RegionDetailResponse) XXX_Marshal 

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

func (*RegionDetailResponse) XXX_Merge 

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

func (*RegionDetailResponse) XXX_Size 

func (m *RegionDetailResponse) XXX_Size() int

func (*RegionDetailResponse) XXX_Unmarshal 

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

type RegionLeaderRequest 

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

For get the leader of the region.

func (*RegionLeaderRequest) Descriptor 

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

func (*RegionLeaderRequest) Marshal 

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

func (*RegionLeaderRequest) MarshalTo 

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

func (*RegionLeaderRequest) MarshalToSizedBuffer 

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

func (*RegionLeaderRequest) ProtoMessage 

func (*RegionLeaderRequest) ProtoMessage()

func (*RegionLeaderRequest) Reset 

func (m *RegionLeaderRequest) Reset()

func (*RegionLeaderRequest) Size 

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

func (*RegionLeaderRequest) String 

func (m *RegionLeaderRequest) String() string

func (*RegionLeaderRequest) Unmarshal 

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

func (*RegionLeaderRequest) XXX_DiscardUnknown 

func (m *RegionLeaderRequest) XXX_DiscardUnknown()

func (*RegionLeaderRequest) XXX_Marshal 

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

func (*RegionLeaderRequest) XXX_Merge 

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

func (*RegionLeaderRequest) XXX_Size 

func (m *RegionLeaderRequest) XXX_Size() int

func (*RegionLeaderRequest) XXX_Unmarshal 

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

type RegionLeaderResponse 

type RegionLeaderResponse struct {
	Leader               *metapb.Peer `protobuf:"bytes,1,opt,name=leader,proto3" json:"leader,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*RegionLeaderResponse) Descriptor 

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

func (*RegionLeaderResponse) GetLeader 

func (m *RegionLeaderResponse) GetLeader() *metapb.Peer

func (*RegionLeaderResponse) Marshal 

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

func (*RegionLeaderResponse) MarshalTo 

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

func (*RegionLeaderResponse) MarshalToSizedBuffer 

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

func (*RegionLeaderResponse) ProtoMessage 

func (*RegionLeaderResponse) ProtoMessage()

func (*RegionLeaderResponse) Reset 

func (m *RegionLeaderResponse) Reset()

func (*RegionLeaderResponse) Size 

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

func (*RegionLeaderResponse) String 

func (m *RegionLeaderResponse) String() string

func (*RegionLeaderResponse) Unmarshal 

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

func (*RegionLeaderResponse) XXX_DiscardUnknown 

func (m *RegionLeaderResponse) XXX_DiscardUnknown()

func (*RegionLeaderResponse) XXX_Marshal 

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

func (*RegionLeaderResponse) XXX_Merge 

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

func (*RegionLeaderResponse) XXX_Size 

func (m *RegionLeaderResponse) XXX_Size() int

func (*RegionLeaderResponse) XXX_Unmarshal 

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

type Request 

type Request struct {
	CmdType              CmdType             `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.CmdType" json:"cmd_type,omitempty"`
	Get                  *GetRequest         `protobuf:"bytes,2,opt,name=get,proto3" json:"get,omitempty"`
	Put                  *PutRequest         `protobuf:"bytes,4,opt,name=put,proto3" json:"put,omitempty"`
	Delete               *DeleteRequest      `protobuf:"bytes,5,opt,name=delete,proto3" json:"delete,omitempty"`
	Snap                 *SnapRequest        `protobuf:"bytes,6,opt,name=snap,proto3" json:"snap,omitempty"`
	Prewrite             *PrewriteRequest    `protobuf:"bytes,7,opt,name=prewrite,proto3" json:"prewrite,omitempty"`
	DeleteRange          *DeleteRangeRequest `protobuf:"bytes,8,opt,name=delete_range,json=deleteRange,proto3" json:"delete_range,omitempty"`
	IngestSst            *IngestSSTRequest   `protobuf:"bytes,9,opt,name=ingest_sst,json=ingestSst,proto3" json:"ingest_sst,omitempty"`
	ReadIndex            *ReadIndexRequest   `protobuf:"bytes,10,opt,name=read_index,json=readIndex,proto3" json:"read_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*Request) Descriptor 

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

func (*Request) GetCmdType 

func (m *Request) GetCmdType() CmdType

func (*Request) GetDelete 

func (m *Request) GetDelete() *DeleteRequest

func (*Request) GetDeleteRange 

func (m *Request) GetDeleteRange() *DeleteRangeRequest

func (*Request) GetGet 

func (m *Request) GetGet() *GetRequest

func (*Request) GetIngestSst 

func (m *Request) GetIngestSst() *IngestSSTRequest

func (*Request) GetPrewrite 

func (m *Request) GetPrewrite() *PrewriteRequest

func (*Request) GetPut 

func (m *Request) GetPut() *PutRequest

func (*Request) GetReadIndex 

func (m *Request) GetReadIndex() *ReadIndexRequest

func (*Request) GetSnap 

func (m *Request) GetSnap() *SnapRequest

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 {
	CmdType              CmdType              `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.CmdType" json:"cmd_type,omitempty"`
	Get                  *GetResponse         `protobuf:"bytes,2,opt,name=get,proto3" json:"get,omitempty"`
	Put                  *PutResponse         `protobuf:"bytes,4,opt,name=put,proto3" json:"put,omitempty"`
	Delete               *DeleteResponse      `protobuf:"bytes,5,opt,name=delete,proto3" json:"delete,omitempty"`
	Snap                 *SnapResponse        `protobuf:"bytes,6,opt,name=snap,proto3" json:"snap,omitempty"`
	Prewrite             *PrewriteResponse    `protobuf:"bytes,7,opt,name=prewrite,proto3" json:"prewrite,omitempty"`
	DelteRange           *DeleteRangeResponse `protobuf:"bytes,8,opt,name=delte_range,json=delteRange,proto3" json:"delte_range,omitempty"`
	IngestSst            *IngestSSTResponse   `protobuf:"bytes,9,opt,name=ingest_sst,json=ingestSst,proto3" json:"ingest_sst,omitempty"`
	ReadIndex            *ReadIndexResponse   `protobuf:"bytes,10,opt,name=read_index,json=readIndex,proto3" json:"read_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetCmdType 

func (m *Response) GetCmdType() CmdType

func (*Response) GetDelete 

func (m *Response) GetDelete() *DeleteResponse

func (*Response) GetDelteRange 

func (m *Response) GetDelteRange() *DeleteRangeResponse

func (*Response) GetGet 

func (m *Response) GetGet() *GetResponse

func (*Response) GetIngestSst 

func (m *Response) GetIngestSst() *IngestSSTResponse

func (*Response) GetPrewrite 

func (m *Response) GetPrewrite() *PrewriteResponse

func (*Response) GetPut 

func (m *Response) GetPut() *PutResponse

func (*Response) GetReadIndex 

func (m *Response) GetReadIndex() *ReadIndexResponse

func (*Response) GetSnap 

func (m *Response) GetSnap() *SnapResponse

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 RollbackMergeRequest 

type RollbackMergeRequest struct {
	Commit               uint64   `protobuf:"varint,1,opt,name=commit,proto3" json:"commit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RollbackMergeRequest) Descriptor 

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

func (*RollbackMergeRequest) GetCommit 

func (m *RollbackMergeRequest) GetCommit() uint64

func (*RollbackMergeRequest) Marshal 

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

func (*RollbackMergeRequest) MarshalTo 

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

func (*RollbackMergeRequest) MarshalToSizedBuffer 

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

func (*RollbackMergeRequest) ProtoMessage 

func (*RollbackMergeRequest) ProtoMessage()

func (*RollbackMergeRequest) Reset 

func (m *RollbackMergeRequest) Reset()

func (*RollbackMergeRequest) Size 

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

func (*RollbackMergeRequest) String 

func (m *RollbackMergeRequest) String() string

func (*RollbackMergeRequest) Unmarshal 

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

func (*RollbackMergeRequest) XXX_DiscardUnknown 

func (m *RollbackMergeRequest) XXX_DiscardUnknown()

func (*RollbackMergeRequest) XXX_Marshal 

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

func (*RollbackMergeRequest) XXX_Merge 

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

func (*RollbackMergeRequest) XXX_Size 

func (m *RollbackMergeRequest) XXX_Size() int

func (*RollbackMergeRequest) XXX_Unmarshal 

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

type RollbackMergeResponse 

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

func (*RollbackMergeResponse) Descriptor 

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

func (*RollbackMergeResponse) Marshal 

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

func (*RollbackMergeResponse) MarshalTo 

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

func (*RollbackMergeResponse) MarshalToSizedBuffer 

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

func (*RollbackMergeResponse) ProtoMessage 

func (*RollbackMergeResponse) ProtoMessage()

func (*RollbackMergeResponse) Reset 

func (m *RollbackMergeResponse) Reset()

func (*RollbackMergeResponse) Size 

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

func (*RollbackMergeResponse) String 

func (m *RollbackMergeResponse) String() string

func (*RollbackMergeResponse) Unmarshal 

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

func (*RollbackMergeResponse) XXX_DiscardUnknown 

func (m *RollbackMergeResponse) XXX_DiscardUnknown()

func (*RollbackMergeResponse) XXX_Marshal 

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

func (*RollbackMergeResponse) XXX_Merge 

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

func (*RollbackMergeResponse) XXX_Size 

func (m *RollbackMergeResponse) XXX_Size() int

func (*RollbackMergeResponse) XXX_Unmarshal 

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

type SnapRequest 

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

func (*SnapRequest) Descriptor 

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

func (*SnapRequest) Marshal 

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

func (*SnapRequest) MarshalTo 

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

func (*SnapRequest) MarshalToSizedBuffer 

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

func (*SnapRequest) ProtoMessage 

func (*SnapRequest) ProtoMessage()

func (*SnapRequest) Reset 

func (m *SnapRequest) Reset()

func (*SnapRequest) Size 

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

func (*SnapRequest) String 

func (m *SnapRequest) String() string

func (*SnapRequest) Unmarshal 

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

func (*SnapRequest) XXX_DiscardUnknown 

func (m *SnapRequest) XXX_DiscardUnknown()

func (*SnapRequest) XXX_Marshal 

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

func (*SnapRequest) XXX_Merge 

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

func (*SnapRequest) XXX_Size 

func (m *SnapRequest) XXX_Size() int

func (*SnapRequest) XXX_Unmarshal 

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

type SnapResponse 

type SnapResponse struct {
	Region               *metapb.Region `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SnapResponse) Descriptor 

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

func (*SnapResponse) GetRegion 

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

func (*SnapResponse) Marshal 

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

func (*SnapResponse) MarshalTo 

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

func (*SnapResponse) MarshalToSizedBuffer 

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

func (*SnapResponse) ProtoMessage 

func (*SnapResponse) ProtoMessage()

func (*SnapResponse) Reset 

func (m *SnapResponse) Reset()

func (*SnapResponse) Size 

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

func (*SnapResponse) String 

func (m *SnapResponse) String() string

func (*SnapResponse) Unmarshal 

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

func (*SnapResponse) XXX_DiscardUnknown 

func (m *SnapResponse) XXX_DiscardUnknown()

func (*SnapResponse) XXX_Marshal 

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

func (*SnapResponse) XXX_Merge 

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

func (*SnapResponse) XXX_Size 

func (m *SnapResponse) XXX_Size() int

func (*SnapResponse) XXX_Unmarshal 

func (m *SnapResponse) 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=split_key,json=splitKey,proto3" json:"split_key,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.
	NewRegionId uint64 `protobuf:"varint,2,opt,name=new_region_id,json=newRegionId,proto3" json:"new_region_id,omitempty"`
	// The peer ids for the new split region.
	NewPeerIds []uint64 `protobuf:"varint,3,rep,packed,name=new_peer_ids,json=newPeerIds,proto3" json:"new_peer_ids,omitempty"`
	// If true, right region derive the origin region_id,
	// left region use new_region_id.
	// Will be ignored in batch split, use `BatchSplitRequest::right_derive` instead.
	RightDerive bool `protobuf:"varint,4,opt,name=right_derive,json=rightDerive,proto3" json:"right_derive,omitempty"` // Deprecated: Do not use.
	// It should be false iff the region split by user key such as split table or create partion table etc,
	// the new region's will not share the source region size, so it's region size is zero.
	// It should be true iff the region's load reaches the threshold such as size, keys, load check etc,
	// the new region's size will share the origin region, so it's region size is half of the source region.
	ShareSourceRegionSize bool     `` /* 129-byte string literal not displayed */
	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) GetNewRegionId 

func (m *SplitRequest) GetNewRegionId() uint64

func (*SplitRequest) GetRightDerive deprecated 

func (m *SplitRequest) GetRightDerive() bool

Deprecated: Do not use.

func (*SplitRequest) GetShareSourceRegionSize 

func (m *SplitRequest) GetShareSourceRegionSize() 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.Region `protobuf:"bytes,1,opt,name=left,proto3" json:"left,omitempty"`
	Right                *metapb.Region `protobuf:"bytes,2,opt,name=right,proto3" json:"right,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SplitResponse) Descriptor 

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

func (*SplitResponse) GetLeft 

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

func (*SplitResponse) GetRight 

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

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 StatusCmdType 

type StatusCmdType int32
const (
	StatusCmdType_InvalidStatus StatusCmdType = 0
	StatusCmdType_RegionLeader  StatusCmdType = 1
	StatusCmdType_RegionDetail  StatusCmdType = 2
)

func (StatusCmdType) EnumDescriptor 

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

func (StatusCmdType) String 

func (x StatusCmdType) String() string

type StatusRequest 

type StatusRequest struct {
	CmdType              StatusCmdType        `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.StatusCmdType" json:"cmd_type,omitempty"`
	RegionLeader         *RegionLeaderRequest `protobuf:"bytes,2,opt,name=region_leader,json=regionLeader,proto3" json:"region_leader,omitempty"`
	RegionDetail         *RegionDetailRequest `protobuf:"bytes,3,opt,name=region_detail,json=regionDetail,proto3" json:"region_detail,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) GetCmdType 

func (m *StatusRequest) GetCmdType() StatusCmdType

func (*StatusRequest) GetRegionDetail 

func (m *StatusRequest) GetRegionDetail() *RegionDetailRequest

func (*StatusRequest) GetRegionLeader 

func (m *StatusRequest) GetRegionLeader() *RegionLeaderRequest

func (*StatusRequest) Marshal 

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

func (*StatusRequest) MarshalTo 

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

func (*StatusRequest) MarshalToSizedBuffer 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) Size 

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

func (*StatusRequest) String 

func (m *StatusRequest) String() string

func (*StatusRequest) Unmarshal 

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

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

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

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type StatusResponse 

type StatusResponse struct {
	CmdType              StatusCmdType         `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.StatusCmdType" json:"cmd_type,omitempty"`
	RegionLeader         *RegionLeaderResponse `protobuf:"bytes,2,opt,name=region_leader,json=regionLeader,proto3" json:"region_leader,omitempty"`
	RegionDetail         *RegionDetailResponse `protobuf:"bytes,3,opt,name=region_detail,json=regionDetail,proto3" json:"region_detail,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetCmdType 

func (m *StatusResponse) GetCmdType() StatusCmdType

func (*StatusResponse) GetRegionDetail 

func (m *StatusResponse) GetRegionDetail() *RegionDetailResponse

func (*StatusResponse) GetRegionLeader 

func (m *StatusResponse) GetRegionLeader() *RegionLeaderResponse

func (*StatusResponse) Marshal 

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

func (*StatusResponse) MarshalTo 

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

func (*StatusResponse) MarshalToSizedBuffer 

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

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) Size 

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

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) Unmarshal 

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

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

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

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

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

type SwitchWitnessRequest 

type SwitchWitnessRequest struct {
	PeerId               uint64   `protobuf:"varint,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	IsWitness            bool     `protobuf:"varint,2,opt,name=is_witness,json=isWitness,proto3" json:"is_witness,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SwitchWitnessRequest) Descriptor 

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

func (*SwitchWitnessRequest) GetIsWitness 

func (m *SwitchWitnessRequest) GetIsWitness() bool

func (*SwitchWitnessRequest) GetPeerId 

func (m *SwitchWitnessRequest) GetPeerId() uint64

func (*SwitchWitnessRequest) Marshal 

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

func (*SwitchWitnessRequest) MarshalTo 

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

func (*SwitchWitnessRequest) MarshalToSizedBuffer 

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

func (*SwitchWitnessRequest) ProtoMessage 

func (*SwitchWitnessRequest) ProtoMessage()

func (*SwitchWitnessRequest) Reset 

func (m *SwitchWitnessRequest) Reset()

func (*SwitchWitnessRequest) Size 

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

func (*SwitchWitnessRequest) String 

func (m *SwitchWitnessRequest) String() string

func (*SwitchWitnessRequest) Unmarshal 

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

func (*SwitchWitnessRequest) XXX_DiscardUnknown 

func (m *SwitchWitnessRequest) XXX_DiscardUnknown()

func (*SwitchWitnessRequest) XXX_Marshal 

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

func (*SwitchWitnessRequest) XXX_Merge 

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

func (*SwitchWitnessRequest) XXX_Size 

func (m *SwitchWitnessRequest) XXX_Size() int

func (*SwitchWitnessRequest) XXX_Unmarshal 

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

type TransferLeaderRequest 

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

func (*TransferLeaderRequest) Descriptor 

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

func (*TransferLeaderRequest) GetPeer 

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

func (*TransferLeaderRequest) GetPeers 

func (m *TransferLeaderRequest) GetPeers() []*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 {
	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) 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

type UpdateGcPeerRequest 

type UpdateGcPeerRequest struct {
	PeerId               []uint64 `protobuf:"varint,1,rep,packed,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateGcPeerRequest) Descriptor 

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

func (*UpdateGcPeerRequest) GetPeerId 

func (m *UpdateGcPeerRequest) GetPeerId() []uint64

func (*UpdateGcPeerRequest) Marshal 

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

func (*UpdateGcPeerRequest) MarshalTo 

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

func (*UpdateGcPeerRequest) MarshalToSizedBuffer 

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

func (*UpdateGcPeerRequest) ProtoMessage 

func (*UpdateGcPeerRequest) ProtoMessage()

func (*UpdateGcPeerRequest) Reset 

func (m *UpdateGcPeerRequest) Reset()

func (*UpdateGcPeerRequest) Size 

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

func (*UpdateGcPeerRequest) String 

func (m *UpdateGcPeerRequest) String() string

func (*UpdateGcPeerRequest) Unmarshal 

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

func (*UpdateGcPeerRequest) XXX_DiscardUnknown 

func (m *UpdateGcPeerRequest) XXX_DiscardUnknown()

func (*UpdateGcPeerRequest) XXX_Marshal 

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

func (*UpdateGcPeerRequest) XXX_Merge 

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

func (*UpdateGcPeerRequest) XXX_Size 

func (m *UpdateGcPeerRequest) XXX_Size() int

func (*UpdateGcPeerRequest) XXX_Unmarshal 

func (m *UpdateGcPeerRequest) 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) MarshalToSizedBuffer 

func (m *VerifyHashRequest) MarshalToSizedBuffer(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) MarshalToSizedBuffer 

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