pdpb

package
v0.0.0-...-40faf7d Latest Latest
Warning

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

Go to latest
Published: Nov 24, 2016 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package pdpb is a generated protocol buffer package.

It is generated from these files:

pdpb.proto

It has these top-level messages:

Leader
TsoRequest
Timestamp
TsoResponse
BootstrapRequest
BootstrapResponse
IsBootstrappedRequest
IsBootstrappedResponse
AllocIdRequest
AllocIdResponse
GetStoreRequest
GetStoreResponse
GetRegionRequest
GetRegionResponse
GetRegionByIDRequest
GetClusterConfigRequest
GetClusterConfigResponse
PutStoreRequest
PutStoreResponse
PDMember
GetPDMembersRequest
GetPDMembersResponse
PeerStats
RegionHeartbeatRequest
ChangePeer
TransferLeader
RegionHeartbeatResponse
PutClusterConfigRequest
PutClusterConfigResponse
AskSplitRequest
AskSplitResponse
StoreStats
StoreHeartbeatRequest
StoreHeartbeatResponse
ReportSplitRequest
ReportSplitResponse
RequestHeader
ResponseHeader
Request
Response
BootstrappedError
StoreIsTombstoneError
Error

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 CommandType_name = map[int32]string{
	0:  "Invalid",
	1:  "Tso",
	2:  "Bootstrap",
	3:  "IsBootstrapped",
	4:  "AllocId",
	5:  "GetStore",
	6:  "PutStore",
	7:  "AskSplit",
	8:  "GetRegion",
	9:  "RegionHeartbeat",
	10: "GetClusterConfig",
	11: "PutClusterConfig",
	12: "StoreHeartbeat",
	13: "ReportSplit",
	14: "GetRegionByID",
	15: "GetPDMembers",
}
View Source
var CommandType_value = map[string]int32{
	"Invalid":          0,
	"Tso":              1,
	"Bootstrap":        2,
	"IsBootstrapped":   3,
	"AllocId":          4,
	"GetStore":         5,
	"PutStore":         6,
	"AskSplit":         7,
	"GetRegion":        8,
	"RegionHeartbeat":  9,
	"GetClusterConfig": 10,
	"PutClusterConfig": 11,
	"StoreHeartbeat":   12,
	"ReportSplit":      13,
	"GetRegionByID":    14,
	"GetPDMembers":     15,
}

Functions

This section is empty.

Types

type AllocIdRequest

type AllocIdRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*AllocIdRequest) Descriptor

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

func (*AllocIdRequest) Marshal

func (m *AllocIdRequest) Marshal() (data []byte, err error)

func (*AllocIdRequest) MarshalTo

func (m *AllocIdRequest) MarshalTo(data []byte) (int, error)

func (*AllocIdRequest) ProtoMessage

func (*AllocIdRequest) ProtoMessage()

func (*AllocIdRequest) Reset

func (m *AllocIdRequest) Reset()

func (*AllocIdRequest) Size

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

func (*AllocIdRequest) String

func (m *AllocIdRequest) String() string

func (*AllocIdRequest) Unmarshal

func (m *AllocIdRequest) Unmarshal(data []byte) error

type AllocIdResponse

