Documentation ¶
Index ¶
- Variables
- type AllocIDReq
- func (*AllocIDReq) Descriptor() ([]byte, []int)
- 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 (*AllocIDReq) ProtoMessage()
- 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
- func (*AllocIDRsp) Descriptor() ([]byte, []int)
- 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 (*AllocIDRsp) ProtoMessage()
- 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
- func (*AskBatchSplitReq) Descriptor() ([]byte, []int)
- 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 (*AskBatchSplitReq) ProtoMessage()
- 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
- func (*AskBatchSplitRsp) Descriptor() ([]byte, []int)
- 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 (*AskBatchSplitRsp) ProtoMessage()
- 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
- func (*AskSplitReq) Descriptor() ([]byte, []int)
- 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 (*AskSplitReq) ProtoMessage()
- 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
- func (*AskSplitRsp) Descriptor() ([]byte, []int)
- 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 (*AskSplitRsp) ProtoMessage()
- 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
- func (*BatchReportSplitReq) Descriptor() ([]byte, []int)
- 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 (*BatchReportSplitReq) ProtoMessage()
- 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
- func (*BatchReportSplitRsp) Descriptor() ([]byte, []int)
- 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 (*BatchReportSplitRsp) ProtoMessage()
- 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
- func (*ChangePeer) Descriptor() ([]byte, []int)
- 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 (*ChangePeer) ProtoMessage()
- 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
- func (*ChangePeerV2) Descriptor() ([]byte, []int)
- 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 (*ChangePeerV2) ProtoMessage()
- 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
- func (*ContainerEventData) Descriptor() ([]byte, []int)
- 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 (*ContainerEventData) ProtoMessage()
- 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
- func (*ContainerHeartbeatReq) Descriptor() ([]byte, []int)
- 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 (*ContainerHeartbeatReq) ProtoMessage()
- 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
- func (*ContainerHeartbeatRsp) Descriptor() ([]byte, []int)
- 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 (*ContainerHeartbeatRsp) ProtoMessage()
- 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
- func (*ContainerStats) Descriptor() ([]byte, []int)
- 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 (*ContainerStats) ProtoMessage()
- 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
- func (*CreateWatcherReq) Descriptor() ([]byte, []int)
- 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 (*CreateWatcherReq) ProtoMessage()
- 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
- func (*EventNotify) Descriptor() ([]byte, []int)
- 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 (*EventNotify) ProtoMessage()
- 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
- func (*GetContainerReq) Descriptor() ([]byte, []int)
- 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 (*GetContainerReq) ProtoMessage()
- 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
- func (*GetContainerRsp) Descriptor() ([]byte, []int)
- 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 (*GetContainerRsp) ProtoMessage()
- 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
- func (*GetDCLocationsReq) Descriptor() ([]byte, []int)
- 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 (*GetDCLocationsReq) ProtoMessage()
- 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
- func (*GetDCLocationsRsp) Descriptor() ([]byte, []int)
- 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 (*GetDCLocationsRsp) ProtoMessage()
- 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
- func (*InitEventData) Descriptor() ([]byte, []int)
- 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 (*InitEventData) ProtoMessage()
- 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
- func (*LeaderChangedEventData) Descriptor() ([]byte, []int)
- 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 (*LeaderChangedEventData) ProtoMessage()
- 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
- func (*Merge) Descriptor() ([]byte, []int)
- 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 (*Merge) ProtoMessage()
- 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
- func (*RecordPair) Descriptor() ([]byte, []int)
- 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 (*RecordPair) ProtoMessage()
- 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
- func (*ReportSplitReq) Descriptor() ([]byte, []int)
- 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 (*ReportSplitReq) ProtoMessage()
- 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
- func (*ReportSplitRsp) Descriptor() ([]byte, []int)
- 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 (*ReportSplitRsp) ProtoMessage()
- 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
- func (*Request) Descriptor() ([]byte, []int)
- 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 (*Request) ProtoMessage()
- 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
- func (*ResourceEventData) Descriptor() ([]byte, []int)
- 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 (*ResourceEventData) ProtoMessage()
- 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
- func (*ResourceHeartbeatReq) Descriptor() ([]byte, []int)
- 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 (*ResourceHeartbeatReq) ProtoMessage()
- 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
- func (*ResourceHeartbeatRsp) Descriptor() ([]byte, []int)
- 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 (*ResourceHeartbeatRsp) ProtoMessage()
- 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
- func (*Response) Descriptor() ([]byte, []int)
- 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 (*Response) ProtoMessage()
- 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
- func (*SplitID) Descriptor() ([]byte, []int)
- 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 (*SplitID) ProtoMessage()
- 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
- func (*SplitResource) Descriptor() ([]byte, []int)
- 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 (*SplitResource) ProtoMessage()
- 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
- func (*TSOReq) Descriptor() ([]byte, []int)
- 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 (*TSOReq) ProtoMessage()
- 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
- func (*TSORsp) Descriptor() ([]byte, []int)
- 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 (*TSORsp) ProtoMessage()
- 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
- func (*TimeInterval) Descriptor() ([]byte, []int)
- 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 (*TimeInterval) ProtoMessage()
- 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
- func (*TransferLeader) Descriptor() ([]byte, []int)
- 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 (*TransferLeader) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthRpcpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRpcpb = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupRpcpb = fmt.Errorf("proto: unexpected end of group") )
var Type_name = map[int32]string{
0: "TypeResourceHeartbeatReq",
1: "TypeResourceHeartbeatRsp",
2: "TypeContainerHeartbeatReq",
3: "TypeContainerHeartbeatRsp",
4: "TypeGetContainerReq",
5: "TypeGetContainerRsp",
6: "TypeAllocIDReq",
7: "TypeAllocIDRsp",
8: "TypeAskSplitReq",
9: "TypeAskSplitRsp",
10: "TypeAskBatchSplitReq",
11: "TypeAskBatchSplitRsp",
12: "TypeReportSplitReq",
13: "TypeReportSplitRsp",
14: "TypeBatchReportSplitReq",
15: "TypeBatchReportSplitRsp",
16: "TypeTSOReq",
17: "TypeTSORsp",
18: "TypeCreateWatcherReq",
19: "TypeEventNotify",
20: "TypeGetDCLocationsReq",
21: "TypeGetDCLocationsRsp",
}
var Type_value = map[string]int32{
"TypeResourceHeartbeatReq": 0,
"TypeResourceHeartbeatRsp": 1,
"TypeContainerHeartbeatReq": 2,
"TypeContainerHeartbeatRsp": 3,
"TypeGetContainerReq": 4,
"TypeGetContainerRsp": 5,
"TypeAllocIDReq": 6,
"TypeAllocIDRsp": 7,
"TypeAskSplitReq": 8,
"TypeAskSplitRsp": 9,
"TypeAskBatchSplitReq": 10,
"TypeAskBatchSplitRsp": 11,
"TypeReportSplitReq": 12,
"TypeReportSplitRsp": 13,
"TypeBatchReportSplitReq": 14,
"TypeBatchReportSplitRsp": 15,
"TypeTSOReq": 16,
"TypeTSORsp": 17,
"TypeCreateWatcherReq": 18,
"TypeEventNotify": 19,
"TypeGetDCLocationsReq": 20,
"TypeGetDCLocationsRsp": 21,
}
Functions ¶
This section is empty.
Types ¶
type AllocIDReq ¶
type AllocIDReq struct { }
AllocIDReq alloc id request
func (*AllocIDReq) Descriptor ¶
func (*AllocIDReq) Descriptor() ([]byte, []int)
func (*AllocIDReq) Marshal ¶
func (m *AllocIDReq) Marshal() (dAtA []byte, err error)
func (*AllocIDReq) MarshalToSizedBuffer ¶
func (m *AllocIDReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AllocIDReq) ProtoMessage ¶
func (*AllocIDReq) ProtoMessage()
func (*AllocIDReq) Reset ¶
func (m *AllocIDReq) Reset()
func (*AllocIDReq) Size ¶
func (m *AllocIDReq) Size() (n int)
func (*AllocIDReq) String ¶
func (m *AllocIDReq) String() string
func (*AllocIDReq) Unmarshal ¶
func (m *AllocIDReq) Unmarshal(dAtA []byte) error
func (*AllocIDReq) XXX_DiscardUnknown ¶
func (m *AllocIDReq) XXX_DiscardUnknown()
func (*AllocIDReq) XXX_Marshal ¶
func (m *AllocIDReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AllocIDReq) XXX_Merge ¶
func (m *AllocIDReq) XXX_Merge(src proto.Message)
func (*AllocIDReq) XXX_Size ¶
func (m *AllocIDReq) XXX_Size() int
func (*AllocIDReq) XXX_Unmarshal ¶
func (m *AllocIDReq) XXX_Unmarshal(b []byte) error
type AllocIDRsp ¶
type AllocIDRsp struct {
ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
AllocIDRsp alloc id response
func (*AllocIDRsp) Descriptor ¶
func (*AllocIDRsp) Descriptor() ([]byte, []int)
func (*AllocIDRsp) GetID ¶
func (m *AllocIDRsp) GetID() uint64
func (*AllocIDRsp) Marshal ¶
func (m *AllocIDRsp) Marshal() (dAtA []byte, err error)
func (*AllocIDRsp) MarshalToSizedBuffer ¶
func (m *AllocIDRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AllocIDRsp) ProtoMessage ¶
func (*AllocIDRsp) ProtoMessage()
func (*AllocIDRsp) Reset ¶
func (m *AllocIDRsp) Reset()
func (*AllocIDRsp) Size ¶
func (m *AllocIDRsp) Size() (n int)
func (*AllocIDRsp) String ¶
func (m *AllocIDRsp) String() string
func (*AllocIDRsp) Unmarshal ¶
func (m *AllocIDRsp) Unmarshal(dAtA []byte) error
func (*AllocIDRsp) XXX_DiscardUnknown ¶
func (m *AllocIDRsp) XXX_DiscardUnknown()
func (*AllocIDRsp) XXX_Marshal ¶
func (m *AllocIDRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AllocIDRsp) XXX_Merge ¶
func (m *AllocIDRsp) XXX_Merge(src proto.Message)
func (*AllocIDRsp) XXX_Size ¶
func (m *AllocIDRsp) XXX_Size() int
func (*AllocIDRsp) XXX_Unmarshal ¶
func (m *AllocIDRsp) XXX_Unmarshal(b []byte) error
type AskBatchSplitReq ¶
type AskBatchSplitReq struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Count uint32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` }
AskBatchSplitReq ask batch split request
func (*AskBatchSplitReq) Descriptor ¶
func (*AskBatchSplitReq) Descriptor() ([]byte, []int)
func (*AskBatchSplitReq) GetCount ¶
func (m *AskBatchSplitReq) GetCount() uint32
func (*AskBatchSplitReq) GetData ¶
func (m *AskBatchSplitReq) GetData() []byte
func (*AskBatchSplitReq) Marshal ¶
func (m *AskBatchSplitReq) Marshal() (dAtA []byte, err error)
func (*AskBatchSplitReq) MarshalToSizedBuffer ¶
func (m *AskBatchSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AskBatchSplitReq) ProtoMessage ¶
func (*AskBatchSplitReq) ProtoMessage()
func (*AskBatchSplitReq) Reset ¶
func (m *AskBatchSplitReq) Reset()
func (*AskBatchSplitReq) Size ¶
func (m *AskBatchSplitReq) Size() (n int)
func (*AskBatchSplitReq) String ¶
func (m *AskBatchSplitReq) String() string
func (*AskBatchSplitReq) Unmarshal ¶
func (m *AskBatchSplitReq) Unmarshal(dAtA []byte) error
func (*AskBatchSplitReq) XXX_DiscardUnknown ¶
func (m *AskBatchSplitReq) XXX_DiscardUnknown()
func (*AskBatchSplitReq) XXX_Marshal ¶
func (m *AskBatchSplitReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AskBatchSplitReq) XXX_Merge ¶
func (m *AskBatchSplitReq) XXX_Merge(src proto.Message)
func (*AskBatchSplitReq) XXX_Size ¶
func (m *AskBatchSplitReq) XXX_Size() int
func (*AskBatchSplitReq) XXX_Unmarshal ¶
func (m *AskBatchSplitReq) XXX_Unmarshal(b []byte) error
type AskBatchSplitRsp ¶
type AskBatchSplitRsp struct {
SplitIDs []SplitID `protobuf:"bytes,1,rep,name=splitIDs,proto3" json:"splitIDs"`
}
AskBatchSplitRsp ask batch split response
func (*AskBatchSplitRsp) Descriptor ¶
func (*AskBatchSplitRsp) Descriptor() ([]byte, []int)
func (*AskBatchSplitRsp) GetSplitIDs ¶
func (m *AskBatchSplitRsp) GetSplitIDs() []SplitID
func (*AskBatchSplitRsp) Marshal ¶
func (m *AskBatchSplitRsp) Marshal() (dAtA []byte, err error)
func (*AskBatchSplitRsp) MarshalToSizedBuffer ¶
func (m *AskBatchSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AskBatchSplitRsp) ProtoMessage ¶
func (*AskBatchSplitRsp) ProtoMessage()
func (*AskBatchSplitRsp) Reset ¶
func (m *AskBatchSplitRsp) Reset()
func (*AskBatchSplitRsp) Size ¶
func (m *AskBatchSplitRsp) Size() (n int)
func (*AskBatchSplitRsp) String ¶
func (m *AskBatchSplitRsp) String() string
func (*AskBatchSplitRsp) Unmarshal ¶
func (m *AskBatchSplitRsp) Unmarshal(dAtA []byte) error
func (*AskBatchSplitRsp) XXX_DiscardUnknown ¶
func (m *AskBatchSplitRsp) XXX_DiscardUnknown()
func (*AskBatchSplitRsp) XXX_Marshal ¶
func (m *AskBatchSplitRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AskBatchSplitRsp) XXX_Merge ¶
func (m *AskBatchSplitRsp) XXX_Merge(src proto.Message)
func (*AskBatchSplitRsp) XXX_Size ¶
func (m *AskBatchSplitRsp) XXX_Size() int
func (*AskBatchSplitRsp) XXX_Unmarshal ¶
func (m *AskBatchSplitRsp) XXX_Unmarshal(b []byte) error
type AskSplitReq ¶
type AskSplitReq struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
AskSplitReq ask split request
func (*AskSplitReq) Descriptor ¶
func (*AskSplitReq) Descriptor() ([]byte, []int)
func (*AskSplitReq) GetData ¶
func (m *AskSplitReq) GetData() []byte
func (*AskSplitReq) Marshal ¶
func (m *AskSplitReq) Marshal() (dAtA []byte, err error)
func (*AskSplitReq) MarshalToSizedBuffer ¶
func (m *AskSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AskSplitReq) ProtoMessage ¶
func (*AskSplitReq) ProtoMessage()
func (*AskSplitReq) Reset ¶
func (m *AskSplitReq) Reset()
func (*AskSplitReq) Size ¶
func (m *AskSplitReq) Size() (n int)
func (*AskSplitReq) String ¶
func (m *AskSplitReq) String() string
func (*AskSplitReq) Unmarshal ¶
func (m *AskSplitReq) Unmarshal(dAtA []byte) error
func (*AskSplitReq) XXX_DiscardUnknown ¶
func (m *AskSplitReq) XXX_DiscardUnknown()
func (*AskSplitReq) XXX_Marshal ¶
func (m *AskSplitReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AskSplitReq) XXX_Merge ¶
func (m *AskSplitReq) XXX_Merge(src proto.Message)
func (*AskSplitReq) XXX_Size ¶
func (m *AskSplitReq) XXX_Size() int
func (*AskSplitReq) XXX_Unmarshal ¶
func (m *AskSplitReq) XXX_Unmarshal(b []byte) error
type AskSplitRsp ¶
type AskSplitRsp struct {
SplitID SplitID `protobuf:"bytes,1,opt,name=splitID,proto3" json:"splitID"`
}
AskSplitRsp ask split response
func (*AskSplitRsp) Descriptor ¶
func (*AskSplitRsp) Descriptor() ([]byte, []int)
func (*AskSplitRsp) GetSplitID ¶
func (m *AskSplitRsp) GetSplitID() SplitID
func (*AskSplitRsp) Marshal ¶
func (m *AskSplitRsp) Marshal() (dAtA []byte, err error)
func (*AskSplitRsp) MarshalToSizedBuffer ¶
func (m *AskSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AskSplitRsp) ProtoMessage ¶
func (*AskSplitRsp) ProtoMessage()
func (*AskSplitRsp) Reset ¶
func (m *AskSplitRsp) Reset()
func (*AskSplitRsp) Size ¶
func (m *AskSplitRsp) Size() (n int)
func (*AskSplitRsp) String ¶
func (m *AskSplitRsp) String() string
func (*AskSplitRsp) Unmarshal ¶
func (m *AskSplitRsp) Unmarshal(dAtA []byte) error
func (*AskSplitRsp) XXX_DiscardUnknown ¶
func (m *AskSplitRsp) XXX_DiscardUnknown()
func (*AskSplitRsp) XXX_Marshal ¶
func (m *AskSplitRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AskSplitRsp) XXX_Merge ¶
func (m *AskSplitRsp) XXX_Merge(src proto.Message)
func (*AskSplitRsp) XXX_Size ¶
func (m *AskSplitRsp) XXX_Size() int
func (*AskSplitRsp) XXX_Unmarshal ¶
func (m *AskSplitRsp) XXX_Unmarshal(b []byte) error
type BatchReportSplitReq ¶
type BatchReportSplitReq struct {
Resources [][]byte `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
}
BatchReportSplitReq report split request
func (*BatchReportSplitReq) Descriptor ¶
func (*BatchReportSplitReq) Descriptor() ([]byte, []int)
func (*BatchReportSplitReq) GetResources ¶
func (m *BatchReportSplitReq) GetResources() [][]byte
func (*BatchReportSplitReq) Marshal ¶
func (m *BatchReportSplitReq) Marshal() (dAtA []byte, err error)
func (*BatchReportSplitReq) MarshalTo ¶
func (m *BatchReportSplitReq) MarshalTo(dAtA []byte) (int, error)
func (*BatchReportSplitReq) MarshalToSizedBuffer ¶
func (m *BatchReportSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BatchReportSplitReq) ProtoMessage ¶
func (*BatchReportSplitReq) ProtoMessage()
func (*BatchReportSplitReq) Reset ¶
func (m *BatchReportSplitReq) Reset()
func (*BatchReportSplitReq) Size ¶
func (m *BatchReportSplitReq) Size() (n int)
func (*BatchReportSplitReq) String ¶
func (m *BatchReportSplitReq) String() string
func (*BatchReportSplitReq) Unmarshal ¶
func (m *BatchReportSplitReq) Unmarshal(dAtA []byte) error
func (*BatchReportSplitReq) XXX_DiscardUnknown ¶
func (m *BatchReportSplitReq) XXX_DiscardUnknown()
func (*BatchReportSplitReq) XXX_Marshal ¶
func (m *BatchReportSplitReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BatchReportSplitReq) XXX_Merge ¶
func (m *BatchReportSplitReq) XXX_Merge(src proto.Message)
func (*BatchReportSplitReq) XXX_Size ¶
func (m *BatchReportSplitReq) XXX_Size() int
func (*BatchReportSplitReq) XXX_Unmarshal ¶
func (m *BatchReportSplitReq) XXX_Unmarshal(b []byte) error
type BatchReportSplitRsp ¶
type BatchReportSplitRsp struct { }
BatchReportSplitRsp report split response
func (*BatchReportSplitRsp) Descriptor ¶
func (*BatchReportSplitRsp) Descriptor() ([]byte, []int)
func (*BatchReportSplitRsp) Marshal ¶
func (m *BatchReportSplitRsp) Marshal() (dAtA []byte, err error)
func (*BatchReportSplitRsp) MarshalTo ¶
func (m *BatchReportSplitRsp) MarshalTo(dAtA []byte) (int, error)
func (*BatchReportSplitRsp) MarshalToSizedBuffer ¶
func (m *BatchReportSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BatchReportSplitRsp) ProtoMessage ¶
func (*BatchReportSplitRsp) ProtoMessage()
func (*BatchReportSplitRsp) Reset ¶
func (m *BatchReportSplitRsp) Reset()
func (*BatchReportSplitRsp) Size ¶
func (m *BatchReportSplitRsp) Size() (n int)
func (*BatchReportSplitRsp) String ¶
func (m *BatchReportSplitRsp) String() string
func (*BatchReportSplitRsp) Unmarshal ¶
func (m *BatchReportSplitRsp) Unmarshal(dAtA []byte) error
func (*BatchReportSplitRsp) XXX_DiscardUnknown ¶
func (m *BatchReportSplitRsp) XXX_DiscardUnknown()
func (*BatchReportSplitRsp) XXX_Marshal ¶
func (m *BatchReportSplitRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BatchReportSplitRsp) XXX_Merge ¶
func (m *BatchReportSplitRsp) XXX_Merge(src proto.Message)
func (*BatchReportSplitRsp) XXX_Size ¶
func (m *BatchReportSplitRsp) XXX_Size() int
func (*BatchReportSplitRsp) XXX_Unmarshal ¶
func (m *BatchReportSplitRsp) XXX_Unmarshal(b []byte) error
type ChangePeer ¶
type ChangePeer struct { Peer metapb.Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer"` ChangeType metapb.ChangePeerType `protobuf:"varint,2,opt,name=changeType,proto3,enum=metapb.ChangePeerType" json:"changeType,omitempty"` }
ChangePeer change peer
func (*ChangePeer) Descriptor ¶
func (*ChangePeer) Descriptor() ([]byte, []int)
func (*ChangePeer) GetChangeType ¶
func (m *ChangePeer) GetChangeType() metapb.ChangePeerType
func (*ChangePeer) GetPeer ¶
func (m *ChangePeer) GetPeer() metapb.Peer
func (*ChangePeer) Marshal ¶
func (m *ChangePeer) Marshal() (dAtA []byte, err error)
func (*ChangePeer) MarshalToSizedBuffer ¶
func (m *ChangePeer) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChangePeer) ProtoMessage ¶
func (*ChangePeer) ProtoMessage()
func (*ChangePeer) Reset ¶
func (m *ChangePeer) Reset()
func (*ChangePeer) Size ¶
func (m *ChangePeer) Size() (n int)
func (*ChangePeer) String ¶
func (m *ChangePeer) String() string
func (*ChangePeer) Unmarshal ¶
func (m *ChangePeer) Unmarshal(dAtA []byte) error
func (*ChangePeer) XXX_DiscardUnknown ¶
func (m *ChangePeer) XXX_DiscardUnknown()
func (*ChangePeer) XXX_Marshal ¶
func (m *ChangePeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChangePeer) XXX_Merge ¶
func (m *ChangePeer) XXX_Merge(src proto.Message)
func (*ChangePeer) XXX_Size ¶
func (m *ChangePeer) XXX_Size() int
func (*ChangePeer) XXX_Unmarshal ¶
func (m *ChangePeer) XXX_Unmarshal(b []byte) error
type ChangePeerV2 ¶
type ChangePeerV2 struct { // If changes is empty, it means that to exit joint state. Changes []ChangePeer `protobuf:"bytes,1,rep,name=changes,proto3" json:"changes"` }
ChangePeerV2 change peer v2
func (*ChangePeerV2) Descriptor ¶
func (*ChangePeerV2) Descriptor() ([]byte, []int)
func (*ChangePeerV2) GetChanges ¶
func (m *ChangePeerV2) GetChanges() []ChangePeer
func (*ChangePeerV2) Marshal ¶
func (m *ChangePeerV2) Marshal() (dAtA []byte, err error)
func (*ChangePeerV2) MarshalToSizedBuffer ¶
func (m *ChangePeerV2) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChangePeerV2) ProtoMessage ¶
func (*ChangePeerV2) ProtoMessage()
func (*ChangePeerV2) Reset ¶
func (m *ChangePeerV2) Reset()
func (*ChangePeerV2) Size ¶
func (m *ChangePeerV2) Size() (n int)
func (*ChangePeerV2) String ¶
func (m *ChangePeerV2) String() string
func (*ChangePeerV2) Unmarshal ¶
func (m *ChangePeerV2) Unmarshal(dAtA []byte) error
func (*ChangePeerV2) XXX_DiscardUnknown ¶
func (m *ChangePeerV2) XXX_DiscardUnknown()
func (*ChangePeerV2) XXX_Marshal ¶
func (m *ChangePeerV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChangePeerV2) XXX_Merge ¶
func (m *ChangePeerV2) XXX_Merge(src proto.Message)
func (*ChangePeerV2) XXX_Size ¶
func (m *ChangePeerV2) XXX_Size() int
func (*ChangePeerV2) XXX_Unmarshal ¶
func (m *ChangePeerV2) XXX_Unmarshal(b []byte) error
type ContainerEventData ¶
type ContainerEventData struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
ContainerEventData container created or updated
func (*ContainerEventData) Descriptor ¶
func (*ContainerEventData) Descriptor() ([]byte, []int)
func (*ContainerEventData) GetData ¶
func (m *ContainerEventData) GetData() []byte
func (*ContainerEventData) Marshal ¶
func (m *ContainerEventData) Marshal() (dAtA []byte, err error)
func (*ContainerEventData) MarshalTo ¶
func (m *ContainerEventData) MarshalTo(dAtA []byte) (int, error)
func (*ContainerEventData) MarshalToSizedBuffer ¶
func (m *ContainerEventData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContainerEventData) ProtoMessage ¶
func (*ContainerEventData) ProtoMessage()
func (*ContainerEventData) Reset ¶
func (m *ContainerEventData) Reset()
func (*ContainerEventData) Size ¶
func (m *ContainerEventData) Size() (n int)
func (*ContainerEventData) String ¶
func (m *ContainerEventData) String() string
func (*ContainerEventData) Unmarshal ¶
func (m *ContainerEventData) Unmarshal(dAtA []byte) error
func (*ContainerEventData) XXX_DiscardUnknown ¶
func (m *ContainerEventData) XXX_DiscardUnknown()
func (*ContainerEventData) XXX_Marshal ¶
func (m *ContainerEventData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerEventData) XXX_Merge ¶
func (m *ContainerEventData) XXX_Merge(src proto.Message)
func (*ContainerEventData) XXX_Size ¶
func (m *ContainerEventData) XXX_Size() int
func (*ContainerEventData) XXX_Unmarshal ¶
func (m *ContainerEventData) XXX_Unmarshal(b []byte) error
type ContainerHeartbeatReq ¶
type ContainerHeartbeatReq struct {
Stats ContainerStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats"`
}
ContainerHeartbeatReq container heartbeat request
func (*ContainerHeartbeatReq) Descriptor ¶
func (*ContainerHeartbeatReq) Descriptor() ([]byte, []int)
func (*ContainerHeartbeatReq) GetStats ¶
func (m *ContainerHeartbeatReq) GetStats() ContainerStats
func (*ContainerHeartbeatReq) Marshal ¶
func (m *ContainerHeartbeatReq) Marshal() (dAtA []byte, err error)
func (*ContainerHeartbeatReq) MarshalTo ¶
func (m *ContainerHeartbeatReq) MarshalTo(dAtA []byte) (int, error)
func (*ContainerHeartbeatReq) MarshalToSizedBuffer ¶
func (m *ContainerHeartbeatReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContainerHeartbeatReq) ProtoMessage ¶
func (*ContainerHeartbeatReq) ProtoMessage()
func (*ContainerHeartbeatReq) Reset ¶
func (m *ContainerHeartbeatReq) Reset()
func (*ContainerHeartbeatReq) Size ¶
func (m *ContainerHeartbeatReq) Size() (n int)
func (*ContainerHeartbeatReq) String ¶
func (m *ContainerHeartbeatReq) String() string
func (*ContainerHeartbeatReq) Unmarshal ¶
func (m *ContainerHeartbeatReq) Unmarshal(dAtA []byte) error
func (*ContainerHeartbeatReq) XXX_DiscardUnknown ¶
func (m *ContainerHeartbeatReq) XXX_DiscardUnknown()
func (*ContainerHeartbeatReq) XXX_Marshal ¶
func (m *ContainerHeartbeatReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerHeartbeatReq) XXX_Merge ¶
func (m *ContainerHeartbeatReq) XXX_Merge(src proto.Message)
func (*ContainerHeartbeatReq) XXX_Size ¶
func (m *ContainerHeartbeatReq) XXX_Size() int
func (*ContainerHeartbeatReq) XXX_Unmarshal ¶
func (m *ContainerHeartbeatReq) XXX_Unmarshal(b []byte) error
type ContainerHeartbeatRsp ¶
type ContainerHeartbeatRsp struct { }
ContainerHeartbeatRsp container heartbeat response
func (*ContainerHeartbeatRsp) Descriptor ¶
func (*ContainerHeartbeatRsp) Descriptor() ([]byte, []int)
func (*ContainerHeartbeatRsp) Marshal ¶
func (m *ContainerHeartbeatRsp) Marshal() (dAtA []byte, err error)
func (*ContainerHeartbeatRsp) MarshalTo ¶
func (m *ContainerHeartbeatRsp) MarshalTo(dAtA []byte) (int, error)
func (*ContainerHeartbeatRsp) MarshalToSizedBuffer ¶
func (m *ContainerHeartbeatRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContainerHeartbeatRsp) ProtoMessage ¶
func (*ContainerHeartbeatRsp) ProtoMessage()
func (*ContainerHeartbeatRsp) Reset ¶
func (m *ContainerHeartbeatRsp) Reset()
func (*ContainerHeartbeatRsp) Size ¶
func (m *ContainerHeartbeatRsp) Size() (n int)
func (*ContainerHeartbeatRsp) String ¶
func (m *ContainerHeartbeatRsp) String() string
func (*ContainerHeartbeatRsp) Unmarshal ¶
func (m *ContainerHeartbeatRsp) Unmarshal(dAtA []byte) error
func (*ContainerHeartbeatRsp) XXX_DiscardUnknown ¶
func (m *ContainerHeartbeatRsp) XXX_DiscardUnknown()
func (*ContainerHeartbeatRsp) XXX_Marshal ¶
func (m *ContainerHeartbeatRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerHeartbeatRsp) XXX_Merge ¶
func (m *ContainerHeartbeatRsp) XXX_Merge(src proto.Message)
func (*ContainerHeartbeatRsp) XXX_Size ¶
func (m *ContainerHeartbeatRsp) XXX_Size() int
func (*ContainerHeartbeatRsp) XXX_Unmarshal ¶
func (m *ContainerHeartbeatRsp) XXX_Unmarshal(b []byte) error
type ContainerStats ¶
type ContainerStats struct { // Container id ContainerID uint64 `protobuf:"varint,1,opt,name=containerID,proto3" json:"containerID,omitempty"` // When the container is started (unix timestamp in seconds). StartTime uint64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"` // Actually reported time interval Interval *TimeInterval `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"` // Capacity for the container. Capacity uint64 `protobuf:"varint,4,opt,name=capacity,proto3" json:"capacity,omitempty"` // Available size for the container. Available uint64 `protobuf:"varint,5,opt,name=available,proto3" json:"available,omitempty"` // Actually used space by db UsedSize uint64 `protobuf:"varint,6,opt,name=usedSize,proto3" json:"usedSize,omitempty"` // If the container is busy IsBusy bool `protobuf:"varint,7,opt,name=isBusy,proto3" json:"isBusy,omitempty"` // Total resource count in this container. ResourceCount uint64 `protobuf:"varint,8,opt,name=resourceCount,proto3" json:"resourceCount,omitempty"` // Current sending snapshot count. SendingSnapCount uint64 `protobuf:"varint,9,opt,name=sendingSnapCount,proto3" json:"sendingSnapCount,omitempty"` // Current receiving snapshot count. ReceivingSnapCount uint64 `protobuf:"varint,10,opt,name=receivingSnapCount,proto3" json:"receivingSnapCount,omitempty"` // How many resource is applying snapshot. ApplyingSnapCount uint64 `protobuf:"varint,11,opt,name=applyingSnapCount,proto3" json:"applyingSnapCount,omitempty"` // Bytes written for the container during this period. BytesWritten uint64 `protobuf:"varint,12,opt,name=bytesWritten,proto3" json:"bytesWritten,omitempty"` // Bytes read for the container during this period. BytesRead uint64 `protobuf:"varint,13,opt,name=bytesRead,proto3" json:"bytesRead,omitempty"` // Bytes written for the container during this period. KeysWritten uint64 `protobuf:"varint,14,opt,name=keysWritten,proto3" json:"keysWritten,omitempty"` // Bytes read for the container during this period. KeysRead uint64 `protobuf:"varint,15,opt,name=keysRead,proto3" json:"keysRead,omitempty"` // Threads' CPU usages in the container CpuUsages []RecordPair `protobuf:"bytes,16,rep,name=cpuUsages,proto3" json:"cpuUsages"` // Threads' read disk I/O rates in the container ReadIORates []RecordPair `protobuf:"bytes,17,rep,name=readIORates,proto3" json:"readIORates"` // Threads' write disk I/O rates in the container WriteIORates []RecordPair `protobuf:"bytes,18,rep,name=writeIORates,proto3" json:"writeIORates"` // Operations' latencies in the container OpLatencies []RecordPair `protobuf:"bytes,19,rep,name=opLatencies,proto3" json:"opLatencies"` }
ContainerStats container stats
func (*ContainerStats) Descriptor ¶
func (*ContainerStats) Descriptor() ([]byte, []int)
func (*ContainerStats) GetApplyingSnapCount ¶
func (m *ContainerStats) GetApplyingSnapCount() uint64
func (*ContainerStats) GetAvailable ¶
func (m *ContainerStats) GetAvailable() uint64
func (*ContainerStats) GetBytesRead ¶
func (m *ContainerStats) GetBytesRead() uint64
func (*ContainerStats) GetBytesWritten ¶
func (m *ContainerStats) GetBytesWritten() uint64
func (*ContainerStats) GetCapacity ¶
func (m *ContainerStats) GetCapacity() uint64
func (*ContainerStats) GetContainerID ¶
func (m *ContainerStats) GetContainerID() uint64
func (*ContainerStats) GetCpuUsages ¶
func (m *ContainerStats) GetCpuUsages() []RecordPair
func (*ContainerStats) GetInterval ¶
func (m *ContainerStats) GetInterval() *TimeInterval
func (*ContainerStats) GetIsBusy ¶
func (m *ContainerStats) GetIsBusy() bool
func (*ContainerStats) GetKeysRead ¶
func (m *ContainerStats) GetKeysRead() uint64
func (*ContainerStats) GetKeysWritten ¶
func (m *ContainerStats) GetKeysWritten() uint64
func (*ContainerStats) GetOpLatencies ¶
func (m *ContainerStats) GetOpLatencies() []RecordPair
func (*ContainerStats) GetReadIORates ¶
func (m *ContainerStats) GetReadIORates() []RecordPair
func (*ContainerStats) GetReceivingSnapCount ¶
func (m *ContainerStats) GetReceivingSnapCount() uint64
func (*ContainerStats) GetResourceCount ¶
func (m *ContainerStats) GetResourceCount() uint64
func (*ContainerStats) GetSendingSnapCount ¶
func (m *ContainerStats) GetSendingSnapCount() uint64
func (*ContainerStats) GetStartTime ¶
func (m *ContainerStats) GetStartTime() uint64
func (*ContainerStats) GetUsedSize ¶
func (m *ContainerStats) GetUsedSize() uint64
func (*ContainerStats) GetWriteIORates ¶
func (m *ContainerStats) GetWriteIORates() []RecordPair
func (*ContainerStats) Marshal ¶
func (m *ContainerStats) Marshal() (dAtA []byte, err error)
func (*ContainerStats) MarshalToSizedBuffer ¶
func (m *ContainerStats) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContainerStats) ProtoMessage ¶
func (*ContainerStats) ProtoMessage()
func (*ContainerStats) Reset ¶
func (m *ContainerStats) Reset()
func (*ContainerStats) Size ¶
func (m *ContainerStats) Size() (n int)
func (*ContainerStats) String ¶
func (m *ContainerStats) String() string
func (*ContainerStats) Unmarshal ¶
func (m *ContainerStats) Unmarshal(dAtA []byte) error
func (*ContainerStats) XXX_DiscardUnknown ¶
func (m *ContainerStats) XXX_DiscardUnknown()
func (*ContainerStats) XXX_Marshal ¶
func (m *ContainerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerStats) XXX_Merge ¶
func (m *ContainerStats) XXX_Merge(src proto.Message)
func (*ContainerStats) XXX_Size ¶
func (m *ContainerStats) XXX_Size() int
func (*ContainerStats) XXX_Unmarshal ¶
func (m *ContainerStats) XXX_Unmarshal(b []byte) error
type CreateWatcherReq ¶
type CreateWatcherReq struct {
Flag uint32 `protobuf:"varint,1,opt,name=flag,proto3" json:"flag,omitempty"`
}
CreateWatcherReq create watcher req
func (*CreateWatcherReq) Descriptor ¶
func (*CreateWatcherReq) Descriptor() ([]byte, []int)
func (*CreateWatcherReq) GetFlag ¶
func (m *CreateWatcherReq) GetFlag() uint32
func (*CreateWatcherReq) Marshal ¶
func (m *CreateWatcherReq) Marshal() (dAtA []byte, err error)
func (*CreateWatcherReq) MarshalToSizedBuffer ¶
func (m *CreateWatcherReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateWatcherReq) ProtoMessage ¶
func (*CreateWatcherReq) ProtoMessage()
func (*CreateWatcherReq) Reset ¶
func (m *CreateWatcherReq) Reset()
func (*CreateWatcherReq) Size ¶
func (m *CreateWatcherReq) Size() (n int)
func (*CreateWatcherReq) String ¶
func (m *CreateWatcherReq) String() string
func (*CreateWatcherReq) Unmarshal ¶
func (m *CreateWatcherReq) Unmarshal(dAtA []byte) error
func (*CreateWatcherReq) XXX_DiscardUnknown ¶
func (m *CreateWatcherReq) XXX_DiscardUnknown()
func (*CreateWatcherReq) XXX_Marshal ¶
func (m *CreateWatcherReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateWatcherReq) XXX_Merge ¶
func (m *CreateWatcherReq) XXX_Merge(src proto.Message)
func (*CreateWatcherReq) XXX_Size ¶
func (m *CreateWatcherReq) XXX_Size() int
func (*CreateWatcherReq) XXX_Unmarshal ¶
func (m *CreateWatcherReq) XXX_Unmarshal(b []byte) error
type EventNotify ¶
type EventNotify struct { Seq uint64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"` Type uint32 `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"` InitEvent *InitEventData `protobuf:"bytes,3,opt,name=initEvent,proto3" json:"initEvent,omitempty"` ResourceEvent *ResourceEventData `protobuf:"bytes,4,opt,name=resourceEvent,proto3" json:"resourceEvent,omitempty"` ContainerEvent *ContainerEventData `protobuf:"bytes,5,opt,name=containerEvent,proto3" json:"containerEvent,omitempty"` LeaderChangedEvent *LeaderChangedEventData `protobuf:"bytes,6,opt,name=leaderChangedEvent,proto3" json:"leaderChangedEvent,omitempty"` }
EventNotify event notify
func (*EventNotify) Descriptor ¶
func (*EventNotify) Descriptor() ([]byte, []int)
func (*EventNotify) GetContainerEvent ¶
func (m *EventNotify) GetContainerEvent() *ContainerEventData
func (*EventNotify) GetInitEvent ¶
func (m *EventNotify) GetInitEvent() *InitEventData
func (*EventNotify) GetLeaderChangedEvent ¶
func (m *EventNotify) GetLeaderChangedEvent() *LeaderChangedEventData
func (*EventNotify) GetResourceEvent ¶
func (m *EventNotify) GetResourceEvent() *ResourceEventData
func (*EventNotify) GetSeq ¶
func (m *EventNotify) GetSeq() uint64
func (*EventNotify) GetType ¶
func (m *EventNotify) GetType() uint32
func (*EventNotify) Marshal ¶
func (m *EventNotify) Marshal() (dAtA []byte, err error)
func (*EventNotify) MarshalToSizedBuffer ¶
func (m *EventNotify) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventNotify) ProtoMessage ¶
func (*EventNotify) ProtoMessage()
func (*EventNotify) Reset ¶
func (m *EventNotify) Reset()
func (*EventNotify) Size ¶
func (m *EventNotify) Size() (n int)
func (*EventNotify) String ¶
func (m *EventNotify) String() string
func (*EventNotify) Unmarshal ¶
func (m *EventNotify) Unmarshal(dAtA []byte) error
func (*EventNotify) XXX_DiscardUnknown ¶
func (m *EventNotify) XXX_DiscardUnknown()
func (*EventNotify) XXX_Marshal ¶
func (m *EventNotify) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventNotify) XXX_Merge ¶
func (m *EventNotify) XXX_Merge(src proto.Message)
func (*EventNotify) XXX_Size ¶
func (m *EventNotify) XXX_Size() int
func (*EventNotify) XXX_Unmarshal ¶
func (m *EventNotify) XXX_Unmarshal(b []byte) error
type GetContainerReq ¶
type GetContainerReq struct {
ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
GetContainerReq get container request
func (*GetContainerReq) Descriptor ¶
func (*GetContainerReq) Descriptor() ([]byte, []int)
func (*GetContainerReq) GetID ¶
func (m *GetContainerReq) GetID() uint64
func (*GetContainerReq) Marshal ¶
func (m *GetContainerReq) Marshal() (dAtA []byte, err error)
func (*GetContainerReq) MarshalToSizedBuffer ¶
func (m *GetContainerReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetContainerReq) ProtoMessage ¶
func (*GetContainerReq) ProtoMessage()
func (*GetContainerReq) Reset ¶
func (m *GetContainerReq) Reset()
func (*GetContainerReq) Size ¶
func (m *GetContainerReq) Size() (n int)
func (*GetContainerReq) String ¶
func (m *GetContainerReq) String() string
func (*GetContainerReq) Unmarshal ¶
func (m *GetContainerReq) Unmarshal(dAtA []byte) error
func (*GetContainerReq) XXX_DiscardUnknown ¶
func (m *GetContainerReq) XXX_DiscardUnknown()
func (*GetContainerReq) XXX_Marshal ¶
func (m *GetContainerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetContainerReq) XXX_Merge ¶
func (m *GetContainerReq) XXX_Merge(src proto.Message)
func (*GetContainerReq) XXX_Size ¶
func (m *GetContainerReq) XXX_Size() int
func (*GetContainerReq) XXX_Unmarshal ¶
func (m *GetContainerReq) XXX_Unmarshal(b []byte) error
type GetContainerRsp ¶
type GetContainerRsp struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Stats *ContainerStats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"` }
GetContainerRsp get container response
func (*GetContainerRsp) Descriptor ¶
func (*GetContainerRsp) Descriptor() ([]byte, []int)
func (*GetContainerRsp) GetData ¶
func (m *GetContainerRsp) GetData() []byte
func (*GetContainerRsp) GetStats ¶
func (m *GetContainerRsp) GetStats() *ContainerStats
func (*GetContainerRsp) Marshal ¶
func (m *GetContainerRsp) Marshal() (dAtA []byte, err error)
func (*GetContainerRsp) MarshalToSizedBuffer ¶
func (m *GetContainerRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetContainerRsp) ProtoMessage ¶
func (*GetContainerRsp) ProtoMessage()
func (*GetContainerRsp) Reset ¶
func (m *GetContainerRsp) Reset()
func (*GetContainerRsp) Size ¶
func (m *GetContainerRsp) Size() (n int)
func (*GetContainerRsp) String ¶
func (m *GetContainerRsp) String() string
func (*GetContainerRsp) Unmarshal ¶
func (m *GetContainerRsp) Unmarshal(dAtA []byte) error
func (*GetContainerRsp) XXX_DiscardUnknown ¶
func (m *GetContainerRsp) XXX_DiscardUnknown()
func (*GetContainerRsp) XXX_Marshal ¶
func (m *GetContainerRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetContainerRsp) XXX_Merge ¶
func (m *GetContainerRsp) XXX_Merge(src proto.Message)
func (*GetContainerRsp) XXX_Size ¶
func (m *GetContainerRsp) XXX_Size() int
func (*GetContainerRsp) XXX_Unmarshal ¶
func (m *GetContainerRsp) XXX_Unmarshal(b []byte) error
type GetDCLocationsReq ¶
type GetDCLocationsReq struct { }
GetDCLocationsReq get dc locations request
func (*GetDCLocationsReq) Descriptor ¶
func (*GetDCLocationsReq) Descriptor() ([]byte, []int)
func (*GetDCLocationsReq) Marshal ¶
func (m *GetDCLocationsReq) Marshal() (dAtA []byte, err error)
func (*GetDCLocationsReq) MarshalTo ¶
func (m *GetDCLocationsReq) MarshalTo(dAtA []byte) (int, error)
func (*GetDCLocationsReq) MarshalToSizedBuffer ¶
func (m *GetDCLocationsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDCLocationsReq) ProtoMessage ¶
func (*GetDCLocationsReq) ProtoMessage()
func (*GetDCLocationsReq) Reset ¶
func (m *GetDCLocationsReq) Reset()
func (*GetDCLocationsReq) Size ¶
func (m *GetDCLocationsReq) Size() (n int)
func (*GetDCLocationsReq) String ¶
func (m *GetDCLocationsReq) String() string
func (*GetDCLocationsReq) Unmarshal ¶
func (m *GetDCLocationsReq) Unmarshal(dAtA []byte) error
func (*GetDCLocationsReq) XXX_DiscardUnknown ¶
func (m *GetDCLocationsReq) XXX_DiscardUnknown()
func (*GetDCLocationsReq) XXX_Marshal ¶
func (m *GetDCLocationsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDCLocationsReq) XXX_Merge ¶
func (m *GetDCLocationsReq) XXX_Merge(src proto.Message)
func (*GetDCLocationsReq) XXX_Size ¶
func (m *GetDCLocationsReq) XXX_Size() int
func (*GetDCLocationsReq) XXX_Unmarshal ¶
func (m *GetDCLocationsReq) XXX_Unmarshal(b []byte) error
type GetDCLocationsRsp ¶
type GetDCLocationsRsp struct {
DCLocations map[string]int32 `` /* 164-byte string literal not displayed */
}
GetDCLocationsRsp get dc locations response
func (*GetDCLocationsRsp) Descriptor ¶
func (*GetDCLocationsRsp) Descriptor() ([]byte, []int)
func (*GetDCLocationsRsp) GetDCLocations ¶
func (m *GetDCLocationsRsp) GetDCLocations() map[string]int32
func (*GetDCLocationsRsp) Marshal ¶
func (m *GetDCLocationsRsp) Marshal() (dAtA []byte, err error)
func (*GetDCLocationsRsp) MarshalTo ¶
func (m *GetDCLocationsRsp) MarshalTo(dAtA []byte) (int, error)
func (*GetDCLocationsRsp) MarshalToSizedBuffer ¶
func (m *GetDCLocationsRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDCLocationsRsp) ProtoMessage ¶
func (*GetDCLocationsRsp) ProtoMessage()
func (*GetDCLocationsRsp) Reset ¶
func (m *GetDCLocationsRsp) Reset()
func (*GetDCLocationsRsp) Size ¶
func (m *GetDCLocationsRsp) Size() (n int)
func (*GetDCLocationsRsp) String ¶
func (m *GetDCLocationsRsp) String() string
func (*GetDCLocationsRsp) Unmarshal ¶
func (m *GetDCLocationsRsp) Unmarshal(dAtA []byte) error
func (*GetDCLocationsRsp) XXX_DiscardUnknown ¶
func (m *GetDCLocationsRsp) XXX_DiscardUnknown()
func (*GetDCLocationsRsp) XXX_Marshal ¶
func (m *GetDCLocationsRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDCLocationsRsp) XXX_Merge ¶
func (m *GetDCLocationsRsp) XXX_Merge(src proto.Message)
func (*GetDCLocationsRsp) XXX_Size ¶
func (m *GetDCLocationsRsp) XXX_Size() int
func (*GetDCLocationsRsp) XXX_Unmarshal ¶
func (m *GetDCLocationsRsp) XXX_Unmarshal(b []byte) error
type InitEventData ¶
type InitEventData struct { Resources [][]byte `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"` Leaders []uint64 `protobuf:"varint,2,rep,packed,name=leaders,proto3" json:"leaders,omitempty"` Containers [][]byte `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"` }
InitEventData init event data
func (*InitEventData) Descriptor ¶
func (*InitEventData) Descriptor() ([]byte, []int)
func (*InitEventData) GetContainers ¶
func (m *InitEventData) GetContainers() [][]byte
func (*InitEventData) GetLeaders ¶
func (m *InitEventData) GetLeaders() []uint64
func (*InitEventData) GetResources ¶
func (m *InitEventData) GetResources() [][]byte
func (*InitEventData) Marshal ¶
func (m *InitEventData) Marshal() (dAtA []byte, err error)
func (*InitEventData) MarshalToSizedBuffer ¶
func (m *InitEventData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InitEventData) ProtoMessage ¶
func (*InitEventData) ProtoMessage()
func (*InitEventData) Reset ¶
func (m *InitEventData) Reset()
func (*InitEventData) Size ¶
func (m *InitEventData) Size() (n int)
func (*InitEventData) String ¶
func (m *InitEventData) String() string
func (*InitEventData) Unmarshal ¶
func (m *InitEventData) Unmarshal(dAtA []byte) error
func (*InitEventData) XXX_DiscardUnknown ¶
func (m *InitEventData) XXX_DiscardUnknown()
func (*InitEventData) XXX_Marshal ¶
func (m *InitEventData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitEventData) XXX_Merge ¶
func (m *InitEventData) XXX_Merge(src proto.Message)
func (*InitEventData) XXX_Size ¶
func (m *InitEventData) XXX_Size() int
func (*InitEventData) XXX_Unmarshal ¶
func (m *InitEventData) XXX_Unmarshal(b []byte) error
type LeaderChangedEventData ¶
type LeaderChangedEventData struct { ResourceID uint64 `protobuf:"varint,1,opt,name=resourceID,proto3" json:"resourceID,omitempty"` LeaderID uint64 `protobuf:"varint,2,opt,name=leaderID,proto3" json:"leaderID,omitempty"` }
LeaderChangedEventData leader changed
func (*LeaderChangedEventData) Descriptor ¶
func (*LeaderChangedEventData) Descriptor() ([]byte, []int)
func (*LeaderChangedEventData) GetLeaderID ¶
func (m *LeaderChangedEventData) GetLeaderID() uint64
func (*LeaderChangedEventData) GetResourceID ¶
func (m *LeaderChangedEventData) GetResourceID() uint64
func (*LeaderChangedEventData) Marshal ¶
func (m *LeaderChangedEventData) Marshal() (dAtA []byte, err error)
func (*LeaderChangedEventData) MarshalTo ¶
func (m *LeaderChangedEventData) MarshalTo(dAtA []byte) (int, error)
func (*LeaderChangedEventData) MarshalToSizedBuffer ¶
func (m *LeaderChangedEventData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaderChangedEventData) ProtoMessage ¶
func (*LeaderChangedEventData) ProtoMessage()
func (*LeaderChangedEventData) Reset ¶
func (m *LeaderChangedEventData) Reset()
func (*LeaderChangedEventData) Size ¶
func (m *LeaderChangedEventData) Size() (n int)
func (*LeaderChangedEventData) String ¶
func (m *LeaderChangedEventData) String() string
func (*LeaderChangedEventData) Unmarshal ¶
func (m *LeaderChangedEventData) Unmarshal(dAtA []byte) error
func (*LeaderChangedEventData) XXX_DiscardUnknown ¶
func (m *LeaderChangedEventData) XXX_DiscardUnknown()
func (*LeaderChangedEventData) XXX_Marshal ¶
func (m *LeaderChangedEventData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaderChangedEventData) XXX_Merge ¶
func (m *LeaderChangedEventData) XXX_Merge(src proto.Message)
func (*LeaderChangedEventData) XXX_Size ¶
func (m *LeaderChangedEventData) XXX_Size() int
func (*LeaderChangedEventData) XXX_Unmarshal ¶
func (m *LeaderChangedEventData) XXX_Unmarshal(b []byte) error
type Merge ¶
type Merge struct { // target resource Target []byte `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` }
Merge merge
func (*Merge) Descriptor ¶
func (*Merge) ProtoMessage ¶
func (*Merge) ProtoMessage()
func (*Merge) XXX_DiscardUnknown ¶
func (m *Merge) XXX_DiscardUnknown()
func (*Merge) XXX_Marshal ¶
func (*Merge) XXX_Unmarshal ¶
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"` }
RecordPair record pair
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) MarshalToSizedBuffer ¶
func (m *RecordPair) MarshalToSizedBuffer(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 (m *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 ReportSplitReq ¶
type ReportSplitReq struct { Left []byte `protobuf:"bytes,1,opt,name=left,proto3" json:"left,omitempty"` Right []byte `protobuf:"bytes,2,opt,name=right,proto3" json:"right,omitempty"` }
ReportSplitReq report split request
func (*ReportSplitReq) Descriptor ¶
func (*ReportSplitReq) Descriptor() ([]byte, []int)
func (*ReportSplitReq) GetLeft ¶
func (m *ReportSplitReq) GetLeft() []byte
func (*ReportSplitReq) GetRight ¶
func (m *ReportSplitReq) GetRight() []byte
func (*ReportSplitReq) Marshal ¶
func (m *ReportSplitReq) Marshal() (dAtA []byte, err error)
func (*ReportSplitReq) MarshalToSizedBuffer ¶
func (m *ReportSplitReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReportSplitReq) ProtoMessage ¶
func (*ReportSplitReq) ProtoMessage()
func (*ReportSplitReq) Reset ¶
func (m *ReportSplitReq) Reset()
func (*ReportSplitReq) Size ¶
func (m *ReportSplitReq) Size() (n int)
func (*ReportSplitReq) String ¶
func (m *ReportSplitReq) String() string
func (*ReportSplitReq) Unmarshal ¶
func (m *ReportSplitReq) Unmarshal(dAtA []byte) error
func (*ReportSplitReq) XXX_DiscardUnknown ¶
func (m *ReportSplitReq) XXX_DiscardUnknown()
func (*ReportSplitReq) XXX_Marshal ¶
func (m *ReportSplitReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportSplitReq) XXX_Merge ¶
func (m *ReportSplitReq) XXX_Merge(src proto.Message)
func (*ReportSplitReq) XXX_Size ¶
func (m *ReportSplitReq) XXX_Size() int
func (*ReportSplitReq) XXX_Unmarshal ¶
func (m *ReportSplitReq) XXX_Unmarshal(b []byte) error
type ReportSplitRsp ¶
type ReportSplitRsp struct { }
ReportSplitRsp report split response
func (*ReportSplitRsp) Descriptor ¶
func (*ReportSplitRsp) Descriptor() ([]byte, []int)
func (*ReportSplitRsp) Marshal ¶
func (m *ReportSplitRsp) Marshal() (dAtA []byte, err error)
func (*ReportSplitRsp) MarshalToSizedBuffer ¶
func (m *ReportSplitRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReportSplitRsp) ProtoMessage ¶
func (*ReportSplitRsp) ProtoMessage()
func (*ReportSplitRsp) Reset ¶
func (m *ReportSplitRsp) Reset()
func (*ReportSplitRsp) Size ¶
func (m *ReportSplitRsp) Size() (n int)
func (*ReportSplitRsp) String ¶
func (m *ReportSplitRsp) String() string
func (*ReportSplitRsp) Unmarshal ¶
func (m *ReportSplitRsp) Unmarshal(dAtA []byte) error
func (*ReportSplitRsp) XXX_DiscardUnknown ¶
func (m *ReportSplitRsp) XXX_DiscardUnknown()
func (*ReportSplitRsp) XXX_Marshal ¶
func (m *ReportSplitRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReportSplitRsp) XXX_Merge ¶
func (m *ReportSplitRsp) XXX_Merge(src proto.Message)
func (*ReportSplitRsp) XXX_Size ¶
func (m *ReportSplitRsp) XXX_Size() int
func (*ReportSplitRsp) XXX_Unmarshal ¶
func (m *ReportSplitRsp) XXX_Unmarshal(b []byte) error
type Request ¶
type Request struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` ContainerID uint64 `protobuf:"varint,2,opt,name=containerID,proto3" json:"containerID,omitempty"` Type Type `protobuf:"varint,3,opt,name=type,proto3,enum=rpcpb.Type" json:"type,omitempty"` ResourceHeartbeat ResourceHeartbeatReq `protobuf:"bytes,4,opt,name=ResourceHeartbeat,proto3" json:"ResourceHeartbeat"` ContainerHeartbeat ContainerHeartbeatReq `protobuf:"bytes,5,opt,name=ContainerHeartbeat,proto3" json:"ContainerHeartbeat"` GetContainer GetContainerReq `protobuf:"bytes,6,opt,name=GetContainer,proto3" json:"GetContainer"` AllocID AllocIDReq `protobuf:"bytes,7,opt,name=AllocID,proto3" json:"AllocID"` AskSplit AskSplitReq `protobuf:"bytes,8,opt,name=AskSplit,proto3" json:"AskSplit"` AskBatchSplit AskBatchSplitReq `protobuf:"bytes,9,opt,name=AskBatchSplit,proto3" json:"AskBatchSplit"` ReportSplit ReportSplitReq `protobuf:"bytes,10,opt,name=ReportSplit,proto3" json:"ReportSplit"` BatchReportSplit BatchReportSplitReq `protobuf:"bytes,11,opt,name=BatchReportSplit,proto3" json:"BatchReportSplit"` TSO TSOReq `protobuf:"bytes,12,opt,name=TSO,proto3" json:"TSO"` CreateWatcher CreateWatcherReq `protobuf:"bytes,13,opt,name=CreateWatcher,proto3" json:"CreateWatcher"` GetDCLocations GetDCLocationsReq `protobuf:"bytes,14,opt,name=GetDCLocations,proto3" json:"GetDCLocations"` }
Request the prophet rpc request
func (*Request) Descriptor ¶
func (*Request) GetAllocID ¶
func (m *Request) GetAllocID() AllocIDReq
func (*Request) GetAskBatchSplit ¶
func (m *Request) GetAskBatchSplit() AskBatchSplitReq
func (*Request) GetAskSplit ¶
func (m *Request) GetAskSplit() AskSplitReq
func (*Request) GetBatchReportSplit ¶
func (m *Request) GetBatchReportSplit() BatchReportSplitReq
func (*Request) GetContainerHeartbeat ¶
func (m *Request) GetContainerHeartbeat() ContainerHeartbeatReq
func (*Request) GetContainerID ¶
func (*Request) GetCreateWatcher ¶
func (m *Request) GetCreateWatcher() CreateWatcherReq
func (*Request) GetGetContainer ¶
func (m *Request) GetGetContainer() GetContainerReq
func (*Request) GetGetDCLocations ¶
func (m *Request) GetGetDCLocations() GetDCLocationsReq
func (*Request) GetReportSplit ¶
func (m *Request) GetReportSplit() ReportSplitReq
func (*Request) GetResourceHeartbeat ¶
func (m *Request) GetResourceHeartbeat() ResourceHeartbeatReq
func (*Request) MarshalToSizedBuffer ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) XXX_DiscardUnknown ¶
func (m *Request) XXX_DiscardUnknown()
func (*Request) XXX_Marshal ¶
func (*Request) XXX_Unmarshal ¶
type ResourceEventData ¶
type ResourceEventData struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
ResourceEventData resource created or updated
func (*ResourceEventData) Descriptor ¶
func (*ResourceEventData) Descriptor() ([]byte, []int)
func (*ResourceEventData) GetData ¶
func (m *ResourceEventData) GetData() []byte
func (*ResourceEventData) Marshal ¶
func (m *ResourceEventData) Marshal() (dAtA []byte, err error)
func (*ResourceEventData) MarshalTo ¶
func (m *ResourceEventData) MarshalTo(dAtA []byte) (int, error)
func (*ResourceEventData) MarshalToSizedBuffer ¶
func (m *ResourceEventData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceEventData) ProtoMessage ¶
func (*ResourceEventData) ProtoMessage()
func (*ResourceEventData) Reset ¶
func (m *ResourceEventData) Reset()
func (*ResourceEventData) Size ¶
func (m *ResourceEventData) Size() (n int)
func (*ResourceEventData) String ¶
func (m *ResourceEventData) String() string
func (*ResourceEventData) Unmarshal ¶
func (m *ResourceEventData) Unmarshal(dAtA []byte) error
func (*ResourceEventData) XXX_DiscardUnknown ¶
func (m *ResourceEventData) XXX_DiscardUnknown()
func (*ResourceEventData) XXX_Marshal ¶
func (m *ResourceEventData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResourceEventData) XXX_Merge ¶
func (m *ResourceEventData) XXX_Merge(src proto.Message)
func (*ResourceEventData) XXX_Size ¶
func (m *ResourceEventData) XXX_Size() int
func (*ResourceEventData) XXX_Unmarshal ¶
func (m *ResourceEventData) XXX_Unmarshal(b []byte) error
type ResourceHeartbeatReq ¶
type ResourceHeartbeatReq struct { ContainerID uint64 `protobuf:"varint,1,opt,name=containerID,proto3" json:"containerID,omitempty"` Resource []byte `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"` // Term is the term of raft group. Term uint64 `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"` Leader *metapb.Peer `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"` DownPeers []metapb.PeerStats `protobuf:"bytes,5,rep,name=downPeers,proto3" json:"downPeers"` PendingPeers []metapb.Peer `protobuf:"bytes,6,rep,name=pendingPeers,proto3" json:"pendingPeers"` // Bytes read/written during this period. BytesWritten uint64 `protobuf:"varint,7,opt,name=bytesWritten,proto3" json:"bytesWritten,omitempty"` BytesRead uint64 `protobuf:"varint,8,opt,name=bytesRead,proto3" json:"bytesRead,omitempty"` // Keys read/written during this period. KeysWritten uint64 `protobuf:"varint,9,opt,name=keysWritten,proto3" json:"keysWritten,omitempty"` KeysRead uint64 `protobuf:"varint,10,opt,name=keysRead,proto3" json:"keysRead,omitempty"` // Approximate resource size in bytes. ApproximateSize uint64 `protobuf:"varint,11,opt,name=approximateSize,proto3" json:"approximateSize,omitempty"` // Approximate keys that resource contains. ApproximateKeys uint64 `protobuf:"varint,12,opt,name=approximateKeys,proto3" json:"approximateKeys,omitempty"` // Actually reported time interval Interval *TimeInterval `protobuf:"bytes,13,opt,name=interval,proto3" json:"interval,omitempty"` }
ResourceHeartbeatReq resource heartbeat request
func (*ResourceHeartbeatReq) Descriptor ¶
func (*ResourceHeartbeatReq) Descriptor() ([]byte, []int)
func (*ResourceHeartbeatReq) GetApproximateKeys ¶
func (m *ResourceHeartbeatReq) GetApproximateKeys() uint64
func (*ResourceHeartbeatReq) GetApproximateSize ¶
func (m *ResourceHeartbeatReq) GetApproximateSize() uint64
func (*ResourceHeartbeatReq) GetBytesRead ¶
func (m *ResourceHeartbeatReq) GetBytesRead() uint64
func (*ResourceHeartbeatReq) GetBytesWritten ¶
func (m *ResourceHeartbeatReq) GetBytesWritten() uint64
func (*ResourceHeartbeatReq) GetContainerID ¶
func (m *ResourceHeartbeatReq) GetContainerID() uint64
func (*ResourceHeartbeatReq) GetDownPeers ¶
func (m *ResourceHeartbeatReq) GetDownPeers() []metapb.PeerStats
func (*ResourceHeartbeatReq) GetInterval ¶
func (m *ResourceHeartbeatReq) GetInterval() *TimeInterval
func (*ResourceHeartbeatReq) GetKeysRead ¶
func (m *ResourceHeartbeatReq) GetKeysRead() uint64
func (*ResourceHeartbeatReq) GetKeysWritten ¶
func (m *ResourceHeartbeatReq) GetKeysWritten() uint64
func (*ResourceHeartbeatReq) GetLeader ¶
func (m *ResourceHeartbeatReq) GetLeader() *metapb.Peer
func (*ResourceHeartbeatReq) GetPendingPeers ¶
func (m *ResourceHeartbeatReq) GetPendingPeers() []metapb.Peer
func (*ResourceHeartbeatReq) GetResource ¶
func (m *ResourceHeartbeatReq) GetResource() []byte
func (*ResourceHeartbeatReq) GetTerm ¶
func (m *ResourceHeartbeatReq) GetTerm() uint64
func (*ResourceHeartbeatReq) Marshal ¶
func (m *ResourceHeartbeatReq) Marshal() (dAtA []byte, err error)
func (*ResourceHeartbeatReq) MarshalTo ¶
func (m *ResourceHeartbeatReq) MarshalTo(dAtA []byte) (int, error)
func (*ResourceHeartbeatReq) MarshalToSizedBuffer ¶
func (m *ResourceHeartbeatReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceHeartbeatReq) ProtoMessage ¶
func (*ResourceHeartbeatReq) ProtoMessage()
func (*ResourceHeartbeatReq) Reset ¶
func (m *ResourceHeartbeatReq) Reset()
func (*ResourceHeartbeatReq) Size ¶
func (m *ResourceHeartbeatReq) Size() (n int)
func (*ResourceHeartbeatReq) String ¶
func (m *ResourceHeartbeatReq) String() string
func (*ResourceHeartbeatReq) Unmarshal ¶
func (m *ResourceHeartbeatReq) Unmarshal(dAtA []byte) error
func (*ResourceHeartbeatReq) XXX_DiscardUnknown ¶
func (m *ResourceHeartbeatReq) XXX_DiscardUnknown()
func (*ResourceHeartbeatReq) XXX_Marshal ¶
func (m *ResourceHeartbeatReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResourceHeartbeatReq) XXX_Merge ¶
func (m *ResourceHeartbeatReq) XXX_Merge(src proto.Message)
func (*ResourceHeartbeatReq) XXX_Size ¶
func (m *ResourceHeartbeatReq) XXX_Size() int
func (*ResourceHeartbeatReq) XXX_Unmarshal ¶
func (m *ResourceHeartbeatReq) XXX_Unmarshal(b []byte) error
type ResourceHeartbeatRsp ¶
type ResourceHeartbeatRsp struct { ResourceID uint64 `protobuf:"varint,1,opt,name=resourceID,proto3" json:"resourceID,omitempty"` ResourceEpoch metapb.ResourceEpoch `protobuf:"bytes,2,opt,name=resourceEpoch,proto3" json:"resourceEpoch"` // Leader of the resource at the moment of the corresponding request was made. TargetPeer *metapb.Peer `protobuf:"bytes,3,opt,name=targetPeer,proto3" json:"targetPeer,omitempty"` // Notice, prophet only allows handling reported epoch >= current prophet's. // Leader peer reports resource status with ResourceHeartbeatReq // to prophet regularly, prophet will determine whether this resource // should do ChangePeer or not. // E,g, max peer number is 3, resource A, first only peer 1 in A. // 1. prophet resource state -> Peers (1), ConfVer (1). // 2. Leader peer 1 reports resource state to prophet, prophet finds the // peer number is < 3, so first changes its current resource // state -> Peers (1, 2), ConfVer (1), and returns ChangePeer Adding 2. // 3. Leader does ChangePeer, then reports Peers (1, 2), ConfVer (2), // prophet updates its state -> Peers (1, 2), ConfVer (2). // 4. Leader may report old Peers (1), ConfVer (1) to pd before ConfChange // finished, pd stills responses ChangePeer Adding 2, of course, we must // guarantee the second ChangePeer can't be applied in your application. ChangePeer *ChangePeer `protobuf:"bytes,4,opt,name=changePeer,proto3" json:"changePeer,omitempty"` TransferLeader *TransferLeader `protobuf:"bytes,5,opt,name=transferLeader,proto3" json:"transferLeader,omitempty"` Merge *Merge `protobuf:"bytes,6,opt,name=merge,proto3" json:"merge,omitempty"` SplitResource *SplitResource `protobuf:"bytes,7,opt,name=splitResource,proto3" json:"splitResource,omitempty"` ChangePeerV2 *ChangePeerV2 `protobuf:"bytes,8,opt,name=changePeerV2,proto3" json:"changePeerV2,omitempty"` }
ResourceHeartbeatRsp resource heartbeat response.
func (*ResourceHeartbeatRsp) Descriptor ¶
func (*ResourceHeartbeatRsp) Descriptor() ([]byte, []int)
func (*ResourceHeartbeatRsp) GetChangePeer ¶
func (m *ResourceHeartbeatRsp) GetChangePeer() *ChangePeer
func (*ResourceHeartbeatRsp) GetChangePeerV2 ¶
func (m *ResourceHeartbeatRsp) GetChangePeerV2() *ChangePeerV2
func (*ResourceHeartbeatRsp) GetMerge ¶
func (m *ResourceHeartbeatRsp) GetMerge() *Merge
func (*ResourceHeartbeatRsp) GetResourceEpoch ¶
func (m *ResourceHeartbeatRsp) GetResourceEpoch() metapb.ResourceEpoch
func (*ResourceHeartbeatRsp) GetResourceID ¶
func (m *ResourceHeartbeatRsp) GetResourceID() uint64
func (*ResourceHeartbeatRsp) GetSplitResource ¶
func (m *ResourceHeartbeatRsp) GetSplitResource() *SplitResource
func (*ResourceHeartbeatRsp) GetTargetPeer ¶
func (m *ResourceHeartbeatRsp) GetTargetPeer() *metapb.Peer
func (*ResourceHeartbeatRsp) GetTransferLeader ¶
func (m *ResourceHeartbeatRsp) GetTransferLeader() *TransferLeader
func (*ResourceHeartbeatRsp) Marshal ¶
func (m *ResourceHeartbeatRsp) Marshal() (dAtA []byte, err error)
func (*ResourceHeartbeatRsp) MarshalTo ¶
func (m *ResourceHeartbeatRsp) MarshalTo(dAtA []byte) (int, error)
func (*ResourceHeartbeatRsp) MarshalToSizedBuffer ¶
func (m *ResourceHeartbeatRsp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceHeartbeatRsp) ProtoMessage ¶
func (*ResourceHeartbeatRsp) ProtoMessage()
func (*ResourceHeartbeatRsp) Reset ¶
func (m *ResourceHeartbeatRsp) Reset()
func (*ResourceHeartbeatRsp) Size ¶
func (m *ResourceHeartbeatRsp) Size() (n int)
func (*ResourceHeartbeatRsp) String ¶
func (m *ResourceHeartbeatRsp) String() string
func (*ResourceHeartbeatRsp) Unmarshal ¶
func (m *ResourceHeartbeatRsp) Unmarshal(dAtA []byte) error
func (*ResourceHeartbeatRsp) XXX_DiscardUnknown ¶
func (m *ResourceHeartbeatRsp) XXX_DiscardUnknown()
func (*ResourceHeartbeatRsp) XXX_Marshal ¶
func (m *ResourceHeartbeatRsp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResourceHeartbeatRsp) XXX_Merge ¶
func (m *ResourceHeartbeatRsp) XXX_Merge(src proto.Message)
func (*ResourceHeartbeatRsp) XXX_Size ¶
func (m *ResourceHeartbeatRsp) XXX_Size() int
func (*ResourceHeartbeatRsp) XXX_Unmarshal ¶
func (m *ResourceHeartbeatRsp) XXX_Unmarshal(b []byte) error
type Response ¶
type Response struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=rpcpb.Type" json:"type,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` Leader string `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"` ResourceHeartbeat ResourceHeartbeatRsp `protobuf:"bytes,5,opt,name=ResourceHeartbeat,proto3" json:"ResourceHeartbeat"` ContainerHeartbeat ContainerHeartbeatRsp `protobuf:"bytes,6,opt,name=ContainerHeartbeat,proto3" json:"ContainerHeartbeat"` GetContainer GetContainerRsp `protobuf:"bytes,7,opt,name=GetContainer,proto3" json:"GetContainer"` AllocID AllocIDRsp `protobuf:"bytes,8,opt,name=AllocID,proto3" json:"AllocID"` AskSplit AskSplitRsp `protobuf:"bytes,9,opt,name=AskSplit,proto3" json:"AskSplit"` AskBatchSplit AskBatchSplitRsp `protobuf:"bytes,10,opt,name=AskBatchSplit,proto3" json:"AskBatchSplit"` ReportSplit ReportSplitRsp `protobuf:"bytes,11,opt,name=ReportSplit,proto3" json:"ReportSplit"` BatchReportSplit BatchReportSplitRsp `protobuf:"bytes,12,opt,name=BatchReportSplit,proto3" json:"BatchReportSplit"` TSO TSORsp `protobuf:"bytes,13,opt,name=TSO,proto3" json:"TSO"` Event EventNotify `protobuf:"bytes,14,opt,name=Event,proto3" json:"Event"` GetDCLocations GetDCLocationsRsp `protobuf:"bytes,15,opt,name=GetDCLocations,proto3" json:"GetDCLocations"` }
Response the prophet rpc response
func (*Response) Descriptor ¶
func (*Response) GetAllocID ¶
func (m *Response) GetAllocID() AllocIDRsp
func (*Response) GetAskBatchSplit ¶
func (m *Response) GetAskBatchSplit() AskBatchSplitRsp
func (*Response) GetAskSplit ¶
func (m *Response) GetAskSplit() AskSplitRsp
func (*Response) GetBatchReportSplit ¶
func (m *Response) GetBatchReportSplit() BatchReportSplitRsp
func (*Response) GetContainerHeartbeat ¶
func (m *Response) GetContainerHeartbeat() ContainerHeartbeatRsp
func (*Response) GetEvent ¶
func (m *Response) GetEvent() EventNotify
func (*Response) GetGetContainer ¶
func (m *Response) GetGetContainer() GetContainerRsp
func (*Response) GetGetDCLocations ¶
func (m *Response) GetGetDCLocations() GetDCLocationsRsp
func (*Response) GetReportSplit ¶
func (m *Response) GetReportSplit() ReportSplitRsp
func (*Response) GetResourceHeartbeat ¶
func (m *Response) GetResourceHeartbeat() ResourceHeartbeatRsp
func (*Response) MarshalToSizedBuffer ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) XXX_DiscardUnknown ¶
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶
func (*Response) XXX_Unmarshal ¶
type SplitID ¶
type SplitID struct { NewID uint64 `protobuf:"varint,1,opt,name=newID,proto3" json:"newID,omitempty"` NewPeerIDs []uint64 `protobuf:"varint,2,rep,packed,name=newPeerIDs,proto3" json:"newPeerIDs,omitempty"` }
SplitID split id
func (*SplitID) Descriptor ¶
func (*SplitID) GetNewPeerIDs ¶
func (*SplitID) MarshalToSizedBuffer ¶
func (*SplitID) ProtoMessage ¶
func (*SplitID) ProtoMessage()
func (*SplitID) XXX_DiscardUnknown ¶
func (m *SplitID) XXX_DiscardUnknown()
func (*SplitID) XXX_Marshal ¶
func (*SplitID) XXX_Unmarshal ¶
type SplitResource ¶
type SplitResource struct { Policy metapb.CheckPolicy `protobuf:"varint,1,opt,name=policy,proto3,enum=metapb.CheckPolicy" json:"policy,omitempty"` Keys [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"` }
SplitResource split resource
func (*SplitResource) Descriptor ¶
func (*SplitResource) Descriptor() ([]byte, []int)
func (*SplitResource) GetKeys ¶
func (m *SplitResource) GetKeys() [][]byte
func (*SplitResource) GetPolicy ¶
func (m *SplitResource) GetPolicy() metapb.CheckPolicy
func (*SplitResource) Marshal ¶
func (m *SplitResource) Marshal() (dAtA []byte, err error)
func (*SplitResource) MarshalToSizedBuffer ¶
func (m *SplitResource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SplitResource) ProtoMessage ¶
func (*SplitResource) ProtoMessage()
func (*SplitResource) Reset ¶
func (m *SplitResource) Reset()
func (*SplitResource) Size ¶
func (m *SplitResource) Size() (n int)
func (*SplitResource) String ¶
func (m *SplitResource) String() string
func (*SplitResource) Unmarshal ¶
func (m *SplitResource) Unmarshal(dAtA []byte) error
func (*SplitResource) XXX_DiscardUnknown ¶
func (m *SplitResource) XXX_DiscardUnknown()
func (*SplitResource) XXX_Marshal ¶
func (m *SplitResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SplitResource) XXX_Merge ¶
func (m *SplitResource) XXX_Merge(src proto.Message)
func (*SplitResource) XXX_Size ¶
func (m *SplitResource) XXX_Size() int
func (*SplitResource) XXX_Unmarshal ¶
func (m *SplitResource) XXX_Unmarshal(b []byte) error
type TSOReq ¶
type TSOReq struct {
Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
}
TSOReq get tso request
func (*TSOReq) Descriptor ¶
func (*TSOReq) MarshalToSizedBuffer ¶
func (*TSOReq) ProtoMessage ¶
func (*TSOReq) ProtoMessage()
func (*TSOReq) XXX_DiscardUnknown ¶
func (m *TSOReq) XXX_DiscardUnknown()
func (*TSOReq) XXX_Marshal ¶
func (*TSOReq) XXX_Unmarshal ¶
type TSORsp ¶
type TSORsp struct { Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Timestamp *metapb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` }
TSORsp get tso response
func (*TSORsp) Descriptor ¶
func (*TSORsp) GetTimestamp ¶
func (*TSORsp) MarshalToSizedBuffer ¶
func (*TSORsp) ProtoMessage ¶
func (*TSORsp) ProtoMessage()
func (*TSORsp) XXX_DiscardUnknown ¶
func (m *TSORsp) XXX_DiscardUnknown()
func (*TSORsp) XXX_Marshal ¶
func (*TSORsp) XXX_Unmarshal ¶
type TimeInterval ¶
type TimeInterval struct { // The unix timestamp in seconds of the start of this period. Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` // The unix timestamp in seconds of the end of this period. End uint64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` }
TimeInterval time interval
func (*TimeInterval) Descriptor ¶
func (*TimeInterval) Descriptor() ([]byte, []int)
func (*TimeInterval) GetEnd ¶
func (m *TimeInterval) GetEnd() uint64
func (*TimeInterval) GetStart ¶
func (m *TimeInterval) GetStart() uint64
func (*TimeInterval) Marshal ¶
func (m *TimeInterval) Marshal() (dAtA []byte, err error)
func (*TimeInterval) MarshalToSizedBuffer ¶
func (m *TimeInterval) MarshalToSizedBuffer(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 (m *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 TransferLeader ¶
type TransferLeader struct {
Peer metapb.Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer"`
}
TransferLeader transfer leader
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) MarshalToSizedBuffer ¶
func (m *TransferLeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TransferLeader) ProtoMessage ¶
func (*TransferLeader) ProtoMessage()
func (*TransferLeader) Reset ¶
func (m *TransferLeader) Reset()
func (*TransferLeader) Size ¶
func (m *TransferLeader) Size() (n int)
func (*TransferLeader) String ¶
func (m *TransferLeader) String() string
func (*TransferLeader) Unmarshal ¶
func (m *TransferLeader) Unmarshal(dAtA []byte) error
func (*TransferLeader) XXX_DiscardUnknown ¶
func (m *TransferLeader) XXX_DiscardUnknown()
func (*TransferLeader) XXX_Marshal ¶
func (m *TransferLeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransferLeader) XXX_Merge ¶
func (m *TransferLeader) XXX_Merge(src proto.Message)
func (*TransferLeader) XXX_Size ¶
func (m *TransferLeader) XXX_Size() int
func (*TransferLeader) XXX_Unmarshal ¶
func (m *TransferLeader) XXX_Unmarshal(b []byte) error
type Type ¶
type Type int32
Type rpc type
const ( TypeResourceHeartbeatReq Type = 0 TypeResourceHeartbeatRsp Type = 1 TypeContainerHeartbeatReq Type = 2 TypeContainerHeartbeatRsp Type = 3 TypeGetContainerReq Type = 4 TypeGetContainerRsp Type = 5 TypeAllocIDReq Type = 6 TypeAllocIDRsp Type = 7 TypeAskSplitReq Type = 8 TypeAskSplitRsp Type = 9 TypeAskBatchSplitReq Type = 10 TypeAskBatchSplitRsp Type = 11 TypeReportSplitReq Type = 12 TypeReportSplitRsp Type = 13 TypeBatchReportSplitReq Type = 14 TypeBatchReportSplitRsp Type = 15 TypeTSOReq Type = 16 TypeTSORsp Type = 17 TypeCreateWatcherReq Type = 18 TypeEventNotify Type = 19 TypeGetDCLocationsReq Type = 20 TypeGetDCLocationsRsp Type = 21 )