meta

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 9, 2022 License: Apache-2.0 Imports: 8 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMeta = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMeta   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ReplicaState_name = map[int32]string{
	0: "Normal",
	1: "Applying",
	2: "Tombstone",
}
View Source 
var ReplicaState_value = map[string]int32{
	"Normal":    0,
	"Applying":  1,
	"Tombstone": 2,
}
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) MarshalTo 

func (m *AllocatedShard) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Cluster) GetID 

func (m *Cluster) GetID() uint64

func (*Cluster) GetMaxReplicas 

func (m *Cluster) GetMaxReplicas() uint32

func (*Cluster) Marshal 

func (m *Cluster) Marshal() (dAtA []byte, err error)

func (*Cluster) MarshalTo 

func (m *Cluster) MarshalTo(dAtA []byte) (int, error)

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset 

func (m *Cluster) Reset()

func (*Cluster) Size 

func (m *Cluster) Size() (n int)

func (*Cluster) String 

func (m *Cluster) String() string

func (*Cluster) Unmarshal 

func (m *Cluster) Unmarshal(dAtA []byte) error

func (*Cluster) XXX_DiscardUnknown 

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal 

func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cluster) XXX_Merge 

func (m *Cluster) XXX_Merge(src proto.Message)

func (*Cluster) XXX_Size 

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal 

func (m *Cluster) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*LogIndex) GetIndex 

func (m *LogIndex) GetIndex() uint64

func (*LogIndex) GetTerm 

func (m *LogIndex) GetTerm() uint64

func (*LogIndex) Marshal 

func (m *LogIndex) Marshal() (dAtA []byte, err error)

func (*LogIndex) MarshalTo 

func (m *LogIndex) MarshalTo(dAtA []byte) (int, error)

func (*LogIndex) ProtoMessage 

func (*LogIndex) ProtoMessage()

func (*LogIndex) Reset 

func (m *LogIndex) Reset()

func (*LogIndex) Size 

func (m *LogIndex) Size() (n int)

func (*LogIndex) String 

func (m *LogIndex) String() string

func (*LogIndex) Unmarshal 

func (m *LogIndex) Unmarshal(dAtA []byte) error

func (*LogIndex) XXX_DiscardUnknown 

func (m *LogIndex) XXX_DiscardUnknown()

func (*LogIndex) XXX_Marshal 

func (m *LogIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogIndex) XXX_Merge 

func (m *LogIndex) XXX_Merge(src proto.Message)

func (*LogIndex) XXX_Size 

func (m *LogIndex) XXX_Size() int

func (*LogIndex) XXX_Unmarshal 

func (m *LogIndex) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *RaftMessage) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *RaftMessageBatch) MarshalTo(dAtA []byte) (int, 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) Clone 

func (m Shard) Clone() Shard

Clone clone the shard

func (*Shard) Descriptor 

func (*Shard) Descriptor() ([]byte, []int)

func (*Shard) GetData 

func (m *Shard) GetData() []byte

func (*Shard) GetDisableSplit 

func (m *Shard) GetDisableSplit() bool

func (*Shard) GetEnd 

func (m *Shard) GetEnd() []byte

func (*Shard) GetEpoch 

func (m *Shard) GetEpoch() metapb.ResourceEpoch

func (*Shard) GetGroup 

func (m *Shard) GetGroup() uint64

func (*Shard) GetID 

func (m *Shard) GetID() uint64

func (*Shard) GetLabels 

func (m *Shard) GetLabels() []metapb.Pair

func (*Shard) GetReplicas 

func (m *Shard) GetReplicas() []metapb.Replica

func (*Shard) GetRuleGroups 

func (m *Shard) GetRuleGroups() []string

func (*Shard) GetStart 

func (m *Shard) GetStart() []byte

func (*Shard) GetState 

func (m *Shard) GetState() metapb.ResourceState

func (*Shard) GetUnique 

func (m *Shard) GetUnique() string

func (*Shard) Marshal 

func (m *Shard) Marshal() (dAtA []byte, err error)

func (*Shard) MarshalTo 

func (m *Shard) MarshalTo(dAtA []byte) (int, error)

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) Reset 

func (m *Shard) Reset()

func (*Shard) Size 

func (m *Shard) Size() (n int)

