pdpb

package
Version: v0.0.0-...-a412f7a Latest Latest
Warning

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

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

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 CheckPolicy_name = map[int32]string{
	0: "SCAN",
	1: "APPROXIMATE",
	2: "USEKEY",
}
View Source
var CheckPolicy_value = map[string]int32{
	"SCAN":        0,
	"APPROXIMATE": 1,
	"USEKEY":      2,
}
View Source
var ErrorType_name = map[int32]string{
	0: "OK",
	1: "UNKNOWN",
	2: "NOT_BOOTSTRAPPED",
	3: "STORE_TOMBSTONE",
	4: "ALREADY_BOOTSTRAPPED",
	5: "INCOMPATIBLE_VERSION",
	6: "REGION_NOT_FOUND",
}
View Source
var ErrorType_value = map[string]int32{
	"OK":                   0,
	"UNKNOWN":              1,
	"NOT_BOOTSTRAPPED":     2,
	"STORE_TOMBSTONE":      3,
	"ALREADY_BOOTSTRAPPED": 4,
	"INCOMPATIBLE_VERSION": 5,
	"REGION_NOT_FOUND":     6,
}
View Source
var OperatorStatus_name = map[int32]string{
	0: "SUCCESS",
	1: "TIMEOUT",
	2: "CANCEL",
	3: "REPLACE",
	4: "RUNNING",
}
View Source
var OperatorStatus_value = map[string]int32{
	"SUCCESS": 0,
	"TIMEOUT": 1,
	"CANCEL":  2,
	"REPLACE": 3,
	"RUNNING": 4,
}
View Source
var QueryKind_name = map[int32]string{
	0:  "Others",
	1:  "GC",
	2:  "Get",
	3:  "Scan",
	4:  "Coprocessor",
	5:  "Delete",
	6:  "DeleteRange",
	7:  "Put",
	8:  "Prewrite",
	9:  "AcquirePessimisticLock",
	10: "Commit",
	11: "Rollback",
}
View Source
var QueryKind_value = map[string]int32{
	"Others":                 0,
	"GC":                     1,
	"Get":                    2,
	"Scan":                   3,
	"Coprocessor":            4,
	"Delete":                 5,
	"DeleteRange":            6,
	"Put":                    7,
	"Prewrite":               8,
	"AcquirePessimisticLock": 9,
	"Commit":                 10,
	"Rollback":               11,
}

Functions

func RegisterPDServer

func RegisterPDServer(s *grpc.Server, srv PDServer)

Types

type AllocIDRequest

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

func (*AllocIDRequest) Descriptor

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

func (*AllocIDRequest) GetHeader

func (m *AllocIDRequest) GetHeader() *RequestHeader

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

func (*AllocIDRequest) XXX_DiscardUnknown

func (m *AllocIDRequest) XXX_DiscardUnknown()

func (*AllocIDRequest) XXX_Marshal

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

func (*AllocIDRequest) XXX_Merge

func (dst *AllocIDRequest) XXX_Merge(src proto.Message)

func (*AllocIDRequest) XXX_Size

func (m *AllocIDRequest) XXX_Size() int

func (*AllocIDRequest) XXX_Unmarshal

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

type AllocIDResponse

type AllocIDResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Id                   uint64          `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*AllocIDResponse) Descriptor

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

func (*AllocIDResponse) GetHeader

func (m *AllocIDResponse) GetHeader() *ResponseHeader

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

func (*AllocIDResponse) XXX_DiscardUnknown

func (m *AllocIDResponse) XXX_DiscardUnknown()

func (*AllocIDResponse) XXX_Marshal

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

func (*AllocIDResponse) XXX_Merge

func (dst *AllocIDResponse) XXX_Merge(src proto.Message)

func (*AllocIDResponse) XXX_Size

func (m *AllocIDResponse) XXX_Size() int

func (*AllocIDResponse) XXX_Unmarshal

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

type AskBatchSplitRequest

type AskBatchSplitRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Region               *metapb.Region `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"`
	SplitCount           uint32         `protobuf:"varint,3,opt,name=split_count,json=splitCount,proto3" json:"split_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AskBatchSplitRequest) Descriptor

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

func (*AskBatchSplitRequest) GetHeader

func (m *AskBatchSplitRequest) GetHeader() *RequestHeader

func (*AskBatchSplitRequest) GetRegion

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

func (*AskBatchSplitRequest) GetSplitCount

func (m *AskBatchSplitRequest) GetSplitCount() uint32

func (*AskBatchSplitRequest) Marshal

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

func (*AskBatchSplitRequest) MarshalTo

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

func (*AskBatchSplitRequest) ProtoMessage

func (*AskBatchSplitRequest) ProtoMessage()

func (*AskBatchSplitRequest) Reset

func (m *AskBatchSplitRequest) Reset()

func (*AskBatchSplitRequest) Size

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

func (*AskBatchSplitRequest) String

func (m *AskBatchSplitRequest) String() string

func (*AskBatchSplitRequest) Unmarshal

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

func (*AskBatchSplitRequest) XXX_DiscardUnknown

func (m *AskBatchSplitRequest) XXX_DiscardUnknown()

func (*AskBatchSplitRequest) XXX_Marshal

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

func (*AskBatchSplitRequest) XXX_Merge

func (dst *AskBatchSplitRequest) XXX_Merge(src proto.Message)

func (*AskBatchSplitRequest) XXX_Size

func (m *AskBatchSplitRequest) XXX_Size() int

func (*AskBatchSplitRequest) XXX_Unmarshal

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

type AskBatchSplitResponse

type AskBatchSplitResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Ids                  []*SplitID      `protobuf:"bytes,2,rep,name=ids" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*AskBatchSplitResponse) Descriptor

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

