raft_cmdpb

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

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

 Go to latest Published: Oct 26, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRaftCmdpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftCmdpb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var AdminCmdType_name = map[int32]string{
	0:  "InvalidAdmin",
	1:  "ChangePeer",
	2:  "Split",
	3:  "CompactLog",
	4:  "TransferLeader",
	5:  "ComputeHash",
	6:  "VerifyHash",
	7:  "PrepareMerge",
	8:  "CommitMerge",
	9:  "RollbackMerge",
	10: "BatchSplit",
	11: "CompactRegion",
	12: "WarmupRegion",
}
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,
	"CompactRegion":  11,
	"WarmupRegion":   12,
}
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_CompactRegion  AdminCmdType = 11
	AdminCmdType_WarmupRegion   AdminCmdType = 12
)

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" json:"change_peer,omitempty"`
	Split                *SplitRequest          `protobuf:"bytes,3,opt,name=split" json:"split,omitempty"` // Deprecated: Do not use.
	CompactLog           *CompactLogRequest     `protobuf:"bytes,4,opt,name=compact_log,json=compactLog" json:"compact_log,omitempty"`
	TransferLeader       *TransferLeaderRequest `protobuf:"bytes,5,opt,name=transfer_leader,json=transferLeader" json:"transfer_leader,omitempty"`
	VerifyHash           *VerifyHashRequest     `protobuf:"bytes,6,opt,name=verify_hash,json=verifyHash" json:"verify_hash,omitempty"`
	PrepareMerge         *PrepareMergeRequest   `protobuf:"bytes,7,opt,name=prepare_merge,json=prepareMerge" json:"prepare_merge,omitempty"`
	CommitMerge          *CommitMergeRequest    `protobuf:"bytes,8,opt,name=commit_merge,json=commitMerge" json:"commit_merge,omitempty"`
	RollbackMerge        *RollbackMergeRequest  `protobuf:"bytes,9,opt,name=rollback_merge,json=rollbackMerge" json:"rollback_merge,omitempty"`
	Splits               *BatchSplitRequest     `protobuf:"bytes,10,opt,name=splits" json:"splits,omitempty"`
	CompactRegion        *CompactRegionRequest  `protobuf:"bytes,11,opt,name=compact_region,json=compactRegion" json:"compact_region,omitempty"`
	WarmupRegion         *WarmupRegionRequest   `protobuf:"bytes,12,opt,name=warmup_region,json=warmupRegion" json:"warmup_region,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) GetCmdType 

func (m *AdminRequest) GetCmdType() AdminCmdType

func (*AdminRequest) GetCommitMerge 

func (m *AdminRequest) GetCommitMerge() *CommitMergeRequest

func (*AdminRequest) GetCompactLog 

func (m *AdminRequest) GetCompactLog() *CompactLogRequest

func (*AdminRequest) GetCompactRegion 

func (m *AdminRequest) GetCompactRegion() *CompactRegionRequest

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

func (m *AdminRequest) GetTransferLeader() *TransferLeaderRequest

func (*AdminRequest) GetVerifyHash 

func (m *AdminRequest) GetVerifyHash() *VerifyHashRequest

func (*AdminRequest) GetWarmupRegion 

func (m *AdminRequest) GetWarmupRegion() *WarmupRegionRequest

func (*AdminRequest) Marshal 

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

func (*AdminRequest) MarshalTo 

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

func (*AdminRequest) ProtoMessage 

func (*AdminRequest) ProtoMessage()

func (*AdminRequest) Reset 

func (m *AdminRequest) Reset()

func (*AdminRequest) Size 

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

func (*AdminRequest) String 

func (m *AdminRequest) String() string

func (*AdminRequest) Unmarshal 

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

func (*AdminRequest) XXX_DiscardUnknown 

func (m *AdminRequest) XXX_DiscardUnknown()

func (*AdminRequest) XXX_Marshal 

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

func (*AdminRequest) XXX_Merge 

func (dst *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" json:"change_peer,omitempty"`
	Split                *SplitResponse          `protobuf:"bytes,3,opt,name=split" json:"split,omitempty"` // Deprecated: Do not use.
	CompactLog           *CompactLogResponse     `protobuf:"bytes,4,opt,name=compact_log,json=compactLog" json:"compact_log,omitempty"`
	TransferLeader       *TransferLeaderResponse `protobuf:"bytes,5,opt,name=transfer_leader,json=transferLeader" json:"transfer_leader,omitempty"`
	VerifyHash           *VerifyHashResponse     `protobuf:"bytes,6,opt,name=verify_hash,json=verifyHash" json:"verify_hash,omitempty"`
	PrepareMerge         *PrepareMergeResponse   `protobuf:"bytes,7,opt,name=prepare_merge,json=prepareMerge" json:"prepare_merge,omitempty"`
	CommitMerge          *CommitMergeResponse    `protobuf:"bytes,8,opt,name=commit_merge,json=commitMerge" json:"commit_merge,omitempty"`
	RollbackMerge        *RollbackMergeResponse  `protobuf:"bytes,9,opt,name=rollback_merge,json=rollbackMerge" json:"rollback_merge,omitempty"`
	Splits               *BatchSplitResponse     `protobuf:"bytes,10,opt,name=splits" json:"splits,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) GetCmdType 

func (m *AdminResponse) GetCmdType() AdminCmdType

func (*AdminResponse) GetCommitMerge 

func (m *AdminResponse) GetCommitMerge() *CommitMergeResponse

func (*AdminResponse) GetCompactLog 

func (m *AdminResponse) GetCompactLog() *CompactLogResponse

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

func (m *AdminResponse) GetTransferLeader() *TransferLeaderResponse

func (*AdminResponse) GetVerifyHash 

func (m *AdminResponse) GetVerifyHash() *VerifyHashResponse

func (*AdminResponse) Marshal 

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

func (*AdminResponse) MarshalTo 

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

func (*AdminResponse) ProtoMessage 

func (*AdminResponse) ProtoMessage()

func (*AdminResponse) Reset 

func (m *AdminResponse) Reset()

func (*AdminResponse) Size 

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

func (*AdminResponse) String 

func (m *AdminResponse) String() string

func (*AdminResponse) Unmarshal 

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

func (*AdminResponse) XXX_DiscardUnknown 

func (m *AdminResponse) XXX_DiscardUnknown()

func (*AdminResponse) XXX_Marshal 

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

func (*AdminResponse) XXX_Merge 

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

func (*BatchSplitRequest) Descriptor 

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

func (*BatchSplitRequest) GetRequests 

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

func (*BatchSplitRequest) GetRightDerive 

func (m *BatchSplitRequest) GetRightDerive() bool

func (*BatchSplitRequest) Marshal 

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

func (*BatchSplitRequest) MarshalTo 

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

func (*BatchSplitRequest) ProtoMessage 

func (*BatchSplitRequest) ProtoMessage()

func (*BatchSplitRequest) Reset 

func (m *BatchSplitRequest) Reset()

func (*BatchSplitRequest) Size 

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

func (*BatchSplitRequest) String 

func (m *BatchSplitRequest) String() string

func (*BatchSplitRequest) Unmarshal 

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

func (*BatchSplitRequest) XXX_DiscardUnknown 

func (m *BatchSplitRequest) XXX_DiscardUnknown()

func (*BatchSplitRequest) XXX_Marshal 

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

func (*BatchSplitRequest) XXX_Merge 

func (dst *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" 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) 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 (dst *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 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" 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) 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 (dst *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" 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) 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 (dst *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 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" json:"source,omitempty"`
	Commit               uint64           `protobuf:"varint,2,opt,name=commit,proto3" json:"commit,omitempty"`
	Entries              []*eraftpb.Entry `protobuf:"bytes,3,rep,name=entries" json:"entries,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) Marshal 

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

func (*CommitMergeRequest) MarshalTo 

func (m *CommitMergeRequest) MarshalTo(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 (dst *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) 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 (dst *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"`
	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) Marshal 

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

