raft_cmdpb

package
v0.0.0-...-b5bbcdc Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRaftCmdpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaftCmdpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRaftCmdpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AdminCmdType_name = map[int32]string{
	0:  "InvalidAdmin",
	1:  "ChangePeer",
	3:  "CompactLog",
	4:  "TransferLeader",
	10: "Split",
}
View Source 
var AdminCmdType_value = map[string]int32{
	"InvalidAdmin":   0,
	"ChangePeer":     1,
	"CompactLog":     3,
	"TransferLeader": 4,
	"Split":          10,
}
View Source 
var CmdType_name = map[int32]string{
	0: "Invalid",
	1: "Get",
	3: "Put",
	4: "Delete",
	5: "Snap",
}
View Source 
var CmdType_value = map[string]int32{
	"Invalid": 0,
	"Get":     1,
	"Put":     3,
	"Delete":  4,
	"Snap":    5,
}

Functions

This section is empty.

Types

type AdminCmdType 

type AdminCmdType int32
const (
	AdminCmdType_InvalidAdmin   AdminCmdType = 0
	AdminCmdType_ChangePeer     AdminCmdType = 1
	AdminCmdType_CompactLog     AdminCmdType = 3
	AdminCmdType_TransferLeader AdminCmdType = 4
	AdminCmdType_Split          AdminCmdType = 10
)

func (AdminCmdType) EnumDescriptor 

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

func (AdminCmdType) String 

func (x AdminCmdType) String() string

type AdminRequest 