func (*Shard) String 

func (m *Shard) String() string

func (*Shard) Unmarshal 

func (m *Shard) Unmarshal(dAtA []byte) error

func (*Shard) XXX_DiscardUnknown 

func (m *Shard) XXX_DiscardUnknown()

func (*Shard) XXX_Marshal 

func (m *Shard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Shard) XXX_Merge 

func (m *Shard) XXX_Merge(src proto.Message)

func (*Shard) XXX_Size 

func (m *Shard) XXX_Size() int

func (*Shard) XXX_Unmarshal 

func (m *Shard) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *ShardLocalState) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ShardMetadata) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*ShardPool) GetAllocatedOffset 

func (m *ShardPool) GetAllocatedOffset() uint64

func (*ShardPool) GetAllocatedShards 

func (m *ShardPool) GetAllocatedShards() []*AllocatedShard

func (*ShardPool) GetCapacity 

func (m *ShardPool) GetCapacity() uint64

func (*ShardPool) GetRangePrefix 

func (m *ShardPool) GetRangePrefix() []byte

func (*ShardPool) GetSeq 

func (m *ShardPool) GetSeq() uint64

func (*ShardPool) Marshal 

func (m *ShardPool) Marshal() (dAtA []byte, err error)

func (*ShardPool) MarshalTo 

func (m *ShardPool) MarshalTo(dAtA []byte) (int, error)

func (*ShardPool) ProtoMessage 

func (*ShardPool) ProtoMessage()

func (*ShardPool) Reset 

func (m *ShardPool) Reset()

func (*ShardPool) Size 

func (m *ShardPool) Size() (n int)

func (*ShardPool) String 

func (m *ShardPool) String() string

func (*ShardPool) Unmarshal 

func (m *ShardPool) Unmarshal(dAtA []byte) error

func (*ShardPool) XXX_DiscardUnknown 

func (m *ShardPool) XXX_DiscardUnknown()

func (*ShardPool) XXX_Marshal 

func (m *ShardPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardPool) XXX_Merge 

func (m *ShardPool) XXX_Merge(src proto.Message)

func (*ShardPool) XXX_Size 

func (m *ShardPool) XXX_Size() int

func (*ShardPool) XXX_Unmarshal 

func (m *ShardPool) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *ShardsPool) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ShardsPoolCmd) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SnapshotChunk) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SnapshotInfo) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SnapshotMessage) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Store) GetClientAddr 

func (m *Store) GetClientAddr() string

func (*Store) GetDeployPath 

func (m *Store) GetDeployPath() string

func (*Store) GetGitHash 

func (m *Store) GetGitHash() string

func (*Store) GetID 

func (m *Store) GetID() uint64

func (*Store) GetLabels 

func (m *Store) GetLabels() []metapb.Pair

func (*Store) GetLastHeartbeatTime 

func (m *Store) GetLastHeartbeatTime() int64

func (*Store) GetPhysicallyDestroyed 

func (m *Store) GetPhysicallyDestroyed() bool

func (*Store) GetRaftAddr 

func (m *Store) GetRaftAddr() string

func (*Store) GetStartTime 

func (m *Store) GetStartTime() int64

func (*Store) GetState 

func (m *Store) GetState() metapb.ContainerState

func (*Store) GetVersion 

func (m *Store) GetVersion() string

func (*Store) Marshal 

func (m *Store) Marshal() (dAtA []byte, err error)

func (*Store) MarshalTo 

func (m *Store) MarshalTo(dAtA []byte) (int, error)

func (*Store) ProtoMessage 

func (*Store) ProtoMessage()

func (*Store) Reset 

func (m *Store) Reset()

func (*Store) Size 

func (m *Store) Size() (n int)

func (*Store) String 

func (m *Store) String() string

func (*Store) Unmarshal 

func (m *Store) Unmarshal(dAtA []byte) error

func (*Store) XXX_DiscardUnknown 

func (m *Store) XXX_DiscardUnknown()

func (*Store) XXX_Marshal 

func (m *Store) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Store) XXX_Merge 

func (m *Store) XXX_Merge(src proto.Message)

func (*Store) XXX_Size 

func (m *Store) XXX_Size() int

func (*Store) XXX_Unmarshal 

func (m *Store) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *StoreIdent) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.