pdpb

package
v0.0.0-...-3b800f5 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package pdpb is a generated protocol buffer package.

It is generated from these files: 

pdpb.proto

It has these top-level messages: 

ChangePeer
TransferLeader
PeerStats
Range
StoreStats
RequestHeader
ResponseHeader
Leader
Watcher
RegisterWatcherReq
RegisterWatcherRsp
WatcherHeartbeatReq
WatcherHeartbeatRsp
WatcherNotify
WatcherNotifySync
WatcherNotifyRsp
WatchEvent
CellEvent
StoreEvent
LeaderReq
LeaderRsp
ListStoreReq
ListStoreRsp
PutStoreReq
PutStoreRsp
GetStoreReq
GetStoreRsp
GetClusterIDReq
GetClusterIDRsp
GetInitParamsReq
GetInitParamsRsp
AllocIDReq
AllocIDRsp
IsClusterBootstrapReq
IsClusterBootstrapRsp
BootstrapClusterReq
BootstrapClusterRsp
CellHeartbeatReq
CellHeartbeatRsp
StoreHeartbeatReq
StoreHeartbeatRsp
AskSplitReq
AskSplitRsp
ReportSplitReq
ReportSplitRsp
GetLastRangesReq
GetLastRangesRsp
SetLogLevel
FieldDef
IndexDef
IndexKeyRequest
IndexSplitRequest
IndexDestroyCellRequest
IndexRebuildCellRequest
IndexRequest
KeyMetaVal

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_unrecognized []byte `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) 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

type AllocIDRsp 

type AllocIDRsp struct {
	ID               uint64 `protobuf:"varint,1,opt,name=id" json:"id"`
	XXX_unrecognized []byte `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) 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

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_unrecognized []byte        `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) 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

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_unrecognized []byte         `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) 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

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_unrecognized []byte        `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) 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

type BootstrapClusterRsp 

type BootstrapClusterRsp struct {
	AlreadyBootstrapped bool   `protobuf:"varint,1,opt,name=alreadyBootstrapped" json:"alreadyBootstrapped"`
	XXX_unrecognized    []byte `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) 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

type CellEvent 

type CellEvent struct {
	Range            *Range `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
	XXX_unrecognized []byte `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) 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

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_unrecognized []byte `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) 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

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_unrecognized []byte          `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) 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

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_unrecognized []byte         `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) 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

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_unrecognized []byte     `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) 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

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_unrecognized []byte `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) 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

type GetClusterIDRsp 

type GetClusterIDRsp struct {
	ID               uint64 `protobuf:"varint,1,opt,name=id" json:"id"`
	XXX_unrecognized []byte `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) 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

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_unrecognized []byte `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) 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

type GetInitParamsRsp 

type GetInitParamsRsp struct {
	Params           []byte `protobuf:"bytes,1,opt,name=params" json:"params,omitempty"`
	XXX_unrecognized []byte `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) 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

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_unrecognized []byte `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) 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

type GetLastRangesRsp 

type GetLastRangesRsp struct {
	Ranges           []*Range `protobuf:"bytes,1,rep,name=ranges" json:"ranges,omitempty"`
	XXX_unrecognized []byte   `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) 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

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_unrecognized []byte        `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) 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

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_unrecognized []byte         `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) 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

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_unrecognized []byte      `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) 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

type IndexDestroyCellRequest 

type IndexDestroyCellRequest struct {
	CellID           uint64 `protobuf:"varint,1,opt,name=cellID" json:"cellID"`
	XXX_unrecognized []byte `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) 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

type IndexKeyRequest 

type IndexKeyRequest struct {
	CellID           uint64           `protobuf:"varint,1,opt,name=cellID" json:"cellID"`
	Epoch            metapb.CellEpoch `protobuf:"bytes,2,opt,name=epoch" json:"epoch"`
	IdxName          string           `protobuf:"bytes,3,opt,name=idxName" json:"idxName"`
	DataKeys         [][]byte         `protobuf:"bytes,4,rep,name=dataKeys" json:"dataKeys,omitempty"`
	IsDel            bool             `protobuf:"varint,5,opt,name=isDel" json:"isDel"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*IndexKeyRequest) Descriptor 

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

func (*IndexKeyRequest) GetCellID 

func (m *IndexKeyRequest) GetCellID() uint64

func (*IndexKeyRequest) GetDataKeys 

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

func (*IndexKeyRequest) GetEpoch 

func (m *IndexKeyRequest) GetEpoch() metapb.CellEpoch

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

type IndexRebuildCellRequest 

type IndexRebuildCellRequest struct {
	CellID           uint64 `protobuf:"varint,1,opt,name=cellID" json:"cellID"`
	XXX_unrecognized []byte `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) 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

