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 LogIndex
- func (*LogIndex) Descriptor() ([]byte, []int)
- 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 (*LogIndex) ProtoMessage()
- 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
- func (*RaftMessage) Descriptor() ([]byte, []int)
- 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 (*RaftMessage) ProtoMessage()
- 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
- func (*RaftMessageBatch) Descriptor() ([]byte, []int)
- func (m *RaftMessageBatch) GetMessages() []RaftMessage
- func (m *RaftMessageBatch) Marshal() (dAtA []byte, err error)
- func (m *RaftMessageBatch) MarshalTo(dAtA []byte) (int, error)
- func (*RaftMessageBatch) ProtoMessage()
- 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
- type Shard
- func (m Shard) Clone() 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) 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 (*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 ShardLocalState
- func (*ShardLocalState) Descriptor() ([]byte, []int)
- 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 (*ShardLocalState) ProtoMessage()
- 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
- func (*ShardMetadata) Descriptor() ([]byte, []int)
- 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 (*ShardMetadata) ProtoMessage()
- 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
- 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 SnapshotChunk
- func (*SnapshotChunk) Descriptor() ([]byte, []int)
- 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 (c *SnapshotChunk) IsLastChunk() bool
- func (c *SnapshotChunk) IsLastFileChunk() bool
- func (m *SnapshotChunk) Marshal() (dAtA []byte, err error)
- func (m *SnapshotChunk) MarshalTo(dAtA []byte) (int, error)
- func (*SnapshotChunk) ProtoMessage()
- 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
- func (*SnapshotInfo) Descriptor() ([]byte, []int)
- 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 (*SnapshotInfo) ProtoMessage()
- 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
- func (*SnapshotMessage) Descriptor() ([]byte, []int)
- 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 (*SnapshotMessage) ProtoMessage()
- 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
- func (*SnapshotMessageHeader) Descriptor() ([]byte, []int)
- 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 (*SnapshotMessageHeader) ProtoMessage()
- 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
- 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 ¶
var ( ErrInvalidLengthMeta = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMeta = fmt.Errorf("proto: integer overflow") )
var ReplicaState_name = map[int32]string{
0: "Normal",
1: "Applying",
2: "Tombstone",
}
var ReplicaState_value = map[string]int32{
"Normal": 0,
"Applying": 1,
"Tombstone": 2,
}
var ShardsPoolCmdType_name = map[int32]string{
0: "CreateShard",
1: "AllocShard",
}
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 LogIndex ¶
type LogIndex struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Term uint64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
LogIndex is used to indicate a position in the log.
func (*LogIndex) Descriptor ¶
func (*LogIndex) ProtoMessage ¶
func (*LogIndex) ProtoMessage()
func (*LogIndex) XXX_DiscardUnknown ¶
func (m *LogIndex) XXX_DiscardUnknown()
func (*LogIndex) XXX_Marshal ¶
func (*LogIndex) XXX_Unmarshal ¶
type RaftMessage ¶
type RaftMessage struct { ShardID uint64 `protobuf:"varint,1,opt,name=shardID,proto3" json:"shardID,omitempty"` Group uint64 `protobuf:"varint,2,opt,name=group,proto3" json:"group,omitempty"` From metapb.Replica `protobuf:"bytes,3,opt,name=from,proto3" json:"from"` To metapb.Replica `protobuf:"bytes,4,opt,name=to,proto3" json:"to"` Message raftpb.Message `protobuf:"bytes,5,opt,name=message,proto3" json:"message"` ShardEpoch metapb.ResourceEpoch `protobuf:"bytes,6,opt,name=shardEpoch,proto3" json:"shardEpoch"` IsTombstone bool `protobuf:"varint,7,opt,name=isTombstone,proto3" json:"isTombstone,omitempty"` Start []byte `protobuf:"bytes,8,opt,name=start,proto3" json:"start,omitempty"` End []byte `protobuf:"bytes,9,opt,name=end,proto3" json:"end,omitempty"` DisableSplit bool `protobuf:"varint,10,opt,name=disableSplit,proto3" json:"disableSplit,omitempty"` Unique string `protobuf:"bytes,11,opt,name=unique,proto3" json:"unique,omitempty"` RuleGroups []string `protobuf:"bytes,12,rep,name=ruleGroups,proto3" json:"ruleGroups,omitempty"` CommitIndex uint64 `protobuf:"varint,13,opt,name=commitIndex,proto3" json:"commitIndex,omitempty"` SendTime uint64 `protobuf:"varint,14,opt,name=sendTime,proto3" json:"sendTime,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RaftMessage the message wrapped raft msg with shard info
func (*RaftMessage) Descriptor ¶
func (*RaftMessage) Descriptor() ([]byte, []int)
func (*RaftMessage) GetCommitIndex ¶
func (m *RaftMessage) GetCommitIndex() uint64
func (*RaftMessage) GetDisableSplit ¶
func (m *RaftMessage) GetDisableSplit() bool
func (*RaftMessage) GetEnd ¶
func (m *RaftMessage) GetEnd() []byte
func (*RaftMessage) GetFrom ¶
func (m *RaftMessage) GetFrom() metapb.Replica
func (*RaftMessage) GetGroup ¶
func (m *RaftMessage) GetGroup() uint64
func (*RaftMessage) GetIsTombstone ¶
func (m *RaftMessage) GetIsTombstone() bool
func (*RaftMessage) GetMessage ¶
func (m *RaftMessage) GetMessage() raftpb.Message
func (*RaftMessage) GetRuleGroups ¶
func (m *RaftMessage) GetRuleGroups() []string
func (*RaftMessage) GetSendTime ¶
func (m *RaftMessage) GetSendTime() uint64
func (*RaftMessage) GetShardEpoch ¶
func (m *RaftMessage) GetShardEpoch() metapb.ResourceEpoch
func (*RaftMessage) GetShardID ¶
func (m *RaftMessage) GetShardID() uint64
func (*RaftMessage) GetStart ¶
func (m *RaftMessage) GetStart() []byte
func (*RaftMessage) GetTo ¶
func (m *RaftMessage) GetTo() metapb.Replica
func (*RaftMessage) GetUnique ¶
func (m *RaftMessage) GetUnique() string
func (*RaftMessage) Marshal ¶
func (m *RaftMessage) Marshal() (dAtA []byte, err error)
func (*RaftMessage) ProtoMessage ¶
func (*RaftMessage) ProtoMessage()
func (*RaftMessage) Reset ¶
func (m *RaftMessage) Reset()
func (*RaftMessage) Size ¶
func (m *RaftMessage) Size() (n int)
func (*RaftMessage) String ¶
func (m *RaftMessage) String() string
func (*RaftMessage) Unmarshal ¶
func (m *RaftMessage) Unmarshal(dAtA []byte) error
func (*RaftMessage) XXX_DiscardUnknown ¶
func (m *RaftMessage) XXX_DiscardUnknown()
func (*RaftMessage) XXX_Marshal ¶
func (m *RaftMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RaftMessage) XXX_Merge ¶
func (m *RaftMessage) XXX_Merge(src proto.Message)
func (*RaftMessage) XXX_Size ¶
func (m *RaftMessage) XXX_Size() int
func (*RaftMessage) XXX_Unmarshal ¶
func (m *RaftMessage) XXX_Unmarshal(b []byte) error
type RaftMessageBatch ¶
type RaftMessageBatch struct { Messages []RaftMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RaftMessageBatch is a group of messages sent to the same store.
func (*RaftMessageBatch) Descriptor ¶
func (*RaftMessageBatch) Descriptor() ([]byte, []int)
func (*RaftMessageBatch) GetMessages ¶
func (m *RaftMessageBatch) GetMessages() []RaftMessage
func (*RaftMessageBatch) Marshal ¶
func (m *RaftMessageBatch) Marshal() (dAtA []byte, err error)
func (*RaftMessageBatch) ProtoMessage ¶
func (*RaftMessageBatch) ProtoMessage()
func (*RaftMessageBatch) Reset ¶
func (m *RaftMessageBatch) Reset()
func (*RaftMessageBatch) Size ¶
func (m *RaftMessageBatch) Size() (n int)
func (*RaftMessageBatch) String ¶
func (m *RaftMessageBatch) String() string
func (*RaftMessageBatch) Unmarshal ¶
func (m *RaftMessageBatch) Unmarshal(dAtA []byte) error
func (*RaftMessageBatch) XXX_DiscardUnknown ¶
func (m *RaftMessageBatch) XXX_DiscardUnknown()
func (*RaftMessageBatch) XXX_Marshal ¶
func (m *RaftMessageBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RaftMessageBatch) XXX_Merge ¶
func (m *RaftMessageBatch) XXX_Merge(src proto.Message)
func (*RaftMessageBatch) XXX_Size ¶
func (m *RaftMessageBatch) XXX_Size() int
func (*RaftMessageBatch) XXX_Unmarshal ¶
func (m *RaftMessageBatch) XXX_Unmarshal(b []byte) error
type ReplicaState ¶
type ReplicaState int32
ReplicaState the state of the shard peer
const ( ReplicaState_Normal ReplicaState = 0 ReplicaState_Applying ReplicaState = 1 ReplicaState_Tombstone ReplicaState = 2 )
func (ReplicaState) EnumDescriptor ¶
func (ReplicaState) EnumDescriptor() ([]byte, []int)
func (ReplicaState) String ¶
func (x ReplicaState) String() string
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"` Replicas []metapb.Replica `protobuf:"bytes,6,rep,name=replicas,proto3" json:"replicas"` 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"` Labels []metapb.Pair `protobuf:"bytes,13,rep,name=labels,proto3" json:"labels"` 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) GetReplicas ¶
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 ShardLocalState ¶
type ShardLocalState struct { Shard Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard"` State ReplicaState `protobuf:"varint,2,opt,name=state,proto3,enum=meta.ReplicaState" json:"state,omitempty"` // RemoveData Whether or not the local Shard data needs to be deleted, // which needs to be specified when the Shard status is set to Destroying RemoveData bool `protobuf:"varint,3,opt,name=removeData,proto3" json:"removeData,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShardLocalState shard local state
func (*ShardLocalState) Descriptor ¶
func (*ShardLocalState) Descriptor() ([]byte, []int)
func (*ShardLocalState) GetRemoveData ¶
func (m *ShardLocalState) GetRemoveData() bool
func (*ShardLocalState) GetShard ¶
func (m *ShardLocalState) GetShard() Shard
func (*ShardLocalState) GetState ¶
func (m *ShardLocalState) GetState() ReplicaState
func (*ShardLocalState) Marshal ¶
func (m *ShardLocalState) Marshal() (dAtA []byte, err error)
func (*ShardLocalState) ProtoMessage ¶
func (*ShardLocalState) ProtoMessage()
func (*ShardLocalState) Reset ¶
func (m *ShardLocalState) Reset()
func (*ShardLocalState) Size ¶
func (m *ShardLocalState) Size() (n int)
func (*ShardLocalState) String ¶
func (m *ShardLocalState) String() string
func (*ShardLocalState) Unmarshal ¶
func (m *ShardLocalState) Unmarshal(dAtA []byte) error
func (*ShardLocalState) XXX_DiscardUnknown ¶
func (m *ShardLocalState) XXX_DiscardUnknown()
func (*ShardLocalState) XXX_Marshal ¶
func (m *ShardLocalState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShardLocalState) XXX_Merge ¶
func (m *ShardLocalState) XXX_Merge(src proto.Message)
func (*ShardLocalState) XXX_Size ¶
func (m *ShardLocalState) XXX_Size() int
func (*ShardLocalState) XXX_Unmarshal ¶
func (m *ShardLocalState) XXX_Unmarshal(b []byte) error
type ShardMetadata ¶
type ShardMetadata struct { ShardID uint64 `protobuf:"varint,1,opt,name=shardID,proto3" json:"shardID,omitempty"` LogIndex uint64 `protobuf:"varint,2,opt,name=logIndex,proto3" json:"logIndex,omitempty"` Metadata ShardLocalState `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShardMetadata is the metadata of the shard consistent with the current table shard data
func (*ShardMetadata) Descriptor ¶
func (*ShardMetadata) Descriptor() ([]byte, []int)
func (*ShardMetadata) GetLogIndex ¶
func (m *ShardMetadata) GetLogIndex() uint64
func (*ShardMetadata) GetMetadata ¶
func (m *ShardMetadata) GetMetadata() ShardLocalState
func (*ShardMetadata) GetShardID ¶
func (m *ShardMetadata) GetShardID() uint64
func (*ShardMetadata) Marshal ¶
func (m *ShardMetadata) Marshal() (dAtA []byte, err error)
func (*ShardMetadata) ProtoMessage ¶
func (*ShardMetadata) ProtoMessage()
func (*ShardMetadata) Reset ¶
func (m *ShardMetadata) Reset()
func (*ShardMetadata) Size ¶
func (m *ShardMetadata) Size() (n int)
func (*ShardMetadata) String ¶
func (m *ShardMetadata) String() string
func (*ShardMetadata) Unmarshal ¶
func (m *ShardMetadata) Unmarshal(dAtA []byte) error
func (*ShardMetadata) XXX_DiscardUnknown ¶
func (m *ShardMetadata) XXX_DiscardUnknown()
func (*ShardMetadata) XXX_Marshal ¶
func (m *ShardMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShardMetadata) XXX_Merge ¶
func (m *ShardMetadata) XXX_Merge(src proto.Message)
func (*ShardMetadata) XXX_Size ¶
func (m *ShardMetadata) XXX_Size() int
func (*ShardMetadata) XXX_Unmarshal ¶
func (m *ShardMetadata) XXX_Unmarshal(b []byte) error
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=meta.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 SnapshotChunk ¶
type SnapshotChunk struct { ContainerID uint64 `protobuf:"varint,1,opt,name=containerID,proto3" json:"containerID,omitempty"` ShardID uint64 `protobuf:"varint,2,opt,name=shardID,proto3" json:"shardID,omitempty"` ReplicaID uint64 `protobuf:"varint,3,opt,name=replicaID,proto3" json:"replicaID,omitempty"` From uint64 `protobuf:"varint,4,opt,name=from,proto3" json:"from,omitempty"` ChunkID uint64 `protobuf:"varint,5,opt,name=chunkID,proto3" json:"chunkID,omitempty"` ChunkSize uint64 `protobuf:"varint,6,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"` ChunkCount uint64 `protobuf:"varint,7,opt,name=chunkCount,proto3" json:"chunkCount,omitempty"` Index uint64 `protobuf:"varint,8,opt,name=index,proto3" json:"index,omitempty"` Term uint64 `protobuf:"varint,9,opt,name=term,proto3" json:"term,omitempty"` FilePath string `protobuf:"bytes,10,opt,name=filePath,proto3" json:"filePath,omitempty"` FileSize uint64 `protobuf:"varint,11,opt,name=fileSize,proto3" json:"fileSize,omitempty"` FileChunkID uint64 `protobuf:"varint,12,opt,name=fileChunkID,proto3" json:"fileChunkID,omitempty"` FileChunkCount uint64 `protobuf:"varint,13,opt,name=fileChunkCount,proto3" json:"fileChunkCount,omitempty"` Data []byte `protobuf:"bytes,14,opt,name=data,proto3" json:"data,omitempty"` Extra []byte `protobuf:"bytes,15,opt,name=extra,proto3" json:"extra,omitempty"` ConfState raftpb.ConfState `protobuf:"bytes,16,opt,name=confState,proto3" json:"confState"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SnapshotChunk) Descriptor ¶
func (*SnapshotChunk) Descriptor() ([]byte, []int)
func (*SnapshotChunk) GetChunkCount ¶
func (m *SnapshotChunk) GetChunkCount() uint64
func (*SnapshotChunk) GetChunkID ¶
func (m *SnapshotChunk) GetChunkID() uint64
func (*SnapshotChunk) GetChunkSize ¶
func (m *SnapshotChunk) GetChunkSize() uint64
func (*SnapshotChunk) GetConfState ¶
func (m *SnapshotChunk) GetConfState() raftpb.ConfState
func (*SnapshotChunk) GetContainerID ¶
func (m *SnapshotChunk) GetContainerID() uint64
func (*SnapshotChunk) GetData ¶
func (m *SnapshotChunk) GetData() []byte
func (*SnapshotChunk) GetExtra ¶
func (m *SnapshotChunk) GetExtra() []byte
func (*SnapshotChunk) GetFileChunkCount ¶
func (m *SnapshotChunk) GetFileChunkCount() uint64
func (*SnapshotChunk) GetFileChunkID ¶
func (m *SnapshotChunk) GetFileChunkID() uint64
func (*SnapshotChunk) GetFilePath ¶
func (m *SnapshotChunk) GetFilePath() string
func (*SnapshotChunk) GetFileSize ¶
func (m *SnapshotChunk) GetFileSize() uint64
func (*SnapshotChunk) GetFrom ¶
func (m *SnapshotChunk) GetFrom() uint64
func (*SnapshotChunk) GetIndex ¶
func (m *SnapshotChunk) GetIndex() uint64
func (*SnapshotChunk) GetReplicaID ¶
func (m *SnapshotChunk) GetReplicaID() uint64
func (*SnapshotChunk) GetShardID ¶
func (m *SnapshotChunk) GetShardID() uint64
func (*SnapshotChunk) GetTerm ¶
func (m *SnapshotChunk) GetTerm() uint64
func (*SnapshotChunk) IsLastChunk ¶
func (c *SnapshotChunk) IsLastChunk() bool
IsLastChunk returns a boolean value indicating whether the current chunk is the last one for the snapshot.
func (*SnapshotChunk) IsLastFileChunk ¶
func (c *SnapshotChunk) IsLastFileChunk() bool
IsLastFileChunk returns a boolean value indicating whether the chunk is the last chunk of a snapshot file.
func (*SnapshotChunk) Marshal ¶
func (m *SnapshotChunk) Marshal() (dAtA []byte, err error)
func (*SnapshotChunk) ProtoMessage ¶
func (*SnapshotChunk) ProtoMessage()
func (*SnapshotChunk) Reset ¶
func (m *SnapshotChunk) Reset()
func (*SnapshotChunk) Size ¶
func (m *SnapshotChunk) Size() (n int)
func (*SnapshotChunk) String ¶
func (m *SnapshotChunk) String() string
func (*SnapshotChunk) Unmarshal ¶
func (m *SnapshotChunk) Unmarshal(dAtA []byte) error
func (*SnapshotChunk) XXX_DiscardUnknown ¶
func (m *SnapshotChunk) XXX_DiscardUnknown()
func (*SnapshotChunk) XXX_Marshal ¶
func (m *SnapshotChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SnapshotChunk) XXX_Merge ¶
func (m *SnapshotChunk) XXX_Merge(src proto.Message)
func (*SnapshotChunk) XXX_Size ¶
func (m *SnapshotChunk) XXX_Size() int
func (*SnapshotChunk) XXX_Unmarshal ¶
func (m *SnapshotChunk) XXX_Unmarshal(b []byte) error
type SnapshotInfo ¶
type SnapshotInfo struct { Extra uint64 `protobuf:"varint,1,opt,name=extra,proto3" json:"extra,omitempty"` Dummy bool `protobuf:"varint,2,opt,name=dummy,proto3" json:"dummy,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SnapshotInfo contains additional information associated with a snapshot.
func (*SnapshotInfo) Descriptor ¶
func (*SnapshotInfo) Descriptor() ([]byte, []int)
func (*SnapshotInfo) GetDummy ¶
func (m *SnapshotInfo) GetDummy() bool
func (*SnapshotInfo) GetExtra ¶
func (m *SnapshotInfo) GetExtra() uint64
func (*SnapshotInfo) Marshal ¶
func (m *SnapshotInfo) Marshal() (dAtA []byte, err error)
func (*SnapshotInfo) ProtoMessage ¶
func (*SnapshotInfo) ProtoMessage()
func (*SnapshotInfo) Reset ¶
func (m *SnapshotInfo) Reset()
func (*SnapshotInfo) Size ¶
func (m *SnapshotInfo) Size() (n int)
func (*SnapshotInfo) String ¶
func (m *SnapshotInfo) String() string
func (*SnapshotInfo) Unmarshal ¶
func (m *SnapshotInfo) Unmarshal(dAtA []byte) error
func (*SnapshotInfo) XXX_DiscardUnknown ¶
func (m *SnapshotInfo) XXX_DiscardUnknown()
func (*SnapshotInfo) XXX_Marshal ¶
func (m *SnapshotInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SnapshotInfo) XXX_Merge ¶
func (m *SnapshotInfo) XXX_Merge(src proto.Message)
func (*SnapshotInfo) XXX_Size ¶
func (m *SnapshotInfo) XXX_Size() int
func (*SnapshotInfo) XXX_Unmarshal ¶
func (m *SnapshotInfo) XXX_Unmarshal(b []byte) error
type SnapshotMessage ¶
type SnapshotMessage struct { Header SnapshotMessageHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` First bool `protobuf:"varint,3,opt,name=first,proto3" json:"first,omitempty"` Last bool `protobuf:"varint,4,opt,name=last,proto3" json:"last,omitempty"` FileSize uint64 `protobuf:"varint,5,opt,name=fileSize,proto3" json:"fileSize,omitempty"` CheckSum uint64 `protobuf:"varint,6,opt,name=checkSum,proto3" json:"checkSum,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SnapshotMessage snapshot message
func (*SnapshotMessage) Descriptor ¶
func (*SnapshotMessage) Descriptor() ([]byte, []int)
func (*SnapshotMessage) GetCheckSum ¶
func (m *SnapshotMessage) GetCheckSum() uint64
func (*SnapshotMessage) GetData ¶
func (m *SnapshotMessage) GetData() []byte
func (*SnapshotMessage) GetFileSize ¶
func (m *SnapshotMessage) GetFileSize() uint64
func (*SnapshotMessage) GetFirst ¶
func (m *SnapshotMessage) GetFirst() bool
func (*SnapshotMessage) GetHeader ¶
func (m *SnapshotMessage) GetHeader() SnapshotMessageHeader
func (*SnapshotMessage) GetLast ¶
func (m *SnapshotMessage) GetLast() bool
func (*SnapshotMessage) Marshal ¶
func (m *SnapshotMessage) Marshal() (dAtA []byte, err error)
func (*SnapshotMessage) ProtoMessage ¶
func (*SnapshotMessage) ProtoMessage()
func (*SnapshotMessage) Reset ¶
func (m *SnapshotMessage) Reset()
func (*SnapshotMessage) Size ¶
func (m *SnapshotMessage) Size() (n int)
func (*SnapshotMessage) String ¶
func (m *SnapshotMessage) String() string
func (*SnapshotMessage) Unmarshal ¶
func (m *SnapshotMessage) Unmarshal(dAtA []byte) error
func (*SnapshotMessage) XXX_DiscardUnknown ¶
func (m *SnapshotMessage) XXX_DiscardUnknown()
func (*SnapshotMessage) XXX_Marshal ¶
func (m *SnapshotMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SnapshotMessage) XXX_Merge ¶
func (m *SnapshotMessage) XXX_Merge(src proto.Message)
func (*SnapshotMessage) XXX_Size ¶
func (m *SnapshotMessage) XXX_Size() int
func (*SnapshotMessage) XXX_Unmarshal ¶
func (m *SnapshotMessage) XXX_Unmarshal(b []byte) error
type SnapshotMessageHeader ¶
type SnapshotMessageHeader struct { Shard Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard"` From metapb.Replica `protobuf:"bytes,2,opt,name=from,proto3" json:"from"` To metapb.Replica `protobuf:"bytes,3,opt,name=to,proto3" json:"to"` Term uint64 `protobuf:"varint,4,opt,name=term,proto3" json:"term,omitempty"` Index uint64 `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SnapshotMessageHeader snapshot message header
func (*SnapshotMessageHeader) Descriptor ¶
func (*SnapshotMessageHeader) Descriptor() ([]byte, []int)
func (*SnapshotMessageHeader) GetFrom ¶
func (m *SnapshotMessageHeader) GetFrom() metapb.Replica
func (*SnapshotMessageHeader) GetIndex ¶
func (m *SnapshotMessageHeader) GetIndex() uint64
func (*SnapshotMessageHeader) GetShard ¶
func (m *SnapshotMessageHeader) GetShard() Shard
func (*SnapshotMessageHeader) GetTerm ¶
func (m *SnapshotMessageHeader) GetTerm() uint64
func (*SnapshotMessageHeader) GetTo ¶
func (m *SnapshotMessageHeader) GetTo() metapb.Replica
func (*SnapshotMessageHeader) Marshal ¶
func (m *SnapshotMessageHeader) Marshal() (dAtA []byte, err error)
func (*SnapshotMessageHeader) MarshalTo ¶
func (m *SnapshotMessageHeader) MarshalTo(dAtA []byte) (int, error)
func (*SnapshotMessageHeader) ProtoMessage ¶
func (*SnapshotMessageHeader) ProtoMessage()
func (*SnapshotMessageHeader) Reset ¶
func (m *SnapshotMessageHeader) Reset()
func (*SnapshotMessageHeader) Size ¶
func (m *SnapshotMessageHeader) Size() (n int)
func (*SnapshotMessageHeader) String ¶
func (m *SnapshotMessageHeader) String() string
func (*SnapshotMessageHeader) Unmarshal ¶
func (m *SnapshotMessageHeader) Unmarshal(dAtA []byte) error
func (*SnapshotMessageHeader) XXX_DiscardUnknown ¶
func (m *SnapshotMessageHeader) XXX_DiscardUnknown()
func (*SnapshotMessageHeader) XXX_Marshal ¶
func (m *SnapshotMessageHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SnapshotMessageHeader) XXX_Merge ¶
func (m *SnapshotMessageHeader) XXX_Merge(src proto.Message)
func (*SnapshotMessageHeader) XXX_Size ¶
func (m *SnapshotMessageHeader) XXX_Size() int
func (*SnapshotMessageHeader) XXX_Unmarshal ¶
func (m *SnapshotMessageHeader) 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