Versions in this module Expand all Collapse all v0 v0.3.0 Mar 9, 2022 v0.2.0 Jan 5, 2022 Changes in this version + var ErrIntOverflowMeta = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMeta = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupMeta = fmt.Errorf("proto: unexpected end of group") + var ReplicaState_name = map[int32]string + var ReplicaState_value = map[string]int32 + var ShardsPoolCmdType_name = map[int32]string + var ShardsPoolCmdType_value = map[string]int32 + type AllocatedShard struct + AllocatedAt uint64 + Purpose []byte + ShardID uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AllocatedShard) Descriptor() ([]byte, []int) + func (*AllocatedShard) ProtoMessage() + func (m *AllocatedShard) GetAllocatedAt() uint64 + func (m *AllocatedShard) GetPurpose() []byte + func (m *AllocatedShard) GetShardID() uint64 + func (m *AllocatedShard) Marshal() (dAtA []byte, err error) + func (m *AllocatedShard) MarshalTo(dAtA []byte) (int, error) + func (m *AllocatedShard) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AllocatedShard) Reset() + func (m *AllocatedShard) Size() (n int) + func (m *AllocatedShard) String() string + func (m *AllocatedShard) Unmarshal(dAtA []byte) error + func (m *AllocatedShard) XXX_DiscardUnknown() + func (m *AllocatedShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AllocatedShard) XXX_Merge(src proto.Message) + func (m *AllocatedShard) XXX_Size() int + func (m *AllocatedShard) XXX_Unmarshal(b []byte) error + type Cluster struct + ID uint64 + MaxReplicas uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Cluster) Descriptor() ([]byte, []int) + func (*Cluster) ProtoMessage() + func (m *Cluster) GetID() uint64 + func (m *Cluster) GetMaxReplicas() uint32 + func (m *Cluster) Marshal() (dAtA []byte, err error) + func (m *Cluster) MarshalTo(dAtA []byte) (int, error) + func (m *Cluster) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Cluster) Reset() + func (m *Cluster) Size() (n int) + func (m *Cluster) String() string + func (m *Cluster) Unmarshal(dAtA []byte) error + func (m *Cluster) XXX_DiscardUnknown() + func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Cluster) XXX_Merge(src proto.Message) + func (m *Cluster) XXX_Size() int + func (m *Cluster) XXX_Unmarshal(b []byte) error + type LogIndex struct + Index uint64 + Term uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogIndex) Descriptor() ([]byte, []int) + func (*LogIndex) ProtoMessage() + func (m *LogIndex) GetIndex() uint64 + func (m *LogIndex) GetTerm() uint64 + func (m *LogIndex) Marshal() (dAtA []byte, err error) + func (m *LogIndex) MarshalTo(dAtA []byte) (int, error) + func (m *LogIndex) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LogIndex) Reset() + func (m *LogIndex) Size() (n int) + func (m *LogIndex) String() string + func (m *LogIndex) Unmarshal(dAtA []byte) error + func (m *LogIndex) XXX_DiscardUnknown() + func (m *LogIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LogIndex) XXX_Merge(src proto.Message) + func (m *LogIndex) XXX_Size() int + func (m *LogIndex) XXX_Unmarshal(b []byte) error + type RaftMessage struct + CommitIndex uint64 + DisableSplit bool + End []byte + From metapb.Replica + Group uint64 + IsTombstone bool + Message raftpb.Message + RuleGroups []string + SendTime uint64 + ShardEpoch metapb.ResourceEpoch + ShardID uint64 + Start []byte + To metapb.Replica + Unique string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftMessage) Descriptor() ([]byte, []int) + func (*RaftMessage) ProtoMessage() + func (m *RaftMessage) GetCommitIndex() uint64 + func (m *RaftMessage) GetDisableSplit() bool + func (m *RaftMessage) GetEnd() []byte + func (m *RaftMessage) GetFrom() metapb.Replica + func (m *RaftMessage) GetGroup() uint64 + func (m *RaftMessage) GetIsTombstone() bool + func (m *RaftMessage) GetMessage() raftpb.Message + func (m *RaftMessage) GetRuleGroups() []string + func (m *RaftMessage) GetSendTime() uint64 + func (m *RaftMessage) GetShardEpoch() metapb.ResourceEpoch + func (m *RaftMessage) GetShardID() uint64 + func (m *RaftMessage) GetStart() []byte + func (m *RaftMessage) GetTo() metapb.Replica + func (m *RaftMessage) GetUnique() string + func (m *RaftMessage) Marshal() (dAtA []byte, err error) + func (m *RaftMessage) MarshalTo(dAtA []byte) (int, error) + func (m *RaftMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftMessage) Reset() + func (m *RaftMessage) Size() (n int) + func (m *RaftMessage) String() string + func (m *RaftMessage) Unmarshal(dAtA []byte) error + func (m *RaftMessage) XXX_DiscardUnknown() + func (m *RaftMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftMessage) XXX_Merge(src proto.Message) + func (m *RaftMessage) XXX_Size() int + func (m *RaftMessage) XXX_Unmarshal(b []byte) error + type RaftMessageBatch struct + Messages []RaftMessage + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RaftMessageBatch) Descriptor() ([]byte, []int) + func (*RaftMessageBatch) ProtoMessage() + func (m *RaftMessageBatch) GetMessages() []RaftMessage + func (m *RaftMessageBatch) Marshal() (dAtA []byte, err error) + func (m *RaftMessageBatch) MarshalTo(dAtA []byte) (int, error) + func (m *RaftMessageBatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RaftMessageBatch) Reset() + func (m *RaftMessageBatch) Size() (n int) + func (m *RaftMessageBatch) String() string + func (m *RaftMessageBatch) Unmarshal(dAtA []byte) error + func (m *RaftMessageBatch) XXX_DiscardUnknown() + func (m *RaftMessageBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RaftMessageBatch) XXX_Merge(src proto.Message) + func (m *RaftMessageBatch) XXX_Size() int + func (m *RaftMessageBatch) XXX_Unmarshal(b []byte) error + type ReplicaState int32 + const ReplicaState_Applying + const ReplicaState_Normal + const ReplicaState_Tombstone + func (ReplicaState) EnumDescriptor() ([]byte, []int) + func (x ReplicaState) String() string + type Shard struct + Data []byte + DisableSplit bool + End []byte + Epoch metapb.ResourceEpoch + Group uint64 + ID uint64 + Labels []metapb.Pair + Replicas []metapb.Replica + RuleGroups []string + Start []byte + State metapb.ResourceState + Unique string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Shard) Descriptor() ([]byte, []int) + func (*Shard) ProtoMessage() + func (m *Shard) GetData() []byte + func (m *Shard) GetDisableSplit() bool + func (m *Shard) GetEnd() []byte + func (m *Shard) GetEpoch() metapb.ResourceEpoch + func (m *Shard) GetGroup() uint64 + func (m *Shard) GetID() uint64 + func (m *Shard) GetLabels() []metapb.Pair + func (m *Shard) GetReplicas() []metapb.Replica + func (m *Shard) GetRuleGroups() []string + func (m *Shard) GetStart() []byte + func (m *Shard) GetState() metapb.ResourceState + func (m *Shard) GetUnique() string + func (m *Shard) Marshal() (dAtA []byte, err error) + func (m *Shard) MarshalTo(dAtA []byte) (int, error) + func (m *Shard) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Shard) Reset() + func (m *Shard) Size() (n int) + func (m *Shard) String() string + func (m *Shard) Unmarshal(dAtA []byte) error + func (m *Shard) XXX_DiscardUnknown() + func (m *Shard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Shard) XXX_Merge(src proto.Message) + func (m *Shard) XXX_Size() int + func (m *Shard) XXX_Unmarshal(b []byte) error + func (m Shard) Clone() Shard + type ShardLocalState struct + RemoveData bool + Shard Shard + State ReplicaState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardLocalState) Descriptor() ([]byte, []int) + func (*ShardLocalState) ProtoMessage() + func (m *ShardLocalState) GetRemoveData() bool + func (m *ShardLocalState) GetShard() Shard + func (m *ShardLocalState) GetState() ReplicaState + func (m *ShardLocalState) Marshal() (dAtA []byte, err error) + func (m *ShardLocalState) MarshalTo(dAtA []byte) (int, error) + func (m *ShardLocalState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardLocalState) Reset() + func (m *ShardLocalState) Size() (n int) + func (m *ShardLocalState) String() string + func (m *ShardLocalState) Unmarshal(dAtA []byte) error + func (m *ShardLocalState) XXX_DiscardUnknown() + func (m *ShardLocalState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardLocalState) XXX_Merge(src proto.Message) + func (m *ShardLocalState) XXX_Size() int + func (m *ShardLocalState) XXX_Unmarshal(b []byte) error + type ShardMetadata struct + LogIndex uint64 + Metadata ShardLocalState + ShardID uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardMetadata) Descriptor() ([]byte, []int) + func (*ShardMetadata) ProtoMessage() + func (m *ShardMetadata) GetLogIndex() uint64 + func (m *ShardMetadata) GetMetadata() ShardLocalState + func (m *ShardMetadata) GetShardID() uint64 + func (m *ShardMetadata) Marshal() (dAtA []byte, err error) + func (m *ShardMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *ShardMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardMetadata) Reset() + func (m *ShardMetadata) Size() (n int) + func (m *ShardMetadata) String() string + func (m *ShardMetadata) Unmarshal(dAtA []byte) error + func (m *ShardMetadata) XXX_DiscardUnknown() + func (m *ShardMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardMetadata) XXX_Merge(src proto.Message) + func (m *ShardMetadata) XXX_Size() int + func (m *ShardMetadata) XXX_Unmarshal(b []byte) error + type ShardPool struct + AllocatedOffset uint64 + AllocatedShards []*AllocatedShard + Capacity uint64 + RangePrefix []byte + Seq uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardPool) Descriptor() ([]byte, []int) + func (*ShardPool) ProtoMessage() + func (m *ShardPool) GetAllocatedOffset() uint64 + func (m *ShardPool) GetAllocatedShards() []*AllocatedShard + func (m *ShardPool) GetCapacity() uint64 + func (m *ShardPool) GetRangePrefix() []byte + func (m *ShardPool) GetSeq() uint64 + func (m *ShardPool) Marshal() (dAtA []byte, err error) + func (m *ShardPool) MarshalTo(dAtA []byte) (int, error) + func (m *ShardPool) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardPool) Reset() + func (m *ShardPool) Size() (n int) + func (m *ShardPool) String() string + func (m *ShardPool) Unmarshal(dAtA []byte) error + func (m *ShardPool) XXX_DiscardUnknown() + func (m *ShardPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardPool) XXX_Merge(src proto.Message) + func (m *ShardPool) XXX_Size() int + func (m *ShardPool) XXX_Unmarshal(b []byte) error + type ShardsPool struct + Pools map[uint64]*ShardPool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardsPool) Descriptor() ([]byte, []int) + func (*ShardsPool) ProtoMessage() + func (m *ShardsPool) GetPools() map[uint64]*ShardPool + func (m *ShardsPool) Marshal() (dAtA []byte, err error) + func (m *ShardsPool) MarshalTo(dAtA []byte) (int, error) + func (m *ShardsPool) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardsPool) Reset() + func (m *ShardsPool) Size() (n int) + func (m *ShardsPool) String() string + func (m *ShardsPool) Unmarshal(dAtA []byte) error + func (m *ShardsPool) XXX_DiscardUnknown() + func (m *ShardsPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardsPool) XXX_Merge(src proto.Message) + func (m *ShardsPool) XXX_Size() int + func (m *ShardsPool) XXX_Unmarshal(b []byte) error + type ShardsPoolAllocCmd struct + Group uint64 + Purpose []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardsPoolAllocCmd) Descriptor() ([]byte, []int) + func (*ShardsPoolAllocCmd) ProtoMessage() + func (m *ShardsPoolAllocCmd) GetGroup() uint64 + func (m *ShardsPoolAllocCmd) GetPurpose() []byte + func (m *ShardsPoolAllocCmd) Marshal() (dAtA []byte, err error) + func (m *ShardsPoolAllocCmd) MarshalTo(dAtA []byte) (int, error) + func (m *ShardsPoolAllocCmd) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardsPoolAllocCmd) Reset() + func (m *ShardsPoolAllocCmd) Size() (n int) + func (m *ShardsPoolAllocCmd) String() string + func (m *ShardsPoolAllocCmd) Unmarshal(dAtA []byte) error + func (m *ShardsPoolAllocCmd) XXX_DiscardUnknown() + func (m *ShardsPoolAllocCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardsPoolAllocCmd) XXX_Merge(src proto.Message) + func (m *ShardsPoolAllocCmd) XXX_Size() int + func (m *ShardsPoolAllocCmd) XXX_Unmarshal(b []byte) error + type ShardsPoolCmd struct + Alloc *ShardsPoolAllocCmd + Create *ShardsPoolCreateCmd + Type ShardsPoolCmdType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardsPoolCmd) Descriptor() ([]byte, []int) + func (*ShardsPoolCmd) ProtoMessage() + func (m *ShardsPoolCmd) GetAlloc() *ShardsPoolAllocCmd + func (m *ShardsPoolCmd) GetCreate() *ShardsPoolCreateCmd + func (m *ShardsPoolCmd) GetType() ShardsPoolCmdType + func (m *ShardsPoolCmd) Marshal() (dAtA []byte, err error) + func (m *ShardsPoolCmd) MarshalTo(dAtA []byte) (int, error) + func (m *ShardsPoolCmd) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardsPoolCmd) Reset() + func (m *ShardsPoolCmd) Size() (n int) + func (m *ShardsPoolCmd) String() string + func (m *ShardsPoolCmd) Unmarshal(dAtA []byte) error + func (m *ShardsPoolCmd) XXX_DiscardUnknown() + func (m *ShardsPoolCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardsPoolCmd) XXX_Merge(src proto.Message) + func (m *ShardsPoolCmd) XXX_Size() int + func (m *ShardsPoolCmd) XXX_Unmarshal(b []byte) error + type ShardsPoolCmdType int32 + const ShardsPoolCmdType_AllocShard + const ShardsPoolCmdType_CreateShard + func (ShardsPoolCmdType) EnumDescriptor() ([]byte, []int) + func (x ShardsPoolCmdType) String() string + type ShardsPoolCreateCmd struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardsPoolCreateCmd) Descriptor() ([]byte, []int) + func (*ShardsPoolCreateCmd) ProtoMessage() + func (m *ShardsPoolCreateCmd) Marshal() (dAtA []byte, err error) + func (m *ShardsPoolCreateCmd) MarshalTo(dAtA []byte) (int, error) + func (m *ShardsPoolCreateCmd) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShardsPoolCreateCmd) Reset() + func (m *ShardsPoolCreateCmd) Size() (n int) + func (m *ShardsPoolCreateCmd) String() string + func (m *ShardsPoolCreateCmd) Unmarshal(dAtA []byte) error + func (m *ShardsPoolCreateCmd) XXX_DiscardUnknown() + func (m *ShardsPoolCreateCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardsPoolCreateCmd) XXX_Merge(src proto.Message) + func (m *ShardsPoolCreateCmd) XXX_Size() int + func (m *ShardsPoolCreateCmd) XXX_Unmarshal(b []byte) error + type SnapshotChunk struct + ChunkCount uint64 + ChunkID uint64 + ChunkSize uint64 + ConfState raftpb.ConfState + ContainerID uint64 + Data []byte + Extra []byte + FileChunkCount uint64 + FileChunkID uint64 + FilePath string + FileSize uint64 + From uint64 + Index uint64 + ReplicaID uint64 + ShardID uint64 + Term uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotChunk) Descriptor() ([]byte, []int) + func (*SnapshotChunk) ProtoMessage() + func (c *SnapshotChunk) IsLastChunk() bool + func (c *SnapshotChunk) IsLastFileChunk() bool + func (m *SnapshotChunk) GetChunkCount() uint64 + func (m *SnapshotChunk) GetChunkID() uint64 + func (m *SnapshotChunk) GetChunkSize() uint64 + func (m *SnapshotChunk) GetConfState() raftpb.ConfState + func (m *SnapshotChunk) GetContainerID() uint64 + func (m *SnapshotChunk) GetData() []byte + func (m *SnapshotChunk) GetExtra() []byte + func (m *SnapshotChunk) GetFileChunkCount() uint64 + func (m *SnapshotChunk) GetFileChunkID() uint64 + func (m *SnapshotChunk) GetFilePath() string + func (m *SnapshotChunk) GetFileSize() uint64 + func (m *SnapshotChunk) GetFrom() uint64 + func (m *SnapshotChunk) GetIndex() uint64 + func (m *SnapshotChunk) GetReplicaID() uint64 + func (m *SnapshotChunk) GetShardID() uint64 + func (m *SnapshotChunk) GetTerm() uint64 + func (m *SnapshotChunk) Marshal() (dAtA []byte, err error) + func (m *SnapshotChunk) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotChunk) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotChunk) Reset() + func (m *SnapshotChunk) Size() (n int) + func (m *SnapshotChunk) String() string + func (m *SnapshotChunk) Unmarshal(dAtA []byte) error + func (m *SnapshotChunk) XXX_DiscardUnknown() + func (m *SnapshotChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotChunk) XXX_Merge(src proto.Message) + func (m *SnapshotChunk) XXX_Size() int + func (m *SnapshotChunk) XXX_Unmarshal(b []byte) error + type SnapshotInfo struct + Dummy bool + Extra uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotInfo) Descriptor() ([]byte, []int) + func (*SnapshotInfo) ProtoMessage() + func (m *SnapshotInfo) GetDummy() bool + func (m *SnapshotInfo) GetExtra() uint64 + func (m *SnapshotInfo) Marshal() (dAtA []byte, err error) + func (m *SnapshotInfo) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotInfo) Reset() + func (m *SnapshotInfo) Size() (n int) + func (m *SnapshotInfo) String() string + func (m *SnapshotInfo) Unmarshal(dAtA []byte) error + func (m *SnapshotInfo) XXX_DiscardUnknown() + func (m *SnapshotInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotInfo) XXX_Merge(src proto.Message) + func (m *SnapshotInfo) XXX_Size() int + func (m *SnapshotInfo) XXX_Unmarshal(b []byte) error + type SnapshotMessage struct + CheckSum uint64 + Data []byte + FileSize uint64 + First bool + Header SnapshotMessageHeader + Last bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotMessage) Descriptor() ([]byte, []int) + func (*SnapshotMessage) ProtoMessage() + func (m *SnapshotMessage) GetCheckSum() uint64 + func (m *SnapshotMessage) GetData() []byte + func (m *SnapshotMessage) GetFileSize() uint64 + func (m *SnapshotMessage) GetFirst() bool + func (m *SnapshotMessage) GetHeader() SnapshotMessageHeader + func (m *SnapshotMessage) GetLast() bool + func (m *SnapshotMessage) Marshal() (dAtA []byte, err error) + func (m *SnapshotMessage) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotMessage) Reset() + func (m *SnapshotMessage) Size() (n int) + func (m *SnapshotMessage) String() string + func (m *SnapshotMessage) Unmarshal(dAtA []byte) error + func (m *SnapshotMessage) XXX_DiscardUnknown() + func (m *SnapshotMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotMessage) XXX_Merge(src proto.Message) + func (m *SnapshotMessage) XXX_Size() int + func (m *SnapshotMessage) XXX_Unmarshal(b []byte) error + type SnapshotMessageHeader struct + From metapb.Replica + Index uint64 + Shard Shard + Term uint64 + To metapb.Replica + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotMessageHeader) Descriptor() ([]byte, []int) + func (*SnapshotMessageHeader) ProtoMessage() + func (m *SnapshotMessageHeader) GetFrom() metapb.Replica + func (m *SnapshotMessageHeader) GetIndex() uint64 + func (m *SnapshotMessageHeader) GetShard() Shard + func (m *SnapshotMessageHeader) GetTerm() uint64 + func (m *SnapshotMessageHeader) GetTo() metapb.Replica + func (m *SnapshotMessageHeader) Marshal() (dAtA []byte, err error) + func (m *SnapshotMessageHeader) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotMessageHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SnapshotMessageHeader) Reset() + func (m *SnapshotMessageHeader) Size() (n int) + func (m *SnapshotMessageHeader) String() string + func (m *SnapshotMessageHeader) Unmarshal(dAtA []byte) error + func (m *SnapshotMessageHeader) XXX_DiscardUnknown() + func (m *SnapshotMessageHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotMessageHeader) XXX_Merge(src proto.Message) + func (m *SnapshotMessageHeader) XXX_Size() int + func (m *SnapshotMessageHeader) XXX_Unmarshal(b []byte) error + type Store struct + ClientAddr string + DeployPath string + GitHash string + ID uint64 + Labels []metapb.Pair + LastHeartbeatTime int64 + PhysicallyDestroyed bool + RaftAddr string + StartTime int64 + State metapb.ContainerState + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Store) Descriptor() ([]byte, []int) + func (*Store) ProtoMessage() + func (m *Store) GetClientAddr() string + func (m *Store) GetDeployPath() string + func (m *Store) GetGitHash() string + func (m *Store) GetID() uint64 + func (m *Store) GetLabels() []metapb.Pair + func (m *Store) GetLastHeartbeatTime() int64 + func (m *Store) GetPhysicallyDestroyed() bool + func (m *Store) GetRaftAddr() string + func (m *Store) GetStartTime() int64 + func (m *Store) GetState() metapb.ContainerState + func (m *Store) GetVersion() string + func (m *Store) Marshal() (dAtA []byte, err error) + func (m *Store) MarshalTo(dAtA []byte) (int, error) + func (m *Store) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Store) Reset() + func (m *Store) Size() (n int) + func (m *Store) String() string + func (m *Store) Unmarshal(dAtA []byte) error + func (m *Store) XXX_DiscardUnknown() + func (m *Store) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Store) XXX_Merge(src proto.Message) + func (m *Store) XXX_Size() int + func (m *Store) XXX_Unmarshal(b []byte) error + type StoreIdent struct + ClusterID uint64 + StoreID uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreIdent) Descriptor() ([]byte, []int) + func (*StoreIdent) ProtoMessage() + func (m *StoreIdent) GetClusterID() uint64 + func (m *StoreIdent) GetStoreID() uint64 + func (m *StoreIdent) Marshal() (dAtA []byte, err error) + func (m *StoreIdent) MarshalTo(dAtA []byte) (int, error) + func (m *StoreIdent) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StoreIdent) Reset() + func (m *StoreIdent) Size() (n int) + func (m *StoreIdent) String() string + func (m *StoreIdent) Unmarshal(dAtA []byte) error + func (m *StoreIdent) XXX_DiscardUnknown() + func (m *StoreIdent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StoreIdent) XXX_Merge(src proto.Message) + func (m *StoreIdent) XXX_Size() int + func (m *StoreIdent) XXX_Unmarshal(b []byte) error