func (*CompactLogRequest) MarshalTo 

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

func (*CompactLogRequest) ProtoMessage 

func (*CompactLogRequest) ProtoMessage()

func (*CompactLogRequest) Reset 

func (m *CompactLogRequest) Reset()

func (*CompactLogRequest) Size 

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

func (*CompactLogRequest) String 

func (m *CompactLogRequest) String() string

func (*CompactLogRequest) Unmarshal 

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

func (*CompactLogRequest) XXX_DiscardUnknown 

func (m *CompactLogRequest) XXX_DiscardUnknown()

func (*CompactLogRequest) XXX_Marshal 

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

func (*CompactLogRequest) XXX_Merge 

func (dst *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) 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 (dst *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 CompactRegionRequest 

type CompactRegionRequest struct {
	Level                int32    `protobuf:"varint,1,opt,name=level,proto3" json:"level,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompactRegionRequest) Descriptor 

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

func (*CompactRegionRequest) GetLevel 

func (m *CompactRegionRequest) GetLevel() int32

func (*CompactRegionRequest) Marshal 

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

func (*CompactRegionRequest) MarshalTo 

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

func (*CompactRegionRequest) ProtoMessage 

func (*CompactRegionRequest) ProtoMessage()

func (*CompactRegionRequest) Reset 

func (m *CompactRegionRequest) Reset()

func (*CompactRegionRequest) Size 

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

func (*CompactRegionRequest) String 

func (m *CompactRegionRequest) String() string

func (*CompactRegionRequest) Unmarshal 

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

func (*CompactRegionRequest) XXX_DiscardUnknown 

func (m *CompactRegionRequest) XXX_DiscardUnknown()

func (*CompactRegionRequest) XXX_Marshal 

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

func (*CompactRegionRequest) XXX_Merge 

func (dst *CompactRegionRequest) XXX_Merge(src proto.Message)

func (*CompactRegionRequest) XXX_Size 

func (m *CompactRegionRequest) XXX_Size() int

func (*CompactRegionRequest) XXX_Unmarshal 

func (m *CompactRegionRequest) 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) 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 (dst *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) 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 (dst *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) 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 (dst *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) 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 (dst *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 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) 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 (dst *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) 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 (dst *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" 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) 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 (dst *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) 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 (dst *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 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" 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) 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 (dst *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) 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 (dst *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) 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 (dst *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) 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 (dst *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) 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 (dst *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) 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 (dst *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" json:"header,omitempty"`
	// We can't enclose normal requests and administrator request
	// at same time.
	Requests             []*Request     `protobuf:"bytes,2,rep,name=requests" json:"requests,omitempty"`
	AdminRequest         *AdminRequest  `protobuf:"bytes,3,opt,name=admin_request,json=adminRequest" json:"admin_request,omitempty"`
	StatusRequest        *StatusRequest `protobuf:"bytes,4,opt,name=status_request,json=statusRequest" 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) 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 (dst *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" json:"header,omitempty"`
	Responses            []*Response         `protobuf:"bytes,2,rep,name=responses" json:"responses,omitempty"`
	AdminResponse        *AdminResponse      `protobuf:"bytes,3,opt,name=admin_response,json=adminResponse" json:"admin_response,omitempty"`
	StatusResponse       *StatusResponse     `protobuf:"bytes,4,opt,name=status_response,json=statusResponse" 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) 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 (dst *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" 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" 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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RaftRequestHeader) Descriptor 

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

func (*RaftRequestHeader) GetPeer 

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

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

func (*ReadIndexRequest) Descriptor 

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

func (*ReadIndexRequest) Marshal 

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

func (*ReadIndexRequest) MarshalTo 

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

func (*ReadIndexResponse) Descriptor 

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

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) 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 (dst *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) 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 (dst *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" json:"region,omitempty"`
	Leader               *metapb.Peer   `protobuf:"bytes,2,opt,name=leader" 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) 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 (dst *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) 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 (dst *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" 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) 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 (dst *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" json:"get,omitempty"`
	Put                  *PutRequest         `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"`
	Delete               *DeleteRequest      `protobuf:"bytes,5,opt,name=delete" json:"delete,omitempty"`
	Snap                 *SnapRequest        `protobuf:"bytes,6,opt,name=snap" json:"snap,omitempty"`
	Prewrite             *PrewriteRequest    `protobuf:"bytes,7,opt,name=prewrite" json:"prewrite,omitempty"`
	DeleteRange          *DeleteRangeRequest `protobuf:"bytes,8,opt,name=delete_range,json=deleteRange" json:"delete_range,omitempty"`
	IngestSst            *IngestSSTRequest   `protobuf:"bytes,9,opt,name=ingest_sst,json=ingestSst" json:"ingest_sst,omitempty"`
	ReadIndex            *ReadIndexRequest   `protobuf:"bytes,10,opt,name=read_index,json=readIndex" 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) 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 (dst *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" json:"get,omitempty"`
	Put                  *PutResponse         `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"`
	Delete               *DeleteResponse      `protobuf:"bytes,5,opt,name=delete" json:"delete,omitempty"`
	Snap                 *SnapResponse        `protobuf:"bytes,6,opt,name=snap" json:"snap,omitempty"`
	Prewrite             *PrewriteResponse    `protobuf:"bytes,7,opt,name=prewrite" json:"prewrite,omitempty"`
	DelteRange           *DeleteRangeResponse `protobuf:"bytes,8,opt,name=delte_range,json=delteRange" json:"delte_range,omitempty"`
	IngestSst            *IngestSSTResponse   `protobuf:"bytes,9,opt,name=ingest_sst,json=ingestSst" json:"ingest_sst,omitempty"`
	ReadIndex            *ReadIndexResponse   `protobuf:"bytes,10,opt,name=read_index,json=readIndex" 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) 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 (dst *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) 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 (dst *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) 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 (dst *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) 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 (dst *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" 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) 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 (dst *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" 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.
	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) GetSplitKey 

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

func (*SplitRequest) Marshal 

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

func (*SplitRequest) MarshalTo 

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

func (*SplitRequest) ProtoMessage 

func (*SplitRequest) ProtoMessage()

func (*SplitRequest) Reset 

func (m *SplitRequest) Reset()

func (*SplitRequest) Size 

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

func (*SplitRequest) String 

func (m *SplitRequest) String() string

func (*SplitRequest) Unmarshal 

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

func (*SplitRequest) XXX_DiscardUnknown 

func (m *SplitRequest) XXX_DiscardUnknown()

func (*SplitRequest) XXX_Marshal 

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

func (*SplitRequest) XXX_Merge 

func (dst *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" json:"left,omitempty"`
	Right                *metapb.Region `protobuf:"bytes,2,opt,name=right" 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) 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 (dst *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" json:"region_leader,omitempty"`
	RegionDetail         *RegionDetailRequest `protobuf:"bytes,3,opt,name=region_detail,json=regionDetail" 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) 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 (dst *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" json:"region_leader,omitempty"`
	RegionDetail         *RegionDetailResponse `protobuf:"bytes,3,opt,name=region_detail,json=regionDetail" 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) 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 (dst *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 TransferLeaderRequest 

type TransferLeaderRequest struct {
	Peer                 *metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,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) Marshal 

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

func (*TransferLeaderRequest) MarshalTo 

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

func (*TransferLeaderRequest) ProtoMessage 

func (*TransferLeaderRequest) ProtoMessage()

func (*TransferLeaderRequest) Reset 

func (m *TransferLeaderRequest) Reset()

func (*TransferLeaderRequest) Size 

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

func (*TransferLeaderRequest) String 

func (m *TransferLeaderRequest) String() string

func (*TransferLeaderRequest) Unmarshal 

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

func (*TransferLeaderRequest) XXX_DiscardUnknown 

func (m *TransferLeaderRequest) XXX_DiscardUnknown()

func (*TransferLeaderRequest) XXX_Marshal 

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

func (*TransferLeaderRequest) XXX_Merge 

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

func (*TransferLeaderRequest) XXX_Size 

func (m *TransferLeaderRequest) XXX_Size() int

func (*TransferLeaderRequest) XXX_Unmarshal 

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

type TransferLeaderResponse 

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

func (*TransferLeaderResponse) Descriptor 

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

func (*TransferLeaderResponse) Marshal 

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

func (*TransferLeaderResponse) MarshalTo 

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

func (*TransferLeaderResponse) ProtoMessage 

func (*TransferLeaderResponse) ProtoMessage()

func (*TransferLeaderResponse) Reset 

func (m *TransferLeaderResponse) Reset()

func (*TransferLeaderResponse) Size 

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

func (*TransferLeaderResponse) String 

func (m *TransferLeaderResponse) String() string

func (*TransferLeaderResponse) Unmarshal 

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

func (*TransferLeaderResponse) XXX_DiscardUnknown 

func (m *TransferLeaderResponse) XXX_DiscardUnknown()

func (*TransferLeaderResponse) XXX_Marshal 

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

func (*TransferLeaderResponse) XXX_Merge 

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

func (*TransferLeaderResponse) XXX_Size 

func (m *TransferLeaderResponse) XXX_Size() int

func (*TransferLeaderResponse) XXX_Unmarshal 

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

type VerifyHashRequest 

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

func (*VerifyHashRequest) Descriptor 

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

func (*VerifyHashRequest) GetHash 

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

func (*VerifyHashRequest) GetIndex 

func (m *VerifyHashRequest) GetIndex() uint64

func (*VerifyHashRequest) Marshal 

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

func (*VerifyHashRequest) MarshalTo 

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

func (*VerifyHashRequest) ProtoMessage 

func (*VerifyHashRequest) ProtoMessage()

func (*VerifyHashRequest) Reset 

func (m *VerifyHashRequest) Reset()

func (*VerifyHashRequest) Size 

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

func (*VerifyHashRequest) String 

func (m *VerifyHashRequest) String() string

func (*VerifyHashRequest) Unmarshal 

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

func (*VerifyHashRequest) XXX_DiscardUnknown 

func (m *VerifyHashRequest) XXX_DiscardUnknown()

func (*VerifyHashRequest) XXX_Marshal 

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

func (*VerifyHashRequest) XXX_Merge 

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

func (*VerifyHashRequest) XXX_Size 

func (m *VerifyHashRequest) XXX_Size() int

func (*VerifyHashRequest) XXX_Unmarshal 

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

type VerifyHashResponse 

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

func (*VerifyHashResponse) Descriptor 

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

func (*VerifyHashResponse) Marshal 

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

func (*VerifyHashResponse) MarshalTo 

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

func (*VerifyHashResponse) ProtoMessage 

func (*VerifyHashResponse) ProtoMessage()

func (*VerifyHashResponse) Reset 

func (m *VerifyHashResponse) Reset()

func (*VerifyHashResponse) Size 

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

func (*VerifyHashResponse) String 

func (m *VerifyHashResponse) String() string

func (*VerifyHashResponse) Unmarshal 

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

func (*VerifyHashResponse) XXX_DiscardUnknown 

func (m *VerifyHashResponse) XXX_DiscardUnknown()

func (*VerifyHashResponse) XXX_Marshal 

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

func (*VerifyHashResponse) XXX_Merge 

func (dst *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

type WarmupRegionRequest 

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

func (*WarmupRegionRequest) Descriptor 

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

func (*WarmupRegionRequest) Marshal 

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

func (*WarmupRegionRequest) MarshalTo 

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

func (*WarmupRegionRequest) ProtoMessage 

func (*WarmupRegionRequest) ProtoMessage()

func (*WarmupRegionRequest) Reset 

func (m *WarmupRegionRequest) Reset()

func (*WarmupRegionRequest) Size 

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

func (*WarmupRegionRequest) String 

func (m *WarmupRegionRequest) String() string

func (*WarmupRegionRequest) Unmarshal 

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

func (*WarmupRegionRequest) XXX_DiscardUnknown 

func (m *WarmupRegionRequest) XXX_DiscardUnknown()

func (*WarmupRegionRequest) XXX_Marshal 

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

func (*WarmupRegionRequest) XXX_Merge 

func (dst *WarmupRegionRequest) XXX_Merge(src proto.Message)

func (*WarmupRegionRequest) XXX_Size 

func (m *WarmupRegionRequest) XXX_Size() int

func (*WarmupRegionRequest) XXX_Unmarshal 

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