type IndexRequest 

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

func (*IndexRequest) Descriptor 

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

func (*IndexRequest) GetIdxDestroy 

func (m *IndexRequest) GetIdxDestroy() *IndexDestroyCellRequest

func (*IndexRequest) GetIdxKey 

func (m *IndexRequest) GetIdxKey() *IndexKeyRequest

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

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_unrecognized []byte `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) 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

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_unrecognized []byte `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) 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

type IsClusterBootstrapRsp 

type IsClusterBootstrapRsp struct {
	Value            bool   `protobuf:"varint,1,opt,name=value" json:"value"`
	XXX_unrecognized []byte `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) 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

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_unrecognized []byte `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) 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

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_unrecognized []byte `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) 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

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_unrecognized []byte `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) 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

type LeaderRsp 

type LeaderRsp struct {
	Leader           Leader `protobuf:"bytes,1,opt,name=leader" json:"leader"`
	XXX_unrecognized []byte `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) 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

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_unrecognized []byte `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) 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

type ListStoreRsp 

type ListStoreRsp struct {
	Stores           []*metapb.Store `protobuf:"bytes,1,rep,name=stores" json:"stores,omitempty"`
	XXX_unrecognized []byte          `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) 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

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

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

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_unrecognized []byte      `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) 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

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_unrecognized []byte        `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) 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

type PutStoreRsp 

type PutStoreRsp struct {
	Header           ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
	XXX_unrecognized []byte         `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) 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

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_unrecognized []byte       `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) 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

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_unrecognized []byte  `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) 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

type RegisterWatcherRsp 

type RegisterWatcherRsp struct {
	XXX_unrecognized []byte `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) 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

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_unrecognized []byte        `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) 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

type ReportSplitRsp 

type ReportSplitRsp struct {
	Header           ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header"`
	XXX_unrecognized []byte         `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) 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

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_unrecognized []byte `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) 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

type ResponseHeader 

type ResponseHeader struct {
	ClusterID        uint64 `protobuf:"varint,1,opt,name=clusterID" json:"clusterID"`
	XXX_unrecognized []byte `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) 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

type SetLogLevel 

type SetLogLevel struct {
	NewLevel         int32  `protobuf:"varint,1,opt,name=newLevel" json:"newLevel"`
	XXX_unrecognized []byte `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) 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

type StoreEvent 

type StoreEvent struct {
	Store            *metapb.Store `protobuf:"bytes,1,opt,name=store" json:"store,omitempty"`
	XXX_unrecognized []byte        `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) 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

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_unrecognized []byte        `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) 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

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_unrecognized []byte         `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) 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

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_unrecognized []byte `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) 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

type TransferLeader 

type TransferLeader struct {
	Peer             metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer"`
	XXX_unrecognized []byte      `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) 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

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_unrecognized []byte      `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) 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

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_unrecognized []byte `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) 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

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_unrecognized []byte `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) 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

type WatcherHeartbeatRsp 

type WatcherHeartbeatRsp struct {
	Paused           bool   `protobuf:"varint,1,opt,name=paused" json:"paused"`
	XXX_unrecognized []byte `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) 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

type WatcherNotify 

type WatcherNotify struct {
	Offset           uint64 `protobuf:"varint,1,opt,name=offset" json:"offset"`
	XXX_unrecognized []byte `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) 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

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_unrecognized []byte        `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) 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

type WatcherNotifySync 

type WatcherNotifySync struct {
	Offset           uint64 `protobuf:"varint,1,opt,name=offset" json:"offset"`
	XXX_unrecognized []byte `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) 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

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.