type AdminRequest struct {
	CmdType              AdminCmdType           `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.AdminCmdType" json:"cmd_type,omitempty"`
	ChangePeer           *ChangePeerRequest     `protobuf:"bytes,2,opt,name=change_peer,json=changePeer,proto3" json:"change_peer,omitempty"`
	CompactLog           *CompactLogRequest     `protobuf:"bytes,4,opt,name=compact_log,json=compactLog,proto3" json:"compact_log,omitempty"`
	TransferLeader       *TransferLeaderRequest `protobuf:"bytes,5,opt,name=transfer_leader,json=transferLeader,proto3" json:"transfer_leader,omitempty"`
	Split                *SplitRequest          `protobuf:"bytes,10,opt,name=split,proto3" json:"split,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) GetCompactLog 

func (m *AdminRequest) GetCompactLog() *CompactLogRequest

func (*AdminRequest) GetSplit 

func (m *AdminRequest) GetSplit() *SplitRequest

func (*AdminRequest) GetTransferLeader 

func (m *AdminRequest) GetTransferLeader() *TransferLeaderRequest

func (*AdminRequest) Marshal 

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

func (*AdminRequest) MarshalTo 

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

func (*AdminRequest) MarshalToSizedBuffer 

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

func (*AdminRequest) ProtoMessage 

func (*AdminRequest) ProtoMessage()

func (*AdminRequest) Reset 

func (m *AdminRequest) Reset()

func (*AdminRequest) Size 

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

func (*AdminRequest) String 

func (m *AdminRequest) String() string

func (*AdminRequest) Unmarshal 

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

func (*AdminRequest) XXX_DiscardUnknown 

func (m *AdminRequest) XXX_DiscardUnknown()

func (*AdminRequest) XXX_Marshal 

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

func (*AdminRequest) XXX_Merge 

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

func (*AdminRequest) XXX_Size 

func (m *AdminRequest) XXX_Size() int

func (*AdminRequest) XXX_Unmarshal 

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

type AdminResponse 

type AdminResponse struct {
	CmdType              AdminCmdType            `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.AdminCmdType" json:"cmd_type,omitempty"`
	ChangePeer           *ChangePeerResponse     `protobuf:"bytes,2,opt,name=change_peer,json=changePeer,proto3" json:"change_peer,omitempty"`
	CompactLog           *CompactLogResponse     `protobuf:"bytes,4,opt,name=compact_log,json=compactLog,proto3" json:"compact_log,omitempty"`
	TransferLeader       *TransferLeaderResponse `protobuf:"bytes,5,opt,name=transfer_leader,json=transferLeader,proto3" json:"transfer_leader,omitempty"`
	Split                *SplitResponse          `protobuf:"bytes,10,opt,name=split,proto3" json:"split,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) GetCompactLog 

func (m *AdminResponse) GetCompactLog() *CompactLogResponse

func (*AdminResponse) GetSplit 

func (m *AdminResponse) GetSplit() *SplitResponse

func (*AdminResponse) GetTransferLeader 

func (m *AdminResponse) GetTransferLeader() *TransferLeaderResponse

func (*AdminResponse) Marshal 

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

func (*AdminResponse) MarshalTo 

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

func (*AdminResponse) MarshalToSizedBuffer 

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

func (*AdminResponse) ProtoMessage 

func (*AdminResponse) ProtoMessage()

func (*AdminResponse) Reset 

func (m *AdminResponse) Reset()

func (*AdminResponse) Size 

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

func (*AdminResponse) String 

func (m *AdminResponse) String() string

func (*AdminResponse) Unmarshal 

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

func (*AdminResponse) XXX_DiscardUnknown 

func (m *AdminResponse) XXX_DiscardUnknown()

func (*AdminResponse) XXX_Marshal 

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

func (*AdminResponse) XXX_Merge 

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

func (*AdminResponse) XXX_Size 

func (m *AdminResponse) XXX_Size() int

func (*AdminResponse) XXX_Unmarshal 

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

type ChangePeerRequest 

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

func (*ChangePeerRequest) Descriptor 

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

func (*ChangePeerRequest) GetChangeType 

func (m *ChangePeerRequest) GetChangeType() eraftpb.ConfChangeType

func (*ChangePeerRequest) GetPeer 

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

func (*ChangePeerRequest) Marshal 

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

func (*ChangePeerRequest) MarshalTo 

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

func (*ChangePeerRequest) MarshalToSizedBuffer 

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

func (*ChangePeerRequest) ProtoMessage 

func (*ChangePeerRequest) ProtoMessage()

func (*ChangePeerRequest) Reset 

func (m *ChangePeerRequest) Reset()

func (*ChangePeerRequest) Size 

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

func (*ChangePeerRequest) String 

func (m *ChangePeerRequest) String() string

func (*ChangePeerRequest) Unmarshal 

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

func (*ChangePeerRequest) XXX_DiscardUnknown 

func (m *ChangePeerRequest) XXX_DiscardUnknown()

func (*ChangePeerRequest) XXX_Marshal 

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

func (*ChangePeerRequest) XXX_Merge 

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

func (*ChangePeerRequest) XXX_Size 

func (m *ChangePeerRequest) XXX_Size() int

func (*ChangePeerRequest) XXX_Unmarshal 

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

type ChangePeerResponse 

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

func (*ChangePeerResponse) Descriptor 

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

func (*ChangePeerResponse) GetRegion 

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

func (*ChangePeerResponse) Marshal 

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

func (*ChangePeerResponse) MarshalTo 

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

func (*ChangePeerResponse) MarshalToSizedBuffer 

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

func (*ChangePeerResponse) ProtoMessage 

func (*ChangePeerResponse) ProtoMessage()

func (*ChangePeerResponse) Reset 

func (m *ChangePeerResponse) Reset()

func (*ChangePeerResponse) Size 

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

func (*ChangePeerResponse) String 

func (m *ChangePeerResponse) String() string

func (*ChangePeerResponse) Unmarshal 

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

func (*ChangePeerResponse) XXX_DiscardUnknown 

func (m *ChangePeerResponse) XXX_DiscardUnknown()

func (*ChangePeerResponse) XXX_Marshal 

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

func (*ChangePeerResponse) XXX_Merge 

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

func (*ChangePeerResponse) XXX_Size 

func (m *ChangePeerResponse) XXX_Size() int

func (*ChangePeerResponse) XXX_Unmarshal 

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

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

func (CmdType) EnumDescriptor 

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

func (CmdType) String 

func (x CmdType) String() string

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

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

func (*CompactLogRequest) ProtoMessage 

func (*CompactLogRequest) ProtoMessage()

func (*CompactLogRequest) Reset 

func (m *CompactLogRequest) Reset()

func (*CompactLogRequest) Size 

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

func (*CompactLogRequest) String 

func (m *CompactLogRequest) String() string

func (*CompactLogRequest) Unmarshal 

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

func (*CompactLogRequest) XXX_DiscardUnknown 

func (m *CompactLogRequest) XXX_DiscardUnknown()

func (*CompactLogRequest) XXX_Marshal 

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

func (*CompactLogRequest) XXX_Merge 

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

func (*CompactLogRequest) XXX_Size 

func (m *CompactLogRequest) XXX_Size() int

func (*CompactLogRequest) XXX_Unmarshal 

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

type CompactLogResponse 

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

func (*CompactLogResponse) Descriptor 

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

func (*CompactLogResponse) Marshal 

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

func (*CompactLogResponse) MarshalTo 

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

func (*CompactLogResponse) MarshalToSizedBuffer 

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

func (*CompactLogResponse) ProtoMessage 

func (*CompactLogResponse) ProtoMessage()

func (*CompactLogResponse) Reset 

func (m *CompactLogResponse) Reset()

func (*CompactLogResponse) Size 

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

func (*CompactLogResponse) String 

func (m *CompactLogResponse) String() string

func (*CompactLogResponse) Unmarshal 

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

func (*CompactLogResponse) XXX_DiscardUnknown 

func (m *CompactLogResponse) XXX_DiscardUnknown()

func (*CompactLogResponse) XXX_Marshal 

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

func (*CompactLogResponse) XXX_Merge 

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

func (*CompactLogResponse) XXX_Size 

func (m *CompactLogResponse) XXX_Size() int

func (*CompactLogResponse) XXX_Unmarshal 

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

type DeleteRequest 

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

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetCf 

func (m *DeleteRequest) GetCf() string

func (*DeleteRequest) GetKey 

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

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) MarshalToSizedBuffer 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeleteResponse 

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

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) Marshal 

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

func (*DeleteResponse) MarshalTo 

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

func (*DeleteResponse) MarshalToSizedBuffer 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

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

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

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

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

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

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type GetRequest 

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

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetCf 

func (m *GetRequest) GetCf() string

func (*GetRequest) GetKey 

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

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

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

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetValue 

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

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type PutRequest 

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

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetCf 

func (m *PutRequest) GetCf() string

func (*PutRequest) GetKey 

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

func (*PutRequest) GetValue 

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

func (*PutRequest) Marshal 

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

func (*PutRequest) MarshalTo 

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

func (*PutRequest) MarshalToSizedBuffer 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) Size 

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

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) Unmarshal 

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

func (*PutRequest) XXX_DiscardUnknown 

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal 

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

func (*PutRequest) XXX_Merge 

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

func (*PutRequest) XXX_Size 

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal 

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

type PutResponse 

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

func (*PutResponse) Descriptor 

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

func (*PutResponse) Marshal 

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

func (*PutResponse) MarshalTo 

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

func (*PutResponse) MarshalToSizedBuffer 

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

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) Size 

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

func (*PutResponse) String 

func (m *PutResponse) String() string

func (*PutResponse) Unmarshal 

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

func (*PutResponse) XXX_DiscardUnknown 

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal 

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

func (*PutResponse) XXX_Merge 

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

func (*PutResponse) XXX_Size 

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal 

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

type RaftCmdRequest 

type RaftCmdRequest struct {
	Header *RaftRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// We can't enclose normal requests and administrator request
	// at same time.
	Requests             []*Request    `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	AdminRequest         *AdminRequest `protobuf:"bytes,3,opt,name=admin_request,json=adminRequest,proto3" json:"admin_request,omitempty"`
	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) Marshal 

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

