metapb

package
v0.3.1-0...-21490cc Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMetapb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetapb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var CheckPolicy_name = map[int32]string{
	0: "SCAN",
	1: "APPROXIMATE",
	2: "USEKEY",
}
View Source 
var CheckPolicy_value = map[string]int32{
	"SCAN":        0,
	"APPROXIMATE": 1,
	"USEKEY":      2,
}
View Source 
var ConfigChangeType_name = map[int32]string{
	0: "AddNode",
	1: "RemoveNode",
	2: "UpdateNode",
	3: "AddLearnerNode",
}
View Source 
var ConfigChangeType_value = map[string]int32{
	"AddNode":        0,
	"RemoveNode":     1,
	"UpdateNode":     2,
	"AddLearnerNode": 3,
}
View Source 
var JobState_name = map[int32]string{
	0: "Created",
	1: "Working",
	2: "Completed",
}
View Source 
var JobState_value = map[string]int32{
	"Created":   0,
	"Working":   1,
	"Completed": 2,
}
View Source 
var JobType_name = map[int32]string{
	0:   "RemoveShard",
	1:   "CreateShardPool",
	100: "CustomStartAt",
}
View Source 
var JobType_value = map[string]int32{
	"RemoveShard":     0,
	"CreateShardPool": 1,
	"CustomStartAt":   100,
}
View Source 
var OperatorStatus_name = map[int32]string{
	0: "SUCCESS",
	1: "TIMEOUT",
	2: "CANCEL",
	3: "REPLACE",
	4: "RUNNING",
}
View Source 
var OperatorStatus_value = map[string]int32{
	"SUCCESS": 0,
	"TIMEOUT": 1,
	"CANCEL":  2,
	"REPLACE": 3,
	"RUNNING": 4,
}
View Source 
var ReplicaRole_name = map[int32]string{
	0: "Voter",
	1: "Learner",
	2: "IncomingVoter",
	3: "DemotingVoter",
}
View Source 
var ReplicaRole_value = map[string]int32{
	"Voter":         0,
	"Learner":       1,
	"IncomingVoter": 2,
	"DemotingVoter": 3,
}
View Source 
var ReplicaState_name = map[int32]string{
	0: "Normal",
	1: "Applying",
	2: "ReplicaTombstone",
}
View Source 
var ReplicaState_value = map[string]int32{
	"Normal":           0,
	"Applying":         1,
	"ReplicaTombstone": 2,
}
View Source 
var ShardState_name = map[int32]string{
	0: "Running",
	1: "Creating",
	2: "Destroying",
	3: "Destroyed",
}
View Source 
var ShardState_value = map[string]int32{
	"Running":    0,
	"Creating":   1,
	"Destroying": 2,
	"Destroyed":  3,
}
View Source 
var ShardType_name = map[int32]string{
	0: "LeaderOnly",
	1: "AllShards",
}
View Source 
var ShardType_value = map[string]int32{
	"LeaderOnly": 0,
	"AllShards":  1,
}
View Source 
var ShardsPoolCmdType_name = map[int32]string{
	0: "CreateShard",
	1: "AllocShard",
}
View Source 
var ShardsPoolCmdType_value = map[string]int32{
	"CreateShard": 0,
	"AllocShard":  1,
}
View Source 
var StoreState_name = map[int32]string{
	0: "Up",
	1: "Down",
	2: "StoreTombstone",
}
View Source 
var StoreState_value = map[string]int32{
	"Up":             0,
	"Down":           1,
	"StoreTombstone": 2,
}

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

func (m *AllocatedShard) FastUnmarshal(dAtA []byte) error

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 CheckPolicy 

type CheckPolicy int32

CheckPolicy check policy 

const (
	CheckPolicy_SCAN        CheckPolicy = 0
	CheckPolicy_APPROXIMATE CheckPolicy = 1
	CheckPolicy_USEKEY      CheckPolicy = 2
)

func (CheckPolicy) EnumDescriptor 

func (CheckPolicy) EnumDescriptor() ([]byte, []int)

func (CheckPolicy) String 

func (x CheckPolicy) String() string

type ConfigChangeType 

type ConfigChangeType int32

ConfigChangeType change replica type 

const (
	ConfigChangeType_AddNode        ConfigChangeType = 0
	ConfigChangeType_RemoveNode     ConfigChangeType = 1
	ConfigChangeType_UpdateNode     ConfigChangeType = 2
	ConfigChangeType_AddLearnerNode ConfigChangeType = 3
)

func (ConfigChangeType) EnumDescriptor 

func (ConfigChangeType) EnumDescriptor() ([]byte, []int)

func (ConfigChangeType) String 

func (x ConfigChangeType) String() string

type DestroyingStatus 

type DestroyingStatus struct {
	Index                uint64          `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Replicas             map[uint64]bool `` /* 159-byte string literal not displayed */
	State                ShardState      `protobuf:"varint,3,opt,name=state,proto3,enum=metapb.ShardState" json:"state,omitempty"`
	RemoveData           bool            `protobuf:"varint,4,opt,name=removeData,proto3" json:"removeData,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

DestroyingStatus destroying status

func (*DestroyingStatus) Descriptor 

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

func (*DestroyingStatus) FastUnmarshal 

func (m *DestroyingStatus) FastUnmarshal(dAtA []byte) error

func (*DestroyingStatus) GetIndex 

func (m *DestroyingStatus) GetIndex() uint64

func (*DestroyingStatus) GetRemoveData 

func (m *DestroyingStatus) GetRemoveData() bool

func (*DestroyingStatus) GetReplicas 

func (m *DestroyingStatus) GetReplicas() map[uint64]bool

func (*DestroyingStatus) GetState 

func (m *DestroyingStatus) GetState() ShardState

func (*DestroyingStatus) Marshal 

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

func (*DestroyingStatus) MarshalTo 

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

func (*DestroyingStatus) ProtoMessage 

func (*DestroyingStatus) ProtoMessage()

func (*DestroyingStatus) Reset 

func (m *DestroyingStatus) Reset()

func (*DestroyingStatus) Size 

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

func (*DestroyingStatus) String 

func (m *DestroyingStatus) String() string

func (*DestroyingStatus) Unmarshal 

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

func (*DestroyingStatus) XXX_DiscardUnknown 

func (m *DestroyingStatus) XXX_DiscardUnknown()

func (*DestroyingStatus) XXX_Marshal 

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

func (*DestroyingStatus) XXX_Merge 

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

func (*DestroyingStatus) XXX_Size 

func (m *DestroyingStatus) XXX_Size() int

func (*DestroyingStatus) XXX_Unmarshal 

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

type EpochLease 

type EpochLease struct {
	// Epoch lease epoch, each time a Lease switch occurs, the epoch is increased
	Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// ReplicaID lease holding replica
	ReplicaID            uint64   `protobuf:"varint,2,opt,name=replicaID,proto3" json:"replicaID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EpochLease an Epoch-based Lease. A Shard has one and only one Replica that can hold a Lease, and all read and write requests to the Shard need to be initiated by the node holding the Lease. In most cases, the Replica holding the Lease is the Raft Leader, except for a short period of inconsistency when the Raft Leader switches. When Prophet finds that the Lease's holding Replica is inconsistent with Raft's Leader Replica, it will initiate the Lease switch.

func (*EpochLease) Descriptor 

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

func (*EpochLease) FastUnmarshal 

func (m *EpochLease) FastUnmarshal(dAtA []byte) error

func (*EpochLease) GE 

func (m *EpochLease) GE(target *EpochLease) bool

GE return true if current lease >= target lease

func (*EpochLease) GetEpoch 

func (m *EpochLease) GetEpoch() uint64

func (*EpochLease) GetReplicaID 

func (m *EpochLease) GetReplicaID() uint64

func (*EpochLease) LT 

func (m *EpochLease) LT(target *EpochLease) bool

LT return true if current lease < target lease

func (*EpochLease) Marshal 

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

func (*EpochLease) MarshalTo 

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

func (*EpochLease) Match 

func (m *EpochLease) Match(target *EpochLease) bool

Match return true if two lease are matched

func (*EpochLease) ProtoMessage 

func (*EpochLease) ProtoMessage()

func (*EpochLease) Reset 

func (m *EpochLease) Reset()

func (*EpochLease) Size 

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

func (*EpochLease) String 

func (m *EpochLease) String() string

func (*EpochLease) Unmarshal 

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

func (*EpochLease) XXX_DiscardUnknown 

func (m *EpochLease) XXX_DiscardUnknown()

func (*EpochLease) XXX_Marshal 

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

func (*EpochLease) XXX_Merge 

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

func (*EpochLease) XXX_Size 

func (m *EpochLease) XXX_Size() int

func (*EpochLease) XXX_Unmarshal 

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

type Job 

type Job struct {
	Type                 JobType  `protobuf:"varint,1,opt,name=type,proto3,enum=metapb.JobType" json:"type,omitempty"`
	Content              []byte   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	State                JobState `protobuf:"varint,3,opt,name=state,proto3,enum=metapb.JobState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Job job

func (*Job) Descriptor 

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

func (*Job) FastUnmarshal 

func (m *Job) FastUnmarshal(dAtA []byte) error

func (*Job) GetContent 

func (m *Job) GetContent() []byte

func (*Job) GetState 

func (m *Job) GetState() JobState

func (*Job) GetType 

func (m *Job) GetType() JobType

func (*Job) Marshal 

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

func (*Job) MarshalTo 

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

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) Size 

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

func (*Job) String 

func (m *Job) String() string

func (*Job) Unmarshal 

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

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

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

func (*Job) XXX_Merge 

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

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

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

type JobState 

type JobState int32

JobState job state 

const (
	// Created wait to running
	JobState_Created JobState = 0
	// Working job is working
	JobState_Working JobState = 1
	// Completed job completed, need to gc
	JobState_Completed JobState = 2
)

func (JobState) EnumDescriptor 

func (JobState) EnumDescriptor() ([]byte, []int)

func (JobState) String 

func (x JobState) String() string

type JobType 

type JobType int32

JobType job type 

const (
	// RemoveShard remove shard job
	JobType_RemoveShard JobType = 0
	// CreateShardPool create shard pool
	JobType_CreateShardPool JobType = 1
	// CustomStartAt custom job
	JobType_CustomStartAt JobType = 100
)

func (JobType) EnumDescriptor 

func (JobType) EnumDescriptor() ([]byte, []int)

func (JobType) String 

func (x JobType) String() string

type Label 

type Label struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Label key value label

func (*Label) Descriptor 

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

func (*Label) FastUnmarshal 

func (m *Label) FastUnmarshal(dAtA []byte) error

func (*Label) GetKey 

func (m *Label) GetKey() string

func (*Label) GetValue 

func (m *Label) GetValue() string

func (*Label) Marshal 

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

func (*Label) MarshalTo 

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

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) Size 

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

func (*Label) String 

func (m *Label) String() string

func (*Label) Unmarshal 

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

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

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

func (*Label) XXX_Merge 

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

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

func (m *Label) 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) FastUnmarshal 

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

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 Member 

type Member struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Addr                 string   `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Member prophet member

func (*Member) Descriptor 

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

func (*Member) FastUnmarshal 

func (m *Member) FastUnmarshal(dAtA []byte) error

func (*Member) GetAddr 

func (m *Member) GetAddr() string

func (*Member) GetID 

func (m *Member) GetID() uint64

func (*Member) GetName 

func (m *Member) GetName() string

func (*Member) Marshal 

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

func (*Member) MarshalTo 

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

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) Reset 

func (m *Member) Reset()

func (*Member) Size 

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

func (*Member) String 

func (m *Member) String() string

func (*Member) Unmarshal 

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

func (*Member) XXX_DiscardUnknown 

func (m *Member) XXX_DiscardUnknown()

func (*Member) XXX_Marshal 

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

func (*Member) XXX_Merge 

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

func (*Member) XXX_Size 

func (m *Member) XXX_Size() int

func (*Member) XXX_Unmarshal 

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

type OperatorStatus 

type OperatorStatus int32

OperatorStatus Operator Status 

const (
	OperatorStatus_SUCCESS OperatorStatus = 0
	OperatorStatus_TIMEOUT OperatorStatus = 1
	OperatorStatus_CANCEL  OperatorStatus = 2
	OperatorStatus_REPLACE OperatorStatus = 3
	OperatorStatus_RUNNING OperatorStatus = 4
)

func (OperatorStatus) EnumDescriptor 

func (OperatorStatus) EnumDescriptor() ([]byte, []int)

func (OperatorStatus) String 

func (x OperatorStatus) String() string

type ProphetCluster 

type ProphetCluster struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	MaxReplicaCount      uint32   `protobuf:"varint,2,opt,name=maxReplicaCount,proto3" json:"maxReplicaCount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ProphetCluster prophet cluster

func (*ProphetCluster) Descriptor 

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

func (*ProphetCluster) FastUnmarshal 

func (m *ProphetCluster) FastUnmarshal(dAtA []byte) error

func (*ProphetCluster) GetID 

func (m *ProphetCluster) GetID() uint64

func (*ProphetCluster) GetMaxReplicaCount 

func (m *ProphetCluster) GetMaxReplicaCount() uint32

func (*ProphetCluster) Marshal 

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

func (*ProphetCluster) MarshalTo 

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

func (*ProphetCluster) ProtoMessage 

func (*ProphetCluster) ProtoMessage()

func (*ProphetCluster) Reset 

func (m *ProphetCluster) Reset()

func (*ProphetCluster) Size 

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

func (*ProphetCluster) String 

func (m *ProphetCluster) String() string

func (*ProphetCluster) Unmarshal 

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

func (*ProphetCluster) XXX_DiscardUnknown 

func (m *ProphetCluster) XXX_DiscardUnknown()

func (*ProphetCluster) XXX_Marshal 

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

func (*ProphetCluster) XXX_Merge 

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

func (*ProphetCluster) XXX_Size 

func (m *ProphetCluster) XXX_Size() int

func (*ProphetCluster) XXX_Unmarshal 

func (m *ProphetCluster) 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                 Replica        `protobuf:"bytes,3,opt,name=from,proto3" json:"from"`
	To                   Replica        `protobuf:"bytes,4,opt,name=to,proto3" json:"to"`
	Message              raftpb.Message `protobuf:"bytes,5,opt,name=message,proto3" json:"message"`
	ShardEpoch           ShardEpoch     `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"`
	Unique               string         `protobuf:"bytes,10,opt,name=unique,proto3" json:"unique,omitempty"`
	RuleGroups           []string       `protobuf:"bytes,11,rep,name=ruleGroups,proto3" json:"ruleGroups,omitempty"`
	CommitIndex          uint64         `protobuf:"varint,12,opt,name=commitIndex,proto3" json:"commitIndex,omitempty"`
	SendTime             uint64         `protobuf:"varint,13,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) GetEnd 

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

func (*RaftMessage) GetFrom 

func (m *RaftMessage) GetFrom() 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() ShardEpoch

func (*RaftMessage) GetShardID 

func (m *RaftMessage) GetShardID() uint64

func (*RaftMessage) GetStart 

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

func (*RaftMessage) GetTo 

func (m *RaftMessage) GetTo() 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 RecordPair 

type RecordPair struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                uint64   `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RecordPair record pair

func (*RecordPair) Descriptor 

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

func (*RecordPair) FastUnmarshal 

func (m *RecordPair) FastUnmarshal(dAtA []byte) error

func (*RecordPair) GetKey 

func (m *RecordPair) GetKey() string

func (*RecordPair) GetValue 

func (m *RecordPair) GetValue() uint64

func (*RecordPair) Marshal 

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

func (*RecordPair) MarshalTo 

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

func (*RecordPair) ProtoMessage 

func (*RecordPair) ProtoMessage()

func (*RecordPair) Reset 

func (m *RecordPair) Reset()

func (*RecordPair) Size 

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

func (*RecordPair) String 

func (m *RecordPair) String() string

func (*RecordPair) Unmarshal 

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

func (*RecordPair) XXX_DiscardUnknown 

func (m *RecordPair) XXX_DiscardUnknown()

func (*RecordPair) XXX_Marshal 

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

func (*RecordPair) XXX_Merge 

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

func (*RecordPair) XXX_Size 

func (m *RecordPair) XXX_Size() int

func (*RecordPair) XXX_Unmarshal 

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

type RemoveShardJob 

type RemoveShardJob struct {
	ID                   uint64    `protobuf:"varint,1,opt,name=shardID,proto3" json:"shardID,omitempty"`
	Replicas             []Replica `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

RemoveShardJob remove shards job

func (*RemoveShardJob) Descriptor 

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

func (*RemoveShardJob) FastUnmarshal 

func (m *RemoveShardJob) FastUnmarshal(dAtA []byte) error

func (*RemoveShardJob) GetID 

func (m *RemoveShardJob) GetID() uint64

func (*RemoveShardJob) GetReplicas 

func (m *RemoveShardJob) GetReplicas() []Replica

func (*RemoveShardJob) Marshal 

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

func (*RemoveShardJob) MarshalTo 

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

func (*RemoveShardJob) ProtoMessage 

func (*RemoveShardJob) ProtoMessage()

func (*RemoveShardJob) Reset 

func (m *RemoveShardJob) Reset()

func (*RemoveShardJob) Size 

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

func (*RemoveShardJob) String 

func (m *RemoveShardJob) String() string

func (*RemoveShardJob) Unmarshal 

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

func (*RemoveShardJob) XXX_DiscardUnknown 

func (m *RemoveShardJob) XXX_DiscardUnknown()

func (*RemoveShardJob) XXX_Marshal 

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

func (*RemoveShardJob) XXX_Merge 

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

func (*RemoveShardJob) XXX_Size 

func (m *RemoveShardJob) XXX_Size() int

func (*RemoveShardJob) XXX_Unmarshal 

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

type Replica 

type Replica struct {
	ID                   uint64      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	StoreID              uint64      `protobuf:"varint,2,opt,name=storeID,proto3" json:"storeID,omitempty"`
	Role                 ReplicaRole `protobuf:"varint,3,opt,name=role,proto3,enum=metapb.ReplicaRole" json:"role,omitempty"`
	InitialMember        bool        `protobuf:"varint,4,opt,name=initialMember,proto3" json:"initialMember,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Replica of the shard

func (*Replica) Descriptor 

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

func (*Replica) FastUnmarshal 

func (m *Replica) FastUnmarshal(dAtA []byte) error

func (*Replica) GetID 

func (m *Replica) GetID() uint64

func (*Replica) GetInitialMember 

func (m *Replica) GetInitialMember() bool

func (*Replica) GetRole 

func (m *Replica) GetRole() ReplicaRole

func (*Replica) GetStoreID 

func (m *Replica) GetStoreID() uint64

func (*Replica) Marshal 

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

func (*Replica) MarshalTo 

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

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) Reset 

func (m *Replica) Reset()

func (*Replica) Size 

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

func (*Replica) String 

func (m *Replica) String() string

func (*Replica) Unmarshal 

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

func (*Replica) XXX_DiscardUnknown 

func (m *Replica) XXX_DiscardUnknown()

func (*Replica) XXX_Marshal 

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

func (*Replica) XXX_Merge 

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

func (*Replica) XXX_Size 

func (m *Replica) XXX_Size() int

func (*Replica) XXX_Unmarshal 

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

type ReplicaRole 

type ReplicaRole int32

ReplicaRole role of current replica 

const (
	ReplicaRole_Voter         ReplicaRole = 0
	ReplicaRole_Learner       ReplicaRole = 1
	ReplicaRole_IncomingVoter ReplicaRole = 2
	ReplicaRole_DemotingVoter ReplicaRole = 3
)

func (ReplicaRole) EnumDescriptor 

func (ReplicaRole) EnumDescriptor() ([]byte, []int)

func (ReplicaRole) String 

func (x ReplicaRole) String() string

type ReplicaState 

type ReplicaState int32

ReplicaState the state of the shard peer 

const (
	ReplicaState_Normal           ReplicaState = 0
	ReplicaState_Applying         ReplicaState = 1
	ReplicaState_ReplicaTombstone ReplicaState = 2
)

func (ReplicaState) EnumDescriptor 

func (ReplicaState) EnumDescriptor() ([]byte, []int)

func (ReplicaState) String 

func (x ReplicaState) String() string

type ReplicaStats 

