Versions in this module Expand all Collapse all v0 v0.1.0 Mar 12, 2021 Changes in this version + var ErrIntOverflowRpcpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRpcpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupRpcpb = fmt.Errorf("proto: unexpected end of group") + var Type_name = map[int32]string + var Type_value = map[string]int32 + type AllocIDReq struct + func (*AllocIDReq) Descriptor() ([]byte, []int) + func (*AllocIDReq) ProtoMessage() + func (m *AllocIDReq) Marshal() (dAtA []byte, err error) + func (m *AllocIDReq) MarshalTo(dAtA []byte) (int, error) + func (m *AllocIDReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AllocIDReq) Reset() + func (m *AllocIDReq) Size() (n int) + func (m *AllocIDReq) String() string + func (m *AllocIDReq) Unmarshal(dAtA []byte) error + func (m *AllocIDReq) XXX_DiscardUnknown() + func (m *AllocIDReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AllocIDReq) XXX_Merge(src proto.Message) + func (m *AllocIDReq) XXX_Size() int + func (m *AllocIDReq) XXX_Unmarshal(b []byte) error + type AllocIDRsp struct + ID uint64 + func (*AllocIDRsp) Descriptor() ([]byte, []int) + func (*AllocIDRsp) ProtoMessage() + func (m *AllocIDRsp) GetID() uint64 + func (m *AllocIDRsp) Marshal() (dAtA []byte, err error) + func (m *AllocIDRsp) MarshalTo(dAtA []byte) (int, error) + func (m *AllocIDRsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AllocIDRsp) Reset() + func (m *AllocIDRsp) Size() (n int) + func (m *AllocIDRsp) String() string + func (m *AllocIDRsp) Unmarshal(dAtA []byte) error + func (m *AllocIDRsp) XXX_DiscardUnknown() + func (m *AllocIDRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AllocIDRsp) XXX_Merge(src proto.Message) + func (m *AllocIDRsp) XXX_Size() int + func (m *AllocIDRsp) XXX_Unmarshal(b []byte) error + type AskBatchSplitReq struct + Count uint32 + Data []byte + func (*AskBatchSplitReq) Descriptor() ([]byte, []int) + func (*AskBatchSplitReq) ProtoMessage() + func (m *AskBatchSplitReq) GetCount() uint32 + func (m *AskBatchSplitReq) GetData() []byte + func (m *AskBatchSplitReq) Marshal() (dAtA []byte, err error) + func (m *AskBatchSplitReq) MarshalTo(dAtA []byte) (int, error) + func (m *AskBatchSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AskBatchSplitReq) Reset() + func (m *AskBatchSplitReq) Size() (n int) + func (m *AskBatchSplitReq) String() string + func (m *AskBatchSplitReq) Unmarshal(dAtA []byte) error + func (m *AskBatchSplitReq) XXX_DiscardUnknown() + func (m *AskBatchSplitReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AskBatchSplitReq) XXX_Merge(src proto.Message) + func (m *AskBatchSplitReq) XXX_Size() int + func (m *AskBatchSplitReq) XXX_Unmarshal(b []byte) error + type AskBatchSplitRsp struct + SplitIDs []SplitID + func (*AskBatchSplitRsp) Descriptor() ([]byte, []int) + func (*AskBatchSplitRsp) ProtoMessage() + func (m *AskBatchSplitRsp) GetSplitIDs() []SplitID + func (m *AskBatchSplitRsp) Marshal() (dAtA []byte, err error) + func (m *AskBatchSplitRsp) MarshalTo(dAtA []byte) (int, error) + func (m *AskBatchSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AskBatchSplitRsp) Reset() + func (m *AskBatchSplitRsp) Size() (n int) + func (m *AskBatchSplitRsp) String() string + func (m *AskBatchSplitRsp) Unmarshal(dAtA []byte) error + func (m *AskBatchSplitRsp) XXX_DiscardUnknown() + func (m *AskBatchSplitRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AskBatchSplitRsp) XXX_Merge(src proto.Message) + func (m *AskBatchSplitRsp) XXX_Size() int + func (m *AskBatchSplitRsp) XXX_Unmarshal(b []byte) error + type AskSplitReq struct + Data []byte + func (*AskSplitReq) Descriptor() ([]byte, []int) + func (*AskSplitReq) ProtoMessage() + func (m *AskSplitReq) GetData() []byte + func (m *AskSplitReq) Marshal() (dAtA []byte, err error) + func (m *AskSplitReq) MarshalTo(dAtA []byte) (int, error) + func (m *AskSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AskSplitReq) Reset() + func (m *AskSplitReq) Size() (n int) + func (m *AskSplitReq) String() string + func (m *AskSplitReq) Unmarshal(dAtA []byte) error + func (m *AskSplitReq) XXX_DiscardUnknown() + func (m *AskSplitReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AskSplitReq) XXX_Merge(src proto.Message) + func (m *AskSplitReq) XXX_Size() int + func (m *AskSplitReq) XXX_Unmarshal(b []byte) error + type AskSplitRsp struct + SplitID SplitID + func (*AskSplitRsp) Descriptor() ([]byte, []int) + func (*AskSplitRsp) ProtoMessage() + func (m *AskSplitRsp) GetSplitID() SplitID + func (m *AskSplitRsp) Marshal() (dAtA []byte, err error) + func (m *AskSplitRsp) MarshalTo(dAtA []byte) (int, error) + func (m *AskSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AskSplitRsp) Reset() + func (m *AskSplitRsp) Size() (n int) + func (m *AskSplitRsp) String() string + func (m *AskSplitRsp) Unmarshal(dAtA []byte) error + func (m *AskSplitRsp) XXX_DiscardUnknown() + func (m *AskSplitRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AskSplitRsp) XXX_Merge(src proto.Message) + func (m *AskSplitRsp) XXX_Size() int + func (m *AskSplitRsp) XXX_Unmarshal(b []byte) error + type BatchReportSplitReq struct + Resources [][]byte + func (*BatchReportSplitReq) Descriptor() ([]byte, []int) + func (*BatchReportSplitReq) ProtoMessage() + func (m *BatchReportSplitReq) GetResources() [][]byte + func (m *BatchReportSplitReq) Marshal() (dAtA []byte, err error) + func (m *BatchReportSplitReq) MarshalTo(dAtA []byte) (int, error) + func (m *BatchReportSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchReportSplitReq) Reset() + func (m *BatchReportSplitReq) Size() (n int) + func (m *BatchReportSplitReq) String() string + func (m *BatchReportSplitReq) Unmarshal(dAtA []byte) error + func (m *BatchReportSplitReq) XXX_DiscardUnknown() + func (m *BatchReportSplitReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchReportSplitReq) XXX_Merge(src proto.Message) + func (m *BatchReportSplitReq) XXX_Size() int + func (m *BatchReportSplitReq) XXX_Unmarshal(b []byte) error + type BatchReportSplitRsp struct + func (*BatchReportSplitRsp) Descriptor() ([]byte, []int) + func (*BatchReportSplitRsp) ProtoMessage() + func (m *BatchReportSplitRsp) Marshal() (dAtA []byte, err error) + func (m *BatchReportSplitRsp) MarshalTo(dAtA []byte) (int, error) + func (m *BatchReportSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchReportSplitRsp) Reset() + func (m *BatchReportSplitRsp) Size() (n int) + func (m *BatchReportSplitRsp) String() string + func (m *BatchReportSplitRsp) Unmarshal(dAtA []byte) error + func (m *BatchReportSplitRsp) XXX_DiscardUnknown() + func (m *BatchReportSplitRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchReportSplitRsp) XXX_Merge(src proto.Message) + func (m *BatchReportSplitRsp) XXX_Size() int + func (m *BatchReportSplitRsp) XXX_Unmarshal(b []byte) error + type ChangePeer struct + ChangeType metapb.ChangePeerType + Peer metapb.Peer + func (*ChangePeer) Descriptor() ([]byte, []int) + func (*ChangePeer) ProtoMessage() + func (m *ChangePeer) GetChangeType() metapb.ChangePeerType + func (m *ChangePeer) GetPeer() metapb.Peer + func (m *ChangePeer) Marshal() (dAtA []byte, err error) + func (m *ChangePeer) MarshalTo(dAtA []byte) (int, error) + func (m *ChangePeer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangePeer) Reset() + func (m *ChangePeer) Size() (n int) + func (m *ChangePeer) String() string + func (m *ChangePeer) Unmarshal(dAtA []byte) error + func (m *ChangePeer) XXX_DiscardUnknown() + func (m *ChangePeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangePeer) XXX_Merge(src proto.Message) + func (m *ChangePeer) XXX_Size() int + func (m *ChangePeer) XXX_Unmarshal(b []byte) error + type ChangePeerV2 struct + Changes []ChangePeer + func (*ChangePeerV2) Descriptor() ([]byte, []int) + func (*ChangePeerV2) ProtoMessage() + func (m *ChangePeerV2) GetChanges() []ChangePeer + func (m *ChangePeerV2) Marshal() (dAtA []byte, err error) + func (m *ChangePeerV2) MarshalTo(dAtA []byte) (int, error) + func (m *ChangePeerV2) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ChangePeerV2) Reset() + func (m *ChangePeerV2) Size() (n int) + func (m *ChangePeerV2) String() string + func (m *ChangePeerV2) Unmarshal(dAtA []byte) error + func (m *ChangePeerV2) XXX_DiscardUnknown() + func (m *ChangePeerV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangePeerV2) XXX_Merge(src proto.Message) + func (m *ChangePeerV2) XXX_Size() int + func (m *ChangePeerV2) XXX_Unmarshal(b []byte) error + type ContainerEventData struct + Data []byte + func (*ContainerEventData) Descriptor() ([]byte, []int) + func (*ContainerEventData) ProtoMessage() + func (m *ContainerEventData) GetData() []byte + func (m *ContainerEventData) Marshal() (dAtA []byte, err error) + func (m *ContainerEventData) MarshalTo(dAtA []byte) (int, error) + func (m *ContainerEventData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ContainerEventData) Reset() + func (m *ContainerEventData) Size() (n int) + func (m *ContainerEventData) String() string + func (m *ContainerEventData) Unmarshal(dAtA []byte) error + func (m *ContainerEventData) XXX_DiscardUnknown() + func (m *ContainerEventData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerEventData) XXX_Merge(src proto.Message) + func (m *ContainerEventData) XXX_Size() int + func (m *ContainerEventData) XXX_Unmarshal(b []byte) error + type ContainerHeartbeatReq struct + Stats ContainerStats + func (*ContainerHeartbeatReq) Descriptor() ([]byte, []int) + func (*ContainerHeartbeatReq) ProtoMessage() + func (m *ContainerHeartbeatReq) GetStats() ContainerStats + func (m *ContainerHeartbeatReq) Marshal() (dAtA []byte, err error) + func (m *ContainerHeartbeatReq) MarshalTo(dAtA []byte) (int, error) + func (m *ContainerHeartbeatReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ContainerHeartbeatReq) Reset() + func (m *ContainerHeartbeatReq) Size() (n int) + func (m *ContainerHeartbeatReq) String() string + func (m *ContainerHeartbeatReq) Unmarshal(dAtA []byte) error + func (m *ContainerHeartbeatReq) XXX_DiscardUnknown() + func (m *ContainerHeartbeatReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerHeartbeatReq) XXX_Merge(src proto.Message) + func (m *ContainerHeartbeatReq) XXX_Size() int + func (m *ContainerHeartbeatReq) XXX_Unmarshal(b []byte) error + type ContainerHeartbeatRsp struct + func (*ContainerHeartbeatRsp) Descriptor() ([]byte, []int) + func (*ContainerHeartbeatRsp) ProtoMessage() + func (m *ContainerHeartbeatRsp) Marshal() (dAtA []byte, err error) + func (m *ContainerHeartbeatRsp) MarshalTo(dAtA []byte) (int, error) + func (m *ContainerHeartbeatRsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ContainerHeartbeatRsp) Reset() + func (m *ContainerHeartbeatRsp) Size() (n int) + func (m *ContainerHeartbeatRsp) String() string + func (m *ContainerHeartbeatRsp) Unmarshal(dAtA []byte) error + func (m *ContainerHeartbeatRsp) XXX_DiscardUnknown() + func (m *ContainerHeartbeatRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerHeartbeatRsp) XXX_Merge(src proto.Message) + func (m *ContainerHeartbeatRsp) XXX_Size() int + func (m *ContainerHeartbeatRsp) XXX_Unmarshal(b []byte) error + type ContainerStats struct + ApplyingSnapCount uint64 + Available uint64 + BytesRead uint64 + BytesWritten uint64 + Capacity uint64 + ContainerID uint64 + CpuUsages []RecordPair + Interval *TimeInterval + IsBusy bool + KeysRead uint64 + KeysWritten uint64 + OpLatencies []RecordPair + ReadIORates []RecordPair + ReceivingSnapCount uint64 + ResourceCount uint64 + SendingSnapCount uint64 + StartTime uint64 + UsedSize uint64 + WriteIORates []RecordPair + func (*ContainerStats) Descriptor() ([]byte, []int) + func (*ContainerStats) ProtoMessage() + func (m *ContainerStats) GetApplyingSnapCount() uint64 + func (m *ContainerStats) GetAvailable() uint64 + func (m *ContainerStats) GetBytesRead() uint64 + func (m *ContainerStats) GetBytesWritten() uint64 + func (m *ContainerStats) GetCapacity() uint64 + func (m *ContainerStats) GetContainerID() uint64 + func (m *ContainerStats) GetCpuUsages() []RecordPair + func (m *ContainerStats) GetInterval() *TimeInterval + func (m *ContainerStats) GetIsBusy() bool + func (m *ContainerStats) GetKeysRead() uint64 + func (m *ContainerStats) GetKeysWritten() uint64 + func (m *ContainerStats) GetOpLatencies() []RecordPair + func (m *ContainerStats) GetReadIORates() []RecordPair + func (m *ContainerStats) GetReceivingSnapCount() uint64 + func (m *ContainerStats) GetResourceCount() uint64 + func (m *ContainerStats) GetSendingSnapCount() uint64 + func (m *ContainerStats) GetStartTime() uint64 + func (m *ContainerStats) GetUsedSize() uint64 + func (m *ContainerStats) GetWriteIORates() []RecordPair + func (m *ContainerStats) Marshal() (dAtA []byte, err error) + func (m *ContainerStats) MarshalTo(dAtA []byte) (int, error) + func (m *ContainerStats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ContainerStats) Reset() + func (m *ContainerStats) Size() (n int) + func (m *ContainerStats) String() string + func (m *ContainerStats) Unmarshal(dAtA []byte) error + func (m *ContainerStats) XXX_DiscardUnknown() + func (m *ContainerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerStats) XXX_Merge(src proto.Message) + func (m *ContainerStats) XXX_Size() int + func (m *ContainerStats) XXX_Unmarshal(b []byte) error + type CreateWatcherReq struct + Flag uint32 + func (*CreateWatcherReq) Descriptor() ([]byte, []int) + func (*CreateWatcherReq) ProtoMessage() + func (m *CreateWatcherReq) GetFlag() uint32 + func (m *CreateWatcherReq) Marshal() (dAtA []byte, err error) + func (m *CreateWatcherReq) MarshalTo(dAtA []byte) (int, error) + func (m *CreateWatcherReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateWatcherReq) Reset() + func (m *CreateWatcherReq) Size() (n int) + func (m *CreateWatcherReq) String() string + func (m *CreateWatcherReq) Unmarshal(dAtA []byte) error + func (m *CreateWatcherReq) XXX_DiscardUnknown() + func (m *CreateWatcherReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateWatcherReq) XXX_Merge(src proto.Message) + func (m *CreateWatcherReq) XXX_Size() int + func (m *CreateWatcherReq) XXX_Unmarshal(b []byte) error + type EventNotify struct + ContainerEvent *ContainerEventData + InitEvent *InitEventData + LeaderChangedEvent *LeaderChangedEventData + ResourceEvent *ResourceEventData + Seq uint64 + Type uint32 + func (*EventNotify) Descriptor() ([]byte, []int) + func (*EventNotify) ProtoMessage() + func (m *EventNotify) GetContainerEvent() *ContainerEventData + func (m *EventNotify) GetInitEvent() *InitEventData + func (m *EventNotify) GetLeaderChangedEvent() *LeaderChangedEventData + func (m *EventNotify) GetResourceEvent() *ResourceEventData + func (m *EventNotify) GetSeq() uint64 + func (m *EventNotify) GetType() uint32 + func (m *EventNotify) Marshal() (dAtA []byte, err error) + func (m *EventNotify) MarshalTo(dAtA []byte) (int, error) + func (m *EventNotify) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventNotify) Reset() + func (m *EventNotify) Size() (n int) + func (m *EventNotify) String() string + func (m *EventNotify) Unmarshal(dAtA []byte) error + func (m *EventNotify) XXX_DiscardUnknown() + func (m *EventNotify) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventNotify) XXX_Merge(src proto.Message) + func (m *EventNotify) XXX_Size() int + func (m *EventNotify) XXX_Unmarshal(b []byte) error + type GetContainerReq struct + ID uint64 + func (*GetContainerReq) Descriptor() ([]byte, []int) + func (*GetContainerReq) ProtoMessage() + func (m *GetContainerReq) GetID() uint64 + func (m *GetContainerReq) Marshal() (dAtA []byte, err error) + func (m *GetContainerReq) MarshalTo(dAtA []byte) (int, error) + func (m *GetContainerReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetContainerReq) Reset() + func (m *GetContainerReq) Size() (n int) + func (m *GetContainerReq) String() string + func (m *GetContainerReq) Unmarshal(dAtA []byte) error + func (m *GetContainerReq) XXX_DiscardUnknown() + func (m *GetContainerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetContainerReq) XXX_Merge(src proto.Message) + func (m *GetContainerReq) XXX_Size() int + func (m *GetContainerReq) XXX_Unmarshal(b []byte) error + type GetContainerRsp struct + Data []byte + Stats *ContainerStats + func (*GetContainerRsp) Descriptor() ([]byte, []int) + func (*GetContainerRsp) ProtoMessage() + func (m *GetContainerRsp) GetData() []byte + func (m *GetContainerRsp) GetStats() *ContainerStats + func (m *GetContainerRsp) Marshal() (dAtA []byte, err error) + func (m *GetContainerRsp) MarshalTo(dAtA []byte) (int, error) + func (m *GetContainerRsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetContainerRsp) Reset() + func (m *GetContainerRsp) Size() (n int) + func (m *GetContainerRsp) String() string + func (m *GetContainerRsp) Unmarshal(dAtA []byte) error + func (m *GetContainerRsp) XXX_DiscardUnknown() + func (m *GetContainerRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetContainerRsp) XXX_Merge(src proto.Message) + func (m *GetContainerRsp) XXX_Size() int + func (m *GetContainerRsp) XXX_Unmarshal(b []byte) error + type GetDCLocationsReq struct + func (*GetDCLocationsReq) Descriptor() ([]byte, []int) + func (*GetDCLocationsReq) ProtoMessage() + func (m *GetDCLocationsReq) Marshal() (dAtA []byte, err error) + func (m *GetDCLocationsReq) MarshalTo(dAtA []byte) (int, error) + func (m *GetDCLocationsReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetDCLocationsReq) Reset() + func (m *GetDCLocationsReq) Size() (n int) + func (m *GetDCLocationsReq) String() string + func (m *GetDCLocationsReq) Unmarshal(dAtA []byte) error + func (m *GetDCLocationsReq) XXX_DiscardUnknown() + func (m *GetDCLocationsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetDCLocationsReq) XXX_Merge(src proto.Message) + func (m *GetDCLocationsReq) XXX_Size() int + func (m *GetDCLocationsReq) XXX_Unmarshal(b []byte) error + type GetDCLocationsRsp struct + DCLocations map[string]int32 + func (*GetDCLocationsRsp) Descriptor() ([]byte, []int) + func (*GetDCLocationsRsp) ProtoMessage() + func (m *GetDCLocationsRsp) GetDCLocations() map[string]int32 + func (m *GetDCLocationsRsp) Marshal() (dAtA []byte, err error) + func (m *GetDCLocationsRsp) MarshalTo(dAtA []byte) (int, error) + func (m *GetDCLocationsRsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetDCLocationsRsp) Reset() + func (m *GetDCLocationsRsp) Size() (n int) + func (m *GetDCLocationsRsp) String() string + func (m *GetDCLocationsRsp) Unmarshal(dAtA []byte) error + func (m *GetDCLocationsRsp) XXX_DiscardUnknown() + func (m *GetDCLocationsRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetDCLocationsRsp) XXX_Merge(src proto.Message) + func (m *GetDCLocationsRsp) XXX_Size() int + func (m *GetDCLocationsRsp) XXX_Unmarshal(b []byte) error + type InitEventData struct + Containers [][]byte + Leaders []uint64 + Resources [][]byte + func (*InitEventData) Descriptor() ([]byte, []int) + func (*InitEventData) ProtoMessage() + func (m *InitEventData) GetContainers() [][]byte + func (m *InitEventData) GetLeaders() []uint64 + func (m *InitEventData) GetResources() [][]byte + func (m *InitEventData) Marshal() (dAtA []byte, err error) + func (m *InitEventData) MarshalTo(dAtA []byte) (int, error) + func (m *InitEventData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *InitEventData) Reset() + func (m *InitEventData) Size() (n int) + func (m *InitEventData) String() string + func (m *InitEventData) Unmarshal(dAtA []byte) error + func (m *InitEventData) XXX_DiscardUnknown() + func (m *InitEventData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *InitEventData) XXX_Merge(src proto.Message) + func (m *InitEventData) XXX_Size() int + func (m *InitEventData) XXX_Unmarshal(b []byte) error + type LeaderChangedEventData struct + LeaderID uint64 + ResourceID uint64 + func (*LeaderChangedEventData) Descriptor() ([]byte, []int) + func (*LeaderChangedEventData) ProtoMessage() + func (m *LeaderChangedEventData) GetLeaderID() uint64 + func (m *LeaderChangedEventData) GetResourceID() uint64 + func (m *LeaderChangedEventData) Marshal() (dAtA []byte, err error) + func (m *LeaderChangedEventData) MarshalTo(dAtA []byte) (int, error) + func (m *LeaderChangedEventData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LeaderChangedEventData) Reset() + func (m *LeaderChangedEventData) Size() (n int) + func (m *LeaderChangedEventData) String() string + func (m *LeaderChangedEventData) Unmarshal(dAtA []byte) error + func (m *LeaderChangedEventData) XXX_DiscardUnknown() + func (m *LeaderChangedEventData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LeaderChangedEventData) XXX_Merge(src proto.Message) + func (m *LeaderChangedEventData) XXX_Size() int + func (m *LeaderChangedEventData) XXX_Unmarshal(b []byte) error + type Merge struct + Target []byte + func (*Merge) Descriptor() ([]byte, []int) + func (*Merge) ProtoMessage() + func (m *Merge) GetTarget() []byte + func (m *Merge) Marshal() (dAtA []byte, err error) + func (m *Merge) MarshalTo(dAtA []byte) (int, error) + func (m *Merge) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Merge) Reset() + func (m *Merge) Size() (n int) + func (m *Merge) String() string + func (m *Merge) Unmarshal(dAtA []byte) error + func (m *Merge) XXX_DiscardUnknown() + func (m *Merge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Merge) XXX_Merge(src proto.Message) + func (m *Merge) XXX_Size() int + func (m *Merge) XXX_Unmarshal(b []byte) error + type RecordPair struct + Key string + Value uint64 + func (*RecordPair) Descriptor() ([]byte, []int) + func (*RecordPair) ProtoMessage() + func (m *RecordPair) GetKey() string + func (m *RecordPair) GetValue() uint64 + func (m *RecordPair) Marshal() (dAtA []byte, err error) + func (m *RecordPair) MarshalTo(dAtA []byte) (int, error) + func (m *RecordPair) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RecordPair) Reset() + func (m *RecordPair) Size() (n int) + func (m *RecordPair) String() string + func (m *RecordPair) Unmarshal(dAtA []byte) error + func (m *RecordPair) XXX_DiscardUnknown() + func (m *RecordPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RecordPair) XXX_Merge(src proto.Message) + func (m *RecordPair) XXX_Size() int + func (m *RecordPair) XXX_Unmarshal(b []byte) error + type ReportSplitReq struct + Left []byte + Right []byte + func (*ReportSplitReq) Descriptor() ([]byte, []int) + func (*ReportSplitReq) ProtoMessage() + func (m *ReportSplitReq) GetLeft() []byte + func (m *ReportSplitReq) GetRight() []byte + func (m *ReportSplitReq) Marshal() (dAtA []byte, err error) + func (m *ReportSplitReq) MarshalTo(dAtA []byte) (int, error) + func (m *ReportSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReportSplitReq) Reset() + func (m *ReportSplitReq) Size() (n int) + func (m *ReportSplitReq) String() string + func (m *ReportSplitReq) Unmarshal(dAtA []byte) error + func (m *ReportSplitReq) XXX_DiscardUnknown() + func (m *ReportSplitReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReportSplitReq) XXX_Merge(src proto.Message) + func (m *ReportSplitReq) XXX_Size() int + func (m *ReportSplitReq) XXX_Unmarshal(b []byte) error + type ReportSplitRsp struct + func (*ReportSplitRsp) Descriptor() ([]byte, []int) + func (*ReportSplitRsp) ProtoMessage() + func (m *ReportSplitRsp) Marshal() (dAtA []byte, err error) + func (m *ReportSplitRsp) MarshalTo(dAtA []byte) (int, error) + func (m *ReportSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReportSplitRsp) Reset() + func (m *ReportSplitRsp) Size() (n int) + func (m *ReportSplitRsp) String() string + func (m *ReportSplitRsp) Unmarshal(dAtA []byte) error + func (m *ReportSplitRsp) XXX_DiscardUnknown() + func (m *ReportSplitRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReportSplitRsp) XXX_Merge(src proto.Message) + func (m *ReportSplitRsp) XXX_Size() int + func (m *ReportSplitRsp) XXX_Unmarshal(b []byte) error + type Request struct + AllocID AllocIDReq + AskBatchSplit AskBatchSplitReq + AskSplit AskSplitReq + BatchReportSplit BatchReportSplitReq + ContainerHeartbeat ContainerHeartbeatReq + ContainerID uint64 + CreateWatcher CreateWatcherReq + GetContainer GetContainerReq + GetDCLocations GetDCLocationsReq + ID uint64 + ReportSplit ReportSplitReq + ResourceHeartbeat ResourceHeartbeatReq + TSO TSOReq + Type Type + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetAllocID() AllocIDReq + func (m *Request) GetAskBatchSplit() AskBatchSplitReq + func (m *Request) GetAskSplit() AskSplitReq + func (m *Request) GetBatchReportSplit() BatchReportSplitReq + func (m *Request) GetContainerHeartbeat() ContainerHeartbeatReq + func (m *Request) GetContainerID() uint64 + func (m *Request) GetCreateWatcher() CreateWatcherReq + func (m *Request) GetGetContainer() GetContainerReq + func (m *Request) GetGetDCLocations() GetDCLocationsReq + func (m *Request) GetID() uint64 + func (m *Request) GetReportSplit() ReportSplitReq + func (m *Request) GetResourceHeartbeat() ResourceHeartbeatReq + func (m *Request) GetTSO() TSOReq + func (m *Request) GetType() Type + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type ResourceEventData struct + Data []byte + func (*ResourceEventData) Descriptor() ([]byte, []int) + func (*ResourceEventData) ProtoMessage() + func (m *ResourceEventData) GetData() []byte + func (m *ResourceEventData) Marshal() (dAtA []byte, err error) + func (m *ResourceEventData) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceEventData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceEventData) Reset() + func (m *ResourceEventData) Size() (n int) + func (m *ResourceEventData) String() string + func (m *ResourceEventData) Unmarshal(dAtA []byte) error + func (m *ResourceEventData) XXX_DiscardUnknown() + func (m *ResourceEventData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceEventData) XXX_Merge(src proto.Message) + func (m *ResourceEventData) XXX_Size() int + func (m *ResourceEventData) XXX_Unmarshal(b []byte) error + type ResourceHeartbeatReq struct + ApproximateKeys uint64 + ApproximateSize uint64 + BytesRead uint64 + BytesWritten uint64 + ContainerID uint64 + DownPeers []metapb.PeerStats + Interval *TimeInterval + KeysRead uint64 + KeysWritten uint64 + Leader *metapb.Peer + PendingPeers []metapb.Peer + Resource []byte + Term uint64 + func (*ResourceHeartbeatReq) Descriptor() ([]byte, []int) + func (*ResourceHeartbeatReq) ProtoMessage() + func (m *ResourceHeartbeatReq) GetApproximateKeys() uint64 + func (m *ResourceHeartbeatReq) GetApproximateSize() uint64 + func (m *ResourceHeartbeatReq) GetBytesRead() uint64 + func (m *ResourceHeartbeatReq) GetBytesWritten() uint64 + func (m *ResourceHeartbeatReq) GetContainerID() uint64 + func (m *ResourceHeartbeatReq) GetDownPeers() []metapb.PeerStats + func (m *ResourceHeartbeatReq) GetInterval() *TimeInterval + func (m *ResourceHeartbeatReq) GetKeysRead() uint64 + func (m *ResourceHeartbeatReq) GetKeysWritten() uint64 + func (m *ResourceHeartbeatReq) GetLeader() *metapb.Peer + func (m *ResourceHeartbeatReq) GetPendingPeers() []metapb.Peer + func (m *ResourceHeartbeatReq) GetResource() []byte + func (m *ResourceHeartbeatReq) GetTerm() uint64 + func (m *ResourceHeartbeatReq) Marshal() (dAtA []byte, err error) + func (m *ResourceHeartbeatReq) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceHeartbeatReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceHeartbeatReq) Reset() + func (m *ResourceHeartbeatReq) Size() (n int) + func (m *ResourceHeartbeatReq) String() string + func (m *ResourceHeartbeatReq) Unmarshal(dAtA []byte) error + func (m *ResourceHeartbeatReq) XXX_DiscardUnknown() + func (m *ResourceHeartbeatReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceHeartbeatReq) XXX_Merge(src proto.Message) + func (m *ResourceHeartbeatReq) XXX_Size() int + func (m *ResourceHeartbeatReq) XXX_Unmarshal(b []byte) error + type ResourceHeartbeatRsp struct + ChangePeer *ChangePeer + ChangePeerV2 *ChangePeerV2 + Merge *Merge + ResourceEpoch metapb.ResourceEpoch + ResourceID uint64 + SplitResource *SplitResource + TargetPeer *metapb.Peer + TransferLeader *TransferLeader + func (*ResourceHeartbeatRsp) Descriptor() ([]byte, []int) + func (*ResourceHeartbeatRsp) ProtoMessage() + func (m *ResourceHeartbeatRsp) GetChangePeer() *ChangePeer + func (m *ResourceHeartbeatRsp) GetChangePeerV2() *ChangePeerV2 + func (m *ResourceHeartbeatRsp) GetMerge() *Merge + func (m *ResourceHeartbeatRsp) GetResourceEpoch() metapb.ResourceEpoch + func (m *ResourceHeartbeatRsp) GetResourceID() uint64 + func (m *ResourceHeartbeatRsp) GetSplitResource() *SplitResource + func (m *ResourceHeartbeatRsp) GetTargetPeer() *metapb.Peer + func (m *ResourceHeartbeatRsp) GetTransferLeader() *TransferLeader + func (m *ResourceHeartbeatRsp) Marshal() (dAtA []byte, err error) + func (m *ResourceHeartbeatRsp) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceHeartbeatRsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceHeartbeatRsp) Reset() + func (m *ResourceHeartbeatRsp) Size() (n int) + func (m *ResourceHeartbeatRsp) String() string + func (m *ResourceHeartbeatRsp) Unmarshal(dAtA []byte) error + func (m *ResourceHeartbeatRsp) XXX_DiscardUnknown() + func (m *ResourceHeartbeatRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceHeartbeatRsp) XXX_Merge(src proto.Message) + func (m *ResourceHeartbeatRsp) XXX_Size() int + func (m *ResourceHeartbeatRsp) XXX_Unmarshal(b []byte) error + type Response struct + AllocID AllocIDRsp + AskBatchSplit AskBatchSplitRsp + AskSplit AskSplitRsp + BatchReportSplit BatchReportSplitRsp + ContainerHeartbeat ContainerHeartbeatRsp + Error string + Event EventNotify + GetContainer GetContainerRsp + GetDCLocations GetDCLocationsRsp + ID uint64 + Leader string + ReportSplit ReportSplitRsp + ResourceHeartbeat ResourceHeartbeatRsp + TSO TSORsp + Type Type + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetAllocID() AllocIDRsp + func (m *Response) GetAskBatchSplit() AskBatchSplitRsp + func (m *Response) GetAskSplit() AskSplitRsp + func (m *Response) GetBatchReportSplit() BatchReportSplitRsp + func (m *Response) GetContainerHeartbeat() ContainerHeartbeatRsp + func (m *Response) GetError() string + func (m *Response) GetEvent() EventNotify + func (m *Response) GetGetContainer() GetContainerRsp + func (m *Response) GetGetDCLocations() GetDCLocationsRsp + func (m *Response) GetID() uint64 + func (m *Response) GetLeader() string + func (m *Response) GetReportSplit() ReportSplitRsp + func (m *Response) GetResourceHeartbeat() ResourceHeartbeatRsp + func (m *Response) GetTSO() TSORsp + func (m *Response) GetType() Type + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type SplitID struct + NewID uint64 + NewPeerIDs []uint64 + func (*SplitID) Descriptor() ([]byte, []int) + func (*SplitID) ProtoMessage() + func (m *SplitID) GetNewID() uint64 + func (m *SplitID) GetNewPeerIDs() []uint64 + func (m *SplitID) Marshal() (dAtA []byte, err error) + func (m *SplitID) MarshalTo(dAtA []byte) (int, error) + func (m *SplitID) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SplitID) Reset() + func (m *SplitID) Size() (n int) + func (m *SplitID) String() string + func (m *SplitID) Unmarshal(dAtA []byte) error + func (m *SplitID) XXX_DiscardUnknown() + func (m *SplitID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SplitID) XXX_Merge(src proto.Message) + func (m *SplitID) XXX_Size() int + func (m *SplitID) XXX_Unmarshal(b []byte) error + type SplitResource struct + Keys [][]byte + Policy metapb.CheckPolicy + func (*SplitResource) Descriptor() ([]byte, []int) + func (*SplitResource) ProtoMessage() + func (m *SplitResource) GetKeys() [][]byte + func (m *SplitResource) GetPolicy() metapb.CheckPolicy + func (m *SplitResource) Marshal() (dAtA []byte, err error) + func (m *SplitResource) MarshalTo(dAtA []byte) (int, error) + func (m *SplitResource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SplitResource) Reset() + func (m *SplitResource) Size() (n int) + func (m *SplitResource) String() string + func (m *SplitResource) Unmarshal(dAtA []byte) error + func (m *SplitResource) XXX_DiscardUnknown() + func (m *SplitResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SplitResource) XXX_Merge(src proto.Message) + func (m *SplitResource) XXX_Size() int + func (m *SplitResource) XXX_Unmarshal(b []byte) error + type TSOReq struct + Count uint32 + func (*TSOReq) Descriptor() ([]byte, []int) + func (*TSOReq) ProtoMessage() + func (m *TSOReq) GetCount() uint32 + func (m *TSOReq) Marshal() (dAtA []byte, err error) + func (m *TSOReq) MarshalTo(dAtA []byte) (int, error) + func (m *TSOReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TSOReq) Reset() + func (m *TSOReq) Size() (n int) + func (m *TSOReq) String() string + func (m *TSOReq) Unmarshal(dAtA []byte) error + func (m *TSOReq) XXX_DiscardUnknown() + func (m *TSOReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TSOReq) XXX_Merge(src proto.Message) + func (m *TSOReq) XXX_Size() int + func (m *TSOReq) XXX_Unmarshal(b []byte) error + type TSORsp struct + Count uint32 + Timestamp *metapb.Timestamp + func (*TSORsp) Descriptor() ([]byte, []int) + func (*TSORsp) ProtoMessage() + func (m *TSORsp) GetCount() uint32 + func (m *TSORsp) GetTimestamp() *metapb.Timestamp + func (m *TSORsp) Marshal() (dAtA []byte, err error) + func (m *TSORsp) MarshalTo(dAtA []byte) (int, error) + func (m *TSORsp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TSORsp) Reset() + func (m *TSORsp) Size() (n int) + func (m *TSORsp) String() string + func (m *TSORsp) Unmarshal(dAtA []byte) error + func (m *TSORsp) XXX_DiscardUnknown() + func (m *TSORsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TSORsp) XXX_Merge(src proto.Message) + func (m *TSORsp) XXX_Size() int + func (m *TSORsp) XXX_Unmarshal(b []byte) error + type TimeInterval struct + End uint64 + Start uint64 + func (*TimeInterval) Descriptor() ([]byte, []int) + func (*TimeInterval) ProtoMessage() + func (m *TimeInterval) GetEnd() uint64 + func (m *TimeInterval) GetStart() uint64 + func (m *TimeInterval) Marshal() (dAtA []byte, err error) + func (m *TimeInterval) MarshalTo(dAtA []byte) (int, error) + func (m *TimeInterval) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TimeInterval) Reset() + func (m *TimeInterval) Size() (n int) + func (m *TimeInterval) String() string + func (m *TimeInterval) Unmarshal(dAtA []byte) error + func (m *TimeInterval) XXX_DiscardUnknown() + func (m *TimeInterval) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeInterval) XXX_Merge(src proto.Message) + func (m *TimeInterval) XXX_Size() int + func (m *TimeInterval) XXX_Unmarshal(b []byte) error + type TransferLeader struct + Peer metapb.Peer + func (*TransferLeader) Descriptor() ([]byte, []int) + func (*TransferLeader) ProtoMessage() + func (m *TransferLeader) GetPeer() metapb.Peer + func (m *TransferLeader) Marshal() (dAtA []byte, err error) + func (m *TransferLeader) MarshalTo(dAtA []byte) (int, error) + func (m *TransferLeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TransferLeader) Reset() + func (m *TransferLeader) Size() (n int) + func (m *TransferLeader) String() string + func (m *TransferLeader) Unmarshal(dAtA []byte) error + func (m *TransferLeader) XXX_DiscardUnknown() + func (m *TransferLeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TransferLeader) XXX_Merge(src proto.Message) + func (m *TransferLeader) XXX_Size() int + func (m *TransferLeader) XXX_Unmarshal(b []byte) error + type Type int32 + const TypeAllocIDReq + const TypeAllocIDRsp + const TypeAskBatchSplitReq + const TypeAskBatchSplitRsp + const TypeAskSplitReq + const TypeAskSplitRsp + const TypeBatchReportSplitReq + const TypeBatchReportSplitRsp + const TypeContainerHeartbeatReq + const TypeContainerHeartbeatRsp + const TypeCreateWatcherReq + const TypeEventNotify + const TypeGetContainerReq + const TypeGetContainerRsp + const TypeGetDCLocationsReq + const TypeGetDCLocationsRsp + const TypeReportSplitReq + const TypeReportSplitRsp + const TypeResourceHeartbeatReq + const TypeResourceHeartbeatRsp + const TypeTSOReq + const TypeTSORsp + func (Type) EnumDescriptor() ([]byte, []int) + func (x Type) String() string