pdpb

package
v0.0.0-...-f0aa2c5 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPdpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPdpb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ConfChangeType_name = map[int32]string{
	0: "AddNode",
	1: "RemoveNode",
}
View Source 
var ConfChangeType_value = map[string]int32{
	"AddNode":    0,
	"RemoveNode": 1,
}
View Source 
var FieldType_name = map[int32]string{
	0: "Text",
	1: "Uint8",
	2: "Uint16",
	3: "Uint32",
	4: "Uint64",
	5: "Float32",
	6: "Float64",
}
View Source 
var FieldType_value = map[string]int32{
	"Text":    0,
	"Uint8":   1,
	"Uint16":  2,
	"Uint32":  3,
	"Uint64":  4,
	"Float32": 5,
	"Float64": 6,
}

Functions

func RegisterPDServiceServer 

func RegisterPDServiceServer(s *grpc.Server, srv PDServiceServer)

Types

type AllocIDReq 

type AllocIDReq struct {
	From                 string   `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64   `protobuf:"varint,2,opt,name=id" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AllocIDReq) Descriptor 

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

func (*AllocIDReq) GetFrom 

func (m *AllocIDReq) GetFrom() string

func (*AllocIDReq) GetID 

func (m *AllocIDReq) GetID() uint64

func (*AllocIDReq) Marshal 

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

func (*AllocIDReq) MarshalTo 

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

func (*AllocIDReq) MarshalToSizedBuffer 

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

func (*AllocIDReq) ProtoMessage 

func (*AllocIDReq) ProtoMessage()

func (*AllocIDReq) Reset 

func (m *AllocIDReq) Reset()

func (*AllocIDReq) Size 

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

func (*AllocIDReq) String 

func (m *AllocIDReq) String() string

func (*AllocIDReq) Unmarshal 

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

func (*AllocIDReq) XXX_DiscardUnknown 

func (m *AllocIDReq) XXX_DiscardUnknown()

func (*AllocIDReq) XXX_Marshal 

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

func (*AllocIDReq) XXX_Merge 

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

func (*AllocIDReq) XXX_Size 

func (m *AllocIDReq) XXX_Size() int

func (*AllocIDReq) XXX_Unmarshal 

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

type AllocIDRsp 

type AllocIDRsp struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AllocIDRsp) Descriptor 

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

func (*AllocIDRsp) GetID 

func (m *AllocIDRsp) GetID() uint64

func (*AllocIDRsp) Marshal 

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

func (*AllocIDRsp) MarshalTo 

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

func (*AllocIDRsp) MarshalToSizedBuffer 

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

func (*AllocIDRsp) ProtoMessage 

func (*AllocIDRsp) ProtoMessage()

func (*AllocIDRsp) Reset 

func (m *AllocIDRsp) Reset()

func (*AllocIDRsp) Size 

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

func (*AllocIDRsp) String 

func (m *AllocIDRsp) String() string

func (*AllocIDRsp) Unmarshal 

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

func (*AllocIDRsp) XXX_DiscardUnknown 

func (m *AllocIDRsp) XXX_DiscardUnknown()

func (*AllocIDRsp) XXX_Marshal 

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

func (*AllocIDRsp) XXX_Merge 

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

func (*AllocIDRsp) XXX_Size 

func (m *AllocIDRsp) XXX_Size() int

func (*AllocIDRsp) XXX_Unmarshal 

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

type AskSplitReq 

type AskSplitReq struct {
	From                 string        `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64        `protobuf:"varint,2,opt,name=id" json:"id"`
	Header               RequestHeader `protobuf:"bytes,3,opt,name=header" json:"header"`
	Cell                 metapb.Cell   `protobuf:"bytes,4,opt,name=cell" json:"cell"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*AskSplitReq) Descriptor 

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

func (*AskSplitReq) GetCell 

func (m *AskSplitReq) GetCell() metapb.Cell

func (*AskSplitReq) GetFrom 

func (m *AskSplitReq) GetFrom() string

func (*AskSplitReq) GetHeader 

func (m *AskSplitReq) GetHeader() RequestHeader

func (*AskSplitReq) GetID 

func (m *AskSplitReq) GetID() uint64

func (*AskSplitReq) Marshal 

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

func (*AskSplitReq) MarshalTo 

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

func (*AskSplitReq) MarshalToSizedBuffer 

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

func (*AskSplitReq) ProtoMessage 

func (*AskSplitReq) ProtoMessage()

func (*AskSplitReq) Reset 

func (m *AskSplitReq) Reset()

func (*AskSplitReq) Size 

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

func (*AskSplitReq) String 

func (m *AskSplitReq) String() string

func (*AskSplitReq) Unmarshal 

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

func (*AskSplitReq) XXX_DiscardUnknown 

func (m *AskSplitReq) XXX_DiscardUnknown()

func (*AskSplitReq) XXX_Marshal 

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

func (*AskSplitReq) XXX_Merge 

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

func (*AskSplitReq) XXX_Size 

func (m *AskSplitReq) XXX_Size() int

func (*AskSplitReq) XXX_Unmarshal 

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

type AskSplitRsp 

type AskSplitRsp struct {
	Header               ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
	NewCellID            uint64         `protobuf:"varint,2,opt,name=newCellID" json:"newCellID"`
	NewPeerIDs           []uint64       `protobuf:"varint,3,rep,name=newPeerIDs" json:"newPeerIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AskSplitRsp) Descriptor 

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

func (*AskSplitRsp) GetHeader 

func (m *AskSplitRsp) GetHeader() ResponseHeader

func (*AskSplitRsp) GetNewCellID 

func (m *AskSplitRsp) GetNewCellID() uint64

func (*AskSplitRsp) GetNewPeerIDs 

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

func (*AskSplitRsp) Marshal 

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

func (*AskSplitRsp) MarshalTo 

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

func (*AskSplitRsp) MarshalToSizedBuffer 

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

func (*AskSplitRsp) ProtoMessage 

func (*AskSplitRsp) ProtoMessage()

func (*AskSplitRsp) Reset 

func (m *AskSplitRsp) Reset()

func (*AskSplitRsp) Size 

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

func (*AskSplitRsp) String 

func (m *AskSplitRsp) String() string

func (*AskSplitRsp) Unmarshal 

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

func (*AskSplitRsp) XXX_DiscardUnknown 

func (m *AskSplitRsp) XXX_DiscardUnknown()

func (*AskSplitRsp) XXX_Marshal 

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

func (*AskSplitRsp) XXX_Merge 

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

func (*AskSplitRsp) XXX_Size 

func (m *AskSplitRsp) XXX_Size() int

func (*AskSplitRsp) XXX_Unmarshal 

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

type BootstrapClusterReq 

type BootstrapClusterReq struct {
	From                 string        `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64        `protobuf:"varint,2,opt,name=id" json:"id"`
	Store                metapb.Store  `protobuf:"bytes,3,opt,name=store" json:"store"`
	Cells                []metapb.Cell `protobuf:"bytes,4,rep,name=cells" json:"cells"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*BootstrapClusterReq) Descriptor 

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

func (*BootstrapClusterReq) GetCells 

func (m *BootstrapClusterReq) GetCells() []metapb.Cell

func (*BootstrapClusterReq) GetFrom 

func (m *BootstrapClusterReq) GetFrom() string

func (*BootstrapClusterReq) GetID 

func (m *BootstrapClusterReq) GetID() uint64

func (*BootstrapClusterReq) GetStore 

func (m *BootstrapClusterReq) GetStore() metapb.Store

func (*BootstrapClusterReq) Marshal 

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

func (*BootstrapClusterReq) MarshalTo 

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

func (*BootstrapClusterReq) MarshalToSizedBuffer 

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

func (*BootstrapClusterReq) ProtoMessage 

func (*BootstrapClusterReq) ProtoMessage()

func (*BootstrapClusterReq) Reset 

func (m *BootstrapClusterReq) Reset()

func (*BootstrapClusterReq) Size 

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

func (*BootstrapClusterReq) String 

func (m *BootstrapClusterReq) String() string

func (*BootstrapClusterReq) Unmarshal 

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

func (*BootstrapClusterReq) XXX_DiscardUnknown 

func (m *BootstrapClusterReq) XXX_DiscardUnknown()

func (*BootstrapClusterReq) XXX_Marshal 

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

func (*BootstrapClusterReq) XXX_Merge 

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

func (*BootstrapClusterReq) XXX_Size 

func (m *BootstrapClusterReq) XXX_Size() int

func (*BootstrapClusterReq) XXX_Unmarshal 

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

type BootstrapClusterRsp 

type BootstrapClusterRsp struct {
	AlreadyBootstrapped  bool     `protobuf:"varint,1,opt,name=alreadyBootstrapped" json:"alreadyBootstrapped"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BootstrapClusterRsp) Descriptor 

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

func (*BootstrapClusterRsp) GetAlreadyBootstrapped 

func (m *BootstrapClusterRsp) GetAlreadyBootstrapped() bool

func (*BootstrapClusterRsp) Marshal 

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

func (*BootstrapClusterRsp) MarshalTo 

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

func (*BootstrapClusterRsp) MarshalToSizedBuffer 

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

func (*BootstrapClusterRsp) ProtoMessage 

func (*BootstrapClusterRsp) ProtoMessage()

func (*BootstrapClusterRsp) Reset 

func (m *BootstrapClusterRsp) Reset()

func (*BootstrapClusterRsp) Size 

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

func (*BootstrapClusterRsp) String 

func (m *BootstrapClusterRsp) String() string

func (*BootstrapClusterRsp) Unmarshal 

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

func (*BootstrapClusterRsp) XXX_DiscardUnknown 

func (m *BootstrapClusterRsp) XXX_DiscardUnknown()

func (*BootstrapClusterRsp) XXX_Marshal 

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

func (*BootstrapClusterRsp) XXX_Merge 

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

func (*BootstrapClusterRsp) XXX_Size 

func (m *BootstrapClusterRsp) XXX_Size() int

func (*BootstrapClusterRsp) XXX_Unmarshal 

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

type CellEvent 

