pdpb

package
v0.0.0-...-a9a2a47 Latest Latest
Warning

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

Go to latest
Published: Jun 22, 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 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) AskSplit

func (*UnimplementedPDServiceServer) BootstrapCluster

func (*UnimplementedPDServiceServer) CellHeartbeat

func (*UnimplementedPDServiceServer) GetClusterID

func (*UnimplementedPDServiceServer) GetInitParams

func (*UnimplementedPDServiceServer) GetLastRanges

func (*UnimplementedPDServiceServer) GetLeader

func (*UnimplementedPDServiceServer) GetStore

func (*UnimplementedPDServiceServer) IsClusterBootstrap

func (*UnimplementedPDServiceServer) ListStore

func (*UnimplementedPDServiceServer) PutStore

func (*UnimplementedPDServiceServer) RegisterWatcher

func (*UnimplementedPDServiceServer) ReportSplit

func (*UnimplementedPDServiceServer) StoreHeartbeat

func (*UnimplementedPDServiceServer) WatcherHeartbeat

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL