schedulerpb

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

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

 Go to latest Published: Dec 15, 2024 License: Apache-2.0 Imports: 9 Imported by: 14

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSchedulerpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSchedulerpb   = fmt.Errorf("proto: integer overflow")
)
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,
}

Functions

func RegisterSchedulerServer 

func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer)

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 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"`
	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) 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"`
	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) 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 Error 

type Error struct {
	Type                 ErrorType `protobuf:"varint,1,opt,name=type,proto3,enum=schedulerpb.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 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"`
	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) 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=schedulerpb.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"`
	Slaves               []*metapb.Peer  `protobuf:"bytes,4,rep,name=slaves" json:"slaves,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetRegionResponse) Descriptor 

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

func (*GetRegionResponse) GetHeader 

func (m *GetRegionResponse) GetHeader() *ResponseHeader

func (*GetRegionResponse) GetLeader 

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

func (*GetRegionResponse) GetRegion 

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

func (*GetRegionResponse) GetSlaves 

func (m *GetRegionResponse) GetSlaves() []*metapb.Peer

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 Scheduler member.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// member_id is the unique id of the Scheduler 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Member) Descriptor 

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

func (*Member) GetClientUrls 

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

func (*Member) GetLeaderPriority 

func (m *Member) GetLeaderPriority() int32

func (*Member) GetMemberId 

func (m *Member) GetMemberId() uint64

func (*Member) GetName 

func (m *Member) GetName() string

func (*Member) GetPeerUrls 

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

func (*Member) Marshal 

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

func (*Member) MarshalTo 

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

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) Reset 

func (m *Member) Reset()

func (*Member) Size 

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

func (*Member) String 

func (m *Member) String() string

func (*Member) Unmarshal 

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

func (*Member) XXX_DiscardUnknown 

func (m *Member) XXX_DiscardUnknown()

func (*Member) XXX_Marshal 

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

func (*Member) XXX_Merge 

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

func (*Member) XXX_Size 

func (m *Member) XXX_Size() int

func (*Member) XXX_Unmarshal 

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

type OperatorStatus 

type OperatorStatus int32
const (
	OperatorStatus_SUCCESS OperatorStatus = 0
	OperatorStatus_TIMEOUT OperatorStatus = 1
	OperatorStatus_CANCEL  OperatorStatus = 2
	OperatorStatus_REPLACE OperatorStatus = 3
	OperatorStatus_RUNNING OperatorStatus = 4
)

func (OperatorStatus) EnumDescriptor 

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

func (OperatorStatus) String 

func (x OperatorStatus) String() string

type PutClusterConfigRequest 

type PutClusterConfigRequest struct {
	Header               *RequestHeader  `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 (*PutClusterConfigRequest) Descriptor 

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

func (*PutClusterConfigRequest) GetCluster 

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

func (*PutClusterConfigRequest) GetHeader 

func (m *PutClusterConfigRequest) GetHeader() *RequestHeader

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

func (*PutClusterConfigRequest) XXX_DiscardUnknown 

func (m *PutClusterConfigRequest) XXX_DiscardUnknown()

func (*PutClusterConfigRequest) XXX_Marshal 

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

func (*PutClusterConfigRequest) XXX_Merge 

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

func (*PutClusterConfigRequest) XXX_Size 

func (m *PutClusterConfigRequest) XXX_Size() int

func (*PutClusterConfigRequest) XXX_Unmarshal 

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

type PutClusterConfigResponse 

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

func (*PutClusterConfigResponse) Descriptor 

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

func (*PutClusterConfigResponse) GetHeader 

func (m *PutClusterConfigResponse) GetHeader() *ResponseHeader

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

func (*PutClusterConfigResponse) XXX_DiscardUnknown 

func (m *PutClusterConfigResponse) XXX_DiscardUnknown()

func (*PutClusterConfigResponse) XXX_Marshal 

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

func (*PutClusterConfigResponse) XXX_Merge 

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

func (*PutClusterConfigResponse) XXX_Size 

func (m *PutClusterConfigResponse) XXX_Size() int

func (*PutClusterConfigResponse) XXX_Unmarshal 

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

type PutStoreRequest 

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

func (*PutStoreRequest) Descriptor 

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

func (*PutStoreRequest) GetHeader 

func (m *PutStoreRequest) GetHeader() *RequestHeader

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

func (*PutStoreRequest) XXX_DiscardUnknown 

func (m *PutStoreRequest) XXX_DiscardUnknown()

func (*PutStoreRequest) XXX_Marshal 

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

func (*PutStoreRequest) XXX_Merge 

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

func (*PutStoreRequest) XXX_Size 

func (m *PutStoreRequest) XXX_Size() int

func (*PutStoreRequest) XXX_Unmarshal 

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

type PutStoreResponse 

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

func (*PutStoreResponse) Descriptor 

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

func (*PutStoreResponse) GetHeader 

func (m *PutStoreResponse) GetHeader() *ResponseHeader

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

func (*PutStoreResponse) XXX_DiscardUnknown 

func (m *PutStoreResponse) XXX_DiscardUnknown()

func (*PutStoreResponse) XXX_Marshal 

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

func (*PutStoreResponse) XXX_Merge 

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

func (*PutStoreResponse) XXX_Size 

func (m *PutStoreResponse) XXX_Size() int

func (*PutStoreResponse) XXX_Unmarshal 

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

type RecordPair 

type RecordPair struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                uint64   `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecordPair) Descriptor 

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

func (*RecordPair) GetKey 

func (m *RecordPair) GetKey() string

func (*RecordPair) GetValue 

func (m *RecordPair) GetValue() uint64

func (*RecordPair) Marshal 

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

func (*RecordPair) MarshalTo 

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

func (*RecordPair) ProtoMessage 

func (*RecordPair) ProtoMessage()

func (*RecordPair) Reset 

func (m *RecordPair) Reset()

func (*RecordPair) Size 

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

func (*RecordPair) String 

func (m *RecordPair) String() string

func (*RecordPair) Unmarshal 

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

func (*RecordPair) XXX_DiscardUnknown 

func (m *RecordPair) XXX_DiscardUnknown()

func (*RecordPair) XXX_Marshal 

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

func (*RecordPair) XXX_Merge 

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

func (*RecordPair) XXX_Size 

func (m *RecordPair) XXX_Size() int

func (*RecordPair) XXX_Unmarshal 

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

type RegionHeartbeatRequest 

type RegionHeartbeatRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Region *metapb.Region `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"`
	// Leader Peer sending the heartbeat.
	Leader *metapb.Peer `protobuf:"bytes,3,opt,name=leader" json:"leader,omitempty"`
	// Pending peers are the peers that the leader can't consider as
	// working followers.
	PendingPeers []*metapb.Peer `protobuf:"bytes,5,rep,name=pending_peers,json=pendingPeers" json:"pending_peers,omitempty"`
	// Approximate region size.
	ApproximateSize      uint64   `protobuf:"varint,10,opt,name=approximate_size,json=approximateSize,proto3" json:"approximate_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegionHeartbeatRequest) Descriptor 

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

func (*RegionHeartbeatRequest) GetApproximateSize 

func (m *RegionHeartbeatRequest) GetApproximateSize() uint64

func (*RegionHeartbeatRequest) GetHeader 

func (m *RegionHeartbeatRequest) GetHeader() *RequestHeader

func (*RegionHeartbeatRequest) GetLeader 

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

func (*RegionHeartbeatRequest) GetPendingPeers 

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

func (*RegionHeartbeatRequest) XXX_DiscardUnknown 

func (m *RegionHeartbeatRequest) XXX_DiscardUnknown()

func (*RegionHeartbeatRequest) XXX_Marshal 

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

func (*RegionHeartbeatRequest) XXX_Merge 

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

func (*RegionHeartbeatRequest) XXX_Size 

func (m *RegionHeartbeatRequest) XXX_Size() int

func (*RegionHeartbeatRequest) XXX_Unmarshal 

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

type RegionHeartbeatResponse 

type RegionHeartbeatResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// Notice, Scheduleeer only allows handling reported epoch >= current scheduler's.
	// Leader peer reports region status with RegionHeartbeatRequest
	// to scheduler regularly, scheduler 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. Scheduler region state -> Peers (1), ConfVer (1).
	// 2. Leader peer 1 reports region state to scheduler, scheduler 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),
	// scheduler updates its state -> Peers (1, 2), ConfVer (2).
	// 4. Leader may report old Peers (1), ConfVer (1) to scheduler before ConfChange
	// finished, scheduler stills responses ChangePeer Adding 2, of course, we must
	// guarantee the second ChangePeer can't be applied in TiKV.
	ChangePeer *ChangePeer `protobuf:"bytes,2,opt,name=change_peer,json=changePeer" json:"change_peer,omitempty"`
	// Scheduler can return transfer_leader to let TiKV does leader transfer itself.
	TransferLeader *TransferLeader `protobuf:"bytes,3,opt,name=transfer_leader,json=transferLeader" json:"transfer_leader,omitempty"`
	// ID of the region
	RegionId    uint64              `protobuf:"varint,4,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,5,opt,name=region_epoch,json=regionEpoch" json:"region_epoch,omitempty"`
	// Leader of the region at the moment of the corresponding request was made.
	TargetPeer           *metapb.Peer `protobuf:"bytes,6,opt,name=target_peer,json=targetPeer" json:"target_peer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*RegionHeartbeatResponse) Descriptor 

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

func (*RegionHeartbeatResponse) GetChangePeer 

func (m *RegionHeartbeatResponse) GetChangePeer() *ChangePeer

func (*RegionHeartbeatResponse) GetHeader 

func (m *RegionHeartbeatResponse) GetHeader() *ResponseHeader

func (*RegionHeartbeatResponse) GetRegionEpoch 

func (m *RegionHeartbeatResponse) GetRegionEpoch() *metapb.RegionEpoch

func (*RegionHeartbeatResponse) GetRegionId 

func (m *RegionHeartbeatResponse) GetRegionId() uint64

func (*RegionHeartbeatResponse) GetTargetPeer 

func (m *RegionHeartbeatResponse) GetTargetPeer() *metapb.Peer

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

func (*RegionHeartbeatResponse) XXX_DiscardUnknown 

func (m *RegionHeartbeatResponse) XXX_DiscardUnknown()

func (*RegionHeartbeatResponse) XXX_Marshal 

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

func (*RegionHeartbeatResponse) XXX_Merge 

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

func (*RegionHeartbeatResponse) XXX_Size 

func (m *RegionHeartbeatResponse) XXX_Size() int

func (*RegionHeartbeatResponse) XXX_Unmarshal 

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

type ReportSplitRequest 

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

func (*ReportSplitRequest) Descriptor 

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

func (*ReportSplitRequest) GetHeader 

func (m *ReportSplitRequest) GetHeader() *RequestHeader

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

func (*ReportSplitRequest) XXX_DiscardUnknown 

func (m *ReportSplitRequest) XXX_DiscardUnknown()

func (*ReportSplitRequest) XXX_Marshal 

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

func (*ReportSplitRequest) XXX_Merge 

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

func (*ReportSplitRequest) XXX_Size 

func (m *ReportSplitRequest) XXX_Size() int

func (*ReportSplitRequest) XXX_Unmarshal 

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

type ReportSplitResponse 

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

func (*ReportSplitResponse) Descriptor 

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

func (*ReportSplitResponse) GetHeader 

func (m *ReportSplitResponse) GetHeader() *ResponseHeader

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

func (*ReportSplitResponse) XXX_DiscardUnknown 

func (m *ReportSplitResponse) XXX_DiscardUnknown()

func (*ReportSplitResponse) XXX_Marshal 

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

func (*ReportSplitResponse) XXX_Merge 

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

func (*ReportSplitResponse) XXX_Size 

func (m *ReportSplitResponse) XXX_Size() int

func (*ReportSplitResponse) XXX_Unmarshal 

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

type RequestHeader 

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

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetClusterId 

func (m *RequestHeader) GetClusterId() uint64

func (*RequestHeader) Marshal 

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

func (*RequestHeader) MarshalTo 

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

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset 

func (m *RequestHeader) Reset()

func (*RequestHeader) Size 

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

func (*RequestHeader) String 

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal 

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

func (*RequestHeader) XXX_DiscardUnknown 

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal 

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

func (*RequestHeader) XXX_Merge 

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

func (*RequestHeader) XXX_Size 

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal 

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

type ResponseHeader 

type ResponseHeader struct {
	// cluster_id is the ID of the cluster which sent the response.
	ClusterId            uint64   `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Error                *Error   `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetClusterId 

func (m *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetError 

func (m *ResponseHeader) GetError() *Error

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

func (*ResponseHeader) XXX_DiscardUnknown 

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal 

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

func (*ResponseHeader) XXX_Merge 

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

func (*ResponseHeader) XXX_Size 

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal 

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

type ScanRegionsRequest 

type ScanRegionsRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	StartKey             []byte         `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	Limit                int32          `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	EndKey               []byte         `protobuf:"bytes,4,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ScanRegionsRequest) Descriptor 

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

func (*ScanRegionsRequest) GetEndKey 

func (m *ScanRegionsRequest) GetEndKey() []byte

func (*ScanRegionsRequest) GetHeader 

func (m *ScanRegionsRequest) GetHeader() *RequestHeader

func (*ScanRegionsRequest) GetLimit 

func (m *ScanRegionsRequest) GetLimit() int32

func (*ScanRegionsRequest) GetStartKey 

func (m *ScanRegionsRequest) GetStartKey() []byte

func (*ScanRegionsRequest) Marshal 

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

func (*ScanRegionsRequest) MarshalTo 

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

func (*ScanRegionsRequest) ProtoMessage 

func (*ScanRegionsRequest) ProtoMessage()

func (*ScanRegionsRequest) Reset 

func (m *ScanRegionsRequest) Reset()

func (*ScanRegionsRequest) Size 

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

func (*ScanRegionsRequest) String 

func (m *ScanRegionsRequest) String() string

func (*ScanRegionsRequest) Unmarshal 

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

func (*ScanRegionsRequest) XXX_DiscardUnknown 

func (m *ScanRegionsRequest) XXX_DiscardUnknown()

func (*ScanRegionsRequest) XXX_Marshal 

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

func (*ScanRegionsRequest) XXX_Merge 

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

func (*ScanRegionsRequest) XXX_Size 

func (m *ScanRegionsRequest) XXX_Size() int

func (*ScanRegionsRequest) XXX_Unmarshal 

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

type ScanRegionsResponse 

type ScanRegionsResponse struct {
	Header               *ResponseHeader  `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Regions              []*metapb.Region `protobuf:"bytes,2,rep,name=regions" json:"regions,omitempty"`
	Leaders              []*metapb.Peer   `protobuf:"bytes,3,rep,name=leaders" json:"leaders,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ScanRegionsResponse) Descriptor 

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

func (*ScanRegionsResponse) GetHeader 

func (m *ScanRegionsResponse) GetHeader() *ResponseHeader

func (*ScanRegionsResponse) GetLeaders 

func (m *ScanRegionsResponse) GetLeaders() []*metapb.Peer

func (*ScanRegionsResponse) GetRegions 

func (m *ScanRegionsResponse) GetRegions() []*metapb.Region

func (*ScanRegionsResponse) Marshal 

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

func (*ScanRegionsResponse) MarshalTo 

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

func (*ScanRegionsResponse) ProtoMessage 

func (*ScanRegionsResponse) ProtoMessage()

func (*ScanRegionsResponse) Reset 

func (m *ScanRegionsResponse) Reset()

func (*ScanRegionsResponse) Size 

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

func (*ScanRegionsResponse) String 

func (m *ScanRegionsResponse) String() string

func (*ScanRegionsResponse) Unmarshal 

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

func (*ScanRegionsResponse) XXX_DiscardUnknown 

func (m *ScanRegionsResponse) XXX_DiscardUnknown()

func (*ScanRegionsResponse) XXX_Marshal 

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

func (*ScanRegionsResponse) XXX_Merge 

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

func (*ScanRegionsResponse) XXX_Size 

func (m *ScanRegionsResponse) XXX_Size() int

func (*ScanRegionsResponse) XXX_Unmarshal 

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

type ScatterRegionRequest 

type ScatterRegionRequest 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"`
	// Scheduler will use these region information if it can't find the region.
	// For example, the region is just split and hasn't report to Scheduler yet.
	Region               *metapb.Region `protobuf:"bytes,3,opt,name=region" json:"region,omitempty"`
	Leader               *metapb.Peer   `protobuf:"bytes,4,opt,name=leader" json:"leader,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ScatterRegionRequest) Descriptor 

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

func (*ScatterRegionRequest) GetHeader 

func (m *ScatterRegionRequest) GetHeader() *RequestHeader

func (*ScatterRegionRequest) GetLeader 

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

func (*ScatterRegionRequest) GetRegion 

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

func (*ScatterRegionRequest) GetRegionId 

func (m *ScatterRegionRequest) GetRegionId() uint64

func (*ScatterRegionRequest) Marshal 

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

func (*ScatterRegionRequest) MarshalTo 

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

func (*ScatterRegionRequest) ProtoMessage 

func (*ScatterRegionRequest) ProtoMessage()

func (*ScatterRegionRequest) Reset 

func (m *ScatterRegionRequest) Reset()

func (*ScatterRegionRequest) Size 

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

func (*ScatterRegionRequest) String 

func (m *ScatterRegionRequest) String() string

func (*ScatterRegionRequest) Unmarshal 

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

func (*ScatterRegionRequest) XXX_DiscardUnknown 

func (m *ScatterRegionRequest) XXX_DiscardUnknown()

func (*ScatterRegionRequest) XXX_Marshal 

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

func (*ScatterRegionRequest) XXX_Merge 

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

func (*ScatterRegionRequest) XXX_Size 

func (m *ScatterRegionRequest) XXX_Size() int

func (*ScatterRegionRequest) XXX_Unmarshal 

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

type ScatterRegionResponse 

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

func (*ScatterRegionResponse) Descriptor 

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

func (*ScatterRegionResponse) GetHeader 

func (m *ScatterRegionResponse) GetHeader() *ResponseHeader

func (*ScatterRegionResponse) Marshal 

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

func (*ScatterRegionResponse) MarshalTo 

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

func (*ScatterRegionResponse) ProtoMessage 

func (*ScatterRegionResponse) ProtoMessage()

func (*ScatterRegionResponse) Reset 

func (m *ScatterRegionResponse) Reset()

func (*ScatterRegionResponse) Size 

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

func (*ScatterRegionResponse) String 

func (m *ScatterRegionResponse) String() string

func (*ScatterRegionResponse) Unmarshal 

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

func (*ScatterRegionResponse) XXX_DiscardUnknown 

func (m *ScatterRegionResponse) XXX_DiscardUnknown()

func (*ScatterRegionResponse) XXX_Marshal 

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

func (*ScatterRegionResponse) XXX_Merge 

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

func (*ScatterRegionResponse) XXX_Size 

func (m *ScatterRegionResponse) XXX_Size() int

func (*ScatterRegionResponse) XXX_Unmarshal 

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

type SchedulerClient 

type SchedulerClient interface {
	// GetMembers get the member list of this cluster. It does not require
	// the cluster_id in request matchs the id of this cluster.
	GetMembers(ctx context.Context, in *GetMembersRequest, opts ...grpc.CallOption) (*GetMembersResponse, error)
	Tso(ctx context.Context, opts ...grpc.CallOption) (Scheduler_TsoClient, error)
	Bootstrap(ctx context.Context, in *BootstrapRequest, opts ...grpc.CallOption) (*BootstrapResponse, error)
	IsBootstrapped(ctx context.Context, in *IsBootstrappedRequest, opts ...grpc.CallOption) (*IsBootstrappedResponse, error)
	AllocID(ctx context.Context, in *AllocIDRequest, opts ...grpc.CallOption) (*AllocIDResponse, error)
	GetStore(ctx context.Context, in *GetStoreRequest, opts ...grpc.CallOption) (*GetStoreResponse, error)
	PutStore(ctx context.Context, in *PutStoreRequest, opts ...grpc.CallOption) (*PutStoreResponse, error)
	GetAllStores(ctx context.Context, in *GetAllStoresRequest, opts ...grpc.CallOption) (*GetAllStoresResponse, error)
	StoreHeartbeat(ctx context.Context, in *StoreHeartbeatRequest, opts ...grpc.CallOption) (*StoreHeartbeatResponse, error)
	RegionHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Scheduler_RegionHeartbeatClient, error)
	GetRegion(ctx context.Context, in *GetRegionRequest, opts ...grpc.CallOption) (*GetRegionResponse, error)
	GetPrevRegion(ctx context.Context, in *GetRegionRequest, opts ...grpc.CallOption) (*GetRegionResponse, error)
	GetRegionByID(ctx context.Context, in *GetRegionByIDRequest, opts ...grpc.CallOption) (*GetRegionResponse, error)
	ScanRegions(ctx context.Context, in *ScanRegionsRequest, opts ...grpc.CallOption) (*ScanRegionsResponse, error)
	AskSplit(ctx context.Context, in *AskSplitRequest, opts ...grpc.CallOption) (*AskSplitResponse, error)
	GetClusterConfig(ctx context.Context, in *GetClusterConfigRequest, opts ...grpc.CallOption) (*GetClusterConfigResponse, error)
	PutClusterConfig(ctx context.Context, in *PutClusterConfigRequest, opts ...grpc.CallOption) (*PutClusterConfigResponse, error)
	ScatterRegion(ctx context.Context, in *ScatterRegionRequest, opts ...grpc.CallOption) (*ScatterRegionResponse, error)
	GetGCSafePoint(ctx context.Context, in *GetGCSafePointRequest, opts ...grpc.CallOption) (*GetGCSafePointResponse, error)
	UpdateGCSafePoint(ctx context.Context, in *UpdateGCSafePointRequest, opts ...grpc.CallOption) (*UpdateGCSafePointResponse, error)
	GetOperator(ctx context.Context, in *GetOperatorRequest, opts ...grpc.CallOption) (*GetOperatorResponse, error)
}

func NewSchedulerClient 

func NewSchedulerClient(cc *grpc.ClientConn) SchedulerClient

type SchedulerServer 

type SchedulerServer interface {
	// GetMembers get the member list of this cluster. It does not require
	// the cluster_id in request matchs the id of this cluster.
	GetMembers(context.Context, *GetMembersRequest) (*GetMembersResponse, error)
	Tso(Scheduler_TsoServer) error
	Bootstrap(context.Context, *BootstrapRequest) (*BootstrapResponse, error)
	IsBootstrapped(context.Context, *IsBootstrappedRequest) (*IsBootstrappedResponse, error)
	AllocID(context.Context, *AllocIDRequest) (*AllocIDResponse, error)
	GetStore(context.Context, *GetStoreRequest) (*GetStoreResponse, error)
	PutStore(context.Context, *PutStoreRequest) (*PutStoreResponse, error)
	GetAllStores(context.Context, *GetAllStoresRequest) (*GetAllStoresResponse, error)
	StoreHeartbeat(context.Context, *StoreHeartbeatRequest) (*StoreHeartbeatResponse, error)
	RegionHeartbeat(Scheduler_RegionHeartbeatServer) error
	GetRegion(context.Context, *GetRegionRequest) (*GetRegionResponse, error)
	GetPrevRegion(context.Context, *GetRegionRequest) (*GetRegionResponse, error)
	GetRegionByID(context.Context, *GetRegionByIDRequest) (*GetRegionResponse, error)
	ScanRegions(context.Context, *ScanRegionsRequest) (*ScanRegionsResponse, error)
	AskSplit(context.Context, *AskSplitRequest) (*AskSplitResponse, error)
	GetClusterConfig(context.Context, *GetClusterConfigRequest) (*GetClusterConfigResponse, error)
	PutClusterConfig(context.Context, *PutClusterConfigRequest) (*PutClusterConfigResponse, error)
	ScatterRegion(context.Context, *ScatterRegionRequest) (*ScatterRegionResponse, error)
	GetGCSafePoint(context.Context, *GetGCSafePointRequest) (*GetGCSafePointResponse, error)
	UpdateGCSafePoint(context.Context, *UpdateGCSafePointRequest) (*UpdateGCSafePointResponse, error)
	GetOperator(context.Context, *GetOperatorRequest) (*GetOperatorResponse, error)
}

type Scheduler_RegionHeartbeatClient 

type Scheduler_RegionHeartbeatClient interface {
	Send(*RegionHeartbeatRequest) error
	Recv() (*RegionHeartbeatResponse, error)
	grpc.ClientStream
}

type Scheduler_RegionHeartbeatServer 

type Scheduler_RegionHeartbeatServer interface {
	Send(*RegionHeartbeatResponse) error
	Recv() (*RegionHeartbeatRequest, error)
	grpc.ServerStream
}

type Scheduler_TsoClient 

type Scheduler_TsoClient interface {
	Send(*TsoRequest) error
	Recv() (*TsoResponse, error)
	grpc.ClientStream
}

type Scheduler_TsoServer 

type Scheduler_TsoServer interface {
	Send(*TsoResponse) error
	Recv() (*TsoRequest, error)
	grpc.ServerStream
}

type SplitID 

type SplitID struct {
	NewRegionId          uint64   `protobuf:"varint,1,opt,name=new_region_id,json=newRegionId,proto3" json:"new_region_id,omitempty"`
	NewPeerIds           []uint64 `protobuf:"varint,2,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 (*SplitID) Descriptor 

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

func (*SplitID) GetNewPeerIds 

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

func (*SplitID) GetNewRegionId 

func (m *SplitID) GetNewRegionId() uint64

func (*SplitID) Marshal 

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

func (*SplitID) MarshalTo 

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

func (*SplitID) ProtoMessage 

func (*SplitID) ProtoMessage()

func (*SplitID) Reset 

func (m *SplitID) Reset()

func (*SplitID) Size 

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

func (*SplitID) String 

func (m *SplitID) String() string

func (*SplitID) Unmarshal 

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

func (*SplitID) XXX_DiscardUnknown 

func (m *SplitID) XXX_DiscardUnknown()

func (*SplitID) XXX_Marshal 

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

func (*SplitID) XXX_Merge 

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

func (*SplitID) XXX_Size 

func (m *SplitID) XXX_Size() int

func (*SplitID) XXX_Unmarshal 

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

type StoreHeartbeatRequest 

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

func (*StoreHeartbeatRequest) Descriptor 

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

func (*StoreHeartbeatRequest) GetHeader 

func (m *StoreHeartbeatRequest) GetHeader() *RequestHeader

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

func (*StoreHeartbeatRequest) XXX_DiscardUnknown 

func (m *StoreHeartbeatRequest) XXX_DiscardUnknown()

func (*StoreHeartbeatRequest) XXX_Marshal 

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

func (*StoreHeartbeatRequest) XXX_Merge 

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

func (*StoreHeartbeatRequest) XXX_Size 

func (m *StoreHeartbeatRequest) XXX_Size() int

func (*StoreHeartbeatRequest) XXX_Unmarshal 

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

type StoreHeartbeatResponse 

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

func (*StoreHeartbeatResponse) Descriptor 

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

func (*StoreHeartbeatResponse) GetHeader 

func (m *StoreHeartbeatResponse) GetHeader() *ResponseHeader

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

func (*StoreHeartbeatResponse) XXX_DiscardUnknown 

func (m *StoreHeartbeatResponse) XXX_DiscardUnknown()

func (*StoreHeartbeatResponse) XXX_Marshal 

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

func (*StoreHeartbeatResponse) XXX_Merge 

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

func (*StoreHeartbeatResponse) XXX_Size 

func (m *StoreHeartbeatResponse) XXX_Size() int

func (*StoreHeartbeatResponse) XXX_Unmarshal 

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

type StoreStats 

type StoreStats struct {
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	// Capacity for the store.
	Capacity uint64 `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// Available size for the store.
	Available uint64 `protobuf:"varint,3,opt,name=available,proto3" json:"available,omitempty"`
	// Total region count in this store.
	RegionCount uint32 `protobuf:"varint,4,opt,name=region_count,json=regionCount,proto3" json:"region_count,omitempty"`
	// Current sending snapshot count.
	SendingSnapCount uint32 `protobuf:"varint,5,opt,name=sending_snap_count,json=sendingSnapCount,proto3" json:"sending_snap_count,omitempty"`
	// Current receiving snapshot count.
	ReceivingSnapCount uint32 `protobuf:"varint,6,opt,name=receiving_snap_count,json=receivingSnapCount,proto3" json:"receiving_snap_count,omitempty"`
	// When the store is started (unix timestamp in seconds).
	StartTime uint32 `protobuf:"varint,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// How many region is applying snapshot.
	ApplyingSnapCount uint32 `protobuf:"varint,8,opt,name=applying_snap_count,json=applyingSnapCount,proto3" json:"applying_snap_count,omitempty"`
	// If the store is busy
	IsBusy bool `protobuf:"varint,9,opt,name=is_busy,json=isBusy,proto3" json:"is_busy,omitempty"`
	// Actually used space by db
	UsedSize uint64 `protobuf:"varint,10,opt,name=used_size,json=usedSize,proto3" json:"used_size,omitempty"`
	// Actually reported time interval
	Interval *TimeInterval `protobuf:"bytes,15,opt,name=interval" json:"interval,omitempty"`
	// Threads' CPU usages in the store
	CpuUsages []*RecordPair `protobuf:"bytes,16,rep,name=cpu_usages,json=cpuUsages" json:"cpu_usages,omitempty"`
	// Threads' read disk I/O rates in the store
	ReadIoRates []*RecordPair `protobuf:"bytes,17,rep,name=read_io_rates,json=readIoRates" json:"read_io_rates,omitempty"`
	// Threads' write disk I/O rates in the store
	WriteIoRates []*RecordPair `protobuf:"bytes,18,rep,name=write_io_rates,json=writeIoRates" json:"write_io_rates,omitempty"`
	// Operations' latencies in the store
	OpLatencies          []*RecordPair `protobuf:"bytes,19,rep,name=op_latencies,json=opLatencies" json:"op_latencies,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StoreStats) Descriptor 

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

func (*StoreStats) GetApplyingSnapCount 

func (m *StoreStats) GetApplyingSnapCount() uint32

func (*StoreStats) GetAvailable 

func (m *StoreStats) GetAvailable() uint64

func (*StoreStats) GetCapacity 

func (m *StoreStats) GetCapacity() uint64

func (*StoreStats) GetCpuUsages 

func (m *StoreStats) GetCpuUsages() []*RecordPair

func (*StoreStats) GetInterval 

func (m *StoreStats) GetInterval() *TimeInterval

func (*StoreStats) GetIsBusy 

func (m *StoreStats) GetIsBusy() bool

func (*StoreStats) GetOpLatencies 

func (m *StoreStats) GetOpLatencies() []*RecordPair

func (*StoreStats) GetReadIoRates 

func (m *StoreStats) GetReadIoRates() []*RecordPair

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

func (m *StoreStats) GetUsedSize() uint64

func (*StoreStats) GetWriteIoRates 

func (m *StoreStats) GetWriteIoRates() []*RecordPair

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

func (*StoreStats) XXX_DiscardUnknown 

func (m *StoreStats) XXX_DiscardUnknown()

func (*StoreStats) XXX_Marshal 

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

func (*StoreStats) XXX_Merge 

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

func (*StoreStats) XXX_Size 

func (m *StoreStats) XXX_Size() int

func (*StoreStats) XXX_Unmarshal 

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

type TimeInterval 

type TimeInterval struct {
	// The unix timestamp in seconds of the start of this period.
	StartTimestamp uint64 `protobuf:"varint,1,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	// The unix timestamp in seconds of the end of this period.
	EndTimestamp         uint64   `protobuf:"varint,2,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TimeInterval) Descriptor 

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

func (*TimeInterval) GetEndTimestamp 

func (m *TimeInterval) GetEndTimestamp() uint64

func (*TimeInterval) GetStartTimestamp 

func (m *TimeInterval) GetStartTimestamp() uint64

func (*TimeInterval) Marshal 

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

func (*TimeInterval) MarshalTo 

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

func (*TimeInterval) ProtoMessage 

func (*TimeInterval) ProtoMessage()

func (*TimeInterval) Reset 

func (m *TimeInterval) Reset()

func (*TimeInterval) Size 

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

func (*TimeInterval) String 

func (m *TimeInterval) String() string

func (*TimeInterval) Unmarshal 

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

func (*TimeInterval) XXX_DiscardUnknown 

func (m *TimeInterval) XXX_DiscardUnknown()

func (*TimeInterval) XXX_Marshal 

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

func (*TimeInterval) XXX_Merge 

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

func (*TimeInterval) XXX_Size 

func (m *TimeInterval) XXX_Size() int

func (*TimeInterval) XXX_Unmarshal 

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

type Timestamp 

type Timestamp struct {
	Physical             int64    `protobuf:"varint,1,opt,name=physical,proto3" json:"physical,omitempty"`
	Logical              int64    `protobuf:"varint,2,opt,name=logical,proto3" json:"logical,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*Timestamp) XXX_DiscardUnknown 

func (m *Timestamp) XXX_DiscardUnknown()

func (*Timestamp) XXX_Marshal 

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

func (*Timestamp) XXX_Merge 

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

func (*Timestamp) XXX_Size 

func (m *Timestamp) XXX_Size() int

func (*Timestamp) XXX_Unmarshal 

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

type TransferLeader 

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

func (*TransferLeader) Descriptor 

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

func (*TransferLeader) GetPeer 

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

func (*TransferLeader) Marshal 

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

func (*TransferLeader) MarshalTo 

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

func (*TransferLeader) ProtoMessage 

func (*TransferLeader) ProtoMessage()

func (*TransferLeader) Reset 

func (m *TransferLeader) Reset()

func (*TransferLeader) Size 

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

func (*TransferLeader) String 

func (m *TransferLeader) String() string

func (*TransferLeader) Unmarshal 

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

func (*TransferLeader) XXX_DiscardUnknown 

func (m *TransferLeader) XXX_DiscardUnknown()

func (*TransferLeader) XXX_Marshal 

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

func (*TransferLeader) XXX_Merge 

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

func (*TransferLeader) XXX_Size 

func (m *TransferLeader) XXX_Size() int

func (*TransferLeader) XXX_Unmarshal 

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

type TsoRequest 

type TsoRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Count                uint32         `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TsoRequest) Descriptor 

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

func (*TsoRequest) GetCount 

func (m *TsoRequest) GetCount() uint32

func (*TsoRequest) GetHeader 

func (m *TsoRequest) GetHeader() *RequestHeader

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

func (*TsoRequest) XXX_DiscardUnknown 

func (m *TsoRequest) XXX_DiscardUnknown()

func (*TsoRequest) XXX_Marshal 

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

func (*TsoRequest) XXX_Merge 

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

func (*TsoRequest) XXX_Size 

func (m *TsoRequest) XXX_Size() int

func (*TsoRequest) XXX_Unmarshal 

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

type TsoResponse 

type TsoResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Count                uint32          `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Timestamp            *Timestamp      `protobuf:"bytes,3,opt,name=timestamp" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*TsoResponse) Descriptor 

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

func (*TsoResponse) GetCount 

func (m *TsoResponse) GetCount() uint32

func (*TsoResponse) GetHeader 

func (m *TsoResponse) GetHeader() *ResponseHeader

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

func (*TsoResponse) XXX_DiscardUnknown 

func (m *TsoResponse) XXX_DiscardUnknown()

func (*TsoResponse) XXX_Marshal 

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

func (*TsoResponse) XXX_Merge 

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

func (*TsoResponse) XXX_Size 

func (m *TsoResponse) XXX_Size() int

func (*TsoResponse) XXX_Unmarshal 

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

type UpdateGCSafePointRequest 

type UpdateGCSafePointRequest struct {
	Header               *RequestHeader `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 (*UpdateGCSafePointRequest) Descriptor 

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

func (*UpdateGCSafePointRequest) GetHeader 

func (m *UpdateGCSafePointRequest) GetHeader() *RequestHeader

func (*UpdateGCSafePointRequest) GetSafePoint 

func (m *UpdateGCSafePointRequest) GetSafePoint() uint64

func (*UpdateGCSafePointRequest) Marshal 

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

func (*UpdateGCSafePointRequest) MarshalTo 

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

func (*UpdateGCSafePointRequest) ProtoMessage 

func (*UpdateGCSafePointRequest) ProtoMessage()

func (*UpdateGCSafePointRequest) Reset 

func (m *UpdateGCSafePointRequest) Reset()

func (*UpdateGCSafePointRequest) Size 

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

func (*UpdateGCSafePointRequest) String 

func (m *UpdateGCSafePointRequest) String() string

func (*UpdateGCSafePointRequest) Unmarshal 

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

func (*UpdateGCSafePointRequest) XXX_DiscardUnknown 

func (m *UpdateGCSafePointRequest) XXX_DiscardUnknown()

func (*UpdateGCSafePointRequest) XXX_Marshal 

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

func (*UpdateGCSafePointRequest) XXX_Merge 

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

func (*UpdateGCSafePointRequest) XXX_Size 

func (m *UpdateGCSafePointRequest) XXX_Size() int

func (*UpdateGCSafePointRequest) XXX_Unmarshal 

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

type UpdateGCSafePointResponse 

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

func (*UpdateGCSafePointResponse) Descriptor 

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

func (*UpdateGCSafePointResponse) GetHeader 

func (m *UpdateGCSafePointResponse) GetHeader() *ResponseHeader

func (*UpdateGCSafePointResponse) GetNewSafePoint 

func (m *UpdateGCSafePointResponse) GetNewSafePoint() uint64

func (*UpdateGCSafePointResponse) Marshal 

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

func (*UpdateGCSafePointResponse) MarshalTo 

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

func (*UpdateGCSafePointResponse) ProtoMessage 

func (*UpdateGCSafePointResponse) ProtoMessage()

func (*UpdateGCSafePointResponse) Reset 

func (m *UpdateGCSafePointResponse) Reset()

func (*UpdateGCSafePointResponse) Size 

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

func (*UpdateGCSafePointResponse) String 

func (m *UpdateGCSafePointResponse) String() string

func (*UpdateGCSafePointResponse) Unmarshal 

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

func (*UpdateGCSafePointResponse) XXX_DiscardUnknown 

func (m *UpdateGCSafePointResponse) XXX_DiscardUnknown()

func (*UpdateGCSafePointResponse) XXX_Marshal 

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

func (*UpdateGCSafePointResponse) XXX_Merge 

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

func (*UpdateGCSafePointResponse) XXX_Size 

func (m *UpdateGCSafePointResponse) XXX_Size() int

func (*UpdateGCSafePointResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.