type CellEvent struct {
	Range                *Range   `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CellEvent) Descriptor 

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

func (*CellEvent) GetRange 

func (m *CellEvent) GetRange() *Range

func (*CellEvent) Marshal 

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

func (*CellEvent) MarshalTo 

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

func (*CellEvent) MarshalToSizedBuffer 

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

func (*CellEvent) ProtoMessage 

func (*CellEvent) ProtoMessage()

func (*CellEvent) Reset 

func (m *CellEvent) Reset()

func (*CellEvent) Size 

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

func (*CellEvent) String 

func (m *CellEvent) String() string

func (*CellEvent) Unmarshal 

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

func (*CellEvent) XXX_DiscardUnknown 

func (m *CellEvent) XXX_DiscardUnknown()

func (*CellEvent) XXX_Marshal 

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

func (*CellEvent) XXX_Merge 

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

func (*CellEvent) XXX_Size 

func (m *CellEvent) XXX_Size() int

func (*CellEvent) XXX_Unmarshal 

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

type CellHeartbeatReq 

type CellHeartbeatReq struct {
	From   string       `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID     uint64       `protobuf:"varint,2,opt,name=id" json:"id"`
	Cell   metapb.Cell  `protobuf:"bytes,3,opt,name=cell" json:"cell"`
	Leader *metapb.Peer `protobuf:"bytes,4,opt,name=leader" json:"leader,omitempty"`
	// Leader considers that these peers are down.
	DownPeers []PeerStats `protobuf:"bytes,5,rep,name=downPeers" json:"downPeers"`
	// Pending peers are the peers that the leader can't consider as
	// working followers.
	PendingPeers []metapb.Peer `protobuf:"bytes,6,rep,name=pendingPeers" json:"pendingPeers"`
	// Bytes read/written during this period.
	BytesWritten uint64 `protobuf:"varint,7,opt,name=bytesWritten" json:"bytesWritten"`
	BytesRead    uint64 `protobuf:"varint,8,opt,name=bytesRead" json:"bytesRead"`
	// Keys read/written during this period.
	KeysWritten          uint64   `protobuf:"varint,9,opt,name=keysWritten" json:"keysWritten"`
	KeysRead             uint64   `protobuf:"varint,10,opt,name=keysRead" json:"keysRead"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CellHeartbeatReq) Descriptor 

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

func (*CellHeartbeatReq) GetBytesRead 

func (m *CellHeartbeatReq) GetBytesRead() uint64

func (*CellHeartbeatReq) GetBytesWritten 

func (m *CellHeartbeatReq) GetBytesWritten() uint64

func (*CellHeartbeatReq) GetCell 

func (m *CellHeartbeatReq) GetCell() metapb.Cell

func (*CellHeartbeatReq) GetDownPeers 

func (m *CellHeartbeatReq) GetDownPeers() []PeerStats

func (*CellHeartbeatReq) GetFrom 

func (m *CellHeartbeatReq) GetFrom() string

func (*CellHeartbeatReq) GetID 

func (m *CellHeartbeatReq) GetID() uint64

func (*CellHeartbeatReq) GetKeysRead 

func (m *CellHeartbeatReq) GetKeysRead() uint64

func (*CellHeartbeatReq) GetKeysWritten 

func (m *CellHeartbeatReq) GetKeysWritten() uint64

func (*CellHeartbeatReq) GetLeader 

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

func (*CellHeartbeatReq) GetPendingPeers 

func (m *CellHeartbeatReq) GetPendingPeers() []metapb.Peer

func (*CellHeartbeatReq) Marshal 

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

func (*CellHeartbeatReq) MarshalTo 

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

func (*CellHeartbeatReq) MarshalToSizedBuffer 

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

func (*CellHeartbeatReq) ProtoMessage 

func (*CellHeartbeatReq) ProtoMessage()

func (*CellHeartbeatReq) Reset 

func (m *CellHeartbeatReq) Reset()

func (*CellHeartbeatReq) Size 

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

func (*CellHeartbeatReq) String 

func (m *CellHeartbeatReq) String() string

func (*CellHeartbeatReq) Unmarshal 

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

func (*CellHeartbeatReq) XXX_DiscardUnknown 

func (m *CellHeartbeatReq) XXX_DiscardUnknown()

func (*CellHeartbeatReq) XXX_Marshal 

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

func (*CellHeartbeatReq) XXX_Merge 

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

func (*CellHeartbeatReq) XXX_Size 

func (m *CellHeartbeatReq) XXX_Size() int

func (*CellHeartbeatReq) XXX_Unmarshal 

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

type CellHeartbeatRsp 

type CellHeartbeatRsp struct {
	ChangePeer           *ChangePeer     `protobuf:"bytes,1,opt,name=changePeer" json:"changePeer,omitempty"`
	TransferLeader       *TransferLeader `protobuf:"bytes,2,opt,name=transferLeader" json:"transferLeader,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CellHeartbeatRsp) Descriptor 

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

func (*CellHeartbeatRsp) GetChangePeer 

func (m *CellHeartbeatRsp) GetChangePeer() *ChangePeer

func (*CellHeartbeatRsp) GetTransferLeader 

func (m *CellHeartbeatRsp) GetTransferLeader() *TransferLeader

func (*CellHeartbeatRsp) Marshal 

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

func (*CellHeartbeatRsp) MarshalTo 

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

func (*CellHeartbeatRsp) MarshalToSizedBuffer 

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

func (*CellHeartbeatRsp) ProtoMessage 

func (*CellHeartbeatRsp) ProtoMessage()

func (*CellHeartbeatRsp) Reset 

func (m *CellHeartbeatRsp) Reset()

func (*CellHeartbeatRsp) Size 

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

func (*CellHeartbeatRsp) String 

func (m *CellHeartbeatRsp) String() string

func (*CellHeartbeatRsp) Unmarshal 

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

func (*CellHeartbeatRsp) XXX_DiscardUnknown 

func (m *CellHeartbeatRsp) XXX_DiscardUnknown()

func (*CellHeartbeatRsp) XXX_Marshal 

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

func (*CellHeartbeatRsp) XXX_Merge 

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

func (*CellHeartbeatRsp) XXX_Size 

func (m *CellHeartbeatRsp) XXX_Size() int

func (*CellHeartbeatRsp) XXX_Unmarshal 

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

type ChangePeer 

type ChangePeer struct {
	Type                 ConfChangeType `protobuf:"varint,1,opt,name=type,enum=pdpb.ConfChangeType" json:"type"`
	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 (*ChangePeer) Descriptor 

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

func (*ChangePeer) GetPeer 

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

func (*ChangePeer) GetType 

func (m *ChangePeer) GetType() ConfChangeType

func (*ChangePeer) Marshal 

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

func (*ChangePeer) MarshalTo 

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

func (*ChangePeer) MarshalToSizedBuffer 

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

func (*ChangePeer) ProtoMessage 

func (*ChangePeer) ProtoMessage()

func (*ChangePeer) Reset 

func (m *ChangePeer) Reset()

func (*ChangePeer) Size 

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

func (*ChangePeer) String 

func (m *ChangePeer) String() string

func (*ChangePeer) Unmarshal 

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

func (*ChangePeer) XXX_DiscardUnknown 

func (m *ChangePeer) XXX_DiscardUnknown()

func (*ChangePeer) XXX_Marshal 

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

func (*ChangePeer) XXX_Merge 

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

func (*ChangePeer) XXX_Size 

func (m *ChangePeer) XXX_Size() int

func (*ChangePeer) XXX_Unmarshal 

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

type ConfChangeType 

type ConfChangeType int32
const (
	AddNode    ConfChangeType = 0
	RemoveNode ConfChangeType = 1
)

func (ConfChangeType) Enum 

func (x ConfChangeType) Enum() *ConfChangeType

func (ConfChangeType) EnumDescriptor 

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

func (ConfChangeType) String 

func (x ConfChangeType) String() string

func (*ConfChangeType) UnmarshalJSON 

func (x *ConfChangeType) UnmarshalJSON(data []byte) error

type FieldDef 

type FieldDef struct {
	Name                 *string    `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Type                 *FieldType `protobuf:"varint,2,req,name=type,enum=pdpb.FieldType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*FieldDef) Descriptor 

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

func (*FieldDef) GetName 

func (m *FieldDef) GetName() string

func (*FieldDef) GetType 

func (m *FieldDef) GetType() FieldType

func (*FieldDef) Marshal 

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

func (*FieldDef) MarshalTo 

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

func (*FieldDef) MarshalToSizedBuffer 

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

func (*FieldDef) ProtoMessage 

func (*FieldDef) ProtoMessage()

func (*FieldDef) Reset 

func (m *FieldDef) Reset()

func (*FieldDef) Size 

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

func (*FieldDef) String 

func (m *FieldDef) String() string

func (*FieldDef) Unmarshal 

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

func (*FieldDef) XXX_DiscardUnknown 

func (m *FieldDef) XXX_DiscardUnknown()

func (*FieldDef) XXX_Marshal 

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

func (*FieldDef) XXX_Merge 

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

func (*FieldDef) XXX_Size 

func (m *FieldDef) XXX_Size() int

func (*FieldDef) XXX_Unmarshal 

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

type FieldType 

type FieldType int32
const (
	Text    FieldType = 0
	Uint8   FieldType = 1
	Uint16  FieldType = 2
	Uint32  FieldType = 3
	Uint64  FieldType = 4
	Float32 FieldType = 5
	Float64 FieldType = 6
)

func (FieldType) Enum 

func (x FieldType) Enum() *FieldType

func (FieldType) EnumDescriptor 

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

func (FieldType) String 

func (x FieldType) String() string

func (*FieldType) UnmarshalJSON 

func (x *FieldType) UnmarshalJSON(data []byte) error

type GetClusterIDReq 

type GetClusterIDReq struct {
	From                 string   `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64   `protobuf:"varint,2,opt,name=id" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClusterIDReq) Descriptor 

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

func (*GetClusterIDReq) GetFrom 

func (m *GetClusterIDReq) GetFrom() string

func (*GetClusterIDReq) GetID 

func (m *GetClusterIDReq) GetID() uint64

func (*GetClusterIDReq) Marshal 

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

func (*GetClusterIDReq) MarshalTo 

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

func (*GetClusterIDReq) MarshalToSizedBuffer 

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

func (*GetClusterIDReq) ProtoMessage 

func (*GetClusterIDReq) ProtoMessage()

func (*GetClusterIDReq) Reset 

func (m *GetClusterIDReq) Reset()

func (*GetClusterIDReq) Size 

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

func (*GetClusterIDReq) String 

func (m *GetClusterIDReq) String() string

func (*GetClusterIDReq) Unmarshal 

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

func (*GetClusterIDReq) XXX_DiscardUnknown 

func (m *GetClusterIDReq) XXX_DiscardUnknown()

func (*GetClusterIDReq) XXX_Marshal 

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

func (*GetClusterIDReq) XXX_Merge 

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

func (*GetClusterIDReq) XXX_Size 

func (m *GetClusterIDReq) XXX_Size() int

func (*GetClusterIDReq) XXX_Unmarshal 

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

type GetClusterIDRsp 

type GetClusterIDRsp struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClusterIDRsp) Descriptor 

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

func (*GetClusterIDRsp) GetID 

func (m *GetClusterIDRsp) GetID() uint64

func (*GetClusterIDRsp) Marshal 

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

func (*GetClusterIDRsp) MarshalTo 

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

func (*GetClusterIDRsp) MarshalToSizedBuffer 

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

func (*GetClusterIDRsp) ProtoMessage 

func (*GetClusterIDRsp) ProtoMessage()

func (*GetClusterIDRsp) Reset 

func (m *GetClusterIDRsp) Reset()

func (*GetClusterIDRsp) Size 

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

func (*GetClusterIDRsp) String 

func (m *GetClusterIDRsp) String() string

func (*GetClusterIDRsp) Unmarshal 

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

func (*GetClusterIDRsp) XXX_DiscardUnknown 

func (m *GetClusterIDRsp) XXX_DiscardUnknown()

func (*GetClusterIDRsp) XXX_Marshal 

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

func (*GetClusterIDRsp) XXX_Merge 

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

func (*GetClusterIDRsp) XXX_Size 

func (m *GetClusterIDRsp) XXX_Size() int

func (*GetClusterIDRsp) XXX_Unmarshal 

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

type GetInitParamsReq 

type GetInitParamsReq struct {
	From                 string   `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64   `protobuf:"varint,2,opt,name=id" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetInitParamsReq) Descriptor 

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

func (*GetInitParamsReq) GetFrom 

func (m *GetInitParamsReq) GetFrom() string

func (*GetInitParamsReq) GetID 

func (m *GetInitParamsReq) GetID() uint64

func (*GetInitParamsReq) Marshal 

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

func (*GetInitParamsReq) MarshalTo 

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

func (*GetInitParamsReq) MarshalToSizedBuffer 

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

func (*GetInitParamsReq) ProtoMessage 

func (*GetInitParamsReq) ProtoMessage()

func (*GetInitParamsReq) Reset 

func (m *GetInitParamsReq) Reset()

func (*GetInitParamsReq) Size 

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

func (*GetInitParamsReq) String 

func (m *GetInitParamsReq) String() string

func (*GetInitParamsReq) Unmarshal 

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

func (*GetInitParamsReq) XXX_DiscardUnknown 

func (m *GetInitParamsReq) XXX_DiscardUnknown()

func (*GetInitParamsReq) XXX_Marshal 

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

func (*GetInitParamsReq) XXX_Merge 

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

func (*GetInitParamsReq) XXX_Size 

func (m *GetInitParamsReq) XXX_Size() int

func (*GetInitParamsReq) XXX_Unmarshal 

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

type GetInitParamsRsp 

type GetInitParamsRsp struct {
	Params               []byte   `protobuf:"bytes,1,opt,name=params" json:"params,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetInitParamsRsp) Descriptor 

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

func (*GetInitParamsRsp) GetParams 

func (m *GetInitParamsRsp) GetParams() []byte

func (*GetInitParamsRsp) Marshal 

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

func (*GetInitParamsRsp) MarshalTo 

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

func (*GetInitParamsRsp) MarshalToSizedBuffer 

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

func (*GetInitParamsRsp) ProtoMessage 

func (*GetInitParamsRsp) ProtoMessage()

func (*GetInitParamsRsp) Reset 

func (m *GetInitParamsRsp) Reset()

func (*GetInitParamsRsp) Size 

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

func (*GetInitParamsRsp) String 

func (m *GetInitParamsRsp) String() string

func (*GetInitParamsRsp) Unmarshal 

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

func (*GetInitParamsRsp) XXX_DiscardUnknown 

func (m *GetInitParamsRsp) XXX_DiscardUnknown()

func (*GetInitParamsRsp) XXX_Marshal 

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

func (*GetInitParamsRsp) XXX_Merge 

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

func (*GetInitParamsRsp) XXX_Size 

func (m *GetInitParamsRsp) XXX_Size() int

func (*GetInitParamsRsp) XXX_Unmarshal 

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

type GetLastRangesReq 

type GetLastRangesReq struct {
	From                 string   `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64   `protobuf:"varint,2,opt,name=id" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetLastRangesReq) Descriptor 

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

func (*GetLastRangesReq) GetFrom 

func (m *GetLastRangesReq) GetFrom() string

func (*GetLastRangesReq) GetID 

func (m *GetLastRangesReq) GetID() uint64

func (*GetLastRangesReq) Marshal 

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

func (*GetLastRangesReq) MarshalTo 

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

func (*GetLastRangesReq) MarshalToSizedBuffer 

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

func (*GetLastRangesReq) ProtoMessage 

func (*GetLastRangesReq) ProtoMessage()

func (*GetLastRangesReq) Reset 

func (m *GetLastRangesReq) Reset()

func (*GetLastRangesReq) Size 

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

func (*GetLastRangesReq) String 

func (m *GetLastRangesReq) String() string

func (*GetLastRangesReq) Unmarshal 

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

func (*GetLastRangesReq) XXX_DiscardUnknown 

func (m *GetLastRangesReq) XXX_DiscardUnknown()

func (*GetLastRangesReq) XXX_Marshal 

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

func (*GetLastRangesReq) XXX_Merge 

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

func (*GetLastRangesReq) XXX_Size 

func (m *GetLastRangesReq) XXX_Size() int

func (*GetLastRangesReq) XXX_Unmarshal 

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

type GetLastRangesRsp 

type GetLastRangesRsp struct {
	Ranges               []*Range `protobuf:"bytes,1,rep,name=ranges" json:"ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetLastRangesRsp) Descriptor 

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

func (*GetLastRangesRsp) GetRanges 

func (m *GetLastRangesRsp) GetRanges() []*Range

func (*GetLastRangesRsp) Marshal 

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

func (*GetLastRangesRsp) MarshalTo 

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

func (*GetLastRangesRsp) MarshalToSizedBuffer 

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

func (*GetLastRangesRsp) ProtoMessage 

func (*GetLastRangesRsp) ProtoMessage()

func (*GetLastRangesRsp) Reset 

func (m *GetLastRangesRsp) Reset()

func (*GetLastRangesRsp) Size 

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

func (*GetLastRangesRsp) String 

func (m *GetLastRangesRsp) String() string

func (*GetLastRangesRsp) Unmarshal 

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

func (*GetLastRangesRsp) XXX_DiscardUnknown 

func (m *GetLastRangesRsp) XXX_DiscardUnknown()

func (*GetLastRangesRsp) XXX_Marshal 

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

func (*GetLastRangesRsp) XXX_Merge 

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

func (*GetLastRangesRsp) XXX_Size 

func (m *GetLastRangesRsp) XXX_Size() int

func (*GetLastRangesRsp) XXX_Unmarshal 

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

type GetStoreReq 

type GetStoreReq struct {
	From                 string        `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64        `protobuf:"varint,2,opt,name=id" json:"id"`
	Header               RequestHeader `protobuf:"bytes,3,opt,name=header" json:"header"`
	StoreID              uint64        `protobuf:"varint,4,opt,name=storeID" json:"storeID"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetStoreReq) Descriptor 

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

func (*GetStoreReq) GetFrom 

func (m *GetStoreReq) GetFrom() string

func (*GetStoreReq) GetHeader 

func (m *GetStoreReq) GetHeader() RequestHeader

func (*GetStoreReq) GetID 

func (m *GetStoreReq) GetID() uint64

func (*GetStoreReq) GetStoreID 

func (m *GetStoreReq) GetStoreID() uint64

func (*GetStoreReq) Marshal 

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

func (*GetStoreReq) MarshalTo 

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

func (*GetStoreReq) MarshalToSizedBuffer 

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

func (*GetStoreReq) ProtoMessage 

func (*GetStoreReq) ProtoMessage()

func (*GetStoreReq) Reset 

func (m *GetStoreReq) Reset()

func (*GetStoreReq) Size 

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

func (*GetStoreReq) String 

func (m *GetStoreReq) String() string

func (*GetStoreReq) Unmarshal 

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

func (*GetStoreReq) XXX_DiscardUnknown 

func (m *GetStoreReq) XXX_DiscardUnknown()

func (*GetStoreReq) XXX_Marshal 

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

func (*GetStoreReq) XXX_Merge 

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

func (*GetStoreReq) XXX_Size 

func (m *GetStoreReq) XXX_Size() int

func (*GetStoreReq) XXX_Unmarshal 

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

type GetStoreRsp 

type GetStoreRsp struct {
	Header               ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
	Store                metapb.Store   `protobuf:"bytes,2,opt,name=store" json:"store"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetStoreRsp) Descriptor 

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

func (*GetStoreRsp) GetHeader 

func (m *GetStoreRsp) GetHeader() ResponseHeader

func (*GetStoreRsp) GetStore 

func (m *GetStoreRsp) GetStore() metapb.Store

func (*GetStoreRsp) Marshal 

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

func (*GetStoreRsp) MarshalTo 

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

func (*GetStoreRsp) MarshalToSizedBuffer 

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

func (*GetStoreRsp) ProtoMessage 

func (*GetStoreRsp) ProtoMessage()

func (*GetStoreRsp) Reset 

func (m *GetStoreRsp) Reset()

func (*GetStoreRsp) Size 

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

func (*GetStoreRsp) String 

func (m *GetStoreRsp) String() string

func (*GetStoreRsp) Unmarshal 

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

func (*GetStoreRsp) XXX_DiscardUnknown 

func (m *GetStoreRsp) XXX_DiscardUnknown()

func (*GetStoreRsp) XXX_Marshal 

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

func (*GetStoreRsp) XXX_Merge 

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

func (*GetStoreRsp) XXX_Size 

func (m *GetStoreRsp) XXX_Size() int

func (*GetStoreRsp) XXX_Unmarshal 

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

type IndexDef 

type IndexDef struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name" json:"name"`
	KeyPattern           string      `protobuf:"bytes,2,opt,name=keyPattern" json:"keyPattern"`
	Fields               []*FieldDef `protobuf:"bytes,3,rep,name=fields" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*IndexDef) Descriptor 

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

func (*IndexDef) GetFields 

func (m *IndexDef) GetFields() []*FieldDef

func (*IndexDef) GetKeyPattern 

func (m *IndexDef) GetKeyPattern() string

func (*IndexDef) GetName 

func (m *IndexDef) GetName() string

func (*IndexDef) Marshal 

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

func (*IndexDef) MarshalTo 

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

func (*IndexDef) MarshalToSizedBuffer 

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

func (*IndexDef) ProtoMessage 

func (*IndexDef) ProtoMessage()

func (*IndexDef) Reset 

func (m *IndexDef) Reset()

func (*IndexDef) Size 

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

func (*IndexDef) String 

func (m *IndexDef) String() string

func (*IndexDef) Unmarshal 

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

func (*IndexDef) XXX_DiscardUnknown 

func (m *IndexDef) XXX_DiscardUnknown()

func (*IndexDef) XXX_Marshal 

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

func (*IndexDef) XXX_Merge 

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

func (*IndexDef) XXX_Size 

func (m *IndexDef) XXX_Size() int

func (*IndexDef) XXX_Unmarshal 

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

type IndexDestroyCellRequest 

type IndexDestroyCellRequest struct {
	CellID               uint64   `protobuf:"varint,1,opt,name=cellID" json:"cellID"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexDestroyCellRequest) Descriptor 

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

func (*IndexDestroyCellRequest) GetCellID 

func (m *IndexDestroyCellRequest) GetCellID() uint64

func (*IndexDestroyCellRequest) Marshal 

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

func (*IndexDestroyCellRequest) MarshalTo 

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

func (*IndexDestroyCellRequest) MarshalToSizedBuffer 

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

func (*IndexDestroyCellRequest) ProtoMessage 

func (*IndexDestroyCellRequest) ProtoMessage()

func (*IndexDestroyCellRequest) Reset 

func (m *IndexDestroyCellRequest) Reset()

func (*IndexDestroyCellRequest) Size 

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

func (*IndexDestroyCellRequest) String 

func (m *IndexDestroyCellRequest) String() string

func (*IndexDestroyCellRequest) Unmarshal 

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

func (*IndexDestroyCellRequest) XXX_DiscardUnknown 

func (m *IndexDestroyCellRequest) XXX_DiscardUnknown()

func (*IndexDestroyCellRequest) XXX_Marshal 

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

func (*IndexDestroyCellRequest) XXX_Merge 

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

func (*IndexDestroyCellRequest) XXX_Size 

func (m *IndexDestroyCellRequest) XXX_Size() int

func (*IndexDestroyCellRequest) XXX_Unmarshal 

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

type IndexKeyRequest 

type IndexKeyRequest struct {
	CellID               uint64   `protobuf:"varint,1,opt,name=cellID" json:"cellID"`
	IdxName              string   `protobuf:"bytes,2,opt,name=idxName" json:"idxName"`
	CmdArgs              [][]byte `protobuf:"bytes,3,rep,name=cmdArgs" json:"cmdArgs,omitempty"`
	IsDel                bool     `protobuf:"varint,4,opt,name=isDel" json:"isDel"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexKeyRequest) Descriptor 

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

func (*IndexKeyRequest) GetCellID 

func (m *IndexKeyRequest) GetCellID() uint64

func (*IndexKeyRequest) GetCmdArgs 

func (m *IndexKeyRequest) GetCmdArgs() [][]byte

func (*IndexKeyRequest) GetIdxName 

func (m *IndexKeyRequest) GetIdxName() string

func (*IndexKeyRequest) GetIsDel 

func (m *IndexKeyRequest) GetIsDel() bool

func (*IndexKeyRequest) Marshal 

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

func (*IndexKeyRequest) MarshalTo 

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

func (*IndexKeyRequest) MarshalToSizedBuffer 

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

func (*IndexKeyRequest) ProtoMessage 

func (*IndexKeyRequest) ProtoMessage()

func (*IndexKeyRequest) Reset 

func (m *IndexKeyRequest) Reset()

func (*IndexKeyRequest) Size 

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

func (*IndexKeyRequest) String 

func (m *IndexKeyRequest) String() string

func (*IndexKeyRequest) Unmarshal 

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

func (*IndexKeyRequest) XXX_DiscardUnknown 

func (m *IndexKeyRequest) XXX_DiscardUnknown()

func (*IndexKeyRequest) XXX_Marshal 

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

func (*IndexKeyRequest) XXX_Merge 

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

func (*IndexKeyRequest) XXX_Size 

func (m *IndexKeyRequest) XXX_Size() int

func (*IndexKeyRequest) XXX_Unmarshal 

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

type IndexRebuildCellRequest 

type IndexRebuildCellRequest struct {
	CellID               uint64   `protobuf:"varint,1,opt,name=cellID" json:"cellID"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexRebuildCellRequest) Descriptor 

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

func (*IndexRebuildCellRequest) GetCellID 

func (m *IndexRebuildCellRequest) GetCellID() uint64

func (*IndexRebuildCellRequest) Marshal 

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

func (*IndexRebuildCellRequest) MarshalTo 

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

func (*IndexRebuildCellRequest) MarshalToSizedBuffer 

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

func (*IndexRebuildCellRequest) ProtoMessage 

func (*IndexRebuildCellRequest) ProtoMessage()

func (*IndexRebuildCellRequest) Reset 

func (m *IndexRebuildCellRequest) Reset()

func (*IndexRebuildCellRequest) Size 

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

func (*IndexRebuildCellRequest) String 

func (m *IndexRebuildCellRequest) String() string

func (*IndexRebuildCellRequest) Unmarshal 

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

func (*IndexRebuildCellRequest) XXX_DiscardUnknown 

func (m *IndexRebuildCellRequest) XXX_DiscardUnknown()

func (*IndexRebuildCellRequest) XXX_Marshal 

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

func (*IndexRebuildCellRequest) XXX_Merge 

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

func (*IndexRebuildCellRequest) XXX_Size 

func (m *IndexRebuildCellRequest) XXX_Size() int

func (*IndexRebuildCellRequest) XXX_Unmarshal 

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

type IndexRequest 

type IndexRequest struct {
	IdxSplit             *IndexSplitRequest       `protobuf:"bytes,1,opt,name=idxSplit" json:"idxSplit,omitempty"`
	IdxDestroy           *IndexDestroyCellRequest `protobuf:"bytes,2,opt,name=idxDestroy" json:"idxDestroy,omitempty"`
	IdxRebuild           *IndexRebuildCellRequest `protobuf:"bytes,3,opt,name=idxRebuild" json:"idxRebuild,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*IndexRequest) Descriptor 

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

func (*IndexRequest) GetIdxDestroy 

func (m *IndexRequest) GetIdxDestroy() *IndexDestroyCellRequest

func (*IndexRequest) GetIdxRebuild 

func (m *IndexRequest) GetIdxRebuild() *IndexRebuildCellRequest

func (*IndexRequest) GetIdxSplit 

func (m *IndexRequest) GetIdxSplit() *IndexSplitRequest

func (*IndexRequest) Marshal 

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

func (*IndexRequest) MarshalTo 

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

func (*IndexRequest) MarshalToSizedBuffer 

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

func (*IndexRequest) ProtoMessage 

func (*IndexRequest) ProtoMessage()

func (*IndexRequest) Reset 

func (m *IndexRequest) Reset()

func (*IndexRequest) Size 

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

func (*IndexRequest) String 

func (m *IndexRequest) String() string

func (*IndexRequest) Unmarshal 

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

func (*IndexRequest) XXX_DiscardUnknown 

func (m *IndexRequest) XXX_DiscardUnknown()

func (*IndexRequest) XXX_Marshal 

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

func (*IndexRequest) XXX_Merge 

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

func (*IndexRequest) XXX_Size 

func (m *IndexRequest) XXX_Size() int

func (*IndexRequest) XXX_Unmarshal 

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

type IndexSplitRequest 

type IndexSplitRequest struct {
	LeftCellID           uint64   `protobuf:"varint,1,opt,name=leftCellID" json:"leftCellID"`
	RightCellID          uint64   `protobuf:"varint,2,opt,name=rightCellID" json:"rightCellID"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexSplitRequest) Descriptor 

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

func (*IndexSplitRequest) GetLeftCellID 

func (m *IndexSplitRequest) GetLeftCellID() uint64

func (*IndexSplitRequest) GetRightCellID 

func (m *IndexSplitRequest) GetRightCellID() uint64

func (*IndexSplitRequest) Marshal 

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

func (*IndexSplitRequest) MarshalTo 

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

func (*IndexSplitRequest) MarshalToSizedBuffer 

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

func (*IndexSplitRequest) ProtoMessage 

func (*IndexSplitRequest) ProtoMessage()

func (*IndexSplitRequest) Reset 

func (m *IndexSplitRequest) Reset()

func (*IndexSplitRequest) Size 

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

func (*IndexSplitRequest) String 

func (m *IndexSplitRequest) String() string

func (*IndexSplitRequest) Unmarshal 

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

func (*IndexSplitRequest) XXX_DiscardUnknown 

func (m *IndexSplitRequest) XXX_DiscardUnknown()

func (*IndexSplitRequest) XXX_Marshal 

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

func (*IndexSplitRequest) XXX_Merge 

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

func (*IndexSplitRequest) XXX_Size 

func (m *IndexSplitRequest) XXX_Size() int

func (*IndexSplitRequest) XXX_Unmarshal 

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

type IsClusterBootstrapReq 

type IsClusterBootstrapReq struct {
	From                 string   `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64   `protobuf:"varint,2,opt,name=id" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsClusterBootstrapReq) Descriptor 

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

func (*IsClusterBootstrapReq) GetFrom 

func (m *IsClusterBootstrapReq) GetFrom() string

func (*IsClusterBootstrapReq) GetID 

func (m *IsClusterBootstrapReq) GetID() uint64

func (*IsClusterBootstrapReq) Marshal 

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

func (*IsClusterBootstrapReq) MarshalTo 

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

func (*IsClusterBootstrapReq) MarshalToSizedBuffer 

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

func (*IsClusterBootstrapReq) ProtoMessage 

func (*IsClusterBootstrapReq) ProtoMessage()

func (*IsClusterBootstrapReq) Reset 

func (m *IsClusterBootstrapReq) Reset()

func (*IsClusterBootstrapReq) Size 

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

func (*IsClusterBootstrapReq) String 

func (m *IsClusterBootstrapReq) String() string

func (*IsClusterBootstrapReq) Unmarshal 

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

func (*IsClusterBootstrapReq) XXX_DiscardUnknown 

func (m *IsClusterBootstrapReq) XXX_DiscardUnknown()

func (*IsClusterBootstrapReq) XXX_Marshal 

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

func (*IsClusterBootstrapReq) XXX_Merge 

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

func (*IsClusterBootstrapReq) XXX_Size 

func (m *IsClusterBootstrapReq) XXX_Size() int

func (*IsClusterBootstrapReq) XXX_Unmarshal 

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

type IsClusterBootstrapRsp 

type IsClusterBootstrapRsp struct {
	Value                bool     `protobuf:"varint,1,opt,name=value" json:"value"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsClusterBootstrapRsp) Descriptor 

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

func (*IsClusterBootstrapRsp) GetValue 

func (m *IsClusterBootstrapRsp) GetValue() bool

func (*IsClusterBootstrapRsp) Marshal 

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

func (*IsClusterBootstrapRsp) MarshalTo 

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

func (*IsClusterBootstrapRsp) MarshalToSizedBuffer 

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

func (*IsClusterBootstrapRsp) ProtoMessage 

func (*IsClusterBootstrapRsp) ProtoMessage()

func (*IsClusterBootstrapRsp) Reset 

func (m *IsClusterBootstrapRsp) Reset()

func (*IsClusterBootstrapRsp) Size 

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

func (*IsClusterBootstrapRsp) String 

func (m *IsClusterBootstrapRsp) String() string

func (*IsClusterBootstrapRsp) Unmarshal 

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

func (*IsClusterBootstrapRsp) XXX_DiscardUnknown 

func (m *IsClusterBootstrapRsp) XXX_DiscardUnknown()

func (*IsClusterBootstrapRsp) XXX_Marshal 

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

func (*IsClusterBootstrapRsp) XXX_Merge 

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

func (*IsClusterBootstrapRsp) XXX_Size 

func (m *IsClusterBootstrapRsp) XXX_Size() int

func (*IsClusterBootstrapRsp) XXX_Unmarshal 

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

type KeyMetaVal 

type KeyMetaVal struct {
	IdxName              string   `protobuf:"bytes,1,opt,name=idxName" json:"idxName"`
	DocID                uint64   `protobuf:"varint,2,opt,name=docID" json:"docID"`
	CellID               uint64   `protobuf:"varint,3,opt,name=cellID" json:"cellID"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyMetaVal) Descriptor 

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

func (*KeyMetaVal) GetCellID 

func (m *KeyMetaVal) GetCellID() uint64

func (*KeyMetaVal) GetDocID 

func (m *KeyMetaVal) GetDocID() uint64

func (*KeyMetaVal) GetIdxName 

func (m *KeyMetaVal) GetIdxName() string

func (*KeyMetaVal) Marshal 

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

func (*KeyMetaVal) MarshalTo 

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

func (*KeyMetaVal) MarshalToSizedBuffer 

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

func (*KeyMetaVal) ProtoMessage 

func (*KeyMetaVal) ProtoMessage()

func (*KeyMetaVal) Reset 

func (m *KeyMetaVal) Reset()

func (*KeyMetaVal) Size 

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

func (*KeyMetaVal) String 

func (m *KeyMetaVal) String() string

func (*KeyMetaVal) Unmarshal 

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

func (*KeyMetaVal) XXX_DiscardUnknown 

func (m *KeyMetaVal) XXX_DiscardUnknown()

func (*KeyMetaVal) XXX_Marshal 

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

func (*KeyMetaVal) XXX_Merge 

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

func (*KeyMetaVal) XXX_Size 

func (m *KeyMetaVal) XXX_Size() int

func (*KeyMetaVal) XXX_Unmarshal 

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

type Leader 

type Leader struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id" json:"id"`
	Name                 string   `protobuf:"bytes,2,opt,name=name" json:"name"`
	Addr                 string   `protobuf:"bytes,3,opt,name=addr" json:"addr"`
	EtcdClientAddr       string   `protobuf:"bytes,4,opt,name=etcdClientAddr" json:"etcdClientAddr"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Leader) Descriptor 

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

func (*Leader) GetAddr 

func (m *Leader) GetAddr() string

func (*Leader) GetEtcdClientAddr 

func (m *Leader) GetEtcdClientAddr() string

func (*Leader) GetID 

func (m *Leader) GetID() uint64

func (*Leader) GetName 

func (m *Leader) GetName() string

func (*Leader) Marshal 

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

func (*Leader) MarshalTo 

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

func (*Leader) MarshalToSizedBuffer 

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

func (*Leader) ProtoMessage 

func (*Leader) ProtoMessage()

func (*Leader) Reset 

func (m *Leader) Reset()

func (*Leader) Size 

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

func (*Leader) String 

func (m *Leader) String() string

func (*Leader) Unmarshal 

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

func (*Leader) XXX_DiscardUnknown 

func (m *Leader) XXX_DiscardUnknown()

func (*Leader) XXX_Marshal 

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

func (*Leader) XXX_Merge 

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

func (*Leader) XXX_Size 

func (m *Leader) XXX_Size() int

func (*Leader) XXX_Unmarshal 

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

type LeaderReq 

type LeaderReq struct {
	From                 string   `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64   `protobuf:"varint,2,opt,name=id" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LeaderReq) Descriptor 

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

func (*LeaderReq) GetFrom 

func (m *LeaderReq) GetFrom() string

func (*LeaderReq) GetID 

func (m *LeaderReq) GetID() uint64

func (*LeaderReq) Marshal 

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

func (*LeaderReq) MarshalTo 

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

func (*LeaderReq) MarshalToSizedBuffer 

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

func (*LeaderReq) ProtoMessage 

func (*LeaderReq) ProtoMessage()

func (*LeaderReq) Reset 

func (m *LeaderReq) Reset()

func (*LeaderReq) Size 

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

func (*LeaderReq) String 

func (m *LeaderReq) String() string

func (*LeaderReq) Unmarshal 

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

func (*LeaderReq) XXX_DiscardUnknown 

func (m *LeaderReq) XXX_DiscardUnknown()

func (*LeaderReq) XXX_Marshal 

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

func (*LeaderReq) XXX_Merge 

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

func (*LeaderReq) XXX_Size 

func (m *LeaderReq) XXX_Size() int

func (*LeaderReq) XXX_Unmarshal 

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

type LeaderRsp 

type LeaderRsp struct {
	Leader               Leader   `protobuf:"bytes,1,opt,name=leader" json:"leader"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LeaderRsp) Descriptor 

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

func (*LeaderRsp) GetLeader 

func (m *LeaderRsp) GetLeader() Leader

func (*LeaderRsp) Marshal 

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

func (*LeaderRsp) MarshalTo 

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

func (*LeaderRsp) MarshalToSizedBuffer 

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

func (*LeaderRsp) ProtoMessage 

func (*LeaderRsp) ProtoMessage()

func (*LeaderRsp) Reset 

func (m *LeaderRsp) Reset()

func (*LeaderRsp) Size 

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

func (*LeaderRsp) String 

func (m *LeaderRsp) String() string

func (*LeaderRsp) Unmarshal 

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

func (*LeaderRsp) XXX_DiscardUnknown 

func (m *LeaderRsp) XXX_DiscardUnknown()

func (*LeaderRsp) XXX_Marshal 

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

func (*LeaderRsp) XXX_Merge 

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

func (*LeaderRsp) XXX_Size 

func (m *LeaderRsp) XXX_Size() int

func (*LeaderRsp) XXX_Unmarshal 

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

type ListStoreReq 

type ListStoreReq struct {
	From                 string   `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64   `protobuf:"varint,2,opt,name=id" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListStoreReq) Descriptor 

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

func (*ListStoreReq) GetFrom 

func (m *ListStoreReq) GetFrom() string

func (*ListStoreReq) GetID 

func (m *ListStoreReq) GetID() uint64

func (*ListStoreReq) Marshal 

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

func (*ListStoreReq) MarshalTo 

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

func (*ListStoreReq) MarshalToSizedBuffer 

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

func (*ListStoreReq) ProtoMessage 

func (*ListStoreReq) ProtoMessage()

func (*ListStoreReq) Reset 

func (m *ListStoreReq) Reset()

func (*ListStoreReq) Size 

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

func (*ListStoreReq) String 

func (m *ListStoreReq) String() string

func (*ListStoreReq) Unmarshal 

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

func (*ListStoreReq) XXX_DiscardUnknown 

func (m *ListStoreReq) XXX_DiscardUnknown()

func (*ListStoreReq) XXX_Marshal 

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

func (*ListStoreReq) XXX_Merge 

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

func (*ListStoreReq) XXX_Size 

func (m *ListStoreReq) XXX_Size() int

func (*ListStoreReq) XXX_Unmarshal 

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

type ListStoreRsp 

type ListStoreRsp struct {
	Stores               []*metapb.Store `protobuf:"bytes,1,rep,name=stores" json:"stores,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListStoreRsp) Descriptor 

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

func (*ListStoreRsp) GetStores 

func (m *ListStoreRsp) GetStores() []*metapb.Store

func (*ListStoreRsp) Marshal 

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

func (*ListStoreRsp) MarshalTo 

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

func (*ListStoreRsp) MarshalToSizedBuffer 

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

func (*ListStoreRsp) ProtoMessage 

func (*ListStoreRsp) ProtoMessage()

func (*ListStoreRsp) Reset 

func (m *ListStoreRsp) Reset()

func (*ListStoreRsp) Size 

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

func (*ListStoreRsp) String 

func (m *ListStoreRsp) String() string

func (*ListStoreRsp) Unmarshal 

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

func (*ListStoreRsp) XXX_DiscardUnknown 

func (m *ListStoreRsp) XXX_DiscardUnknown()

func (*ListStoreRsp) XXX_Marshal 

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

func (*ListStoreRsp) XXX_Merge 

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

func (*ListStoreRsp) XXX_Size 

func (m *ListStoreRsp) XXX_Size() int

func (*ListStoreRsp) XXX_Unmarshal 

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

type PDServiceClient 

type PDServiceClient interface {
	RegisterWatcher(ctx context.Context, in *RegisterWatcherReq, opts ...grpc.CallOption) (*RegisterWatcherRsp, error)
	WatcherHeartbeat(ctx context.Context, in *WatcherHeartbeatReq, opts ...grpc.CallOption) (*WatcherHeartbeatRsp, error)
	GetLeader(ctx context.Context, in *LeaderReq, opts ...grpc.CallOption) (*LeaderRsp, error)
	AllocID(ctx context.Context, in *AllocIDReq, opts ...grpc.CallOption) (*AllocIDRsp, error)
	GetClusterID(ctx context.Context, in *GetClusterIDReq, opts ...grpc.CallOption) (*GetClusterIDRsp, error)
	GetInitParams(ctx context.Context, in *GetInitParamsReq, opts ...grpc.CallOption) (*GetInitParamsRsp, error)
	IsClusterBootstrap(ctx context.Context, in *IsClusterBootstrapReq, opts ...grpc.CallOption) (*IsClusterBootstrapRsp, error)
	BootstrapCluster(ctx context.Context, in *BootstrapClusterReq, opts ...grpc.CallOption) (*BootstrapClusterRsp, error)
	ListStore(ctx context.Context, in *ListStoreReq, opts ...grpc.CallOption) (*ListStoreRsp, error)
	PutStore(ctx context.Context, in *PutStoreReq, opts ...grpc.CallOption) (*PutStoreRsp, error)
	GetStore(ctx context.Context, in *GetStoreReq, opts ...grpc.CallOption) (*GetStoreRsp, error)
	CellHeartbeat(ctx context.Context, in *CellHeartbeatReq, opts ...grpc.CallOption) (*CellHeartbeatRsp, error)
	StoreHeartbeat(ctx context.Context, in *StoreHeartbeatReq, opts ...grpc.CallOption) (*StoreHeartbeatRsp, error)
	AskSplit(ctx context.Context, in *AskSplitReq, opts ...grpc.CallOption) (*AskSplitRsp, error)
	ReportSplit(ctx context.Context, in *ReportSplitReq, opts ...grpc.CallOption) (*ReportSplitRsp, error)
	GetLastRanges(ctx context.Context, in *GetLastRangesReq, opts ...grpc.CallOption) (*GetLastRangesRsp, error)
}

PDServiceClient is the client API for PDService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPDServiceClient 

func NewPDServiceClient(cc *grpc.ClientConn) PDServiceClient

type PDServiceServer 

type PDServiceServer interface {
	RegisterWatcher(context.Context, *RegisterWatcherReq) (*RegisterWatcherRsp, error)
	WatcherHeartbeat(context.Context, *WatcherHeartbeatReq) (*WatcherHeartbeatRsp, error)
	GetLeader(context.Context, *LeaderReq) (*LeaderRsp, error)
	AllocID(context.Context, *AllocIDReq) (*AllocIDRsp, error)
	GetClusterID(context.Context, *GetClusterIDReq) (*GetClusterIDRsp, error)
	GetInitParams(context.Context, *GetInitParamsReq) (*GetInitParamsRsp, error)
	IsClusterBootstrap(context.Context, *IsClusterBootstrapReq) (*IsClusterBootstrapRsp, error)
	BootstrapCluster(context.Context, *BootstrapClusterReq) (*BootstrapClusterRsp, error)
	ListStore(context.Context, *ListStoreReq) (*ListStoreRsp, error)
	PutStore(context.Context, *PutStoreReq) (*PutStoreRsp, error)
	GetStore(context.Context, *GetStoreReq) (*GetStoreRsp, error)
	CellHeartbeat(context.Context, *CellHeartbeatReq) (*CellHeartbeatRsp, error)
	StoreHeartbeat(context.Context, *StoreHeartbeatReq) (*StoreHeartbeatRsp, error)
	AskSplit(context.Context, *AskSplitReq) (*AskSplitRsp, error)
	ReportSplit(context.Context, *ReportSplitReq) (*ReportSplitRsp, error)
	GetLastRanges(context.Context, *GetLastRangesReq) (*GetLastRangesRsp, error)
}

PDServiceServer is the server API for PDService service.

type PeerStats 

type PeerStats struct {
	Peer                 metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer"`
	DownSeconds          uint64      `protobuf:"varint,2,opt,name=downSeconds" json:"downSeconds"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*PeerStats) Descriptor 

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

func (*PeerStats) GetDownSeconds 

func (m *PeerStats) GetDownSeconds() uint64

func (*PeerStats) GetPeer 

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

func (*PeerStats) Marshal 

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

func (*PeerStats) MarshalTo 

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

func (*PeerStats) MarshalToSizedBuffer 

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

func (*PeerStats) ProtoMessage 

func (*PeerStats) ProtoMessage()

func (*PeerStats) Reset 

func (m *PeerStats) Reset()

func (*PeerStats) Size 

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

func (*PeerStats) String 

func (m *PeerStats) String() string

func (*PeerStats) Unmarshal 

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

func (*PeerStats) XXX_DiscardUnknown 

func (m *PeerStats) XXX_DiscardUnknown()

func (*PeerStats) XXX_Marshal 

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

func (*PeerStats) XXX_Merge 

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

func (*PeerStats) XXX_Size 

func (m *PeerStats) XXX_Size() int

func (*PeerStats) XXX_Unmarshal 

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

type PutStoreReq 

type PutStoreReq struct {
	From                 string        `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64        `protobuf:"varint,2,opt,name=id" json:"id"`
	Header               RequestHeader `protobuf:"bytes,3,opt,name=header" json:"header"`
	Store                metapb.Store  `protobuf:"bytes,4,opt,name=store" json:"store"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*PutStoreReq) Descriptor 

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

func (*PutStoreReq) GetFrom 

func (m *PutStoreReq) GetFrom() string

func (*PutStoreReq) GetHeader 

func (m *PutStoreReq) GetHeader() RequestHeader

func (*PutStoreReq) GetID 

func (m *PutStoreReq) GetID() uint64

func (*PutStoreReq) GetStore 

func (m *PutStoreReq) GetStore() metapb.Store

func (*PutStoreReq) Marshal 

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

func (*PutStoreReq) MarshalTo 

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

func (*PutStoreReq) MarshalToSizedBuffer 

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

func (*PutStoreReq) ProtoMessage 

func (*PutStoreReq) ProtoMessage()

func (*PutStoreReq) Reset 

func (m *PutStoreReq) Reset()

func (*PutStoreReq) Size 

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

func (*PutStoreReq) String 

func (m *PutStoreReq) String() string

func (*PutStoreReq) Unmarshal 

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

func (*PutStoreReq) XXX_DiscardUnknown 

func (m *PutStoreReq) XXX_DiscardUnknown()

func (*PutStoreReq) XXX_Marshal 

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

func (*PutStoreReq) XXX_Merge 

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

func (*PutStoreReq) XXX_Size 

func (m *PutStoreReq) XXX_Size() int

func (*PutStoreReq) XXX_Unmarshal 

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

type PutStoreRsp 

type PutStoreRsp struct {
	Header               ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*PutStoreRsp) Descriptor 

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

func (*PutStoreRsp) GetHeader 

func (m *PutStoreRsp) GetHeader() ResponseHeader

func (*PutStoreRsp) Marshal 

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

func (*PutStoreRsp) MarshalTo 

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

func (*PutStoreRsp) MarshalToSizedBuffer 

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

func (*PutStoreRsp) ProtoMessage 

func (*PutStoreRsp) ProtoMessage()

func (*PutStoreRsp) Reset 

func (m *PutStoreRsp) Reset()

func (*PutStoreRsp) Size 

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

func (*PutStoreRsp) String 

func (m *PutStoreRsp) String() string

func (*PutStoreRsp) Unmarshal 

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

func (*PutStoreRsp) XXX_DiscardUnknown 

func (m *PutStoreRsp) XXX_DiscardUnknown()

func (*PutStoreRsp) XXX_Marshal 

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

func (*PutStoreRsp) XXX_Merge 

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

func (*PutStoreRsp) XXX_Size 

func (m *PutStoreRsp) XXX_Size() int

func (*PutStoreRsp) XXX_Unmarshal 

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

type Range 

type Range struct {
	Cell                 metapb.Cell  `protobuf:"bytes,1,opt,name=cell" json:"cell"`
	LeaderStore          metapb.Store `protobuf:"bytes,2,opt,name=leaderStore" json:"leaderStore"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Range) Descriptor 

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

func (*Range) GetCell 

func (m *Range) GetCell() metapb.Cell

func (*Range) GetLeaderStore 

func (m *Range) GetLeaderStore() metapb.Store

func (*Range) Marshal 

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

func (*Range) MarshalTo 

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

func (*Range) MarshalToSizedBuffer 

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

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) Reset 

func (m *Range) Reset()

func (*Range) Size 

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

func (*Range) String 

func (m *Range) String() string

func (*Range) Unmarshal 

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

func (*Range) XXX_DiscardUnknown 

func (m *Range) XXX_DiscardUnknown()

func (*Range) XXX_Marshal 

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

func (*Range) XXX_Merge 

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

func (*Range) XXX_Size 

func (m *Range) XXX_Size() int

func (*Range) XXX_Unmarshal 

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

type RegisterWatcherReq 

type RegisterWatcherReq struct {
	From                 string   `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64   `protobuf:"varint,2,opt,name=id" json:"id"`
	Watcher              Watcher  `protobuf:"bytes,3,opt,name=watcher" json:"watcher"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterWatcherReq) Descriptor 

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

func (*RegisterWatcherReq) GetFrom 

func (m *RegisterWatcherReq) GetFrom() string

func (*RegisterWatcherReq) GetID 

func (m *RegisterWatcherReq) GetID() uint64

func (*RegisterWatcherReq) GetWatcher 

func (m *RegisterWatcherReq) GetWatcher() Watcher

func (*RegisterWatcherReq) Marshal 

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

func (*RegisterWatcherReq) MarshalTo 

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

func (*RegisterWatcherReq) MarshalToSizedBuffer 

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

func (*RegisterWatcherReq) ProtoMessage 

func (*RegisterWatcherReq) ProtoMessage()

func (*RegisterWatcherReq) Reset 

func (m *RegisterWatcherReq) Reset()

func (*RegisterWatcherReq) Size 

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

func (*RegisterWatcherReq) String 

func (m *RegisterWatcherReq) String() string

func (*RegisterWatcherReq) Unmarshal 

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

func (*RegisterWatcherReq) XXX_DiscardUnknown 

func (m *RegisterWatcherReq) XXX_DiscardUnknown()

func (*RegisterWatcherReq) XXX_Marshal 

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

func (*RegisterWatcherReq) XXX_Merge 

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

func (*RegisterWatcherReq) XXX_Size 

func (m *RegisterWatcherReq) XXX_Size() int

func (*RegisterWatcherReq) XXX_Unmarshal 

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

type RegisterWatcherRsp 

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

func (*RegisterWatcherRsp) Descriptor 

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

func (*RegisterWatcherRsp) Marshal 

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

func (*RegisterWatcherRsp) MarshalTo 

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

func (*RegisterWatcherRsp) MarshalToSizedBuffer 

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

func (*RegisterWatcherRsp) ProtoMessage 

func (*RegisterWatcherRsp) ProtoMessage()

func (*RegisterWatcherRsp) Reset 

func (m *RegisterWatcherRsp) Reset()

func (*RegisterWatcherRsp) Size 

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

func (*RegisterWatcherRsp) String 

func (m *RegisterWatcherRsp) String() string

func (*RegisterWatcherRsp) Unmarshal 

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

func (*RegisterWatcherRsp) XXX_DiscardUnknown 

func (m *RegisterWatcherRsp) XXX_DiscardUnknown()

func (*RegisterWatcherRsp) XXX_Marshal 

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

func (*RegisterWatcherRsp) XXX_Merge 

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

func (*RegisterWatcherRsp) XXX_Size 

func (m *RegisterWatcherRsp) XXX_Size() int

func (*RegisterWatcherRsp) XXX_Unmarshal 

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

type ReportSplitReq 

type ReportSplitReq struct {
	From                 string        `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64        `protobuf:"varint,2,opt,name=id" json:"id"`
	Header               RequestHeader `protobuf:"bytes,3,opt,name=header" json:"header"`
	Left                 metapb.Cell   `protobuf:"bytes,4,opt,name=left" json:"left"`
	Right                metapb.Cell   `protobuf:"bytes,5,opt,name=right" json:"right"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ReportSplitReq) Descriptor 

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

func (*ReportSplitReq) GetFrom 

func (m *ReportSplitReq) GetFrom() string

func (*ReportSplitReq) GetHeader 

func (m *ReportSplitReq) GetHeader() RequestHeader

func (*ReportSplitReq) GetID 

func (m *ReportSplitReq) GetID() uint64

func (*ReportSplitReq) GetLeft 

func (m *ReportSplitReq) GetLeft() metapb.Cell

func (*ReportSplitReq) GetRight 

func (m *ReportSplitReq) GetRight() metapb.Cell

func (*ReportSplitReq) Marshal 

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

func (*ReportSplitReq) MarshalTo 

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

func (*ReportSplitReq) MarshalToSizedBuffer 

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

func (*ReportSplitReq) ProtoMessage 

func (*ReportSplitReq) ProtoMessage()

func (*ReportSplitReq) Reset 

func (m *ReportSplitReq) Reset()

func (*ReportSplitReq) Size 

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

func (*ReportSplitReq) String 

func (m *ReportSplitReq) String() string

func (*ReportSplitReq) Unmarshal 

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

func (*ReportSplitReq) XXX_DiscardUnknown 

func (m *ReportSplitReq) XXX_DiscardUnknown()

func (*ReportSplitReq) XXX_Marshal 

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

func (*ReportSplitReq) XXX_Merge 

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

func (*ReportSplitReq) XXX_Size 

func (m *ReportSplitReq) XXX_Size() int

func (*ReportSplitReq) XXX_Unmarshal 

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

type ReportSplitRsp 

type ReportSplitRsp struct {
	Header               ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ReportSplitRsp) Descriptor 

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

func (*ReportSplitRsp) GetHeader 

func (m *ReportSplitRsp) GetHeader() ResponseHeader

func (*ReportSplitRsp) Marshal 

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

func (*ReportSplitRsp) MarshalTo 

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

func (*ReportSplitRsp) MarshalToSizedBuffer 

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

func (*ReportSplitRsp) ProtoMessage 

func (*ReportSplitRsp) ProtoMessage()

func (*ReportSplitRsp) Reset 

func (m *ReportSplitRsp) Reset()

func (*ReportSplitRsp) Size 

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

func (*ReportSplitRsp) String 

func (m *ReportSplitRsp) String() string

func (*ReportSplitRsp) Unmarshal 

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

func (*ReportSplitRsp) XXX_DiscardUnknown 

func (m *ReportSplitRsp) XXX_DiscardUnknown()

func (*ReportSplitRsp) XXX_Marshal 

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

func (*ReportSplitRsp) XXX_Merge 

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

func (*ReportSplitRsp) XXX_Size 

func (m *ReportSplitRsp) XXX_Size() int

func (*ReportSplitRsp) XXX_Unmarshal 

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

type RequestHeader 

type RequestHeader struct {
	// cluster_id is the ID of the cluster which be sent to.
	ClusterID            uint64   `protobuf:"varint,1,opt,name=clusterID" json:"clusterID"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetClusterID 

func (m *RequestHeader) GetClusterID() uint64

func (*RequestHeader) Marshal 

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

func (*RequestHeader) MarshalTo 

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

func (*RequestHeader) MarshalToSizedBuffer 

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

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset 

func (m *RequestHeader) Reset()

func (*RequestHeader) Size 

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

func (*RequestHeader) String 

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal 

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

func (*RequestHeader) XXX_DiscardUnknown 

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal 

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

func (*RequestHeader) XXX_Merge 

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

func (*RequestHeader) XXX_Size 

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal 

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

type ResponseHeader 

type ResponseHeader struct {
	ClusterID            uint64   `protobuf:"varint,1,opt,name=clusterID" json:"clusterID"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetClusterID 

func (m *ResponseHeader) GetClusterID() uint64

func (*ResponseHeader) Marshal 

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

func (*ResponseHeader) MarshalTo 

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

func (*ResponseHeader) MarshalToSizedBuffer 

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

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size 

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

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal 

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

func (*ResponseHeader) XXX_DiscardUnknown 

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal 

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

func (*ResponseHeader) XXX_Merge 

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

func (*ResponseHeader) XXX_Size 

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal 

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

type SetLogLevel 

type SetLogLevel struct {
	NewLevel             int32    `protobuf:"varint,1,opt,name=newLevel" json:"newLevel"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetLogLevel) Descriptor 

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

func (*SetLogLevel) GetNewLevel 

func (m *SetLogLevel) GetNewLevel() int32

func (*SetLogLevel) Marshal 

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

func (*SetLogLevel) MarshalTo 

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

func (*SetLogLevel) MarshalToSizedBuffer 

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

func (*SetLogLevel) ProtoMessage 

func (*SetLogLevel) ProtoMessage()

func (*SetLogLevel) Reset 

func (m *SetLogLevel) Reset()

func (*SetLogLevel) Size 

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

func (*SetLogLevel) String 

func (m *SetLogLevel) String() string

func (*SetLogLevel) Unmarshal 

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

func (*SetLogLevel) XXX_DiscardUnknown 

func (m *SetLogLevel) XXX_DiscardUnknown()

func (*SetLogLevel) XXX_Marshal 

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

func (*SetLogLevel) XXX_Merge 

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

func (*SetLogLevel) XXX_Size 

func (m *SetLogLevel) XXX_Size() int

func (*SetLogLevel) XXX_Unmarshal 

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

type StoreEvent 

type StoreEvent struct {
	Store                *metapb.Store `protobuf:"bytes,1,opt,name=store" json:"store,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StoreEvent) Descriptor 

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

func (*StoreEvent) GetStore 

func (m *StoreEvent) GetStore() *metapb.Store

func (*StoreEvent) Marshal 

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

func (*StoreEvent) MarshalTo 

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

func (*StoreEvent) MarshalToSizedBuffer 

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

func (*StoreEvent) ProtoMessage 

func (*StoreEvent) ProtoMessage()

func (*StoreEvent) Reset 

func (m *StoreEvent) Reset()

func (*StoreEvent) Size 

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

func (*StoreEvent) String 

func (m *StoreEvent) String() string

func (*StoreEvent) Unmarshal 

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

func (*StoreEvent) XXX_DiscardUnknown 

func (m *StoreEvent) XXX_DiscardUnknown()

func (*StoreEvent) XXX_Marshal 

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

func (*StoreEvent) XXX_Merge 

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

func (*StoreEvent) XXX_Size 

func (m *StoreEvent) XXX_Size() int

func (*StoreEvent) XXX_Unmarshal 

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

type StoreHeartbeatReq 

type StoreHeartbeatReq struct {
	From                 string        `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64        `protobuf:"varint,2,opt,name=id" json:"id"`
	Header               RequestHeader `protobuf:"bytes,3,opt,name=header" json:"header"`
	Stats                *StoreStats   `protobuf:"bytes,4,opt,name=stats" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StoreHeartbeatReq) Descriptor 

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

func (*StoreHeartbeatReq) GetFrom 

func (m *StoreHeartbeatReq) GetFrom() string

func (*StoreHeartbeatReq) GetHeader 

func (m *StoreHeartbeatReq) GetHeader() RequestHeader

func (*StoreHeartbeatReq) GetID 

func (m *StoreHeartbeatReq) GetID() uint64

func (*StoreHeartbeatReq) GetStats 

func (m *StoreHeartbeatReq) GetStats() *StoreStats

func (*StoreHeartbeatReq) Marshal 

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

func (*StoreHeartbeatReq) MarshalTo 

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

func (*StoreHeartbeatReq) MarshalToSizedBuffer 

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

func (*StoreHeartbeatReq) ProtoMessage 

func (*StoreHeartbeatReq) ProtoMessage()

func (*StoreHeartbeatReq) Reset 

func (m *StoreHeartbeatReq) Reset()

func (*StoreHeartbeatReq) Size 

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

func (*StoreHeartbeatReq) String 

func (m *StoreHeartbeatReq) String() string

func (*StoreHeartbeatReq) Unmarshal 

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

func (*StoreHeartbeatReq) XXX_DiscardUnknown 

func (m *StoreHeartbeatReq) XXX_DiscardUnknown()

func (*StoreHeartbeatReq) XXX_Marshal 

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

func (*StoreHeartbeatReq) XXX_Merge 

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

func (*StoreHeartbeatReq) XXX_Size 

func (m *StoreHeartbeatReq) XXX_Size() int

func (*StoreHeartbeatReq) XXX_Unmarshal 

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

type StoreHeartbeatRsp 

type StoreHeartbeatRsp struct {
	Header               ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
	SetLogLevel          *SetLogLevel   `protobuf:"bytes,2,opt,name=setLogLevel" json:"setLogLevel,omitempty"`
	Indices              []*IndexDef    `protobuf:"bytes,3,rep,name=indices" json:"indices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StoreHeartbeatRsp) Descriptor 

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

func (*StoreHeartbeatRsp) GetHeader 

func (m *StoreHeartbeatRsp) GetHeader() ResponseHeader

func (*StoreHeartbeatRsp) GetIndices 

func (m *StoreHeartbeatRsp) GetIndices() []*IndexDef

func (*StoreHeartbeatRsp) GetSetLogLevel 

func (m *StoreHeartbeatRsp) GetSetLogLevel() *SetLogLevel

func (*StoreHeartbeatRsp) Marshal 

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

func (*StoreHeartbeatRsp) MarshalTo 

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

func (*StoreHeartbeatRsp) MarshalToSizedBuffer 

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

func (*StoreHeartbeatRsp) ProtoMessage 

func (*StoreHeartbeatRsp) ProtoMessage()

func (*StoreHeartbeatRsp) Reset 

func (m *StoreHeartbeatRsp) Reset()

func (*StoreHeartbeatRsp) Size 

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

func (*StoreHeartbeatRsp) String 

func (m *StoreHeartbeatRsp) String() string

func (*StoreHeartbeatRsp) Unmarshal 

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

func (*StoreHeartbeatRsp) XXX_DiscardUnknown 

func (m *StoreHeartbeatRsp) XXX_DiscardUnknown()

func (*StoreHeartbeatRsp) XXX_Marshal 

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

func (*StoreHeartbeatRsp) XXX_Merge 

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

func (*StoreHeartbeatRsp) XXX_Size 

func (m *StoreHeartbeatRsp) XXX_Size() int

func (*StoreHeartbeatRsp) XXX_Unmarshal 

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

type StoreStats 

type StoreStats struct {
	StoreID uint64 `protobuf:"varint,1,opt,name=storeID" json:"storeID"`
	// Capacity for the store.
	Capacity uint64 `protobuf:"varint,2,opt,name=capacity" json:"capacity"`
	// Available size for the store.
	Available uint64 `protobuf:"varint,3,opt,name=available" json:"available"`
	// Total region count in this store.
	CellCount uint32 `protobuf:"varint,4,opt,name=cellCount" json:"cellCount"`
	// Current sending snapshot count.
	SendingSnapCount uint32 `protobuf:"varint,5,opt,name=sendingSnapCount" json:"sendingSnapCount"`
	// Current receiving snapshot count.
	ReceivingSnapCount uint32 `protobuf:"varint,6,opt,name=receivingSnapCount" json:"receivingSnapCount"`
	// When the store is started (unix timestamp in seconds).
	StartTime uint32 `protobuf:"varint,7,opt,name=startTime" json:"startTime"`
	// How many region is applying snapshot.
	ApplyingSnapCount uint32 `protobuf:"varint,8,opt,name=applyingSnapCount" json:"applyingSnapCount"`
	// If the store is busy
	IsBusy bool `protobuf:"varint,9,opt,name=isBusy" json:"isBusy"`
	// Actually used space by db
	UsedSize uint64 `protobuf:"varint,10,opt,name=usedSize" json:"usedSize"`
	// Bytes written for the store.
	BytesWritten         uint64   `protobuf:"varint,11,opt,name=bytesWritten" json:"bytesWritten"`
	LogLevel             int32    `protobuf:"varint,12,opt,name=logLevel" json:"logLevel"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StoreStats) Descriptor 

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

func (*StoreStats) GetApplyingSnapCount 

func (m *StoreStats) GetApplyingSnapCount() uint32

func (*StoreStats) GetAvailable 

func (m *StoreStats) GetAvailable() uint64

func (*StoreStats) GetBytesWritten 

func (m *StoreStats) GetBytesWritten() uint64

func (*StoreStats) GetCapacity 

func (m *StoreStats) GetCapacity() uint64

func (*StoreStats) GetCellCount 

func (m *StoreStats) GetCellCount() uint32

func (*StoreStats) GetIsBusy 

func (m *StoreStats) GetIsBusy() bool

func (*StoreStats) GetLogLevel 

func (m *StoreStats) GetLogLevel() int32

func (*StoreStats) GetReceivingSnapCount 

func (m *StoreStats) GetReceivingSnapCount() uint32

func (*StoreStats) GetSendingSnapCount 

func (m *StoreStats) GetSendingSnapCount() uint32

func (*StoreStats) GetStartTime 

func (m *StoreStats) GetStartTime() uint32

func (*StoreStats) GetStoreID 

func (m *StoreStats) GetStoreID() uint64

func (*StoreStats) GetUsedSize 

func (m *StoreStats) GetUsedSize() uint64

func (*StoreStats) Marshal 

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

func (*StoreStats) MarshalTo 

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

func (*StoreStats) MarshalToSizedBuffer 

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

func (*StoreStats) ProtoMessage 

func (*StoreStats) ProtoMessage()

func (*StoreStats) Reset 

func (m *StoreStats) Reset()

func (*StoreStats) Size 

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

func (*StoreStats) String 

func (m *StoreStats) String() string

func (*StoreStats) Unmarshal 

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

func (*StoreStats) XXX_DiscardUnknown 

func (m *StoreStats) XXX_DiscardUnknown()

func (*StoreStats) XXX_Marshal 

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

func (*StoreStats) XXX_Merge 

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

func (*StoreStats) XXX_Size 

func (m *StoreStats) XXX_Size() int

func (*StoreStats) XXX_Unmarshal 

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

type TransferLeader 

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

func (*TransferLeader) Descriptor 

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

func (*TransferLeader) GetPeer 

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

func (*TransferLeader) Marshal 

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

func (*TransferLeader) MarshalTo 

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

func (*TransferLeader) MarshalToSizedBuffer 

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

func (*TransferLeader) ProtoMessage 

func (*TransferLeader) ProtoMessage()

func (*TransferLeader) Reset 

func (m *TransferLeader) Reset()

func (*TransferLeader) Size 

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

func (*TransferLeader) String 

func (m *TransferLeader) String() string

func (*TransferLeader) Unmarshal 

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

func (*TransferLeader) XXX_DiscardUnknown 

func (m *TransferLeader) XXX_DiscardUnknown()

func (*TransferLeader) XXX_Marshal 

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

func (*TransferLeader) XXX_Merge 

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

func (*TransferLeader) XXX_Size 

func (m *TransferLeader) XXX_Size() int

func (*TransferLeader) XXX_Unmarshal 

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

type UnimplementedPDServiceServer 

type UnimplementedPDServiceServer struct {
}

UnimplementedPDServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPDServiceServer) AllocID 

func (*UnimplementedPDServiceServer) AllocID(ctx context.Context, req *AllocIDReq) (*AllocIDRsp, error)

func (*UnimplementedPDServiceServer) AskSplit 

func (*UnimplementedPDServiceServer) AskSplit(ctx context.Context, req *AskSplitReq) (*AskSplitRsp, error)

func (*UnimplementedPDServiceServer) BootstrapCluster 

func (*UnimplementedPDServiceServer) BootstrapCluster(ctx context.Context, req *BootstrapClusterReq) (*BootstrapClusterRsp, error)

func (*UnimplementedPDServiceServer) CellHeartbeat 

func (*UnimplementedPDServiceServer) CellHeartbeat(ctx context.Context, req *CellHeartbeatReq) (*CellHeartbeatRsp, error)

func (*UnimplementedPDServiceServer) GetClusterID 

func (*UnimplementedPDServiceServer) GetClusterID(ctx context.Context, req *GetClusterIDReq) (*GetClusterIDRsp, error)

func (*UnimplementedPDServiceServer) GetInitParams 

func (*UnimplementedPDServiceServer) GetInitParams(ctx context.Context, req *GetInitParamsReq) (*GetInitParamsRsp, error)

func (*UnimplementedPDServiceServer) GetLastRanges 

func (*UnimplementedPDServiceServer) GetLastRanges(ctx context.Context, req *GetLastRangesReq) (*GetLastRangesRsp, error)

func (*UnimplementedPDServiceServer) GetLeader 

func (*UnimplementedPDServiceServer) GetLeader(ctx context.Context, req *LeaderReq) (*LeaderRsp, error)

func (*UnimplementedPDServiceServer) GetStore 

func (*UnimplementedPDServiceServer) GetStore(ctx context.Context, req *GetStoreReq) (*GetStoreRsp, error)

func (*UnimplementedPDServiceServer) IsClusterBootstrap 

func (*UnimplementedPDServiceServer) IsClusterBootstrap(ctx context.Context, req *IsClusterBootstrapReq) (*IsClusterBootstrapRsp, error)

func (*UnimplementedPDServiceServer) ListStore 

func (*UnimplementedPDServiceServer) ListStore(ctx context.Context, req *ListStoreReq) (*ListStoreRsp, error)

func (*UnimplementedPDServiceServer) PutStore 

func (*UnimplementedPDServiceServer) PutStore(ctx context.Context, req *PutStoreReq) (*PutStoreRsp, error)

func (*UnimplementedPDServiceServer) RegisterWatcher 

func (*UnimplementedPDServiceServer) RegisterWatcher(ctx context.Context, req *RegisterWatcherReq) (*RegisterWatcherRsp, error)

func (*UnimplementedPDServiceServer) ReportSplit 

func (*UnimplementedPDServiceServer) ReportSplit(ctx context.Context, req *ReportSplitReq) (*ReportSplitRsp, error)

func (*UnimplementedPDServiceServer) StoreHeartbeat 

func (*UnimplementedPDServiceServer) StoreHeartbeat(ctx context.Context, req *StoreHeartbeatReq) (*StoreHeartbeatRsp, error)

func (*UnimplementedPDServiceServer) WatcherHeartbeat 

func (*UnimplementedPDServiceServer) WatcherHeartbeat(ctx context.Context, req *WatcherHeartbeatReq) (*WatcherHeartbeatRsp, error)

type WatchEvent 

type WatchEvent struct {
	Event                uint32      `protobuf:"varint,1,opt,name=event" json:"event"`
	CellEvent            *CellEvent  `protobuf:"bytes,2,opt,name=cellEvent" json:"cellEvent,omitempty"`
	StoreEvent           *StoreEvent `protobuf:"bytes,3,opt,name=storeEvent" json:"storeEvent,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WatchEvent) Descriptor 

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

func (*WatchEvent) GetCellEvent 

func (m *WatchEvent) GetCellEvent() *CellEvent

func (*WatchEvent) GetEvent 

func (m *WatchEvent) GetEvent() uint32

func (*WatchEvent) GetStoreEvent 

func (m *WatchEvent) GetStoreEvent() *StoreEvent

func (*WatchEvent) Marshal 

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

func (*WatchEvent) MarshalTo 

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

func (*WatchEvent) MarshalToSizedBuffer 

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

func (*WatchEvent) ProtoMessage 

func (*WatchEvent) ProtoMessage()

func (*WatchEvent) Reset 

func (m *WatchEvent) Reset()

func (*WatchEvent) Size 

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

func (*WatchEvent) String 

func (m *WatchEvent) String() string

func (*WatchEvent) Unmarshal 

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

func (*WatchEvent) XXX_DiscardUnknown 

func (m *WatchEvent) XXX_DiscardUnknown()

func (*WatchEvent) XXX_Marshal 

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

func (*WatchEvent) XXX_Merge 

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

func (*WatchEvent) XXX_Size 

func (m *WatchEvent) XXX_Size() int

func (*WatchEvent) XXX_Unmarshal 

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

type Watcher 

type Watcher struct {
	Addr                 string   `protobuf:"bytes,1,opt,name=addr" json:"addr"`
	EventFlag            uint32   `protobuf:"varint,2,opt,name=eventFlag" json:"eventFlag"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Watcher) Descriptor 

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

func (*Watcher) GetAddr 

func (m *Watcher) GetAddr() string

func (*Watcher) GetEventFlag 

func (m *Watcher) GetEventFlag() uint32

func (*Watcher) Marshal 

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

func (*Watcher) MarshalTo 

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

func (*Watcher) MarshalToSizedBuffer 

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

func (*Watcher) ProtoMessage 

func (*Watcher) ProtoMessage()

func (*Watcher) Reset 

func (m *Watcher) Reset()

func (*Watcher) Size 

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

func (*Watcher) String 

func (m *Watcher) String() string

func (*Watcher) Unmarshal 

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

func (*Watcher) XXX_DiscardUnknown 

func (m *Watcher) XXX_DiscardUnknown()

func (*Watcher) XXX_Marshal 

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

func (*Watcher) XXX_Merge 

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

func (*Watcher) XXX_Size 

func (m *Watcher) XXX_Size() int

func (*Watcher) XXX_Unmarshal 

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

type WatcherHeartbeatReq 

type WatcherHeartbeatReq struct {
	From                 string   `protobuf:"bytes,1,opt,name=from" json:"from"`
	ID                   uint64   `protobuf:"varint,2,opt,name=id" json:"id"`
	Addr                 string   `protobuf:"bytes,3,opt,name=addr" json:"addr"`
	Offset               uint64   `protobuf:"varint,4,opt,name=offset" json:"offset"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatcherHeartbeatReq) Descriptor 

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

func (*WatcherHeartbeatReq) GetAddr 

func (m *WatcherHeartbeatReq) GetAddr() string

func (*WatcherHeartbeatReq) GetFrom 

func (m *WatcherHeartbeatReq) GetFrom() string

func (*WatcherHeartbeatReq) GetID 

func (m *WatcherHeartbeatReq) GetID() uint64

func (*WatcherHeartbeatReq) GetOffset 

func (m *WatcherHeartbeatReq) GetOffset() uint64

func (*WatcherHeartbeatReq) Marshal 

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

func (*WatcherHeartbeatReq) MarshalTo 

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

func (*WatcherHeartbeatReq) MarshalToSizedBuffer 

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

func (*WatcherHeartbeatReq) ProtoMessage 

func (*WatcherHeartbeatReq) ProtoMessage()

func (*WatcherHeartbeatReq) Reset 

func (m *WatcherHeartbeatReq) Reset()

func (*WatcherHeartbeatReq) Size 

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

func (*WatcherHeartbeatReq) String 

func (m *WatcherHeartbeatReq) String() string

func (*WatcherHeartbeatReq) Unmarshal 

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

func (*WatcherHeartbeatReq) XXX_DiscardUnknown 

func (m *WatcherHeartbeatReq) XXX_DiscardUnknown()

func (*WatcherHeartbeatReq) XXX_Marshal 

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

func (*WatcherHeartbeatReq) XXX_Merge 

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

func (*WatcherHeartbeatReq) XXX_Size 

func (m *WatcherHeartbeatReq) XXX_Size() int

func (*WatcherHeartbeatReq) XXX_Unmarshal 

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

type WatcherHeartbeatRsp 

type WatcherHeartbeatRsp struct {
	Paused               bool     `protobuf:"varint,1,opt,name=paused" json:"paused"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatcherHeartbeatRsp) Descriptor 

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

func (*WatcherHeartbeatRsp) GetPaused 

func (m *WatcherHeartbeatRsp) GetPaused() bool

func (*WatcherHeartbeatRsp) Marshal 

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

func (*WatcherHeartbeatRsp) MarshalTo 

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

func (*WatcherHeartbeatRsp) MarshalToSizedBuffer 

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

func (*WatcherHeartbeatRsp) ProtoMessage 

func (*WatcherHeartbeatRsp) ProtoMessage()

func (*WatcherHeartbeatRsp) Reset 

func (m *WatcherHeartbeatRsp) Reset()

func (*WatcherHeartbeatRsp) Size 

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

func (*WatcherHeartbeatRsp) String 

func (m *WatcherHeartbeatRsp) String() string

func (*WatcherHeartbeatRsp) Unmarshal 

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

func (*WatcherHeartbeatRsp) XXX_DiscardUnknown 

func (m *WatcherHeartbeatRsp) XXX_DiscardUnknown()

func (*WatcherHeartbeatRsp) XXX_Marshal 

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

func (*WatcherHeartbeatRsp) XXX_Merge 

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

func (*WatcherHeartbeatRsp) XXX_Size 

func (m *WatcherHeartbeatRsp) XXX_Size() int

func (*WatcherHeartbeatRsp) XXX_Unmarshal 

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

type WatcherNotify 

type WatcherNotify struct {
	Offset               uint64   `protobuf:"varint,1,opt,name=offset" json:"offset"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatcherNotify) Descriptor 

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

func (*WatcherNotify) GetOffset 

func (m *WatcherNotify) GetOffset() uint64

func (*WatcherNotify) Marshal 

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

func (*WatcherNotify) MarshalTo 

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

func (*WatcherNotify) MarshalToSizedBuffer 

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

func (*WatcherNotify) ProtoMessage 

func (*WatcherNotify) ProtoMessage()

func (*WatcherNotify) Reset 

func (m *WatcherNotify) Reset()

func (*WatcherNotify) Size 

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

func (*WatcherNotify) String 

func (m *WatcherNotify) String() string

func (*WatcherNotify) Unmarshal 

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

func (*WatcherNotify) XXX_DiscardUnknown 

func (m *WatcherNotify) XXX_DiscardUnknown()

func (*WatcherNotify) XXX_Marshal 

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

func (*WatcherNotify) XXX_Merge 

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

func (*WatcherNotify) XXX_Size 

func (m *WatcherNotify) XXX_Size() int

func (*WatcherNotify) XXX_Unmarshal 

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

type WatcherNotifyRsp 

type WatcherNotifyRsp struct {
	Offset               uint64        `protobuf:"varint,1,opt,name=offset" json:"offset"`
	Events               []*WatchEvent `protobuf:"bytes,2,rep,name=events" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*WatcherNotifyRsp) Descriptor 

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

func (*WatcherNotifyRsp) GetEvents 

func (m *WatcherNotifyRsp) GetEvents() []*WatchEvent

func (*WatcherNotifyRsp) GetOffset 

func (m *WatcherNotifyRsp) GetOffset() uint64

func (*WatcherNotifyRsp) Marshal 

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

func (*WatcherNotifyRsp) MarshalTo 

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

func (*WatcherNotifyRsp) MarshalToSizedBuffer 

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

func (*WatcherNotifyRsp) ProtoMessage 

func (*WatcherNotifyRsp) ProtoMessage()

func (*WatcherNotifyRsp) Reset 

func (m *WatcherNotifyRsp) Reset()

func (*WatcherNotifyRsp) Size 

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

func (*WatcherNotifyRsp) String 

func (m *WatcherNotifyRsp) String() string

func (*WatcherNotifyRsp) Unmarshal 

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

func (*WatcherNotifyRsp) XXX_DiscardUnknown 

func (m *WatcherNotifyRsp) XXX_DiscardUnknown()

func (*WatcherNotifyRsp) XXX_Marshal 

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

func (*WatcherNotifyRsp) XXX_Merge 

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

func (*WatcherNotifyRsp) XXX_Size 

func (m *WatcherNotifyRsp) XXX_Size() int

func (*WatcherNotifyRsp) XXX_Unmarshal 

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

type WatcherNotifySync 

type WatcherNotifySync struct {
	Offset               uint64   `protobuf:"varint,1,opt,name=offset" json:"offset"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatcherNotifySync) Descriptor 

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

func (*WatcherNotifySync) GetOffset 

func (m *WatcherNotifySync) GetOffset() uint64

func (*WatcherNotifySync) Marshal 

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

func (*WatcherNotifySync) MarshalTo 

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

func (*WatcherNotifySync) MarshalToSizedBuffer 

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

func (*WatcherNotifySync) ProtoMessage 

func (*WatcherNotifySync) ProtoMessage()

func (*WatcherNotifySync) Reset 

func (m *WatcherNotifySync) Reset()

func (*WatcherNotifySync) Size 

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

func (*WatcherNotifySync) String 

func (m *WatcherNotifySync) String() string

func (*WatcherNotifySync) Unmarshal 

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

func (*WatcherNotifySync) XXX_DiscardUnknown 

func (m *WatcherNotifySync) XXX_DiscardUnknown()

func (*WatcherNotifySync) XXX_Marshal 

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

func (*WatcherNotifySync) XXX_Merge 

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

func (*WatcherNotifySync) XXX_Size 

func (m *WatcherNotifySync) XXX_Size() int

func (*WatcherNotifySync) XXX_Unmarshal 

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