func (*AskBatchSplitResponse) GetHeader

func (m *AskBatchSplitResponse) GetHeader() *ResponseHeader

func (*AskBatchSplitResponse) GetIds

func (m *AskBatchSplitResponse) GetIds() []*SplitID

func (*AskBatchSplitResponse) Marshal

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

func (*AskBatchSplitResponse) MarshalTo

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

func (*AskBatchSplitResponse) ProtoMessage

func (*AskBatchSplitResponse) ProtoMessage()

func (*AskBatchSplitResponse) Reset

func (m *AskBatchSplitResponse) Reset()

func (*AskBatchSplitResponse) Size

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

func (*AskBatchSplitResponse) String

func (m *AskBatchSplitResponse) String() string

func (*AskBatchSplitResponse) Unmarshal

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

func (*AskBatchSplitResponse) XXX_DiscardUnknown

func (m *AskBatchSplitResponse) XXX_DiscardUnknown()

func (*AskBatchSplitResponse) XXX_Marshal

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

func (*AskBatchSplitResponse) XXX_Merge

func (dst *AskBatchSplitResponse) XXX_Merge(src proto.Message)

func (*AskBatchSplitResponse) XXX_Size

func (m *AskBatchSplitResponse) XXX_Size() int

func (*AskBatchSplitResponse) XXX_Unmarshal

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

type AskSplitRequest

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

func (*AskSplitRequest) Descriptor

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

func (*AskSplitRequest) GetHeader

func (m *AskSplitRequest) GetHeader() *RequestHeader

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

func (*AskSplitRequest) XXX_DiscardUnknown

func (m *AskSplitRequest) XXX_DiscardUnknown()

func (*AskSplitRequest) XXX_Marshal

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

func (*AskSplitRequest) XXX_Merge

func (dst *AskSplitRequest) XXX_Merge(src proto.Message)

func (*AskSplitRequest) XXX_Size

func (m *AskSplitRequest) XXX_Size() int

func (*AskSplitRequest) XXX_Unmarshal

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

type AskSplitResponse

type AskSplitResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// 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,2,opt,name=new_region_id,json=newRegionId,proto3" json:"new_region_id,omitempty"`
	// The peer ids for the new split region.
	NewPeerIds           []uint64 `protobuf:"varint,3,rep,packed,name=new_peer_ids,json=newPeerIds" json:"new_peer_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AskSplitResponse) Descriptor

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

func (*AskSplitResponse) GetHeader

func (m *AskSplitResponse) GetHeader() *ResponseHeader

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

func (*AskSplitResponse) XXX_DiscardUnknown

func (m *AskSplitResponse) XXX_DiscardUnknown()

func (*AskSplitResponse) XXX_Marshal

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

func (*AskSplitResponse) XXX_Merge

func (dst *AskSplitResponse) XXX_Merge(src proto.Message)

func (*AskSplitResponse) XXX_Size

func (m *AskSplitResponse) XXX_Size() int

func (*AskSplitResponse) XXX_Unmarshal

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

type BootstrapRequest

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

func (*BootstrapRequest) Descriptor

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

func (*BootstrapRequest) GetHeader

func (m *BootstrapRequest) GetHeader() *RequestHeader

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

func (*BootstrapRequest) XXX_DiscardUnknown

func (m *BootstrapRequest) XXX_DiscardUnknown()

func (*BootstrapRequest) XXX_Marshal

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

func (*BootstrapRequest) XXX_Merge

func (dst *BootstrapRequest) XXX_Merge(src proto.Message)

func (*BootstrapRequest) XXX_Size

func (m *BootstrapRequest) XXX_Size() int

func (*BootstrapRequest) XXX_Unmarshal

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

type BootstrapResponse

type BootstrapResponse struct {
	Header               *ResponseHeader                       `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	ReplicationStatus    *replication_modepb.ReplicationStatus `protobuf:"bytes,2,opt,name=replication_status,json=replicationStatus" json:"replication_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*BootstrapResponse) Descriptor

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

func (*BootstrapResponse) GetHeader

func (m *BootstrapResponse) GetHeader() *ResponseHeader

func (*BootstrapResponse) GetReplicationStatus

func (m *BootstrapResponse) GetReplicationStatus() *replication_modepb.ReplicationStatus

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

func (*BootstrapResponse) XXX_DiscardUnknown

func (m *BootstrapResponse) XXX_DiscardUnknown()

func (*BootstrapResponse) XXX_Marshal

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

func (*BootstrapResponse) XXX_Merge

func (dst *BootstrapResponse) XXX_Merge(src proto.Message)

func (*BootstrapResponse) XXX_Size

func (m *BootstrapResponse) XXX_Size() int

func (*BootstrapResponse) XXX_Unmarshal

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

type ChangePeer

type ChangePeer struct {
	Peer                 *metapb.Peer           `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
	ChangeType           eraftpb.ConfChangeType `protobuf:"varint,2,opt,name=change_type,json=changeType,proto3,enum=eraftpb.ConfChangeType" json:"change_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `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

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 (dst *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 ChangePeerV2

type ChangePeerV2 struct {
	// If changes is empty, it means that to exit joint state.
	Changes              []*ChangePeer `protobuf:"bytes,1,rep,name=changes" json:"changes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ChangePeerV2) Descriptor

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

func (*ChangePeerV2) GetChanges

func (m *ChangePeerV2) GetChanges() []*ChangePeer

func (*ChangePeerV2) Marshal

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

func (*ChangePeerV2) MarshalTo

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

func (*ChangePeerV2) ProtoMessage

func (*ChangePeerV2) ProtoMessage()

func (*ChangePeerV2) Reset

func (m *ChangePeerV2) Reset()

func (*ChangePeerV2) Size

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

func (*ChangePeerV2) String

func (m *ChangePeerV2) String() string

func (*ChangePeerV2) Unmarshal

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

func (*ChangePeerV2) XXX_DiscardUnknown

func (m *ChangePeerV2) XXX_DiscardUnknown()

func (*ChangePeerV2) XXX_Marshal

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

func (*ChangePeerV2) XXX_Merge

func (dst *ChangePeerV2) XXX_Merge(src proto.Message)

func (*ChangePeerV2) XXX_Size

func (m *ChangePeerV2) XXX_Size() int

func (*ChangePeerV2) XXX_Unmarshal

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

type CheckPolicy

type CheckPolicy int32
const (
	CheckPolicy_SCAN        CheckPolicy = 0
	CheckPolicy_APPROXIMATE CheckPolicy = 1
	CheckPolicy_USEKEY      CheckPolicy = 2
)

func (CheckPolicy) EnumDescriptor

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

func (CheckPolicy) String

func (x CheckPolicy) String() string

type Error

type Error struct {
	Type                 ErrorType `protobuf:"varint,1,opt,name=type,proto3,enum=pdpb.ErrorType" json:"type,omitempty"`
	Message              string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Error) Descriptor

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

func (*Error) GetMessage

func (m *Error) GetMessage() string

func (*Error) GetType

func (m *Error) GetType() ErrorType

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

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

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

func (*Error) XXX_Merge

func (dst *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

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

type ErrorType

type ErrorType int32
const (
	ErrorType_OK                   ErrorType = 0
	ErrorType_UNKNOWN              ErrorType = 1
	ErrorType_NOT_BOOTSTRAPPED     ErrorType = 2
	ErrorType_STORE_TOMBSTONE      ErrorType = 3
	ErrorType_ALREADY_BOOTSTRAPPED ErrorType = 4
	ErrorType_INCOMPATIBLE_VERSION ErrorType = 5
	ErrorType_REGION_NOT_FOUND     ErrorType = 6
)

func (ErrorType) EnumDescriptor

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

func (ErrorType) String

func (x ErrorType) String() string

type GetAllStoresRequest

type GetAllStoresRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// Do NOT return tombstone stores if set to true.
	ExcludeTombstoneStores bool     `` /* 130-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*GetAllStoresRequest) Descriptor

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

func (*GetAllStoresRequest) GetExcludeTombstoneStores

func (m *GetAllStoresRequest) GetExcludeTombstoneStores() bool

func (*GetAllStoresRequest) GetHeader

func (m *GetAllStoresRequest) GetHeader() *RequestHeader

func (*GetAllStoresRequest) Marshal

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

func (*GetAllStoresRequest) MarshalTo

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

func (*GetAllStoresRequest) ProtoMessage

func (*GetAllStoresRequest) ProtoMessage()

func (*GetAllStoresRequest) Reset

func (m *GetAllStoresRequest) Reset()

func (*GetAllStoresRequest) Size

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

func (*GetAllStoresRequest) String

func (m *GetAllStoresRequest) String() string

func (*GetAllStoresRequest) Unmarshal

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

func (*GetAllStoresRequest) XXX_DiscardUnknown

func (m *GetAllStoresRequest) XXX_DiscardUnknown()

func (*GetAllStoresRequest) XXX_Marshal

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

func (*GetAllStoresRequest) XXX_Merge

func (dst *GetAllStoresRequest) XXX_Merge(src proto.Message)

func (*GetAllStoresRequest) XXX_Size

func (m *GetAllStoresRequest) XXX_Size() int

func (*GetAllStoresRequest) XXX_Unmarshal

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

type GetAllStoresResponse

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

func (*GetAllStoresResponse) Descriptor

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

func (*GetAllStoresResponse) GetHeader

func (m *GetAllStoresResponse) GetHeader() *ResponseHeader

func (*GetAllStoresResponse) GetStores

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

func (*GetAllStoresResponse) Marshal

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

func (*GetAllStoresResponse) MarshalTo

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

func (*GetAllStoresResponse) ProtoMessage

func (*GetAllStoresResponse) ProtoMessage()

func (*GetAllStoresResponse) Reset

func (m *GetAllStoresResponse) Reset()

func (*GetAllStoresResponse) Size

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

func (*GetAllStoresResponse) String

func (m *GetAllStoresResponse) String() string

func (*GetAllStoresResponse) Unmarshal

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

func (*GetAllStoresResponse) XXX_DiscardUnknown

func (m *GetAllStoresResponse) XXX_DiscardUnknown()

func (*GetAllStoresResponse) XXX_Marshal

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

func (*GetAllStoresResponse) XXX_Merge

func (dst *GetAllStoresResponse) XXX_Merge(src proto.Message)

func (*GetAllStoresResponse) XXX_Size

func (m *GetAllStoresResponse) XXX_Size() int

func (*GetAllStoresResponse) XXX_Unmarshal

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

type GetClusterConfigRequest

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

func (*GetClusterConfigRequest) Descriptor

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

func (*GetClusterConfigRequest) GetHeader

func (m *GetClusterConfigRequest) GetHeader() *RequestHeader

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

func (*GetClusterConfigRequest) XXX_DiscardUnknown

func (m *GetClusterConfigRequest) XXX_DiscardUnknown()

func (*GetClusterConfigRequest) XXX_Marshal

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

func (*GetClusterConfigRequest) XXX_Merge

func (dst *GetClusterConfigRequest) XXX_Merge(src proto.Message)

func (*GetClusterConfigRequest) XXX_Size

func (m *GetClusterConfigRequest) XXX_Size() int

func (*GetClusterConfigRequest) XXX_Unmarshal

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

type GetClusterConfigResponse

type GetClusterConfigResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Cluster              *metapb.Cluster `protobuf:"bytes,2,opt,name=cluster" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetClusterConfigResponse) Descriptor

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

func (*GetClusterConfigResponse) GetCluster

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

func (*GetClusterConfigResponse) GetHeader

func (m *GetClusterConfigResponse) GetHeader() *ResponseHeader

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

func (*GetClusterConfigResponse) XXX_DiscardUnknown

func (m *GetClusterConfigResponse) XXX_DiscardUnknown()

func (*GetClusterConfigResponse) XXX_Marshal

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

func (*GetClusterConfigResponse) XXX_Merge

func (dst *GetClusterConfigResponse) XXX_Merge(src proto.Message)

func (*GetClusterConfigResponse) XXX_Size

func (m *GetClusterConfigResponse) XXX_Size() int

func (*GetClusterConfigResponse) XXX_Unmarshal

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

type GetDCLocationInfoRequest

type GetDCLocationInfoRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DcLocation           string         `protobuf:"bytes,2,opt,name=dc_location,json=dcLocation,proto3" json:"dc_location,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetDCLocationInfoRequest) Descriptor

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

func (*GetDCLocationInfoRequest) GetDcLocation

func (m *GetDCLocationInfoRequest) GetDcLocation() string

func (*GetDCLocationInfoRequest) GetHeader

func (m *GetDCLocationInfoRequest) GetHeader() *RequestHeader

func (*GetDCLocationInfoRequest) Marshal

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

func (*GetDCLocationInfoRequest) MarshalTo

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

func (*GetDCLocationInfoRequest) ProtoMessage

func (*GetDCLocationInfoRequest) ProtoMessage()

func (*GetDCLocationInfoRequest) Reset

func (m *GetDCLocationInfoRequest) Reset()

func (*GetDCLocationInfoRequest) Size

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

func (*GetDCLocationInfoRequest) String

func (m *GetDCLocationInfoRequest) String() string

func (*GetDCLocationInfoRequest) Unmarshal

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

func (*GetDCLocationInfoRequest) XXX_DiscardUnknown

func (m *GetDCLocationInfoRequest) XXX_DiscardUnknown()

func (*GetDCLocationInfoRequest) XXX_Marshal

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

func (*GetDCLocationInfoRequest) XXX_Merge

func (dst *GetDCLocationInfoRequest) XXX_Merge(src proto.Message)

func (*GetDCLocationInfoRequest) XXX_Size

func (m *GetDCLocationInfoRequest) XXX_Size() int

func (*GetDCLocationInfoRequest) XXX_Unmarshal

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

type GetDCLocationInfoResponse

type GetDCLocationInfoResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// suffix sign
	Suffix int32 `protobuf:"varint,2,opt,name=suffix,proto3" json:"suffix,omitempty"`
	// max_ts will be included into this response if PD leader think the receiver needs,
	// which it's set when the number of the max suffix bits changes.
	MaxTs                *Timestamp `protobuf:"bytes,3,opt,name=max_ts,json=maxTs" json:"max_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetDCLocationInfoResponse) Descriptor

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

func (*GetDCLocationInfoResponse) GetHeader

func (m *GetDCLocationInfoResponse) GetHeader() *ResponseHeader

func (*GetDCLocationInfoResponse) GetMaxTs

func (m *GetDCLocationInfoResponse) GetMaxTs() *Timestamp

func (*GetDCLocationInfoResponse) GetSuffix

func (m *GetDCLocationInfoResponse) GetSuffix() int32

func (*GetDCLocationInfoResponse) Marshal

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

func (*GetDCLocationInfoResponse) MarshalTo

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

func (*GetDCLocationInfoResponse) ProtoMessage

func (*GetDCLocationInfoResponse) ProtoMessage()

func (*GetDCLocationInfoResponse) Reset

func (m *GetDCLocationInfoResponse) Reset()

func (*GetDCLocationInfoResponse) Size

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

func (*GetDCLocationInfoResponse) String

func (m *GetDCLocationInfoResponse) String() string

func (*GetDCLocationInfoResponse) Unmarshal

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

func (*GetDCLocationInfoResponse) XXX_DiscardUnknown

func (m *GetDCLocationInfoResponse) XXX_DiscardUnknown()

func (*GetDCLocationInfoResponse) XXX_Marshal

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

func (*GetDCLocationInfoResponse) XXX_Merge

func (dst *GetDCLocationInfoResponse) XXX_Merge(src proto.Message)

func (*GetDCLocationInfoResponse) XXX_Size

func (m *GetDCLocationInfoResponse) XXX_Size() int

func (*GetDCLocationInfoResponse) XXX_Unmarshal

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

type GetGCSafePointRequest

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

func (*GetGCSafePointRequest) Descriptor

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

func (*GetGCSafePointRequest) GetHeader

func (m *GetGCSafePointRequest) GetHeader() *RequestHeader

func (*GetGCSafePointRequest) Marshal

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

func (*GetGCSafePointRequest) MarshalTo

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

func (*GetGCSafePointRequest) ProtoMessage

func (*GetGCSafePointRequest) ProtoMessage()

func (*GetGCSafePointRequest) Reset

func (m *GetGCSafePointRequest) Reset()

func (*GetGCSafePointRequest) Size

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

func (*GetGCSafePointRequest) String

func (m *GetGCSafePointRequest) String() string

func (*GetGCSafePointRequest) Unmarshal

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

func (*GetGCSafePointRequest) XXX_DiscardUnknown

func (m *GetGCSafePointRequest) XXX_DiscardUnknown()

func (*GetGCSafePointRequest) XXX_Marshal

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

func (*GetGCSafePointRequest) XXX_Merge

func (dst *GetGCSafePointRequest) XXX_Merge(src proto.Message)

func (*GetGCSafePointRequest) XXX_Size

func (m *GetGCSafePointRequest) XXX_Size() int

func (*GetGCSafePointRequest) XXX_Unmarshal

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

type GetGCSafePointResponse

type GetGCSafePointResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	SafePoint            uint64          `protobuf:"varint,2,opt,name=safe_point,json=safePoint,proto3" json:"safe_point,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetGCSafePointResponse) Descriptor

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

func (*GetGCSafePointResponse) GetHeader

func (m *GetGCSafePointResponse) GetHeader() *ResponseHeader

func (*GetGCSafePointResponse) GetSafePoint

func (m *GetGCSafePointResponse) GetSafePoint() uint64

func (*GetGCSafePointResponse) Marshal

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

func (*GetGCSafePointResponse) MarshalTo

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

func (*GetGCSafePointResponse) ProtoMessage

func (*GetGCSafePointResponse) ProtoMessage()

func (*GetGCSafePointResponse) Reset

func (m *GetGCSafePointResponse) Reset()

func (*GetGCSafePointResponse) Size

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

func (*GetGCSafePointResponse) String

func (m *GetGCSafePointResponse) String() string

func (*GetGCSafePointResponse) Unmarshal

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

func (*GetGCSafePointResponse) XXX_DiscardUnknown

func (m *GetGCSafePointResponse) XXX_DiscardUnknown()

func (*GetGCSafePointResponse) XXX_Marshal

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

func (*GetGCSafePointResponse) XXX_Merge

func (dst *GetGCSafePointResponse) XXX_Merge(src proto.Message)

func (*GetGCSafePointResponse) XXX_Size

func (m *GetGCSafePointResponse) XXX_Size() int

func (*GetGCSafePointResponse) XXX_Unmarshal

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

type GetMembersRequest

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

func (*GetMembersRequest) Descriptor

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

func (*GetMembersRequest) GetHeader

func (m *GetMembersRequest) GetHeader() *RequestHeader

func (*GetMembersRequest) Marshal

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

func (*GetMembersRequest) MarshalTo

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

func (*GetMembersRequest) ProtoMessage

func (*GetMembersRequest) ProtoMessage()

func (*GetMembersRequest) Reset

func (m *GetMembersRequest) Reset()

func (*GetMembersRequest) Size

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

func (*GetMembersRequest) String

func (m *GetMembersRequest) String() string

func (*GetMembersRequest) Unmarshal

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

func (*GetMembersRequest) XXX_DiscardUnknown

func (m *GetMembersRequest) XXX_DiscardUnknown()

func (*GetMembersRequest) XXX_Marshal

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

func (*GetMembersRequest) XXX_Merge

func (dst *GetMembersRequest) XXX_Merge(src proto.Message)

func (*GetMembersRequest) XXX_Size

func (m *GetMembersRequest) XXX_Size() int

func (*GetMembersRequest) XXX_Unmarshal

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

type GetMembersResponse

type GetMembersResponse struct {
	Header               *ResponseHeader    `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Members              []*Member          `protobuf:"bytes,2,rep,name=members" json:"members,omitempty"`
	Leader               *Member            `protobuf:"bytes,3,opt,name=leader" json:"leader,omitempty"`
	EtcdLeader           *Member            `protobuf:"bytes,4,opt,name=etcd_leader,json=etcdLeader" json:"etcd_leader,omitempty"`
	TsoAllocatorLeaders  map[string]*Member `` /* 194-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetMembersResponse) Descriptor

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

func (*GetMembersResponse) GetEtcdLeader

func (m *GetMembersResponse) GetEtcdLeader() *Member

func (*GetMembersResponse) GetHeader

func (m *GetMembersResponse) GetHeader() *ResponseHeader

func (*GetMembersResponse) GetLeader

func (m *GetMembersResponse) GetLeader() *Member

func (*GetMembersResponse) GetMembers

func (m *GetMembersResponse) GetMembers() []*Member

func (*GetMembersResponse) GetTsoAllocatorLeaders

func (m *GetMembersResponse) GetTsoAllocatorLeaders() map[string]*Member

func (*GetMembersResponse) Marshal

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

func (*GetMembersResponse) MarshalTo

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

func (*GetMembersResponse) ProtoMessage

func (*GetMembersResponse) ProtoMessage()

func (*GetMembersResponse) Reset

func (m *GetMembersResponse) Reset()

func (*GetMembersResponse) Size

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

func (*GetMembersResponse) String

func (m *GetMembersResponse) String() string

func (*GetMembersResponse) Unmarshal

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

func (*GetMembersResponse) XXX_DiscardUnknown

func (m *GetMembersResponse) XXX_DiscardUnknown()

func (*GetMembersResponse) XXX_Marshal

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

func (*GetMembersResponse) XXX_Merge

func (dst *GetMembersResponse) XXX_Merge(src proto.Message)

func (*GetMembersResponse) XXX_Size

func (m *GetMembersResponse) XXX_Size() int

func (*GetMembersResponse) XXX_Unmarshal

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

type GetOperatorRequest

type GetOperatorRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	RegionId             uint64         `protobuf:"varint,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetOperatorRequest) Descriptor

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

func (*GetOperatorRequest) GetHeader

func (m *GetOperatorRequest) GetHeader() *RequestHeader

func (*GetOperatorRequest) GetRegionId

func (m *GetOperatorRequest) GetRegionId() uint64

func (*GetOperatorRequest) Marshal

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

func (*GetOperatorRequest) MarshalTo

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

func (*GetOperatorRequest) ProtoMessage

func (*GetOperatorRequest) ProtoMessage()

func (*GetOperatorRequest) Reset

func (m *GetOperatorRequest) Reset()

func (*GetOperatorRequest) Size

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

func (*GetOperatorRequest) String

func (m *GetOperatorRequest) String() string

func (*GetOperatorRequest) Unmarshal

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

func (*GetOperatorRequest) XXX_DiscardUnknown

func (m *GetOperatorRequest) XXX_DiscardUnknown()

func (*GetOperatorRequest) XXX_Marshal

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

func (*GetOperatorRequest) XXX_Merge

func (dst *GetOperatorRequest) XXX_Merge(src proto.Message)

func (*GetOperatorRequest) XXX_Size

func (m *GetOperatorRequest) XXX_Size() int

func (*GetOperatorRequest) XXX_Unmarshal

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

type GetOperatorResponse

type GetOperatorResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	RegionId             uint64          `protobuf:"varint,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Desc                 []byte          `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	Status               OperatorStatus  `protobuf:"varint,4,opt,name=status,proto3,enum=pdpb.OperatorStatus" json:"status,omitempty"`
	Kind                 []byte          `protobuf:"bytes,5,opt,name=kind,proto3" json:"kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetOperatorResponse) Descriptor

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

func (*GetOperatorResponse) GetDesc

func (m *GetOperatorResponse) GetDesc() []byte

func (*GetOperatorResponse) GetHeader

func (m *GetOperatorResponse) GetHeader() *ResponseHeader

func (*GetOperatorResponse) GetKind

func (m *GetOperatorResponse) GetKind() []byte

func (*GetOperatorResponse) GetRegionId

func (m *GetOperatorResponse) GetRegionId() uint64

func (*GetOperatorResponse) GetStatus

func (m *GetOperatorResponse) GetStatus() OperatorStatus

func (*GetOperatorResponse) Marshal

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

func (*GetOperatorResponse) MarshalTo

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

func (*GetOperatorResponse) ProtoMessage

func (*GetOperatorResponse) ProtoMessage()

func (*GetOperatorResponse) Reset

func (m *GetOperatorResponse) Reset()

func (*GetOperatorResponse) Size

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

func (*GetOperatorResponse) String

func (m *GetOperatorResponse) String() string

func (*GetOperatorResponse) Unmarshal

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

func (*GetOperatorResponse) XXX_DiscardUnknown

func (m *GetOperatorResponse) XXX_DiscardUnknown()

func (*GetOperatorResponse) XXX_Marshal

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

func (*GetOperatorResponse) XXX_Merge

func (dst *GetOperatorResponse) XXX_Merge(src proto.Message)

func (*GetOperatorResponse) XXX_Size

func (m *GetOperatorResponse) XXX_Size() int

func (*GetOperatorResponse) XXX_Unmarshal

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

type GetRegionByIDRequest

type GetRegionByIDRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	RegionId             uint64         `protobuf:"varint,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetRegionByIDRequest) Descriptor

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

func (*GetRegionByIDRequest) GetHeader

func (m *GetRegionByIDRequest) GetHeader() *RequestHeader

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

func (*GetRegionByIDRequest) XXX_DiscardUnknown

func (m *GetRegionByIDRequest) XXX_DiscardUnknown()

func (*GetRegionByIDRequest) XXX_Marshal

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

func (*GetRegionByIDRequest) XXX_Merge

func (dst *GetRegionByIDRequest) XXX_Merge(src proto.Message)

func (*GetRegionByIDRequest) XXX_Size

func (m *GetRegionByIDRequest) XXX_Size() int

func (*GetRegionByIDRequest) XXX_Unmarshal

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

type GetRegionRequest

type GetRegionRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	RegionKey            []byte         `protobuf:"bytes,2,opt,name=region_key,json=regionKey,proto3" json:"region_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetRegionRequest) Descriptor

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

func (*GetRegionRequest) GetHeader

func (m *GetRegionRequest) GetHeader() *RequestHeader

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

func (*GetRegionRequest) XXX_DiscardUnknown

func (m *GetRegionRequest) XXX_DiscardUnknown()

func (*GetRegionRequest) XXX_Marshal

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

func (*GetRegionRequest) XXX_Merge

func (dst *GetRegionRequest) XXX_Merge(src proto.Message)

func (*GetRegionRequest) XXX_Size

func (m *GetRegionRequest) XXX_Size() int

func (*GetRegionRequest) XXX_Unmarshal

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

type GetRegionResponse

type GetRegionResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Region *metapb.Region  `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"`
	Leader *metapb.Peer    `protobuf:"bytes,3,opt,name=leader" json:"leader,omitempty"`
	// Leader considers that these peers are down.
	DownPeers []*PeerStats `protobuf:"bytes,5,rep,name=down_peers,json=downPeers" json:"down_peers,omitempty"`
	// Pending peers are the peers that the leader can't consider as
	// working followers.
	PendingPeers         []*metapb.Peer `protobuf:"bytes,6,rep,name=pending_peers,json=pendingPeers" json:"pending_peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetRegionResponse) Descriptor

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

func (*GetRegionResponse) GetDownPeers

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

func (*GetRegionResponse) GetHeader

func (m *GetRegionResponse) GetHeader() *ResponseHeader

func (*GetRegionResponse) GetLeader

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

func (*GetRegionResponse) GetPendingPeers

func (m *GetRegionResponse) GetPendingPeers() []*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

func (*GetRegionResponse) XXX_DiscardUnknown

func (m *GetRegionResponse) XXX_DiscardUnknown()

func (*GetRegionResponse) XXX_Marshal

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

func (*GetRegionResponse) XXX_Merge

func (dst *GetRegionResponse) XXX_Merge(src proto.Message)

func (*GetRegionResponse) XXX_Size

func (m *GetRegionResponse) XXX_Size() int

func (*GetRegionResponse) XXX_Unmarshal

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

type GetStoreRequest

type GetStoreRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	StoreId              uint64         `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetStoreRequest) Descriptor

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

func (*GetStoreRequest) GetHeader

func (m *GetStoreRequest) GetHeader() *RequestHeader

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

func (*GetStoreRequest) XXX_DiscardUnknown

func (m *GetStoreRequest) XXX_DiscardUnknown()

func (*GetStoreRequest) XXX_Marshal

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

func (*GetStoreRequest) XXX_Merge

func (dst *GetStoreRequest) XXX_Merge(src proto.Message)

func (*GetStoreRequest) XXX_Size

func (m *GetStoreRequest) XXX_Size() int

func (*GetStoreRequest) XXX_Unmarshal

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

type GetStoreResponse

type GetStoreResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Store                *metapb.Store   `protobuf:"bytes,2,opt,name=store" json:"store,omitempty"`
	Stats                *StoreStats     `protobuf:"bytes,3,opt,name=stats" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetStoreResponse) Descriptor

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

func (*GetStoreResponse) GetHeader

func (m *GetStoreResponse) GetHeader() *ResponseHeader

func (*GetStoreResponse) GetStats

func (m *GetStoreResponse) GetStats() *StoreStats

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

func (*GetStoreResponse) XXX_DiscardUnknown

func (m *GetStoreResponse) XXX_DiscardUnknown()

func (*GetStoreResponse) XXX_Marshal

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

func (*GetStoreResponse) XXX_Merge

func (dst *GetStoreResponse) XXX_Merge(src proto.Message)

func (*GetStoreResponse) XXX_Size

func (m *GetStoreResponse) XXX_Size() int

func (*GetStoreResponse) XXX_Unmarshal

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

type IsBootstrappedRequest

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

func (*IsBootstrappedRequest) Descriptor

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

func (*IsBootstrappedRequest) GetHeader

func (m *IsBootstrappedRequest) GetHeader() *RequestHeader

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

func (*IsBootstrappedRequest) XXX_DiscardUnknown

func (m *IsBootstrappedRequest) XXX_DiscardUnknown()

func (*IsBootstrappedRequest) XXX_Marshal

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

func (*IsBootstrappedRequest) XXX_Merge

func (dst *IsBootstrappedRequest) XXX_Merge(src proto.Message)

func (*IsBootstrappedRequest) XXX_Size

func (m *IsBootstrappedRequest) XXX_Size() int

func (*IsBootstrappedRequest) XXX_Unmarshal

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

type IsBootstrappedResponse

type IsBootstrappedResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Bootstrapped         bool            `protobuf:"varint,2,opt,name=bootstrapped,proto3" json:"bootstrapped,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*IsBootstrappedResponse) Descriptor

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

func (*IsBootstrappedResponse) GetBootstrapped

func (m *IsBootstrappedResponse) GetBootstrapped() bool

func (*IsBootstrappedResponse) GetHeader

func (m *IsBootstrappedResponse) GetHeader() *ResponseHeader

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

func (*IsBootstrappedResponse) XXX_DiscardUnknown

func (m *IsBootstrappedResponse) XXX_DiscardUnknown()

func (*IsBootstrappedResponse) XXX_Marshal

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

func (*IsBootstrappedResponse) XXX_Merge

func (dst *IsBootstrappedResponse) XXX_Merge(src proto.Message)

func (*IsBootstrappedResponse) XXX_Size

func (m *IsBootstrappedResponse) XXX_Size() int

func (*IsBootstrappedResponse) XXX_Unmarshal

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

type Member

type Member struct {
	// name is the name of the PD member.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// member_id is the unique id of the PD member.
	MemberId             uint64   `protobuf:"varint,2,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
	PeerUrls             []string `protobuf:"bytes,3,rep,name=peer_urls,json=peerUrls" json:"peer_urls,omitempty"`
	ClientUrls           []string `protobuf:"bytes,4,rep,name=client_urls,json=clientUrls" json:"client_urls,omitempty"`
	LeaderPriority       int32    `protobuf:"varint,5,opt,name=leader_priority,json=leaderPriority,proto3" json:"leader_priority,omitempty"`
	DeployPath           string   `protobuf:"bytes,6,opt,name=deploy_path,json=deployPath,proto3" json:"deploy_path,omitempty"`
	BinaryVersion        string   `protobuf:"bytes,7,opt,name=binary_version,json=binaryVersion,proto3" json:"binary_version,omitempty"`
	GitHash              string   `protobuf:"bytes,8,opt,name=git_hash,json=gitHash,proto3" json:"git_hash,omitempty"`