Versions in this module Expand all Collapse all v0 v0.1.0 Oct 13, 2021 Changes in this version + var ErrIntOverflowBhmetapb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthBhmetapb = fmt.Errorf("proto: negative length found during unmarshaling") + 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) 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) 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 Shard struct + Data []byte + DisableSplit bool + End []byte + Epoch metapb.ResourceEpoch + Group uint64 + ID uint64 + Peers []metapb.Peer + 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) GetPeers() []metapb.Peer + 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) 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 + 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) 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) 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) 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) 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) 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 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) 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) 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