func (*RaftCmdRequest) MarshalTo 

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

func (*RaftCmdRequest) MarshalToSizedBuffer 

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

func (*RaftCmdRequest) ProtoMessage 

func (*RaftCmdRequest) ProtoMessage()

func (*RaftCmdRequest) Reset 

func (m *RaftCmdRequest) Reset()

func (*RaftCmdRequest) Size 

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

func (*RaftCmdRequest) String 

func (m *RaftCmdRequest) String() string

func (*RaftCmdRequest) Unmarshal 

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

func (*RaftCmdRequest) XXX_DiscardUnknown 

func (m *RaftCmdRequest) XXX_DiscardUnknown()

func (*RaftCmdRequest) XXX_Marshal 

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

func (*RaftCmdRequest) XXX_Merge 

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

func (*RaftCmdRequest) XXX_Size 

func (m *RaftCmdRequest) XXX_Size() int

func (*RaftCmdRequest) XXX_Unmarshal 

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

type RaftCmdResponse 

type RaftCmdResponse struct {
	Header               *RaftResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Responses            []*Response         `protobuf:"bytes,2,rep,name=responses,proto3" json:"responses,omitempty"`
	AdminResponse        *AdminResponse      `protobuf:"bytes,3,opt,name=admin_response,json=adminResponse,proto3" json:"admin_response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RaftCmdResponse) Descriptor 

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

func (*RaftCmdResponse) GetAdminResponse 

func (m *RaftCmdResponse) GetAdminResponse() *AdminResponse

func (*RaftCmdResponse) GetHeader 

func (m *RaftCmdResponse) GetHeader() *RaftResponseHeader

func (*RaftCmdResponse) GetResponses 

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

func (*RaftCmdResponse) Marshal 

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

func (*RaftCmdResponse) MarshalTo 

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

func (*RaftCmdResponse) MarshalToSizedBuffer 

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

func (*RaftCmdResponse) ProtoMessage 

func (*RaftCmdResponse) ProtoMessage()

func (*RaftCmdResponse) Reset 

func (m *RaftCmdResponse) Reset()

func (*RaftCmdResponse) Size 

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

func (*RaftCmdResponse) String 

func (m *RaftCmdResponse) String() string

func (*RaftCmdResponse) Unmarshal 

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

func (*RaftCmdResponse) XXX_DiscardUnknown 

func (m *RaftCmdResponse) XXX_DiscardUnknown()

func (*RaftCmdResponse) XXX_Marshal 

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

func (*RaftCmdResponse) XXX_Merge 

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

func (*RaftCmdResponse) XXX_Size 

func (m *RaftCmdResponse) XXX_Size() int

func (*RaftCmdResponse) XXX_Unmarshal 

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

type RaftRequestHeader 

type RaftRequestHeader struct {
	RegionId             uint64              `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Peer                 *metapb.Peer        `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	RegionEpoch          *metapb.RegionEpoch `protobuf:"bytes,4,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
	Term                 uint64              `protobuf:"varint,5,opt,name=term,proto3" json:"term,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) GetRegionEpoch 

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

func (*RaftRequestHeader) GetRegionId 

func (m *RaftRequestHeader) GetRegionId() uint64

func (*RaftRequestHeader) GetTerm 

func (m *RaftRequestHeader) GetTerm() uint64

func (*RaftRequestHeader) Marshal 

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

func (*RaftRequestHeader) MarshalTo 

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

func (*RaftRequestHeader) MarshalToSizedBuffer 

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

func (*RaftRequestHeader) ProtoMessage 

func (*RaftRequestHeader) ProtoMessage()

func (*RaftRequestHeader) Reset 

func (m *RaftRequestHeader) Reset()

func (*RaftRequestHeader) Size 

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

func (*RaftRequestHeader) String 

func (m *RaftRequestHeader) String() string

func (*RaftRequestHeader) Unmarshal 

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

func (*RaftRequestHeader) XXX_DiscardUnknown 

func (m *RaftRequestHeader) XXX_DiscardUnknown()

func (*RaftRequestHeader) XXX_Marshal 

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

func (*RaftRequestHeader) XXX_Merge 

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

func (*RaftRequestHeader) XXX_Size 

func (m *RaftRequestHeader) XXX_Size() int

func (*RaftRequestHeader) XXX_Unmarshal 

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

type RaftResponseHeader 

type RaftResponseHeader struct {
	Error                *errorpb.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Uuid                 []byte         `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	CurrentTerm          uint64         `protobuf:"varint,3,opt,name=current_term,json=currentTerm,proto3" json:"current_term,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RaftResponseHeader) Descriptor 

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

func (*RaftResponseHeader) GetCurrentTerm 

func (m *RaftResponseHeader) GetCurrentTerm() uint64

func (*RaftResponseHeader) GetError 

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

func (*RaftResponseHeader) GetUuid 

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

func (*RaftResponseHeader) Marshal 

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

func (*RaftResponseHeader) MarshalTo 

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

func (*RaftResponseHeader) MarshalToSizedBuffer 

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

func (*RaftResponseHeader) ProtoMessage 

func (*RaftResponseHeader) ProtoMessage()

func (*RaftResponseHeader) Reset 

func (m *RaftResponseHeader) Reset()

func (*RaftResponseHeader) Size 

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

func (*RaftResponseHeader) String 

func (m *RaftResponseHeader) String() string

func (*RaftResponseHeader) Unmarshal 

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

func (*RaftResponseHeader) XXX_DiscardUnknown 

func (m *RaftResponseHeader) XXX_DiscardUnknown()

func (*RaftResponseHeader) XXX_Marshal 

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

func (*RaftResponseHeader) XXX_Merge 

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

func (*RaftResponseHeader) XXX_Size 

func (m *RaftResponseHeader) XXX_Size() int

func (*RaftResponseHeader) XXX_Unmarshal 

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

type Request 

type Request struct {
	CmdType              CmdType        `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.CmdType" json:"cmd_type,omitempty"`
	Get                  *GetRequest    `protobuf:"bytes,2,opt,name=get,proto3" json:"get,omitempty"`
	Put                  *PutRequest    `protobuf:"bytes,4,opt,name=put,proto3" json:"put,omitempty"`
	Delete               *DeleteRequest `protobuf:"bytes,5,opt,name=delete,proto3" json:"delete,omitempty"`
	Snap                 *SnapRequest   `protobuf:"bytes,6,opt,name=snap,proto3" json:"snap,omitempty"`
	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) GetGet 