type AllocIdResponse struct {
	Id               uint64 `protobuf:"varint,1,opt,name=id" json:"id"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AllocIdResponse) Descriptor

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

func (*AllocIdResponse) GetId

func (m *AllocIdResponse) GetId() uint64

func (*AllocIdResponse) Marshal

func (m *AllocIdResponse) Marshal() (data []byte, err error)

func (*AllocIdResponse) MarshalTo

func (m *AllocIdResponse) MarshalTo(data []byte) (int, error)

func (*AllocIdResponse) ProtoMessage

func (*AllocIdResponse) ProtoMessage()

func (*AllocIdResponse) Reset

func (m *AllocIdResponse) Reset()

func (*AllocIdResponse) Size

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

func (*AllocIdResponse) String

func (m *AllocIdResponse) String() string

func (*AllocIdResponse) Unmarshal

func (m *AllocIdResponse) Unmarshal(data []byte) error

type AskSplitRequest

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

func (*AskSplitRequest) Descriptor

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

func (*AskSplitRequest) GetRegion

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

func (*AskSplitRequest) Marshal

func (m *AskSplitRequest) Marshal() (data []byte, err error)

func (*AskSplitRequest) MarshalTo

func (m *AskSplitRequest) MarshalTo(data []byte) (int, error)

func (*AskSplitRequest) ProtoMessage

func (*AskSplitRequest) ProtoMessage()

func (*AskSplitRequest) Reset

func (m *AskSplitRequest) Reset()

func (*AskSplitRequest) Size

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

func (*AskSplitRequest) String

func (m *AskSplitRequest) String() string

func (*AskSplitRequest) Unmarshal

func (m *AskSplitRequest) Unmarshal(data []byte) error

type AskSplitResponse

type AskSplitResponse struct {
	// We split the region into two, first uses the origin
	// parent region id, and the second uses the new_region_id.
	// We must guarantee that the new_region_id is global unique.
	NewRegionId uint64 `protobuf:"varint,1,opt,name=new_region_id,json=newRegionId" json:"new_region_id"`
	// The peer ids for the new split region.
	NewPeerIds       []uint64 `protobuf:"varint,2,rep,name=new_peer_ids,json=newPeerIds" json:"new_peer_ids,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*AskSplitResponse) Descriptor

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

func (*AskSplitResponse) GetNewPeerIds

func (m *AskSplitResponse) GetNewPeerIds() []uint64

func (*AskSplitResponse) GetNewRegionId

func (m *AskSplitResponse) GetNewRegionId() uint64

func (*AskSplitResponse) Marshal

func (m *AskSplitResponse) Marshal() (data []byte, err error)

func (*AskSplitResponse) MarshalTo

func (m *AskSplitResponse) MarshalTo(data []byte) (int, error)

func (*AskSplitResponse) ProtoMessage

func (*AskSplitResponse) ProtoMessage()

func (*AskSplitResponse) Reset

func (m *AskSplitResponse) Reset()

func (*AskSplitResponse) Size

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

func (*AskSplitResponse) String

func (m *AskSplitResponse) String() string

func (*AskSplitResponse) Unmarshal

func (m *AskSplitResponse) Unmarshal(data []byte) error

type BootstrapRequest

type BootstrapRequest struct {
	Store            *metapb.Store  `protobuf:"bytes,1,opt,name=store" json:"store,omitempty"`
	Region           *metapb.Region `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*BootstrapRequest) Descriptor

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

func (*BootstrapRequest) GetRegion

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

func (*BootstrapRequest) GetStore

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

func (*BootstrapRequest) Marshal

func (m *BootstrapRequest) Marshal() (data []byte, err error)

func (*BootstrapRequest) MarshalTo

func (m *BootstrapRequest) MarshalTo(data []byte) (int, error)

func (*BootstrapRequest) ProtoMessage

func (*BootstrapRequest) ProtoMessage()

func (*BootstrapRequest) Reset

func (m *BootstrapRequest) Reset()

func (*BootstrapRequest) Size

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

func (*BootstrapRequest) String

func (m *BootstrapRequest) String() string

func (*BootstrapRequest) Unmarshal

func (m *BootstrapRequest) Unmarshal(data []byte) error

type BootstrapResponse

type BootstrapResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*BootstrapResponse) Descriptor

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

func (*BootstrapResponse) Marshal

func (m *BootstrapResponse) Marshal() (data []byte, err error)

func (*BootstrapResponse) MarshalTo

func (m *BootstrapResponse) MarshalTo(data []byte) (int, error)

func (*BootstrapResponse) ProtoMessage

func (*BootstrapResponse) ProtoMessage()

func (*BootstrapResponse) Reset

func (m *BootstrapResponse) Reset()

func (*BootstrapResponse) Size

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

func (*BootstrapResponse) String

func (m *BootstrapResponse) String() string

func (*BootstrapResponse) Unmarshal

func (m *BootstrapResponse) Unmarshal(data []byte) error

type BootstrappedError

type BootstrappedError struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*BootstrappedError) Descriptor

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

func (*BootstrappedError) Marshal

func (m *BootstrappedError) Marshal() (data []byte, err error)

func (*BootstrappedError) MarshalTo

func (m *BootstrappedError) MarshalTo(data []byte) (int, error)

func (*BootstrappedError) ProtoMessage

func (*BootstrappedError) ProtoMessage()

func (*BootstrappedError) Reset

func (m *BootstrappedError) Reset()

func (*BootstrappedError) Size

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

func (*BootstrappedError) String

func (m *BootstrappedError) String() string

func (*BootstrappedError) Unmarshal

func (m *BootstrappedError) Unmarshal(data []byte) error

type ChangePeer

type ChangePeer struct {
	ChangeType       *eraftpb.ConfChangeType `protobuf:"varint,1,opt,name=change_type,json=changeType,enum=eraftpb.ConfChangeType" json:"change_type,omitempty"`
	Peer             *metapb.Peer            `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*ChangePeer) Descriptor

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

func (*ChangePeer) GetChangeType

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

func (*ChangePeer) GetPeer

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

func (*ChangePeer) Marshal

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

func (*ChangePeer) MarshalTo

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

func (*ChangePeer) ProtoMessage

func (*ChangePeer) ProtoMessage()

func (*ChangePeer) Reset

func (m *ChangePeer) Reset()

func (*ChangePeer) Size

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

func (*ChangePeer) String

func (m *ChangePeer) String() string

func (*ChangePeer) Unmarshal

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

type CommandType

type CommandType int32
const (
	CommandType_Invalid          CommandType = 0
	CommandType_Tso              CommandType = 1
	CommandType_Bootstrap        CommandType = 2
	CommandType_IsBootstrapped   CommandType = 3
	CommandType_AllocId          CommandType = 4
	CommandType_GetStore         CommandType = 5
	CommandType_PutStore         CommandType = 6
	CommandType_AskSplit         CommandType = 7
	CommandType_GetRegion        CommandType = 8
	CommandType_RegionHeartbeat  CommandType = 9
	CommandType_GetClusterConfig CommandType = 10
	CommandType_PutClusterConfig CommandType = 11
	CommandType_StoreHeartbeat   CommandType = 12
	CommandType_ReportSplit      CommandType = 13
	CommandType_GetRegionByID    CommandType = 14
	CommandType_GetPDMembers     CommandType = 15
)

func (CommandType) Enum

func (x CommandType) Enum() *CommandType

func (CommandType) EnumDescriptor

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

func (CommandType) String

func (x CommandType) String() string

func (*CommandType) UnmarshalJSON

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

type Error

type Error struct {
	Message          *string                `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	Bootstrapped     *BootstrappedError     `protobuf:"bytes,2,opt,name=bootstrapped" json:"bootstrapped,omitempty"`
	IsTombstone      *StoreIsTombstoneError `protobuf:"bytes,3,opt,name=is_tombstone,json=isTombstone" json:"is_tombstone,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*Error) Descriptor

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

func (*Error) GetBootstrapped

func (m *Error) GetBootstrapped() *BootstrappedError

func (*Error) GetIsTombstone

func (m *Error) GetIsTombstone() *StoreIsTombstoneError

func (*Error) GetMessage

func (m *Error) GetMessage() string

func (*Error) Marshal

func (m *Error) Marshal() (data []byte, err error)

func (*Error) MarshalTo

func (m *Error) MarshalTo(data []byte) (int, error)

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) Size

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

func (*Error) String

func (m *Error) String() string

func (*Error) Unmarshal

func (m *Error) Unmarshal(data []byte) error

type GetClusterConfigRequest

type GetClusterConfigRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetClusterConfigRequest) Descriptor

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

func (*GetClusterConfigRequest) Marshal

func (m *GetClusterConfigRequest) Marshal() (data []byte, err error)

func (*GetClusterConfigRequest) MarshalTo

func (m *GetClusterConfigRequest) MarshalTo(data []byte) (int, error)

func (*GetClusterConfigRequest) ProtoMessage

func (*GetClusterConfigRequest) ProtoMessage()

func (*GetClusterConfigRequest) Reset

func (m *GetClusterConfigRequest) Reset()

func (*GetClusterConfigRequest) Size

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

func (*GetClusterConfigRequest) String

func (m *GetClusterConfigRequest) String() string

func (*GetClusterConfigRequest) Unmarshal

func (m *GetClusterConfigRequest) Unmarshal(data []byte) error

type GetClusterConfigResponse

type GetClusterConfigResponse struct {
	Cluster          *metapb.Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*GetClusterConfigResponse) Descriptor

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

func (*GetClusterConfigResponse) GetCluster

func (m *GetClusterConfigResponse) GetCluster() *metapb.Cluster

func (*GetClusterConfigResponse) Marshal

func (m *GetClusterConfigResponse) Marshal() (data []byte, err error)

func (*GetClusterConfigResponse) MarshalTo

func (m *GetClusterConfigResponse) MarshalTo(data []byte) (int, error)

func (*GetClusterConfigResponse) ProtoMessage