type ReplicaStats struct {
	Replica              Replica  `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica"`
	DownSeconds          uint64   `protobuf:"varint,2,opt,name=downSeconds,proto3" json:"downSeconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReplicaStats replica stats

func (*ReplicaStats) Descriptor 

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

func (*ReplicaStats) FastUnmarshal 

func (m *ReplicaStats) FastUnmarshal(dAtA []byte) error

func (*ReplicaStats) GetDownSeconds 

func (m *ReplicaStats) GetDownSeconds() uint64

func (*ReplicaStats) GetReplica 

func (m *ReplicaStats) GetReplica() Replica

func (*ReplicaStats) Marshal 

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

func (*ReplicaStats) MarshalTo 

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

func (*ReplicaStats) ProtoMessage 

func (*ReplicaStats) ProtoMessage()

func (*ReplicaStats) Reset 

func (m *ReplicaStats) Reset()

func (*ReplicaStats) Size 

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

func (*ReplicaStats) String 

func (m *ReplicaStats) String() string

func (*ReplicaStats) Unmarshal 

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

func (*ReplicaStats) XXX_DiscardUnknown 

func (m *ReplicaStats) XXX_DiscardUnknown()

func (*ReplicaStats) XXX_Marshal 

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

func (*ReplicaStats) XXX_Merge 

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

func (*ReplicaStats) XXX_Size 

func (m *ReplicaStats) XXX_Size() int

func (*ReplicaStats) XXX_Unmarshal 

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

type ScheduleGroupRule 

type ScheduleGroupRule struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	GroupID              uint64   `protobuf:"varint,2,opt,name=groupID,proto3" json:"groupID,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	GroupByLabel         string   `protobuf:"bytes,4,opt,name=groupByLabel,proto3" json:"groupByLabel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ScheduleGroupRule resoruce group rule

func (*ScheduleGroupRule) Descriptor 

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

func (*ScheduleGroupRule) FastUnmarshal 

func (m *ScheduleGroupRule) FastUnmarshal(dAtA []byte) error

func (*ScheduleGroupRule) GetGroupByLabel 

func (m *ScheduleGroupRule) GetGroupByLabel() string

func (*ScheduleGroupRule) GetGroupID 

func (m *ScheduleGroupRule) GetGroupID() uint64

func (*ScheduleGroupRule) GetID 

func (m *ScheduleGroupRule) GetID() uint64

func (*ScheduleGroupRule) GetName 

func (m *ScheduleGroupRule) GetName() string

func (*ScheduleGroupRule) Marshal 

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

func (*ScheduleGroupRule) MarshalTo 

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

func (*ScheduleGroupRule) ProtoMessage 

func (*ScheduleGroupRule) ProtoMessage()

func (*ScheduleGroupRule) Reset 

func (m *ScheduleGroupRule) Reset()

func (*ScheduleGroupRule) Size 

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

func (*ScheduleGroupRule) String 

func (m *ScheduleGroupRule) String() string

func (*ScheduleGroupRule) Unmarshal 

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

func (*ScheduleGroupRule) XXX_DiscardUnknown 

func (m *ScheduleGroupRule) XXX_DiscardUnknown()

func (*ScheduleGroupRule) XXX_Marshal 

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

func (*ScheduleGroupRule) XXX_Merge 

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

func (*ScheduleGroupRule) XXX_Size 

func (m *ScheduleGroupRule) XXX_Size() int

func (*ScheduleGroupRule) XXX_Unmarshal 

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

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                ShardEpoch `protobuf:"bytes,4,opt,name=epoch,proto3" json:"epoch"`
	State                ShardState `protobuf:"varint,5,opt,name=state,proto3,enum=metapb.ShardState" json:"state,omitempty"`
	Replicas             []Replica  `protobuf:"bytes,6,rep,name=replicas,proto3" json:"replicas"`
	Group                uint64     `protobuf:"varint,7,opt,name=group,proto3" json:"group,omitempty"`
	Unique               string     `protobuf:"bytes,8,opt,name=unique,proto3" json:"unique,omitempty"`
	RuleGroups           []string   `protobuf:"bytes,9,rep,name=ruleGroups,proto3" json:"ruleGroups,omitempty"`
	Labels               []Label    `protobuf:"bytes,10,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 NewShard 

func NewShard() *Shard

func (*Shard) Clone 

func (m *Shard) Clone() *Shard

Clone clones the shard returns the pointer

func (*Shard) ContainsKey 

func (m *Shard) ContainsKey(key []byte) bool

ContainsKey returns true if the shard contains the key

func (*Shard) Descriptor 

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

func (*Shard) FastUnmarshal 

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

func (*Shard) GetEnd 

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

func (*Shard) GetEpoch 

func (m *Shard) GetEpoch() ShardEpoch

func (*Shard) GetGroup 

func (m *Shard) GetGroup() uint64

func (*Shard) GetID 

func (m *Shard) GetID() uint64

func (*Shard) GetLabels 

func (m *Shard) GetLabels() []Label

func (*Shard) GetRange 

func (m *Shard) GetRange() ([]byte, []byte)

func (*Shard) GetReplicas 

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

func (*Shard) GetRuleGroups 

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

func (*Shard) GetStart 

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

func (*Shard) GetState 

func (m *Shard) GetState() ShardState

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

func (m *Shard) MinEnd(end []byte) []byte

MinEnd returns min(end, shard.end)

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) Reset 

func (m *Shard) Reset()

func (*Shard) SetEndKey 

func (m *Shard) SetEndKey(value []byte)

func (*Shard) SetEpoch 

func (m *Shard) SetEpoch(epoch ShardEpoch)

func (*Shard) SetID 

func (m *Shard) SetID(shardID uint64)

func (*Shard) SetReplicas 

func (m *Shard) SetReplicas(replicas []Replica)

func (*Shard) SetRuleGroups 

func (m *Shard) SetRuleGroups(values ...string)

func (*Shard) SetStartKey 

func (m *Shard) SetStartKey(value []byte)

func (*Shard) SetState 

func (m *Shard) SetState(state ShardState)

func (*Shard) SetUnique 

func (m *Shard) SetUnique(value string)

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 ShardEpoch 

type ShardEpoch struct {
	// Conf change version, auto increment when add or remove replica
	ConfigVer uint64 `protobuf:"varint,1,opt,name=configVer,proto3" json:"configVer,omitempty"`
	// Shard generation, auto increment when split or merge
	Generation           uint64   `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ShardEpoch shard epoch

func (*ShardEpoch) Descriptor 

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

func (*ShardEpoch) FastUnmarshal 

func (m *ShardEpoch) FastUnmarshal(dAtA []byte) error

func (*ShardEpoch) GetConfigVer 

func (m *ShardEpoch) GetConfigVer() uint64

func (*ShardEpoch) GetGeneration 

func (m *ShardEpoch) GetGeneration() uint64

func (*ShardEpoch) Marshal 

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

func (*ShardEpoch) MarshalTo 

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

func (*ShardEpoch) ProtoMessage 

func (*ShardEpoch) ProtoMessage()

func (*ShardEpoch) Reset 

func (m *ShardEpoch) Reset()

func (*ShardEpoch) Size 

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

func (*ShardEpoch) String 

func (m *ShardEpoch) String() string

func (*ShardEpoch) Unmarshal 

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

func (*ShardEpoch) XXX_DiscardUnknown 

func (m *ShardEpoch) XXX_DiscardUnknown()

func (*ShardEpoch) XXX_Marshal 

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

func (*ShardEpoch) XXX_Merge 

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

func (*ShardEpoch) XXX_Size 

func (m *ShardEpoch) XXX_Size() int

func (*ShardEpoch) XXX_Unmarshal 

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

type ShardExtra 

type ShardExtra struct {
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	DestroyingStatus     *DestroyingStatus `protobuf:"bytes,2,opt,name=destroyingStatus,proto3" json:"destroyingStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

ShardExtra shard extra

func (*ShardExtra) Descriptor 

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

func (*ShardExtra) FastUnmarshal 

func (m *ShardExtra) FastUnmarshal(dAtA []byte) error

func (*ShardExtra) GetDestroyingStatus 

func (m *ShardExtra) GetDestroyingStatus() *DestroyingStatus

func (*ShardExtra) GetLabels 

func (m *ShardExtra) GetLabels() map[string]string

func (*ShardExtra) Marshal 

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

func (*ShardExtra) MarshalTo 

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

func (*ShardExtra) ProtoMessage 

func (*ShardExtra) ProtoMessage()

func (*ShardExtra) Reset 

func (m *ShardExtra) Reset()

func (*ShardExtra) Size 

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

func (*ShardExtra) String 

func (m *ShardExtra) String() string

func (*ShardExtra) Unmarshal 

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

func (*ShardExtra) XXX_DiscardUnknown 

func (m *ShardExtra) XXX_DiscardUnknown()

func (*ShardExtra) XXX_Marshal 

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

func (*ShardExtra) XXX_Merge 

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

func (*ShardExtra) XXX_Size 

func (m *ShardExtra) XXX_Size() int

func (*ShardExtra) XXX_Unmarshal 

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

type ShardLocalState 

type ShardLocalState struct {
	Shard Shard        `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard"`
	Lease *EpochLease  `protobuf:"bytes,2,opt,name=lease,proto3" json:"lease,omitempty"`
	State ReplicaState `protobuf:"varint,3,opt,name=state,proto3,enum=metapb.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,4,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) FastUnmarshal 

func (m *ShardLocalState) FastUnmarshal(dAtA []byte) error

func (*ShardLocalState) GetLease 

func (m *ShardLocalState) GetLease() *EpochLease

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

func (m *ShardMetadata) FastUnmarshal(dAtA []byte) error

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

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

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 ShardPoolJob 

type ShardPoolJob struct {
	Pools                []ShardPoolJobMeta `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

ShardPoolJob shard pool job

func (*ShardPoolJob) Descriptor 

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

func (*ShardPoolJob) FastUnmarshal 

func (m *ShardPoolJob) FastUnmarshal(dAtA []byte) error

func (*ShardPoolJob) GetPools 

func (m *ShardPoolJob) GetPools() []ShardPoolJobMeta

func (*ShardPoolJob) Marshal 

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

func (*ShardPoolJob) MarshalTo 

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

func (*ShardPoolJob) ProtoMessage 

func (*ShardPoolJob) ProtoMessage()

func (*ShardPoolJob) Reset 

func (m *ShardPoolJob) Reset()

func (*ShardPoolJob) Size 

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

func (*ShardPoolJob) String 

func (m *ShardPoolJob) String() string

func (*ShardPoolJob) Unmarshal 

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

func (*ShardPoolJob) XXX_DiscardUnknown 

func (m *ShardPoolJob) XXX_DiscardUnknown()

func (*ShardPoolJob) XXX_Marshal 

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

func (*ShardPoolJob) XXX_Merge 

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

func (*ShardPoolJob) XXX_Size 

func (m *ShardPoolJob) XXX_Size() int

func (*ShardPoolJob) XXX_Unmarshal 

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

type ShardPoolJobMeta 

type ShardPoolJobMeta struct {
	Group                uint64   `protobuf:"varint,1,opt,name=group,proto3" json:"group,omitempty"`
	Capacity             uint64   `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
	RangePrefix          []byte   `protobuf:"bytes,3,opt,name=rangePrefix,proto3" json:"rangePrefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ShardPoolJobMeta shard pool

func (*ShardPoolJobMeta) Descriptor 

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

func (*ShardPoolJobMeta) FastUnmarshal 

func (m *ShardPoolJobMeta) FastUnmarshal(dAtA []byte) error

func (*ShardPoolJobMeta) GetCapacity 

func (m *ShardPoolJobMeta) GetCapacity() uint64

func (*ShardPoolJobMeta) GetGroup 

func (m *ShardPoolJobMeta) GetGroup() uint64

func (*ShardPoolJobMeta) GetRangePrefix 

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

func (*ShardPoolJobMeta) Marshal 

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

func (*ShardPoolJobMeta) MarshalTo 

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

func (*ShardPoolJobMeta) ProtoMessage 

func (*ShardPoolJobMeta) ProtoMessage()

func (*ShardPoolJobMeta) Reset 

func (m *ShardPoolJobMeta) Reset()

func (*ShardPoolJobMeta) Size 

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

func (*ShardPoolJobMeta) String 

func (m *ShardPoolJobMeta) String() string

func (*ShardPoolJobMeta) Unmarshal 

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

func (*ShardPoolJobMeta) XXX_DiscardUnknown 

func (m *ShardPoolJobMeta) XXX_DiscardUnknown()

func (*ShardPoolJobMeta) XXX_Marshal 

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

func (*ShardPoolJobMeta) XXX_Merge 

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

func (*ShardPoolJobMeta) XXX_Size 

func (m *ShardPoolJobMeta) XXX_Size() int

func (*ShardPoolJobMeta) XXX_Unmarshal 

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

type ShardState 

type ShardState int32

ShardState the shard state 

const (
	// Running is serve state,
	// this state provides read and write services to the public normally.
	ShardState_Running ShardState = 0
	// Creating is waiting to create state,
	// this state does not provide read and write services to the public.
	ShardState_Creating ShardState = 1
	// Destroying is waiting to destroy state,
	// this state normally cannot provide read and write services to the public,
	// and the destruction process of shards has not yet been completed.
	ShardState_Destroying ShardState = 2
	// Destroyed is the destroyed state,
	// this state is normally not available for external read and write services,
	// the shards have been destroyed in the whole cluster and cannot be used again.
	ShardState_Destroyed ShardState = 3
)

func (ShardState) EnumDescriptor 

func (ShardState) EnumDescriptor() ([]byte, []int)

func (ShardState) String 

func (x ShardState) String() string

type ShardStats 

type ShardStats struct {
	// shard ID
	ShardID uint64 `protobuf:"varint,1,opt,name=shardID,proto3" json:"shardID,omitempty"`
	// bytes written during this period
	WrittenBytes uint64 `protobuf:"varint,2,opt,name=writtenBytes,proto3" json:"writtenBytes,omitempty"`
	// keys written during this period
	WrittenKeys uint64 `protobuf:"varint,3,opt,name=writtenKeys,proto3" json:"writtenKeys,omitempty"`
	// bytes read during this period
	ReadBytes uint64 `protobuf:"varint,4,opt,name=readBytes,proto3" json:"readBytes,omitempty"`
	// keys read during this period
	ReadKeys uint64 `protobuf:"varint,5,opt,name=readKeys,proto3" json:"readKeys,omitempty"`
	// approximate data size in bytes of the shard
	ApproximateSize uint64 `protobuf:"varint,6,opt,name=approximateSize,proto3" json:"approximateSize,omitempty"`
	// approximate count of keys in the shard
	ApproximateKeys uint64 `protobuf:"varint,7,opt,name=approximateKeys,proto3" json:"approximateKeys,omitempty"`
	// Actually reported time interval
	Interval             *TimeInterval `protobuf:"bytes,8,opt,name=interval,proto3" json:"interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

ShardStats shard stats

func (*ShardStats) Descriptor 

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

func (*ShardStats) FastUnmarshal 

func (m *ShardStats) FastUnmarshal(dAtA []byte) error

func (*ShardStats) GetApproximateKeys 

func (m *ShardStats) GetApproximateKeys() uint64

func (*ShardStats) GetApproximateSize 

func (m *ShardStats) GetApproximateSize() uint64

func (*ShardStats) GetInterval 

func (m *ShardStats) GetInterval() *TimeInterval

func (*ShardStats) GetReadBytes 

func (m *ShardStats) GetReadBytes() uint64

func (*ShardStats) GetReadKeys 

func (m *ShardStats) GetReadKeys() uint64

func (*ShardStats) GetShardID 

func (m *ShardStats) GetShardID() uint64

func (*ShardStats) GetWrittenBytes 

func (m *ShardStats) GetWrittenBytes() uint64

func (*ShardStats) GetWrittenKeys 

func (m *ShardStats) GetWrittenKeys() uint64

func (*ShardStats) Marshal 

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

func (*ShardStats) MarshalTo 

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

func (*ShardStats) ProtoMessage 

func (*ShardStats) ProtoMessage()

func (*ShardStats) Reset 

func (m *ShardStats) Reset()

func (*ShardStats) Size 

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

func (*ShardStats) String 

func (m *ShardStats) String() string

func (*ShardStats) Unmarshal 

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

func (*ShardStats) XXX_DiscardUnknown 

func (m *ShardStats) XXX_DiscardUnknown()

func (*ShardStats) XXX_Marshal 

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

func (*ShardStats) XXX_Merge 

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

func (*ShardStats) XXX_Size 

func (m *ShardStats) XXX_Size() int

func (*ShardStats) XXX_Unmarshal 

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

type ShardType 

type ShardType int32

ShardKind the shard kind 

const (
	ShardType_LeaderOnly ShardType = 0
	ShardType_AllShards  ShardType = 1
)

func (ShardType) EnumDescriptor 

func (ShardType) EnumDescriptor() ([]byte, []int)

func (ShardType) String 

func (x ShardType) String() string

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

func (m *ShardsPool) FastUnmarshal(dAtA []byte) error

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

func (m *ShardsPoolAllocCmd) FastUnmarshal(dAtA []byte) error

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=metapb.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) FastUnmarshal 

func (m *ShardsPoolCmd) FastUnmarshal(dAtA []byte) error

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

func (m *ShardsPoolCreateCmd) FastUnmarshal(dAtA []byte) error

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 {
	StoreID              uint64           `protobuf:"varint,1,opt,name=storeID,proto3" json:"storeID,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) 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) GetStoreID 

func (m *SnapshotChunk) GetStoreID() 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) FastUnmarshal 

func (m *SnapshotInfo) FastUnmarshal(dAtA []byte) error

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 Store 

type Store struct {
	ID                   uint64     `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	RaftAddress          string     `protobuf:"bytes,2,opt,name=raftAddress,proto3" json:"raftAddress,omitempty"`
	ClientAddress        string     `protobuf:"bytes,3,opt,name=clientAddress,proto3" json:"clientAddress,omitempty"`
	Labels               []Label    `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels"`
	State                StoreState `protobuf:"varint,5,opt,name=state,proto3,enum=metapb.StoreState" 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"`
	CommitID             string     `protobuf:"bytes,9,opt,name=commitID,proto3" json:"commitID,omitempty"`
	DeployPath           string     `protobuf:"bytes,10,opt,name=deployPath,proto3" json:"deployPath,omitempty"`
	Destroyed            bool       `protobuf:"varint,11,opt,name=destroyed,proto3" json:"destroyed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Store the host store metadata

func NewStore 

func NewStore() *Store

func (*Store) Clone 

func (m *Store) Clone() *Store

Clone clones the shard returns the pointer

func (*Store) Descriptor 

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

func (*Store) FastUnmarshal 

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

func (*Store) GetClientAddress 

func (m *Store) GetClientAddress() string

func (*Store) GetCommitID 

func (m *Store) GetCommitID() string

func (*Store) GetDeployPath 

func (m *Store) GetDeployPath() string

func (*Store) GetDestroyed 

func (m *Store) GetDestroyed() bool

func (*Store) GetID 

func (m *Store) GetID() uint64

func (*Store) GetLabels 

func (m *Store) GetLabels() []Label

func (*Store) GetLastHeartbeatTime 

func (m *Store) GetLastHeartbeatTime() int64

func (*Store) GetRaftAddress 

func (m *Store) GetRaftAddress() string

func (*Store) GetStartTime 

func (m *Store) GetStartTime() int64

func (*Store) GetState 

func (m *Store) GetState() StoreState

func (*Store) GetVersion 

func (m *Store) GetVersion() string

func (*Store) GetVersionAndGitHash 

func (m *Store) GetVersionAndGitHash() (string, 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) SetAddrs 

func (m *Store) SetAddrs(clientAddr, raftAddr string)

func (*Store) SetDeployPath 

func (m *Store) SetDeployPath(value string)

func (*Store) SetDestroyed 

func (m *Store) SetDestroyed(value bool)

func (*Store) SetID 

func (m *Store) SetID(storeID uint64)

func (*Store) SetLabels 

func (m *Store) SetLabels(labels []Label)

func (*Store) SetLastHeartbeat 

func (m *Store) SetLastHeartbeat(value int64)

func (*Store) SetStartTime 

func (m *Store) SetStartTime(value int64)

func (*Store) SetState 

func (m *Store) SetState(value StoreState)

func (*Store) SetVersionAndCommitID 

func (m *Store) SetVersionAndCommitID(version, commitID string)

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

func (m *StoreIdent) FastUnmarshal(dAtA []byte) error

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

type StoreState 

type StoreState int32

StoreState the store state 

const (
	// Up is normal state
	StoreState_Up StoreState = 0
	// Down is the unavailable state
	StoreState_Down StoreState = 1
	// Tombstone is the destroy state
	StoreState_StoreTombstone StoreState = 2
)

func (StoreState) EnumDescriptor 

func (StoreState) EnumDescriptor() ([]byte, []int)

func (StoreState) String 

func (x StoreState) String() string

type StoreStats 

type StoreStats struct {
	// Store id
	StoreID uint64 `protobuf:"varint,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	// When the store is started (unix timestamp in seconds).
	StartTime uint64 `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	// Actually reported time interval
	Interval *TimeInterval `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// Capacity for the store.
	Capacity uint64 `protobuf:"varint,4,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// Available size for the store.
	Available uint64 `protobuf:"varint,5,opt,name=available,proto3" json:"available,omitempty"`
	// Actually used space by db
	UsedSize uint64 `protobuf:"varint,6,opt,name=usedSize,proto3" json:"usedSize,omitempty"`
	// If the store is busy
	IsBusy bool `protobuf:"varint,7,opt,name=isBusy,proto3" json:"isBusy,omitempty"`
	// Total shard count in this store.
	ShardCount uint64 `protobuf:"varint,8,opt,name=shardCount,proto3" json:"shardCount,omitempty"`
	// Current sending snapshot count.
	SendingSnapCount uint64 `protobuf:"varint,9,opt,name=sendingSnapCount,proto3" json:"sendingSnapCount,omitempty"`
	// Current receiving snapshot count.
	ReceivingSnapCount uint64 `protobuf:"varint,10,opt,name=receivingSnapCount,proto3" json:"receivingSnapCount,omitempty"`
	// How many shard is applying snapshot.
	ApplyingSnapCount uint64 `protobuf:"varint,11,opt,name=applyingSnapCount,proto3" json:"applyingSnapCount,omitempty"`
	// Bytes written for the store during this period.
	WrittenBytes uint64 `protobuf:"varint,12,opt,name=writtenBytes,proto3" json:"writtenBytes,omitempty"`
	// Bytes read for the store during this period.
	ReadBytes uint64 `protobuf:"varint,13,opt,name=readBytes,proto3" json:"readBytes,omitempty"`
	// Bytes written for the store during this period.
	WrittenKeys uint64 `protobuf:"varint,14,opt,name=writtenKeys,proto3" json:"writtenKeys,omitempty"`
	// Bytes read for the store during this period.
	ReadKeys uint64 `protobuf:"varint,15,opt,name=readKeys,proto3" json:"readKeys,omitempty"`
	// Threads' CPU usages in the store
	CpuUsages []RecordPair `protobuf:"bytes,16,rep,name=cpuUsages,proto3" json:"cpuUsages"`
	// Threads' read disk I/O rates in the store
	ReadIORates []RecordPair `protobuf:"bytes,17,rep,name=readIORates,proto3" json:"readIORates"`
	// Threads' write disk I/O rates in the store
	WriteIORates         []RecordPair `protobuf:"bytes,18,rep,name=writeIORates,proto3" json:"writeIORates"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

StoreStats store stats

func (*StoreStats) Descriptor 

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

func (*StoreStats) FastUnmarshal 

func (m *StoreStats) FastUnmarshal(dAtA []byte) error

func (*StoreStats) GetApplyingSnapCount 

func (m *StoreStats) GetApplyingSnapCount() uint64

func (*StoreStats) GetAvailable 

func (m *StoreStats) GetAvailable() uint64

func (*StoreStats) GetCapacity 

func (m *StoreStats) GetCapacity() uint64

func (*StoreStats) GetCpuUsages 

func (m *StoreStats) GetCpuUsages() []RecordPair

func (*StoreStats) GetInterval 

func (m *StoreStats) GetInterval() *TimeInterval

func (*StoreStats) GetIsBusy 

func (m *StoreStats) GetIsBusy() bool

func (*StoreStats) GetReadBytes 

func (m *StoreStats) GetReadBytes() uint64

func (*StoreStats) GetReadIORates 

func (m *StoreStats) GetReadIORates() []RecordPair

func (*StoreStats) GetReadKeys 

func (m *StoreStats) GetReadKeys() uint64

func (*StoreStats) GetReceivingSnapCount 

func (m *StoreStats) GetReceivingSnapCount() uint64

func (*StoreStats) GetSendingSnapCount 

func (m *StoreStats) GetSendingSnapCount() uint64

func (*StoreStats) GetShardCount 

func (m *StoreStats) GetShardCount() uint64

func (*StoreStats) GetStartTime 

func (m *StoreStats) GetStartTime() uint64

func (*StoreStats) GetStoreID 

func (m *StoreStats) GetStoreID() uint64

func (*StoreStats) GetUsedSize 

func (m *StoreStats) GetUsedSize() uint64

func (*StoreStats) GetWriteIORates 

func (m *StoreStats) GetWriteIORates() []RecordPair

func (*StoreStats) GetWrittenBytes 

func (m *StoreStats) GetWrittenBytes() uint64

func (*StoreStats) GetWrittenKeys 

func (m *StoreStats) GetWrittenKeys() uint64

func (*StoreStats) Marshal 

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

func (*StoreStats) MarshalTo 

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

func (*StoreStats) ProtoMessage 

func (*StoreStats) ProtoMessage()

func (*StoreStats) Reset 

func (m *StoreStats) Reset()

func (*StoreStats) Size 

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

func (*StoreStats) String 

func (m *StoreStats) String() string

func (*StoreStats) Unmarshal 

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

func (*StoreStats) XXX_DiscardUnknown 

func (m *StoreStats) XXX_DiscardUnknown()

func (*StoreStats) XXX_Marshal 

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

func (*StoreStats) XXX_Merge 

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

func (*StoreStats) XXX_Size 

func (m *StoreStats) XXX_Size() int

func (*StoreStats) XXX_Unmarshal 

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

type TimeInterval 

type TimeInterval struct {
	// The unix timestamp in seconds of the start of this period.
	Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// The unix timestamp in seconds of the end of this period.
	End                  uint64   `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TimeInterval time interval

func (*TimeInterval) Descriptor 

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

func (*TimeInterval) FastUnmarshal 

func (m *TimeInterval) FastUnmarshal(dAtA []byte) error

func (*TimeInterval) GetEnd 

func (m *TimeInterval) GetEnd() uint64

func (*TimeInterval) GetStart 

func (m *TimeInterval) GetStart() uint64

func (*TimeInterval) Marshal 

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

func (*TimeInterval) MarshalTo 

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

func (*TimeInterval) ProtoMessage 

func (*TimeInterval) ProtoMessage()

func (*TimeInterval) Reset 

func (m *TimeInterval) Reset()

func (*TimeInterval) Size 

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

func (*TimeInterval) String 

func (m *TimeInterval) String() string

func (*TimeInterval) Unmarshal 

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

func (*TimeInterval) XXX_DiscardUnknown 

func (m *TimeInterval) XXX_DiscardUnknown()

func (*TimeInterval) XXX_Marshal 

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

func (*TimeInterval) XXX_Merge 

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

func (*TimeInterval) XXX_Size 

func (m *TimeInterval) XXX_Size() int

func (*TimeInterval) XXX_Unmarshal 

func (m *TimeInterval) 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.