func (m *Request) GetGet() *GetRequest

func (*Request) GetPut 

func (m *Request) GetPut() *PutRequest

func (*Request) GetSnap 

func (m *Request) GetSnap() *SnapRequest

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer 

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

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type Response 

type Response struct {
	CmdType              CmdType         `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,proto3,enum=raft_cmdpb.CmdType" json:"cmd_type,omitempty"`
	Get                  *GetResponse    `protobuf:"bytes,2,opt,name=get,proto3" json:"get,omitempty"`
	Put                  *PutResponse    `protobuf:"bytes,4,opt,name=put,proto3" json:"put,omitempty"`
	Delete               *DeleteResponse `protobuf:"bytes,5,opt,name=delete,proto3" json:"delete,omitempty"`
	Snap                 *SnapResponse   `protobuf:"bytes,6,opt,name=snap,proto3" json:"snap,omitempty"`
	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) GetGet 

func (m *Response) GetGet() *GetResponse

func (*Response) GetPut 

func (m *Response) GetPut() *PutResponse

func (*Response) GetSnap 

func (m *Response) GetSnap() *SnapResponse

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type SnapRequest 

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

func (*SnapRequest) Descriptor 

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

func (*SnapRequest) Marshal 

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

func (*SnapRequest) MarshalTo 

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

