Documentation ¶
Index ¶
- Variables
- type AllocatedShard
- func (*AllocatedShard) Descriptor() ([]byte, []int)
- 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 (*AllocatedShard) ProtoMessage()
- 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
- func (*Cluster) Descriptor() ([]byte, []int)
- 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 (*Cluster) ProtoMessage()
- 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
- func (*Shard) Descriptor() ([]byte, []int)
- 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 (*Shard) ProtoMessage()
- 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
- func (*ShardPool) Descriptor() ([]byte, []int)
- 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 (*ShardPool) ProtoMessage()
- 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
- func (*ShardsPool) Descriptor() ([]byte, []int)
- func (m *ShardsPool) GetPools() map[uint64]*ShardPool
- func (m *ShardsPool) Marshal() (dAtA []byte, err error)
- func (m *ShardsPool) MarshalTo(dAtA []byte) (int, error)
- func (*ShardsPool) ProtoMessage()
- 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
- func (*ShardsPoolAllocCmd) Descriptor() ([]byte, []int)
- 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 (*ShardsPoolAllocCmd) ProtoMessage()
- 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
- func (*ShardsPoolCmd) Descriptor() ([]byte, []int)
- 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 (*ShardsPoolCmd) ProtoMessage()
- 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
- type ShardsPoolCreateCmd
- func (*ShardsPoolCreateCmd) Descriptor() ([]byte, []int)
- func (m *ShardsPoolCreateCmd) Marshal() (dAtA []byte, err error)
- func (m *ShardsPoolCreateCmd) MarshalTo(dAtA []byte) (int, error)
- func (*ShardsPoolCreateCmd) ProtoMessage()
- 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
- func (*Store) Descriptor() ([]byte, []int)
- 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 (*Store) ProtoMessage()
- 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
- func (*StoreIdent) Descriptor() ([]byte, []int)
- 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 (*StoreIdent) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthBhmetapb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowBhmetapb = fmt.Errorf("proto: integer overflow") )
View Source
var ShardsPoolCmdType_name = map[int32]string{
0: "CreateShard",
1: "AllocShard",
}
View Source
var ShardsPoolCmdType_value = map[string]int32{
"CreateShard": 0,
"AllocShard": 1,
}
Functions ¶
This section is empty.
Types ¶
type AllocatedShard ¶
type AllocatedShard struct { ShardID uint64 `protobuf:"varint,1,opt,name=shardID,proto3" json:"shardID,omitempty"` AllocatedAt uint64 `protobuf:"varint,2,opt,name=allocatedAt,proto3" json:"allocatedAt,omitempty"` Purpose []byte `protobuf:"bytes,3,opt,name=purpose,proto3" json:"purpose,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
AllocatedShard allocated shard info
func (*AllocatedShard) Descriptor ¶
func (*AllocatedShard) Descriptor() ([]byte, []int)
func (*AllocatedShard) GetAllocatedAt ¶
func (m *AllocatedShard) GetAllocatedAt() uint64
func (*AllocatedShard) GetPurpose ¶
func (m *AllocatedShard) GetPurpose() []byte
func (*AllocatedShard) GetShardID ¶
func (m *AllocatedShard) GetShardID() uint64
func (*AllocatedShard) Marshal ¶
func (m *AllocatedShard) Marshal() (dAtA []byte, err error)
func (*AllocatedShard) ProtoMessage ¶
func (*AllocatedShard) ProtoMessage()
func (*AllocatedShard) Reset ¶
func (m *AllocatedShard) Reset()
func (*AllocatedShard) Size ¶
func (m *AllocatedShard) Size() (n int)
func (*AllocatedShard) String ¶
func (m *AllocatedShard) String() string
func (*AllocatedShard) Unmarshal ¶
func (m *AllocatedShard) Unmarshal(dAtA []byte) error
func (*AllocatedShard) XXX_DiscardUnknown ¶
func (m *AllocatedShard) XXX_DiscardUnknown()
func (*AllocatedShard) XXX_Marshal ¶
func (m *AllocatedShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AllocatedShard) XXX_Merge ¶
func (m *AllocatedShard) XXX_Merge(src proto.Message)
func (*AllocatedShard) XXX_Size ¶
func (m *AllocatedShard) XXX_Size() int
func (*AllocatedShard) XXX_Unmarshal ¶
func (m *AllocatedShard) XXX_Unmarshal(b []byte) error
type Cluster ¶
type Cluster struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` MaxReplicas uint32 `protobuf:"varint,2,opt,name=maxReplicas,proto3" json:"maxReplicas,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Cluster the cluster info
func (*Cluster) Descriptor ¶
func (*Cluster) GetMaxReplicas ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) XXX_DiscardUnknown ¶
func (m *Cluster) XXX_DiscardUnknown()
func (*Cluster) XXX_Marshal ¶
func (*Cluster) XXX_Unmarshal ¶
type Shard ¶
type Shard struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Start []byte `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"` End []byte `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"` Epoch metapb.ResourceEpoch `protobuf:"bytes,4,opt,name=epoch,proto3" json:"epoch"` State metapb.ResourceState `protobuf:"varint,5,opt,name=state,proto3,enum=metapb.ResourceState" json:"state,omitempty"` Peers []metapb.Peer `protobuf:"bytes,6,rep,name=peers,proto3" json:"peers"` DisableSplit bool `protobuf:"varint,7,opt,name=disableSplit,proto3" json:"disableSplit,omitempty"` Group uint64 `protobuf:"varint,8,opt,name=group,proto3" json:"group,omitempty"` Unique string `protobuf:"bytes,10,opt,name=unique,proto3" json:"unique,omitempty"` RuleGroups []string `protobuf:"bytes,11,rep,name=ruleGroups,proto3" json:"ruleGroups,omitempty"` Data []byte `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Shard a shard [start,end) of the data
func (*Shard) Descriptor ¶
func (*Shard) GetDisableSplit ¶
func (*Shard) GetEpoch ¶
func (m *Shard) GetEpoch() metapb.ResourceEpoch
func (*Shard) GetRuleGroups ¶
func (*Shard) GetState ¶
func (m *Shard) GetState() metapb.ResourceState
func (*Shard) ProtoMessage ¶
func (*Shard) ProtoMessage()
func (*Shard) XXX_DiscardUnknown ¶
func (m *Shard) XXX_DiscardUnknown()
func (*Shard) XXX_Marshal ¶
func (*Shard) XXX_Unmarshal ¶
type ShardPool ¶
type ShardPool struct { Capacity uint64 `protobuf:"varint,1,opt,name=capacity,proto3" json:"capacity,omitempty"` RangePrefix []byte `protobuf:"bytes,2,opt,name=rangePrefix,proto3" json:"rangePrefix,omitempty"` AllocatedShards []*AllocatedShard `protobuf:"bytes,3,rep,name=allocatedShards,proto3" json:"allocatedShards,omitempty"` Seq uint64 `protobuf:"varint,4,opt,name=seq,proto3" json:"seq,omitempty"` AllocatedOffset uint64 `protobuf:"varint,5,opt,name=allocatedOffset,proto3" json:"allocatedOffset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShardPool shard pool
func (*ShardPool) Descriptor ¶
func (*ShardPool) GetAllocatedOffset ¶
func (*ShardPool) GetAllocatedShards ¶
func (m *ShardPool) GetAllocatedShards() []*AllocatedShard
func (*ShardPool) GetCapacity ¶
func (*ShardPool) GetRangePrefix ¶
func (*ShardPool) ProtoMessage ¶
func (*ShardPool) ProtoMessage()
func (*ShardPool) XXX_DiscardUnknown ¶
func (m *ShardPool) XXX_DiscardUnknown()
func (*ShardPool) XXX_Marshal ¶
func (*ShardPool) XXX_Unmarshal ¶
type ShardsPool ¶
type ShardsPool struct { Pools map[uint64]*ShardPool `` /* 152-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShardsPool shards pool
func (*ShardsPool) Descriptor ¶
func (*ShardsPool) Descriptor() ([]byte, []int)
func (*ShardsPool) GetPools ¶
func (m *ShardsPool) GetPools() map[uint64]*ShardPool
func (*ShardsPool) Marshal ¶
func (m *ShardsPool) Marshal() (dAtA []byte, err error)
func (*ShardsPool) ProtoMessage ¶
func (*ShardsPool) ProtoMessage()
func (*ShardsPool) Reset ¶
func (m *ShardsPool) Reset()
func (*ShardsPool) Size ¶
func (m *ShardsPool) Size() (n int)
func (*ShardsPool) String ¶
func (m *ShardsPool) String() string
func (*ShardsPool) Unmarshal ¶
func (m *ShardsPool) Unmarshal(dAtA []byte) error
func (*ShardsPool) XXX_DiscardUnknown ¶
func (m *ShardsPool) XXX_DiscardUnknown()
func (*ShardsPool) XXX_Marshal ¶
func (m *ShardsPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShardsPool) XXX_Merge ¶
func (m *ShardsPool) XXX_Merge(src proto.Message)
func (*ShardsPool) XXX_Size ¶
func (m *ShardsPool) XXX_Size() int
func (*ShardsPool) XXX_Unmarshal ¶
func (m *ShardsPool) XXX_Unmarshal(b []byte) error
type ShardsPoolAllocCmd ¶
type ShardsPoolAllocCmd struct { Group uint64 `protobuf:"varint,1,opt,name=group,proto3" json:"group,omitempty"` Purpose []byte `protobuf:"bytes,2,opt,name=purpose,proto3" json:"purpose,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShardsPoolAllocCmd shards pool create cmd
func (*ShardsPoolAllocCmd) Descriptor ¶
func (*ShardsPoolAllocCmd) Descriptor() ([]byte, []int)
func (*ShardsPoolAllocCmd) GetGroup ¶
func (m *ShardsPoolAllocCmd) GetGroup() uint64
func (*ShardsPoolAllocCmd) GetPurpose ¶
func (m *ShardsPoolAllocCmd) GetPurpose() []byte
func (*ShardsPoolAllocCmd) Marshal ¶
func (m *ShardsPoolAllocCmd) Marshal() (dAtA []byte, err error)
func (*ShardsPoolAllocCmd) MarshalTo ¶
func (m *ShardsPoolAllocCmd) MarshalTo(dAtA []byte) (int, error)
func (*ShardsPoolAllocCmd) ProtoMessage ¶
func (*ShardsPoolAllocCmd) ProtoMessage()
func (*ShardsPoolAllocCmd) Reset ¶
func (m *ShardsPoolAllocCmd) Reset()
func (*ShardsPoolAllocCmd) Size ¶
func (m *ShardsPoolAllocCmd) Size() (n int)
func (*ShardsPoolAllocCmd) String ¶
func (m *ShardsPoolAllocCmd) String() string
func (*ShardsPoolAllocCmd) Unmarshal ¶
func (m *ShardsPoolAllocCmd) Unmarshal(dAtA []byte) error
func (*ShardsPoolAllocCmd) XXX_DiscardUnknown ¶
func (m *ShardsPoolAllocCmd) XXX_DiscardUnknown()
func (*ShardsPoolAllocCmd) XXX_Marshal ¶
func (m *ShardsPoolAllocCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShardsPoolAllocCmd) XXX_Merge ¶
func (m *ShardsPoolAllocCmd) XXX_Merge(src proto.Message)
func (*ShardsPoolAllocCmd) XXX_Size ¶
func (m *ShardsPoolAllocCmd) XXX_Size() int
func (*ShardsPoolAllocCmd) XXX_Unmarshal ¶
func (m *ShardsPoolAllocCmd) XXX_Unmarshal(b []byte) error
type ShardsPoolCmd ¶
type ShardsPoolCmd struct { Type ShardsPoolCmdType `protobuf:"varint,1,opt,name=type,proto3,enum=bhmetapb.ShardsPoolCmdType" json:"type,omitempty"` Create *ShardsPoolCreateCmd `protobuf:"bytes,2,opt,name=create,proto3" json:"create,omitempty"` Alloc *ShardsPoolAllocCmd `protobuf:"bytes,3,opt,name=alloc,proto3" json:"alloc,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShardsPoolCmd shards pool cmd
func (*ShardsPoolCmd) Descriptor ¶
func (*ShardsPoolCmd) Descriptor() ([]byte, []int)
func (*ShardsPoolCmd) GetAlloc ¶
func (m *ShardsPoolCmd) GetAlloc() *ShardsPoolAllocCmd
func (*ShardsPoolCmd) GetCreate ¶
func (m *ShardsPoolCmd) GetCreate() *ShardsPoolCreateCmd
func (*ShardsPoolCmd) GetType ¶
func (m *ShardsPoolCmd) GetType() ShardsPoolCmdType
func (*ShardsPoolCmd) Marshal ¶
func (m *ShardsPoolCmd) Marshal() (dAtA []byte, err error)
func (*ShardsPoolCmd) ProtoMessage ¶
func (*ShardsPoolCmd) ProtoMessage()
func (*ShardsPoolCmd) Reset ¶
func (m *ShardsPoolCmd) Reset()
func (*ShardsPoolCmd) Size ¶
func (m *ShardsPoolCmd) Size() (n int)
func (*ShardsPoolCmd) String ¶
func (m *ShardsPoolCmd) String() string
func (*ShardsPoolCmd) Unmarshal ¶
func (m *ShardsPoolCmd) Unmarshal(dAtA []byte) error
func (*ShardsPoolCmd) XXX_DiscardUnknown ¶
func (m *ShardsPoolCmd) XXX_DiscardUnknown()
func (*ShardsPoolCmd) XXX_Marshal ¶
func (m *ShardsPoolCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShardsPoolCmd) XXX_Merge ¶
func (m *ShardsPoolCmd) XXX_Merge(src proto.Message)
func (*ShardsPoolCmd) XXX_Size ¶
func (m *ShardsPoolCmd) XXX_Size() int
func (*ShardsPoolCmd) XXX_Unmarshal ¶
func (m *ShardsPoolCmd) XXX_Unmarshal(b []byte) error
type ShardsPoolCmdType ¶
type ShardsPoolCmdType int32
ShardsPoolCmdType shards pool cmd
const ( ShardsPoolCmdType_CreateShard ShardsPoolCmdType = 0 ShardsPoolCmdType_AllocShard ShardsPoolCmdType = 1 )
func (ShardsPoolCmdType) EnumDescriptor ¶
func (ShardsPoolCmdType) EnumDescriptor() ([]byte, []int)
func (ShardsPoolCmdType) String ¶
func (x ShardsPoolCmdType) String() string
type ShardsPoolCreateCmd ¶
type ShardsPoolCreateCmd struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShardsPoolCreateCmd shards pool create cmd
func (*ShardsPoolCreateCmd) Descriptor ¶
func (*ShardsPoolCreateCmd) Descriptor() ([]byte, []int)
func (*ShardsPoolCreateCmd) Marshal ¶
func (m *ShardsPoolCreateCmd) Marshal() (dAtA []byte, err error)
func (*ShardsPoolCreateCmd) MarshalTo ¶
func (m *ShardsPoolCreateCmd) MarshalTo(dAtA []byte) (int, error)
func (*ShardsPoolCreateCmd) ProtoMessage ¶
func (*ShardsPoolCreateCmd) ProtoMessage()
func (*ShardsPoolCreateCmd) Reset ¶
func (m *ShardsPoolCreateCmd) Reset()
func (*ShardsPoolCreateCmd) Size ¶
func (m *ShardsPoolCreateCmd) Size() (n int)
func (*ShardsPoolCreateCmd) String ¶
func (m *ShardsPoolCreateCmd) String() string
func (*ShardsPoolCreateCmd) Unmarshal ¶
func (m *ShardsPoolCreateCmd) Unmarshal(dAtA []byte) error
func (*ShardsPoolCreateCmd) XXX_DiscardUnknown ¶
func (m *ShardsPoolCreateCmd) XXX_DiscardUnknown()
func (*ShardsPoolCreateCmd) XXX_Marshal ¶
func (m *ShardsPoolCreateCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShardsPoolCreateCmd) XXX_Merge ¶
func (m *ShardsPoolCreateCmd) XXX_Merge(src proto.Message)
func (*ShardsPoolCreateCmd) XXX_Size ¶
func (m *ShardsPoolCreateCmd) XXX_Size() int
func (*ShardsPoolCreateCmd) XXX_Unmarshal ¶
func (m *ShardsPoolCreateCmd) XXX_Unmarshal(b []byte) error
type Store ¶
type Store struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` RaftAddr string `protobuf:"bytes,2,opt,name=raftAddr,proto3" json:"raftAddr,omitempty"` ClientAddr string `protobuf:"bytes,3,opt,name=clientAddr,proto3" json:"clientAddr,omitempty"` Labels []metapb.Pair `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels"` State metapb.ContainerState `protobuf:"varint,5,opt,name=state,proto3,enum=metapb.ContainerState" json:"state,omitempty"` StartTime int64 `protobuf:"varint,6,opt,name=startTime,proto3" json:"startTime,omitempty"` LastHeartbeatTime int64 `protobuf:"varint,7,opt,name=lastHeartbeatTime,proto3" json:"lastHeartbeatTime,omitempty"` Version string `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"` GitHash string `protobuf:"bytes,9,opt,name=gitHash,proto3" json:"gitHash,omitempty"` DeployPath string `protobuf:"bytes,10,opt,name=deployPath,proto3" json:"deployPath,omitempty"` PhysicallyDestroyed bool `protobuf:"varint,11,opt,name=physicallyDestroyed,proto3" json:"physicallyDestroyed,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Store the host store metadata
func (*Store) Descriptor ¶
func (*Store) GetClientAddr ¶
func (*Store) GetDeployPath ¶
func (*Store) GetGitHash ¶
func (*Store) GetLastHeartbeatTime ¶
func (*Store) GetPhysicallyDestroyed ¶
func (*Store) GetRaftAddr ¶
func (*Store) GetStartTime ¶
func (*Store) GetState ¶
func (m *Store) GetState() metapb.ContainerState
func (*Store) GetVersion ¶
func (*Store) ProtoMessage ¶
func (*Store) ProtoMessage()
func (*Store) XXX_DiscardUnknown ¶
func (m *Store) XXX_DiscardUnknown()
func (*Store) XXX_Marshal ¶
func (*Store) XXX_Unmarshal ¶
type StoreIdent ¶
type StoreIdent struct { ClusterID uint64 `protobuf:"varint,1,opt,name=clusterID,proto3" json:"clusterID,omitempty"` StoreID uint64 `protobuf:"varint,2,opt,name=storeID,proto3" json:"storeID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StoreIdent store ident
func (*StoreIdent) Descriptor ¶
func (*StoreIdent) Descriptor() ([]byte, []int)
func (*StoreIdent) GetClusterID ¶
func (m *StoreIdent) GetClusterID() uint64
func (*StoreIdent) GetStoreID ¶
func (m *StoreIdent) GetStoreID() uint64
func (*StoreIdent) Marshal ¶
func (m *StoreIdent) Marshal() (dAtA []byte, err error)
func (*StoreIdent) ProtoMessage ¶
func (*StoreIdent) ProtoMessage()
func (*StoreIdent) Reset ¶
func (m *StoreIdent) Reset()
func (*StoreIdent) Size ¶
func (m *StoreIdent) Size() (n int)
func (*StoreIdent) String ¶
func (m *StoreIdent) String() string
func (*StoreIdent) Unmarshal ¶
func (m *StoreIdent) Unmarshal(dAtA []byte) error
func (*StoreIdent) XXX_DiscardUnknown ¶
func (m *StoreIdent) XXX_DiscardUnknown()
func (*StoreIdent) XXX_Marshal ¶
func (m *StoreIdent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StoreIdent) XXX_Merge ¶
func (m *StoreIdent) XXX_Merge(src proto.Message)
func (*StoreIdent) XXX_Size ¶
func (m *StoreIdent) XXX_Size() int
func (*StoreIdent) XXX_Unmarshal ¶
func (m *StoreIdent) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.