func (*GetClusterConfigResponse) ProtoMessage()

func (*GetClusterConfigResponse) Reset

func (m *GetClusterConfigResponse) Reset()

func (*GetClusterConfigResponse) Size

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

func (*GetClusterConfigResponse) String

func (m *GetClusterConfigResponse) String() string

func (*GetClusterConfigResponse) Unmarshal

func (m *GetClusterConfigResponse) Unmarshal(data []byte) error

type GetPDMembersRequest

type GetPDMembersRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetPDMembersRequest) Descriptor

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

func (*GetPDMembersRequest) Marshal

func (m *GetPDMembersRequest) Marshal() (data []byte, err error)

func (*GetPDMembersRequest) MarshalTo

func (m *GetPDMembersRequest) MarshalTo(data []byte) (int, error)

func (*GetPDMembersRequest) ProtoMessage

func (*GetPDMembersRequest) ProtoMessage()

func (*GetPDMembersRequest) Reset

func (m *GetPDMembersRequest) Reset()

func (*GetPDMembersRequest) Size

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

func (*GetPDMembersRequest) String

func (m *GetPDMembersRequest) String() string

func (*GetPDMembersRequest) Unmarshal

func (m *GetPDMembersRequest) Unmarshal(data []byte) error

type GetPDMembersResponse