func (*SnapRequest) MarshalToSizedBuffer 

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

func (*SnapRequest) ProtoMessage 

func (*SnapRequest) ProtoMessage()

func (*SnapRequest) Reset 

func (m *SnapRequest) Reset()

func (*SnapRequest) Size 

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

func (*SnapRequest) String 

func (m *SnapRequest) String() string

func (*SnapRequest) Unmarshal 

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

func (*SnapRequest) XXX_DiscardUnknown 

func (m *SnapRequest) XXX_DiscardUnknown()

func (*SnapRequest) XXX_Marshal 

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

func (*SnapRequest) XXX_Merge 

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

func (*SnapRequest) XXX_Size 

func (m *SnapRequest) XXX_Size() int

func (*SnapRequest) XXX_Unmarshal 

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

type SnapResponse 

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

func (*SnapResponse) Descriptor 

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

func (*SnapResponse) GetRegion 

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

func (*SnapResponse) Marshal 

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

func (*SnapResponse) MarshalTo 

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

func (*SnapResponse) MarshalToSizedBuffer 

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

func (*SnapResponse) ProtoMessage 

func (*SnapResponse) ProtoMessage()

func (*SnapResponse) Reset 

func (m *SnapResponse) Reset()

func (*SnapResponse) Size 

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

func (*SnapResponse) String 

func (m *SnapResponse) String() string

func (*SnapResponse) Unmarshal 

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

func (*SnapResponse) XXX_DiscardUnknown 

func (m *SnapResponse) XXX_DiscardUnknown()

func (*SnapResponse) XXX_Marshal 

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

func (*SnapResponse) XXX_Merge 

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

func (*SnapResponse) XXX_Size 

func (m *SnapResponse) XXX_Size() int

func (*SnapResponse) XXX_Unmarshal 

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

type SplitRequest 