type GetPDMembersResponse struct {
	Members          []*PDMember `protobuf:"bytes,1,rep,name=members" json:"members,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*GetPDMembersResponse) Descriptor

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

func (*GetPDMembersResponse) GetMembers

func (m *GetPDMembersResponse) GetMembers() []*PDMember

func (*GetPDMembersResponse) Marshal

func (m *GetPDMembersResponse) Marshal() (data []byte, err error)

func (*GetPDMembersResponse) MarshalTo

func (m *GetPDMembersResponse) MarshalTo(data []byte) (int, error)

func (*GetPDMembersResponse) ProtoMessage

func (*GetPDMembersResponse) ProtoMessage()

func (*GetPDMembersResponse) Reset

func (m *GetPDMembersResponse) Reset()

func (*GetPDMembersResponse) Size

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

func (*GetPDMembersResponse) String

func (m *GetPDMembersResponse) String() string

func (*GetPDMembersResponse) Unmarshal

func (m *GetPDMembersResponse) Unmarshal(data []byte) error

type GetRegionByIDRequest

type GetRegionByIDRequest struct {
	RegionId         uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId" json:"region_id"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetRegionByIDRequest) Descriptor

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

func (*GetRegionByIDRequest) GetRegionId

func (m *GetRegionByIDRequest) GetRegionId() uint64

func (*GetRegionByIDRequest) Marshal

func (m *GetRegionByIDRequest) Marshal() (data []byte, err error)

func (*GetRegionByIDRequest) MarshalTo

func (m *GetRegionByIDRequest) MarshalTo(data []byte) (int, error)

func (*GetRegionByIDRequest) ProtoMessage

func (*GetRegionByIDRequest) ProtoMessage()

func (*GetRegionByIDRequest) Reset

func (m *GetRegionByIDRequest) Reset()

func (*GetRegionByIDRequest) Size

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

func (*GetRegionByIDRequest) String

func (m *GetRegionByIDRequest) String() string

func (*GetRegionByIDRequest) Unmarshal

func (m *GetRegionByIDRequest) Unmarshal(data []byte) error

type GetRegionRequest

type GetRegionRequest struct {
	RegionKey        []byte `protobuf:"bytes,1,opt,name=region_key,json=regionKey" json:"region_key,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetRegionRequest) Descriptor

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

func (*GetRegionRequest) GetRegionKey

func (m *GetRegionRequest) GetRegionKey() []byte

func (*GetRegionRequest) Marshal

func (m *GetRegionRequest) Marshal() (data []byte, err error)

func (*GetRegionRequest) MarshalTo

func (m *GetRegionRequest) MarshalTo(data []byte) (int, error)

func (*GetRegionRequest) ProtoMessage

func (*GetRegionRequest) ProtoMessage()

func (*GetRegionRequest) Reset

func (m *GetRegionRequest) Reset()

func (*GetRegionRequest) Size

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

func (*GetRegionRequest) String

func (m *GetRegionRequest) String() string

func (*GetRegionRequest) Unmarshal

func (m *GetRegionRequest) Unmarshal(data []byte) error

type GetRegionResponse

type GetRegionResponse struct {
	Region           *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"`
	Leader           *metapb.Peer   `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*GetRegionResponse) Descriptor

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

func (*GetRegionResponse) GetLeader

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

func (*GetRegionResponse) GetRegion

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

func (*GetRegionResponse) Marshal

func (m *GetRegionResponse) Marshal() (data []byte, err error)

func (*GetRegionResponse) MarshalTo

func (m *GetRegionResponse) MarshalTo(data []byte) (int, error)

func (*GetRegionResponse) ProtoMessage

func (*GetRegionResponse) ProtoMessage()

func (*GetRegionResponse) Reset

func (m *GetRegionResponse) Reset()

func (*GetRegionResponse) Size

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

func (*GetRegionResponse) String

func (m *GetRegionResponse) String() string

func (*GetRegionResponse) Unmarshal

func (m *GetRegionResponse) Unmarshal(data []byte) error

type GetStoreRequest

type GetStoreRequest struct {
	StoreId          uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId" json:"store_id"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetStoreRequest) Descriptor

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

func (*GetStoreRequest) GetStoreId

func (m *GetStoreRequest) GetStoreId() uint64

func (*GetStoreRequest) Marshal

func (m *GetStoreRequest) Marshal() (data []byte, err error)

func (*GetStoreRequest) MarshalTo

func (m *GetStoreRequest) MarshalTo(data []byte) (int, error)

func (*GetStoreRequest) ProtoMessage

func (*GetStoreRequest) ProtoMessage()

func (*GetStoreRequest) Reset

func (m *GetStoreRequest) Reset()

func (*GetStoreRequest) Size

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

func (*GetStoreRequest) String

func (m *GetStoreRequest) String() string

func (*GetStoreRequest) Unmarshal

func (m *GetStoreRequest) Unmarshal(data []byte) error

type GetStoreResponse

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

func (*GetStoreResponse) Descriptor

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

func (*GetStoreResponse) GetStore

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

func (*GetStoreResponse) Marshal

func (m *GetStoreResponse) Marshal() (data []byte, err error)

func (*GetStoreResponse) MarshalTo

func (m *GetStoreResponse) MarshalTo(data []byte) (int, error)

func (*GetStoreResponse) ProtoMessage

func (*GetStoreResponse) ProtoMessage()

func (*GetStoreResponse) Reset

func (m *GetStoreResponse) Reset()

func (*GetStoreResponse) Size

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

func (*GetStoreResponse) String

func (m *GetStoreResponse) String() string

func (*GetStoreResponse) Unmarshal

func (m *GetStoreResponse) Unmarshal(data []byte) error

type IsBootstrappedRequest

type IsBootstrappedRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*IsBootstrappedRequest) Descriptor

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

func (*IsBootstrappedRequest) Marshal

func (m *IsBootstrappedRequest) Marshal() (data []byte, err error)

func (*IsBootstrappedRequest) MarshalTo

func (m *IsBootstrappedRequest) MarshalTo(data []byte) (int, error)

func (*IsBootstrappedRequest) ProtoMessage

func (*IsBootstrappedRequest) ProtoMessage()

func (*IsBootstrappedRequest) Reset

func (m *IsBootstrappedRequest) Reset()

func (*IsBootstrappedRequest) Size

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

func (*IsBootstrappedRequest) String

func (m *IsBootstrappedRequest) String() string

func (*IsBootstrappedRequest) Unmarshal

func (m *IsBootstrappedRequest) Unmarshal(data []byte) error

type IsBootstrappedResponse

type IsBootstrappedResponse struct {
	Bootstrapped     *bool  `protobuf:"varint,1,opt,name=bootstrapped" json:"bootstrapped,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IsBootstrappedResponse) Descriptor

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

func (*IsBootstrappedResponse) GetBootstrapped

func (m *IsBootstrappedResponse) GetBootstrapped() bool

func (*IsBootstrappedResponse) Marshal

func (m *IsBootstrappedResponse) Marshal() (data []byte, err error)

func (*IsBootstrappedResponse) MarshalTo

func (m *IsBootstrappedResponse) MarshalTo(data []byte) (int, error)

func (*IsBootstrappedResponse) ProtoMessage

func (*IsBootstrappedResponse) ProtoMessage()

func (*IsBootstrappedResponse) Reset

func (m *IsBootstrappedResponse) Reset()

func (*IsBootstrappedResponse) Size

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

func (*IsBootstrappedResponse) String

func (m *IsBootstrappedResponse) String() string

func (*IsBootstrappedResponse) Unmarshal

func (m *IsBootstrappedResponse) Unmarshal(data []byte) error

type Leader

type Leader struct {
	Addr             string `protobuf:"bytes,1,opt,name=addr" json:"addr"`
	Pid              int64  `protobuf:"varint,2,opt,name=pid" json:"pid"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Leader) Descriptor

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

func (*Leader) GetAddr

func (m *Leader) GetAddr() string

func (*Leader) GetPid

func (m *Leader) GetPid() int64

func (*Leader) Marshal

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

func (*Leader) MarshalTo

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

func (*Leader) ProtoMessage

func (*Leader) ProtoMessage()

func (*Leader) Reset

func (m *Leader) Reset()

func (*Leader) Size

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

func (*Leader) String

func (m *Leader) String() string

func (*Leader) Unmarshal

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

type PDMember

type PDMember struct {
	Name             *string  `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	ClientUrls       []string `protobuf:"bytes,2,rep,name=client_urls,json=clientUrls" json:"client_urls,omitempty"`
	PeerUrls         []string `protobuf:"bytes,3,rep,name=peer_urls,json=peerUrls" json:"peer_urls,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*PDMember) Descriptor

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

func (*PDMember) GetClientUrls

func (m *PDMember) GetClientUrls() []string

func (*PDMember) GetName

func (m *PDMember) GetName() string

func (*PDMember) GetPeerUrls

func (m *PDMember) GetPeerUrls() []string

func (*PDMember) Marshal

func (m *PDMember) Marshal() (data []byte, err error)

func (*PDMember) MarshalTo

func (m *PDMember) MarshalTo(data []byte) (int, error)

func (*PDMember) ProtoMessage

func (*PDMember) ProtoMessage()

func (*PDMember) Reset

func (m *PDMember) Reset()

func (*PDMember) Size

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

func (*PDMember) String

func (m *PDMember) String() string

func (*PDMember) Unmarshal

func (m *PDMember) Unmarshal(data []byte) error

type PeerStats

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

func (*PeerStats) Descriptor

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

func (*PeerStats) GetDownSeconds

func (m *PeerStats) GetDownSeconds() uint64

func (*PeerStats) GetPeer

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

func (*PeerStats) Marshal

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

func (*PeerStats) MarshalTo

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

func (*PeerStats) ProtoMessage

func (*PeerStats) ProtoMessage()

func (*PeerStats) Reset

func (m *PeerStats) Reset()

func (*PeerStats) Size

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

func (*PeerStats) String

func (m *PeerStats) String() string

func (*PeerStats) Unmarshal

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

type PutClusterConfigRequest

type PutClusterConfigRequest struct {
	Cluster          *metapb.Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*PutClusterConfigRequest) Descriptor

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

func (*PutClusterConfigRequest) GetCluster

func (m *PutClusterConfigRequest) GetCluster() *metapb.Cluster

func (*PutClusterConfigRequest) Marshal

func (m *PutClusterConfigRequest) Marshal() (data []byte, err error)

func (*PutClusterConfigRequest) MarshalTo

func (m *PutClusterConfigRequest) MarshalTo(data []byte) (int, error)

func (*PutClusterConfigRequest) ProtoMessage

func (*PutClusterConfigRequest) ProtoMessage()

func (*PutClusterConfigRequest) Reset

func (m *PutClusterConfigRequest) Reset()

func (*PutClusterConfigRequest) Size

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

func (*PutClusterConfigRequest) String

func (m *PutClusterConfigRequest) String() string

func (*PutClusterConfigRequest) Unmarshal

func (m *PutClusterConfigRequest) Unmarshal(data []byte) error

type PutClusterConfigResponse

type PutClusterConfigResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*PutClusterConfigResponse) Descriptor

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

func (*PutClusterConfigResponse) Marshal

func (m *PutClusterConfigResponse) Marshal() (data []byte, err error)

func (*PutClusterConfigResponse) MarshalTo

func (m *PutClusterConfigResponse) MarshalTo(data []byte) (int, error)

func (*PutClusterConfigResponse) ProtoMessage

func (*PutClusterConfigResponse) ProtoMessage()

func (*PutClusterConfigResponse) Reset

func (m *PutClusterConfigResponse) Reset()

func (*PutClusterConfigResponse) Size

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

func (*PutClusterConfigResponse) String

func (m *PutClusterConfigResponse) String() string

func (*PutClusterConfigResponse) Unmarshal

func (m *PutClusterConfigResponse) Unmarshal(data []byte) error

type PutStoreRequest

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

func (*PutStoreRequest) Descriptor

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

func (*PutStoreRequest) GetStore

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

func (*PutStoreRequest) Marshal

func (m *PutStoreRequest) Marshal() (data []byte, err error)

func (*PutStoreRequest) MarshalTo

func (m *PutStoreRequest) MarshalTo(data []byte) (int, error)

func (*PutStoreRequest) ProtoMessage

func (*PutStoreRequest) ProtoMessage()

func (*PutStoreRequest) Reset

func (m *PutStoreRequest) Reset()

func (*PutStoreRequest) Size

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

func (*PutStoreRequest) String

func (m *PutStoreRequest) String() string

func (*PutStoreRequest) Unmarshal

func (m *PutStoreRequest) Unmarshal(data []byte) error

type PutStoreResponse

type PutStoreResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*PutStoreResponse) Descriptor

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

func (*PutStoreResponse) Marshal

func (m *PutStoreResponse) Marshal() (data []byte, err error)

func (*PutStoreResponse) MarshalTo

func (m *PutStoreResponse) MarshalTo(data []byte) (int, error)

func (*PutStoreResponse) ProtoMessage

func (*PutStoreResponse) ProtoMessage()

func (*PutStoreResponse) Reset

func (m *PutStoreResponse) Reset()

func (*PutStoreResponse) Size

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

func (*PutStoreResponse) String

func (m *PutStoreResponse) String() string

func (*PutStoreResponse) Unmarshal

func (m *PutStoreResponse) Unmarshal(data []byte) error

type RegionHeartbeatRequest

type RegionHeartbeatRequest struct {
	Region *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"`
	// Leader Peer sending the heartbeat.
	Leader *metapb.Peer `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"`
	// Leader considers that these peers are down.
	DownPeers        []*PeerStats `protobuf:"bytes,3,rep,name=down_peers,json=downPeers" json:"down_peers,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*RegionHeartbeatRequest) Descriptor

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

func (*RegionHeartbeatRequest) GetDownPeers

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

func (*RegionHeartbeatRequest) GetLeader

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

func (*RegionHeartbeatRequest) GetRegion

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

func (*RegionHeartbeatRequest) Marshal

func (m *RegionHeartbeatRequest) Marshal() (data []byte, err error)

func (*RegionHeartbeatRequest) MarshalTo

func (m *RegionHeartbeatRequest) MarshalTo(data []byte) (int, error)

func (*RegionHeartbeatRequest) ProtoMessage

func (*RegionHeartbeatRequest) ProtoMessage()

func (*RegionHeartbeatRequest) Reset

func (m *RegionHeartbeatRequest) Reset()

func (*RegionHeartbeatRequest) Size

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

func (*RegionHeartbeatRequest) String

func (m *RegionHeartbeatRequest) String() string

func (*RegionHeartbeatRequest) Unmarshal

func (m *RegionHeartbeatRequest) Unmarshal(data []byte) error

type RegionHeartbeatResponse

type RegionHeartbeatResponse struct {
	// Notice, Pd only allows handling reported epoch >= current pd's.
	// Leader peer reports region status with RegionHeartbeatRequest
	// to pd regularly, pd will determine whether this region
	// should do ChangePeer or not.
	// E,g, max peer number is 3, region A, first only peer 1 in A.
	// 1. Pd region state -> Peers (1), ConfVer (1).
	// 2. Leader peer 1 reports region state to pd, pd finds the
	// peer number is < 3, so first changes its current region
	// state -> Peers (1, 2), ConfVer (1), and returns ChangePeer Adding 2.
	// 3. Leader does ChangePeer, then reports Peers (1, 2), ConfVer (2),
	// pd updates its state -> Peers (1, 2), ConfVer (2).
	// 4. Leader may report old Peers (1), ConfVer (1) to pd before ConfChange
	// finished, pd stills responses ChangePeer Adding 2, of course, we must
	// guarantee the second ChangePeer can't be applied in TiKV.
	ChangePeer *ChangePeer `protobuf:"bytes,1,opt,name=change_peer,json=changePeer" json:"change_peer,omitempty"`
	// Pd can return transfer_leader to let TiKV does leader transfer itself.
	TransferLeader   *TransferLeader `protobuf:"bytes,2,opt,name=transfer_leader,json=transferLeader" json:"transfer_leader,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*RegionHeartbeatResponse) Descriptor

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

func (*RegionHeartbeatResponse) GetChangePeer

func (m *RegionHeartbeatResponse) GetChangePeer() *ChangePeer

func (*RegionHeartbeatResponse) GetTransferLeader

func (m *RegionHeartbeatResponse) GetTransferLeader() *TransferLeader

func (*RegionHeartbeatResponse) Marshal

func (m *RegionHeartbeatResponse) Marshal() (data []byte, err error)

func (*RegionHeartbeatResponse) MarshalTo

func (m *RegionHeartbeatResponse) MarshalTo(data []byte) (int, error)

func (*RegionHeartbeatResponse) ProtoMessage

func (*RegionHeartbeatResponse) ProtoMessage()

func (*RegionHeartbeatResponse) Reset

func (m *RegionHeartbeatResponse) Reset()

func (*RegionHeartbeatResponse) Size

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

func (*RegionHeartbeatResponse) String

func (m *RegionHeartbeatResponse) String() string

func (*RegionHeartbeatResponse) Unmarshal

func (m *RegionHeartbeatResponse) Unmarshal(data []byte) error

type ReportSplitRequest

type ReportSplitRequest struct {
	Left             *metapb.Region `protobuf:"bytes,1,opt,name=left" json:"left,omitempty"`
	Right            *metapb.Region `protobuf:"bytes,2,opt,name=right" json:"right,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*ReportSplitRequest) Descriptor

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

func (*ReportSplitRequest) GetLeft

func (m *ReportSplitRequest) GetLeft() *metapb.Region

func (*ReportSplitRequest) GetRight

func (m *ReportSplitRequest) GetRight() *metapb.Region

func (*ReportSplitRequest) Marshal

func (m *ReportSplitRequest) Marshal() (data []byte, err error)

func (*ReportSplitRequest) MarshalTo

func (m *ReportSplitRequest) MarshalTo(data []byte) (int, error)

func (*ReportSplitRequest) ProtoMessage

func (*ReportSplitRequest) ProtoMessage()

func (*ReportSplitRequest) Reset

func (m *ReportSplitRequest) Reset()

func (*ReportSplitRequest) Size

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

func (*ReportSplitRequest) String

func (m *ReportSplitRequest) String() string

func (*ReportSplitRequest) Unmarshal

func (m *ReportSplitRequest) Unmarshal(data []byte) error

type ReportSplitResponse

type ReportSplitResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ReportSplitResponse) Descriptor

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

func (*ReportSplitResponse) Marshal

func (m *ReportSplitResponse) Marshal() (data []byte, err error)

func (*ReportSplitResponse) MarshalTo

func (m *ReportSplitResponse) MarshalTo(data []byte) (int, error)

func (*ReportSplitResponse) ProtoMessage

func (*ReportSplitResponse) ProtoMessage()

func (*ReportSplitResponse) Reset

func (m *ReportSplitResponse) Reset()

func (*ReportSplitResponse) Size

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

func (*ReportSplitResponse) String

func (m *ReportSplitResponse) String() string

func (*ReportSplitResponse) Unmarshal

func (m *ReportSplitResponse) Unmarshal(data []byte) error

type Request

type Request struct {
	Header           *RequestHeader           `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	CmdType          CommandType              `protobuf:"varint,2,opt,name=cmd_type,json=cmdType,enum=pdpb.CommandType" json:"cmd_type"`
	Tso              *TsoRequest              `protobuf:"bytes,3,opt,name=tso" json:"tso,omitempty"`
	Bootstrap        *BootstrapRequest        `protobuf:"bytes,4,opt,name=bootstrap" json:"bootstrap,omitempty"`
	IsBootstrapped   *IsBootstrappedRequest   `protobuf:"bytes,5,opt,name=is_bootstrapped,json=isBootstrapped" json:"is_bootstrapped,omitempty"`
	AllocId          *AllocIdRequest          `protobuf:"bytes,6,opt,name=alloc_id,json=allocId" json:"alloc_id,omitempty"`
	GetStore         *GetStoreRequest         `protobuf:"bytes,7,opt,name=get_store,json=getStore" json:"get_store,omitempty"`
	PutStore         *PutStoreRequest         `protobuf:"bytes,8,opt,name=put_store,json=putStore" json:"put_store,omitempty"`
	AskSplit         *AskSplitRequest         `protobuf:"bytes,9,opt,name=ask_split,json=askSplit" json:"ask_split,omitempty"`
	GetRegion        *GetRegionRequest        `protobuf:"bytes,10,opt,name=get_region,json=getRegion" json:"get_region,omitempty"`
	RegionHeartbeat  *RegionHeartbeatRequest  `protobuf:"bytes,11,opt,name=region_heartbeat,json=regionHeartbeat" json:"region_heartbeat,omitempty"`
	GetClusterConfig *GetClusterConfigRequest `protobuf:"bytes,12,opt,name=get_cluster_config,json=getClusterConfig" json:"get_cluster_config,omitempty"`
	PutClusterConfig *PutClusterConfigRequest `protobuf:"bytes,13,opt,name=put_cluster_config,json=putClusterConfig" json:"put_cluster_config,omitempty"`
	StoreHeartbeat   *StoreHeartbeatRequest   `protobuf:"bytes,14,opt,name=store_heartbeat,json=storeHeartbeat" json:"store_heartbeat,omitempty"`
	ReportSplit      *ReportSplitRequest      `protobuf:"bytes,15,opt,name=report_split,json=reportSplit" json:"report_split,omitempty"`
	GetRegionById    *GetRegionByIDRequest    `protobuf:"bytes,16,opt,name=get_region_by_id,json=getRegionById" json:"get_region_by_id,omitempty"`
	GetPdMembers     *GetPDMembersRequest     `protobuf:"bytes,17,opt,name=get_pd_members,json=getPdMembers" json:"get_pd_members,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*Request) Descriptor

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

func (*Request) GetAllocId

func (m *Request) GetAllocId() *AllocIdRequest

func (*Request) GetAskSplit

func (m *Request) GetAskSplit() *AskSplitRequest

func (*Request) GetBootstrap

func (m *Request) GetBootstrap() *BootstrapRequest

func (*Request) GetCmdType

func (m *Request) GetCmdType() CommandType

func (*Request) GetGetClusterConfig

func (m *Request) GetGetClusterConfig() *GetClusterConfigRequest

func (*Request) GetGetPdMembers

func (m *Request) GetGetPdMembers() *GetPDMembersRequest

func (*Request) GetGetRegion

func (m *Request) GetGetRegion() *GetRegionRequest

func (*Request) GetGetRegionById

func (m *Request) GetGetRegionById() *GetRegionByIDRequest

func (*Request) GetGetStore

func (m *Request) GetGetStore() *GetStoreRequest

func (*Request) GetHeader

func (m *Request) GetHeader() *RequestHeader

func (*Request) GetIsBootstrapped

func (m *Request) GetIsBootstrapped() *IsBootstrappedRequest

func (*Request) GetPutClusterConfig

func (m *Request) GetPutClusterConfig() *PutClusterConfigRequest

func (*Request) GetPutStore

func (m *Request) GetPutStore() *PutStoreRequest

func (*Request) GetRegionHeartbeat

func (m *Request) GetRegionHeartbeat() *RegionHeartbeatRequest

func (*Request) GetReportSplit

func (m *Request) GetReportSplit() *ReportSplitRequest

func (*Request) GetStoreHeartbeat

func (m *Request) GetStoreHeartbeat() *StoreHeartbeatRequest

func (*Request) GetTso

func (m *Request) GetTso() *TsoRequest

func (*Request) Marshal

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

func (*Request) MarshalTo

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

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) Size

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

func (*Request) String

func (m *Request) String() string

func (*Request) Unmarshal

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

type RequestHeader

type RequestHeader struct {
	// 16 bytes, to distinguish request.
	Uuid             []byte `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"`
	ClusterId        uint64 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId" json:"cluster_id"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RequestHeader) Descriptor

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

func (*RequestHeader) GetClusterId

func (m *RequestHeader) GetClusterId() uint64

func (*RequestHeader) GetUuid

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

func (*RequestHeader) Marshal

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

func (*RequestHeader) MarshalTo

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

func (*RequestHeader) ProtoMessage

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset

func (m *RequestHeader) Reset()

func (*RequestHeader) Size

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

func (*RequestHeader) String

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal

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

type Response

type Response struct {
	Header           *ResponseHeader           `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	CmdType          CommandType               `protobuf:"varint,2,opt,name=cmd_type,json=cmdType,enum=pdpb.CommandType" json:"cmd_type"`
	Tso              *TsoResponse              `protobuf:"bytes,3,opt,name=tso" json:"tso,omitempty"`
	Bootstrap        *BootstrapResponse        `protobuf:"bytes,4,opt,name=bootstrap" json:"bootstrap,omitempty"`
	IsBootstrapped   *IsBootstrappedResponse   `protobuf:"bytes,5,opt,name=is_bootstrapped,json=isBootstrapped" json:"is_bootstrapped,omitempty"`
	AllocId          *AllocIdResponse          `protobuf:"bytes,6,opt,name=alloc_id,json=allocId" json:"alloc_id,omitempty"`
	GetStore         *GetStoreResponse         `protobuf:"bytes,7,opt,name=get_store,json=getStore" json:"get_store,omitempty"`
	PutStore         *PutStoreResponse         `protobuf:"bytes,8,opt,name=put_store,json=putStore" json:"put_store,omitempty"`
	AskSplit         *AskSplitResponse         `protobuf:"bytes,9,opt,name=ask_split,json=askSplit" json:"ask_split,omitempty"`
	GetRegion        *GetRegionResponse        `protobuf:"bytes,10,opt,name=get_region,json=getRegion" json:"get_region,omitempty"`
	RegionHeartbeat  *RegionHeartbeatResponse  `protobuf:"bytes,11,opt,name=region_heartbeat,json=regionHeartbeat" json:"region_heartbeat,omitempty"`
	GetClusterConfig *GetClusterConfigResponse `protobuf:"bytes,12,opt,name=get_cluster_config,json=getClusterConfig" json:"get_cluster_config,omitempty"`
	PutClusterConfig *PutClusterConfigResponse `protobuf:"bytes,13,opt,name=put_cluster_config,json=putClusterConfig" json:"put_cluster_config,omitempty"`
	StoreHeartbeat   *StoreHeartbeatResponse   `protobuf:"bytes,14,opt,name=store_heartbeat,json=storeHeartbeat" json:"store_heartbeat,omitempty"`
	ReportSplit      *ReportSplitResponse      `protobuf:"bytes,15,opt,name=report_split,json=reportSplit" json:"report_split,omitempty"`
	GetRegionById    *GetRegionResponse        `protobuf:"bytes,16,opt,name=get_region_by_id,json=getRegionById" json:"get_region_by_id,omitempty"`
	GetPdMembers     *GetPDMembersResponse     `protobuf:"bytes,17,opt,name=get_pd_members,json=getPdMembers" json:"get_pd_members,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*Response) Descriptor

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

func (*Response) GetAllocId

func (m *Response) GetAllocId() *AllocIdResponse

func (*Response) GetAskSplit

func (m *Response) GetAskSplit() *AskSplitResponse

func (*Response) GetBootstrap

func (m *Response) GetBootstrap() *BootstrapResponse

func (*Response) GetCmdType

func (m *Response) GetCmdType() CommandType

func (*Response) GetGetClusterConfig

func (m *Response) GetGetClusterConfig() *GetClusterConfigResponse

func (*Response) GetGetPdMembers

func (m *Response) GetGetPdMembers() *GetPDMembersResponse

func (*Response) GetGetRegion

func (m *Response) GetGetRegion() *GetRegionResponse

func (*Response) GetGetRegionById

func (m *Response) GetGetRegionById() *GetRegionResponse

func (*Response) GetGetStore

func (m *Response) GetGetStore() *GetStoreResponse

func (*Response) GetHeader

func (m *Response) GetHeader() *ResponseHeader

func (*Response) GetIsBootstrapped

func (m *Response) GetIsBootstrapped() *IsBootstrappedResponse

func (*Response) GetPutClusterConfig

func (m *Response) GetPutClusterConfig() *PutClusterConfigResponse

func (*Response) GetPutStore

func (m *Response) GetPutStore() *PutStoreResponse

func (*Response) GetRegionHeartbeat

func (m *Response) GetRegionHeartbeat() *RegionHeartbeatResponse

func (*Response) GetReportSplit

func (m *Response) GetReportSplit() *ReportSplitResponse

func (*Response) GetStoreHeartbeat

func (m *Response) GetStoreHeartbeat() *StoreHeartbeatResponse

func (*Response) GetTso

func (m *Response) GetTso() *TsoResponse

func (*Response) Marshal

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

func (*Response) MarshalTo

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

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) Size

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

func (*Response) String

func (m *Response) String() string

func (*Response) Unmarshal

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

type ResponseHeader

type ResponseHeader struct {
	// 16 bytes, to distinguish request.
	Uuid             []byte `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"`
	ClusterId        uint64 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId" json:"cluster_id"`
	Error            *Error `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ResponseHeader) Descriptor

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

func (*ResponseHeader) GetClusterId

func (m *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetError

func (m *ResponseHeader) GetError() *Error

func (*ResponseHeader) GetUuid

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

func (*ResponseHeader) Marshal

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

func (*ResponseHeader) MarshalTo

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

func (*ResponseHeader) ProtoMessage

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size

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

func (*ResponseHeader) String

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal

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

type StoreHeartbeatRequest

type StoreHeartbeatRequest struct {
	Stats            *StoreStats `protobuf:"bytes,1,opt,name=stats" json:"stats,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*StoreHeartbeatRequest) Descriptor

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

func (*StoreHeartbeatRequest) GetStats

func (m *StoreHeartbeatRequest) GetStats() *StoreStats

func (*StoreHeartbeatRequest) Marshal

func (m *StoreHeartbeatRequest) Marshal() (data []byte, err error)

func (*StoreHeartbeatRequest) MarshalTo

func (m *StoreHeartbeatRequest) MarshalTo(data []byte) (int, error)

func (*StoreHeartbeatRequest) ProtoMessage

func (*StoreHeartbeatRequest) ProtoMessage()

func (*StoreHeartbeatRequest) Reset

func (m *StoreHeartbeatRequest) Reset()

func (*StoreHeartbeatRequest) Size

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

func (*StoreHeartbeatRequest) String

func (m *StoreHeartbeatRequest) String() string

func (*StoreHeartbeatRequest) Unmarshal

func (m *StoreHeartbeatRequest) Unmarshal(data []byte) error

type StoreHeartbeatResponse

type StoreHeartbeatResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*StoreHeartbeatResponse) Descriptor

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

func (*StoreHeartbeatResponse) Marshal

func (m *StoreHeartbeatResponse) Marshal() (data []byte, err error)

func (*StoreHeartbeatResponse) MarshalTo

func (m *StoreHeartbeatResponse) MarshalTo(data []byte) (int, error)

func (*StoreHeartbeatResponse) ProtoMessage

func (*StoreHeartbeatResponse) ProtoMessage()

func (*StoreHeartbeatResponse) Reset

func (m *StoreHeartbeatResponse) Reset()

func (*StoreHeartbeatResponse) Size

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

func (*StoreHeartbeatResponse) String

func (m *StoreHeartbeatResponse) String() string

func (*StoreHeartbeatResponse) Unmarshal

func (m *StoreHeartbeatResponse) Unmarshal(data []byte) error

type StoreIsTombstoneError

type StoreIsTombstoneError struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*StoreIsTombstoneError) Descriptor

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

func (*StoreIsTombstoneError) Marshal

func (m *StoreIsTombstoneError) Marshal() (data []byte, err error)

func (*StoreIsTombstoneError) MarshalTo

func (m *StoreIsTombstoneError) MarshalTo(data []byte) (int, error)

func (*StoreIsTombstoneError) ProtoMessage

func (*StoreIsTombstoneError) ProtoMessage()

func (*StoreIsTombstoneError) Reset

func (m *StoreIsTombstoneError) Reset()

func (*StoreIsTombstoneError) Size

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

func (*StoreIsTombstoneError) String

func (m *StoreIsTombstoneError) String() string

func (*StoreIsTombstoneError) Unmarshal

func (m *StoreIsTombstoneError) Unmarshal(data []byte) error

type StoreStats

type StoreStats struct {
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId" json:"store_id"`
	// 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.
	RegionCount uint32 `protobuf:"varint,4,opt,name=region_count,json=regionCount" json:"region_count"`
	// Current sending snapshot count.
	SendingSnapCount uint32 `protobuf:"varint,5,opt,name=sending_snap_count,json=sendingSnapCount" json:"sending_snap_count"`
	// Current receiving snapshot count.
	ReceivingSnapCount uint32 `protobuf:"varint,6,opt,name=receiving_snap_count,json=receivingSnapCount" json:"receiving_snap_count"`
	// When the store is started (unix timestamp in seconds).
	StartTime uint32 `protobuf:"varint,7,opt,name=start_time,json=startTime" json:"start_time"`
	// How many region is applying snapshot.
	ApplyingSnapCount uint32 `protobuf:"varint,8,opt,name=applying_snap_count,json=applyingSnapCount" json:"applying_snap_count"`
	XXX_unrecognized  []byte `json:"-"`
}

func (*StoreStats) Descriptor

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

func (*StoreStats) GetApplyingSnapCount

func (m *StoreStats) GetApplyingSnapCount() uint32

func (*StoreStats) GetAvailable

func (m *StoreStats) GetAvailable() uint64

func (*StoreStats) GetCapacity

func (m *StoreStats) GetCapacity() uint64

func (*StoreStats) GetReceivingSnapCount

func (m *StoreStats) GetReceivingSnapCount() uint32

func (*StoreStats) GetRegionCount

func (m *StoreStats) GetRegionCount() 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) Marshal

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

func (*StoreStats) MarshalTo

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

func (*StoreStats) ProtoMessage

func (*StoreStats) ProtoMessage()

func (*StoreStats) Reset

func (m *StoreStats) Reset()

func (*StoreStats) Size

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

func (*StoreStats) String

func (m *StoreStats) String() string

func (*StoreStats) Unmarshal

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

type Timestamp

type Timestamp struct {
	Physical         int64  `protobuf:"varint,1,opt,name=physical" json:"physical"`
	Logical          int64  `protobuf:"varint,2,opt,name=logical" json:"logical"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Timestamp) Descriptor

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

func (*Timestamp) GetLogical

func (m *Timestamp) GetLogical() int64

func (*Timestamp) GetPhysical

func (m *Timestamp) GetPhysical() int64

func (*Timestamp) Marshal

func (m *Timestamp) Marshal() (data []byte, err error)

func (*Timestamp) MarshalTo

func (m *Timestamp) MarshalTo(data []byte) (int, error)

func (*Timestamp) ProtoMessage

func (*Timestamp) ProtoMessage()

func (*Timestamp) Reset

func (m *Timestamp) Reset()

func (*Timestamp) Size

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

func (*Timestamp) String

func (m *Timestamp) String() string

func (*Timestamp) Unmarshal

func (m *Timestamp) Unmarshal(data []byte) error

type TransferLeader

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

func (*TransferLeader) Descriptor

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

func (*TransferLeader) GetPeer

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

func (*TransferLeader) Marshal

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

func (*TransferLeader) MarshalTo

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

func (*TransferLeader) ProtoMessage

func (*TransferLeader) ProtoMessage()

func (*TransferLeader) Reset

func (m *TransferLeader) Reset()

func (*TransferLeader) Size

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

func (*TransferLeader) String

func (m *TransferLeader) String() string

func (*TransferLeader) Unmarshal

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

type TsoRequest

type TsoRequest struct {
	Count            uint32 `protobuf:"varint,1,opt,name=count" json:"count"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TsoRequest) Descriptor

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

func (*TsoRequest) GetCount

func (m *TsoRequest) GetCount() uint32

func (*TsoRequest) Marshal

func (m *TsoRequest) Marshal() (data []byte, err error)

func (*TsoRequest) MarshalTo

func (m *TsoRequest) MarshalTo(data []byte) (int, error)

func (*TsoRequest) ProtoMessage

func (*TsoRequest) ProtoMessage()

func (*TsoRequest) Reset

func (m *TsoRequest) Reset()

func (*TsoRequest) Size

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

func (*TsoRequest) String

func (m *TsoRequest) String() string

func (*TsoRequest) Unmarshal

func (m *TsoRequest) Unmarshal(data []byte) error

type TsoResponse

type TsoResponse struct {
	Count            uint32    `protobuf:"varint,1,opt,name=count" json:"count"`
	Timestamp        Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*TsoResponse) Descriptor

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

func (*TsoResponse) GetCount

func (m *TsoResponse) GetCount() uint32

func (*TsoResponse) GetTimestamp

func (m *TsoResponse) GetTimestamp() Timestamp

func (*TsoResponse) Marshal

func (m *TsoResponse) Marshal() (data []byte, err error)

func (*TsoResponse) MarshalTo

func (m *TsoResponse) MarshalTo(data []byte) (int, error)

func (*TsoResponse) ProtoMessage

func (*TsoResponse) ProtoMessage()

func (*TsoResponse) Reset

func (m *TsoResponse) Reset()

func (*TsoResponse) Size

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

func (*TsoResponse) String

func (m *TsoResponse) String() string

func (*TsoResponse) Unmarshal

func (m *TsoResponse) Unmarshal(data []byte) error

Jump to

Keyboard shortcuts

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