type SplitRequest struct {
	// This can be only called in internal Raftstore now.
	// The split_key has to exist in the splitting region.
	SplitKey []byte `protobuf:"bytes,1,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
	// We split the region into two. The first uses the origin
	// parent region id, and the second uses the new_region_id.
	// We must guarantee that the new_region_id is global unique.
	NewRegionId uint64 `protobuf:"varint,2,opt,name=new_region_id,json=newRegionId,proto3" json:"new_region_id,omitempty"`
	// The peer ids for the new split region.
	NewPeerIds           []uint64 `protobuf:"varint,3,rep,packed,name=new_peer_ids,json=newPeerIds,proto3" json:"new_peer_ids,omitempty"`
	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) GetSplitKey 

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

func (*SplitRequest) Marshal 

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

func (*SplitRequest) MarshalTo 

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

func (*SplitRequest) MarshalToSizedBuffer 

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

func (*SplitRequest) ProtoMessage 

func (*SplitRequest) ProtoMessage()

func (*SplitRequest) Reset 

func (m *SplitRequest) Reset()

func (*SplitRequest) Size 

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

func (*SplitRequest) String 

func (m *SplitRequest) String() string

func (*SplitRequest) Unmarshal 

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

func (*SplitRequest) XXX_DiscardUnknown 

func (m *SplitRequest) XXX_DiscardUnknown()

func (*SplitRequest) XXX_Marshal 

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

func (*SplitRequest) XXX_Merge 

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

func (*SplitRequest) XXX_Size 

func (m *SplitRequest) XXX_Size() int

func (*SplitRequest) XXX_Unmarshal 

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

type SplitResponse 

type SplitResponse struct {
	// SplitResponse contains the region where specific keys have split into.
	Regions              []*metapb.Region `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SplitResponse) Descriptor 

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

func (*SplitResponse) GetRegions 

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

func (*SplitResponse) Marshal 

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

func (*SplitResponse) MarshalTo 

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

func (*SplitResponse) MarshalToSizedBuffer 

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

func (*SplitResponse) ProtoMessage 

func (*SplitResponse) ProtoMessage()

func (*SplitResponse) Reset 

func (m *SplitResponse) Reset()

func (*SplitResponse) Size 

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

func (*SplitResponse) String 

func (m *SplitResponse) String() string

func (*SplitResponse) Unmarshal 

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

func (*SplitResponse) XXX_DiscardUnknown 

func (m *SplitResponse) XXX_DiscardUnknown()

func (*SplitResponse) XXX_Marshal 

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

func (*SplitResponse) XXX_Merge 

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

func (*SplitResponse) XXX_Size 

func (m *SplitResponse) XXX_Size() int

func (*SplitResponse) XXX_Unmarshal 

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

type TransferLeaderRequest 

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

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

func (*TransferLeaderRequest) ProtoMessage 

func (*TransferLeaderRequest) ProtoMessage()

func (*TransferLeaderRequest) Reset 

func (m *TransferLeaderRequest) Reset()

func (*TransferLeaderRequest) Size 

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

func (*TransferLeaderRequest) String 

func (m *TransferLeaderRequest) String() string

func (*TransferLeaderRequest) Unmarshal 

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

func (*TransferLeaderRequest) XXX_DiscardUnknown 

func (m *TransferLeaderRequest) XXX_DiscardUnknown()

func (*TransferLeaderRequest) XXX_Marshal 

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

func (*TransferLeaderRequest) XXX_Merge 

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

func (*TransferLeaderRequest) XXX_Size 

func (m *TransferLeaderRequest) XXX_Size() int

func (*TransferLeaderRequest) XXX_Unmarshal 

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

type TransferLeaderResponse 

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

func (*TransferLeaderResponse) Descriptor 

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

func (*TransferLeaderResponse) Marshal 

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

func (*TransferLeaderResponse) MarshalTo 

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

func (*TransferLeaderResponse) MarshalToSizedBuffer 

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

func (*TransferLeaderResponse) ProtoMessage 

func (*TransferLeaderResponse) ProtoMessage()

func (*TransferLeaderResponse) Reset 

func (m *TransferLeaderResponse) Reset()

func (*TransferLeaderResponse) Size 

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

func (*TransferLeaderResponse) String 

func (m *TransferLeaderResponse) String() string

func (*TransferLeaderResponse) Unmarshal 

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

func (*TransferLeaderResponse) XXX_DiscardUnknown 

func (m *TransferLeaderResponse) XXX_DiscardUnknown()

func (*TransferLeaderResponse) XXX_Marshal 

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

func (*TransferLeaderResponse) XXX_Merge 

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

func (*TransferLeaderResponse) XXX_Size 

func (m *TransferLeaderResponse) XXX_Size() int

func (*TransferLeaderResponse) XXX_Unmarshal 

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

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.