metapb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2021 License: Apache-2.0 Imports: 5 Imported by: 2

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 Action_name = map[int32]string{
	0: "None",
	1: "ScaleOut",
}
View Source 
var Action_value = map[string]int32{
	"None":     0,
	"ScaleOut": 1,
}
View Source 
var ChangePeerType_name = map[int32]string{
	0: "AddNode",
	1: "RemoveNode",
	2: "UpdateNode",
	3: "AddLearnerNode",
	4: "ScalePeer",
}
View Source 
var ChangePeerType_value = map[string]int32{
	"AddNode":        0,
	"RemoveNode":     1,
	"UpdateNode":     2,
	"AddLearnerNode": 3,
	"ScalePeer":      4,
}
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 ContainerState_name = map[int32]string{
	0: "UP",
	1: "Offline",
	2: "Tombstone",
}
View Source 
var ContainerState_value = map[string]int32{
	"UP":        0,
	"Offline":   1,
	"Tombstone": 2,
}
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:   "RemoveResource",
	1:   "CreateResourcePool",
	100: "CustomStartAt",
}
View Source 
var JobType_value = map[string]int32{
	"RemoveResource":     0,
	"CreateResourcePool": 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 PeerRole_name = map[int32]string{
	0: "Voter",
	1: "Learner",
	2: "IncomingVoter",
	3: "DemotingVoter",
}
View Source 
var PeerRole_value = map[string]int32{
	"Voter":         0,
	"Learner":       1,
	"IncomingVoter": 2,
	"DemotingVoter": 3,
}
View Source 
var ResourceKind_name = map[int32]string{
	0: "LeaderKind",
	1: "ReplicaKind",
}
View Source 
var ResourceKind_value = map[string]int32{
	"LeaderKind":  0,
	"ReplicaKind": 1,
}
View Source 
var ResourceState_name = map[int32]string{
	0: "Running",
	1: "WaittingCreate",
	2: "Removed",
}
View Source 
var ResourceState_value = map[string]int32{
	"Running":        0,
	"WaittingCreate": 1,
	"Removed":        2,
}

Functions

This section is empty.

Types

type Action 

type Action int32

Action the action while a new node join the cluster 

const (
	Action_None     Action = 0
	Action_ScaleOut Action = 1
)

func (Action) EnumDescriptor 

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

func (Action) String 

func (x Action) String() string

type ChangePeerType 

type ChangePeerType int32

ChangePeerType change peer type 

const (
	ChangePeerType_AddNode        ChangePeerType = 0
	ChangePeerType_RemoveNode     ChangePeerType = 1
	ChangePeerType_UpdateNode     ChangePeerType = 2
	ChangePeerType_AddLearnerNode ChangePeerType = 3
	ChangePeerType_ScalePeer      ChangePeerType = 4
)

func (ChangePeerType) EnumDescriptor 

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

func (ChangePeerType) String 

func (x ChangePeerType) String() string

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 Cluster 

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

Cluster prophet cluster

func (*Cluster) Descriptor 

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

func (*Cluster) GetID 

func (m *Cluster) GetID() uint64

func (*Cluster) GetMaxPeerCount 

func (m *Cluster) GetMaxPeerCount() 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 ContainerState 

type ContainerState int32

State the container state 

const (
	// UP is normal state
	ContainerState_UP ContainerState = 0
	// Offline is the unavailable state
	ContainerState_Offline ContainerState = 1
	// Tombstone is the destory state
	ContainerState_Tombstone ContainerState = 2
)

func (ContainerState) EnumDescriptor 

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

func (ContainerState) String 

func (x ContainerState) String() string

type ContainerStats 

type ContainerStats struct {
	// Container id
	ContainerID uint64 `protobuf:"varint,1,opt,name=containerID,proto3" json:"containerID,omitempty"`
	// When the container 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 container.
	Capacity uint64 `protobuf:"varint,4,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// Available size for the container.
	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 container is busy
	IsBusy bool `protobuf:"varint,7,opt,name=isBusy,proto3" json:"isBusy,omitempty"`
	// Total resource count in this container.
	ResourceCount uint64 `protobuf:"varint,8,opt,name=resourceCount,proto3" json:"resourceCount,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 resource is applying snapshot.
	ApplyingSnapCount uint64 `protobuf:"varint,11,opt,name=applyingSnapCount,proto3" json:"applyingSnapCount,omitempty"`
	// Bytes written for the container during this period.
	WrittenBytes uint64 `protobuf:"varint,12,opt,name=writtenBytes,proto3" json:"writtenBytes,omitempty"`
	// Bytes read for the container during this period.
	ReadBytes uint64 `protobuf:"varint,13,opt,name=readBytes,proto3" json:"readBytes,omitempty"`
	// Bytes written for the container during this period.
	WrittenKeys uint64 `protobuf:"varint,14,opt,name=writtenKeys,proto3" json:"writtenKeys,omitempty"`
	// Bytes read for the container during this period.
	ReadKeys uint64 `protobuf:"varint,15,opt,name=readKeys,proto3" json:"readKeys,omitempty"`
	// Threads' CPU usages in the container
	CpuUsages []RecordPair `protobuf:"bytes,16,rep,name=cpuUsages,proto3" json:"cpuUsages"`
	// Threads' read disk I/O rates in the container
	ReadIORates []RecordPair `protobuf:"bytes,17,rep,name=readIORates,proto3" json:"readIORates"`
	// Threads' write disk I/O rates in the container
	WriteIORates []RecordPair `protobuf:"bytes,18,rep,name=writeIORates,proto3" json:"writeIORates"`
	// Operations' latencies in the container
	OpLatencies          []RecordPair `protobuf:"bytes,19,rep,name=opLatencies,proto3" json:"opLatencies"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ContainerStats container stats

func (*ContainerStats) Descriptor 

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

func (*ContainerStats) GetApplyingSnapCount 

func (m *ContainerStats) GetApplyingSnapCount() uint64

func (*ContainerStats) GetAvailable 

func (m *ContainerStats) GetAvailable() uint64

func (*ContainerStats) GetCapacity 

func (m *ContainerStats) GetCapacity() uint64

func (*ContainerStats) GetContainerID 

func (m *ContainerStats) GetContainerID() uint64

func (*ContainerStats) GetCpuUsages 

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

func (*ContainerStats) GetInterval 

func (m *ContainerStats) GetInterval() *TimeInterval

func (*ContainerStats) GetIsBusy 

func (m *ContainerStats) GetIsBusy() bool

func (*ContainerStats) GetOpLatencies 

func (m *ContainerStats) GetOpLatencies() []RecordPair

func (*ContainerStats) GetReadBytes 

func (m *ContainerStats) GetReadBytes() uint64

func (*ContainerStats) GetReadIORates 

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

func (*ContainerStats) GetReadKeys 

func (m *ContainerStats) GetReadKeys() uint64

func (*ContainerStats) GetReceivingSnapCount 

func (m *ContainerStats) GetReceivingSnapCount() uint64

func (*ContainerStats) GetResourceCount 

func (m *ContainerStats) GetResourceCount() uint64

func (*ContainerStats) GetSendingSnapCount 

func (m *ContainerStats) GetSendingSnapCount() uint64

func (*ContainerStats) GetStartTime 

func (m *ContainerStats) GetStartTime() uint64

func (*ContainerStats) GetUsedSize 

func (m *ContainerStats) GetUsedSize() uint64

func (*ContainerStats) GetWriteIORates 

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

func (*ContainerStats) GetWrittenBytes 

func (m *ContainerStats) GetWrittenBytes() uint64

func (*ContainerStats) GetWrittenKeys 

func (m *ContainerStats) GetWrittenKeys() uint64

func (*ContainerStats) Marshal 

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

func (*ContainerStats) MarshalTo 

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

func (*ContainerStats) ProtoMessage 

func (*ContainerStats) ProtoMessage()

func (*ContainerStats) Reset 

func (m *ContainerStats) Reset()

func (*ContainerStats) Size 

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

func (*ContainerStats) String 

func (m *ContainerStats) String() string

func (*ContainerStats) Unmarshal 

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

func (*ContainerStats) XXX_DiscardUnknown 

func (m *ContainerStats) XXX_DiscardUnknown()

func (*ContainerStats) XXX_Marshal 

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

func (*ContainerStats) XXX_Merge 

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

func (*ContainerStats) XXX_Size 

func (m *ContainerStats) XXX_Size() int

func (*ContainerStats) XXX_Unmarshal 

func (m *ContainerStats) 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) 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 (
	// RemoveResource remove resource job
	JobType_RemoveResource JobType = 0
	// CreateResourcePool create resource pool
	JobType_CreateResourcePool 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 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) 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 Pair 

type Pair 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:"-"`
}

Pair key value pair

func (*Pair) Descriptor 

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

func (*Pair) GetKey 

func (m *Pair) GetKey() string

func (*Pair) GetValue 

func (m *Pair) GetValue() string

func (*Pair) Marshal 

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

func (*Pair) MarshalTo 

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

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) Reset 

func (m *Pair) Reset()

func (*Pair) Size 

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

func (*Pair) String 

func (m *Pair) String() string

func (*Pair) Unmarshal 

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

func (*Pair) XXX_DiscardUnknown 

func (m *Pair) XXX_DiscardUnknown()

func (*Pair) XXX_Marshal 

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

func (*Pair) XXX_Merge 

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

func (*Pair) XXX_Size 

func (m *Pair) XXX_Size() int

func (*Pair) XXX_Unmarshal 

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

type Peer 

type Peer struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ContainerID          uint64   `protobuf:"varint,2,opt,name=containerID,proto3" json:"containerID,omitempty"`
	Role                 PeerRole `protobuf:"varint,3,opt,name=role,proto3,enum=metapb.PeerRole" 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:"-"`
}

Peer is a replica of the resource, we called peer

func (*Peer) Descriptor 

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

func (*Peer) GetContainerID 

func (m *Peer) GetContainerID() uint64

func (*Peer) GetID 

func (m *Peer) GetID() uint64

func (*Peer) GetInitialMember 

func (m *Peer) GetInitialMember() bool

func (*Peer) GetRole 

func (m *Peer) GetRole() PeerRole

func (*Peer) Marshal 

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

func (*Peer) MarshalTo 

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

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) Size 

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

func (*Peer) String 

func (m *Peer) String() string

func (*Peer) Unmarshal 

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

func (*Peer) XXX_DiscardUnknown 

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal 

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

func (*Peer) XXX_Merge 

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

func (*Peer) XXX_Size 

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal 

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

type PeerRole 

type PeerRole int32

PeerRole role of current peer 

const (
	PeerRole_Voter         PeerRole = 0
	PeerRole_Learner       PeerRole = 1
	PeerRole_IncomingVoter PeerRole = 2
	PeerRole_DemotingVoter PeerRole = 3
)

func (PeerRole) EnumDescriptor 

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

func (PeerRole) String 

func (x PeerRole) String() string

type PeerStats 

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

PeerStats peer stats

func (*PeerStats) Descriptor 

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

func (*PeerStats) GetDownSeconds 

func (m *PeerStats) GetDownSeconds() uint64

func (*PeerStats) GetPeer 

func (m *PeerStats) GetPeer() Peer

func (*PeerStats) Marshal 

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

func (*PeerStats) MarshalTo 

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

func (*PeerStats) ProtoMessage 

func (*PeerStats) ProtoMessage()

func (*PeerStats) Reset 

func (m *PeerStats) Reset()

func (*PeerStats) Size 

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

func (*PeerStats) String 

func (m *PeerStats) String() string

func (*PeerStats) Unmarshal 

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

func (*PeerStats) XXX_DiscardUnknown 

func (m *PeerStats) XXX_DiscardUnknown()

func (*PeerStats) XXX_Marshal 

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

func (*PeerStats) XXX_Merge 

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

func (*PeerStats) XXX_Size 

func (m *PeerStats) XXX_Size() int

func (*PeerStats) XXX_Unmarshal 

func (m *PeerStats) 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) 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 RemoveResourceJob 

type RemoveResourceJob struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=resourceID,proto3" json:"resourceID,omitempty"`
	Peers                []Peer   `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RemoveResourceJob remove resources job

func (*RemoveResourceJob) Descriptor 

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

func (*RemoveResourceJob) GetID 

func (m *RemoveResourceJob) GetID() uint64

func (*RemoveResourceJob) GetPeers 

func (m *RemoveResourceJob) GetPeers() []Peer

func (*RemoveResourceJob) Marshal 

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

func (*RemoveResourceJob) MarshalTo 

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

func (*RemoveResourceJob) ProtoMessage 

func (*RemoveResourceJob) ProtoMessage()

func (*RemoveResourceJob) Reset 

func (m *RemoveResourceJob) Reset()

func (*RemoveResourceJob) Size 

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

func (*RemoveResourceJob) String 

func (m *RemoveResourceJob) String() string

func (*RemoveResourceJob) Unmarshal 

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

func (*RemoveResourceJob) XXX_DiscardUnknown 

func (m *RemoveResourceJob) XXX_DiscardUnknown()

func (*RemoveResourceJob) XXX_Marshal 

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

func (*RemoveResourceJob) XXX_Merge 

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

func (*RemoveResourceJob) XXX_Size 

func (m *RemoveResourceJob) XXX_Size() int

func (*RemoveResourceJob) XXX_Unmarshal 

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

type ResourceEpoch 

type ResourceEpoch struct {
	// Conf change version, auto increment when add or remove peer
	ConfVer uint64 `protobuf:"varint,1,opt,name=confVer,proto3" json:"confVer,omitempty"`
	// Resource version, auto increment when split or merge
	Version              uint64   `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResourceEpoch resource epoch

func (*ResourceEpoch) Descriptor 

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

func (*ResourceEpoch) GetConfVer 

func (m *ResourceEpoch) GetConfVer() uint64

func (*ResourceEpoch) GetVersion 

func (m *ResourceEpoch) GetVersion() uint64

func (*ResourceEpoch) Marshal 

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

func (*ResourceEpoch) MarshalTo 

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

func (*ResourceEpoch) ProtoMessage 

func (*ResourceEpoch) ProtoMessage()

func (*ResourceEpoch) Reset 

func (m *ResourceEpoch) Reset()

func (*ResourceEpoch) Size 

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

func (*ResourceEpoch) String 

func (m *ResourceEpoch) String() string

func (*ResourceEpoch) Unmarshal 

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

func (*ResourceEpoch) XXX_DiscardUnknown 

func (m *ResourceEpoch) XXX_DiscardUnknown()

func (*ResourceEpoch) XXX_Marshal 

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

func (*ResourceEpoch) XXX_Merge 

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

func (*ResourceEpoch) XXX_Size 

func (m *ResourceEpoch) XXX_Size() int

func (*ResourceEpoch) XXX_Unmarshal 

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

type ResourceKind 

type ResourceKind int32

ResourceKind the resource king 

const (
	ResourceKind_LeaderKind  ResourceKind = 0
	ResourceKind_ReplicaKind ResourceKind = 1
)

func (ResourceKind) EnumDescriptor 

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

func (ResourceKind) String 

func (x ResourceKind) String() string

type ResourcePool 

type ResourcePool 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:"-"`
}

ResourcePool resource pool

func (*ResourcePool) Descriptor 

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

func (*ResourcePool) GetCapacity 

func (m *ResourcePool) GetCapacity() uint64

func (*ResourcePool) GetGroup 

func (m *ResourcePool) GetGroup() uint64

func (*ResourcePool) GetRangePrefix 

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

func (*ResourcePool) Marshal 

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

func (*ResourcePool) MarshalTo 

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

func (*ResourcePool) ProtoMessage 

func (*ResourcePool) ProtoMessage()

func (*ResourcePool) Reset 

func (m *ResourcePool) Reset()

func (*ResourcePool) Size 

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

func (*ResourcePool) String 

func (m *ResourcePool) String() string

func (*ResourcePool) Unmarshal 

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

func (*ResourcePool) XXX_DiscardUnknown 

func (m *ResourcePool) XXX_DiscardUnknown()

func (*ResourcePool) XXX_Marshal 

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

func (*ResourcePool) XXX_Merge 

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

func (*ResourcePool) XXX_Size 

func (m *ResourcePool) XXX_Size() int

func (*ResourcePool) XXX_Unmarshal 

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

type ResourcePoolJob 

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

ResourcePoolJob resource pool job

func (*ResourcePoolJob) Descriptor 

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

func (*ResourcePoolJob) GetPools 

func (m *ResourcePoolJob) GetPools() []ResourcePool

func (*ResourcePoolJob) Marshal 

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

func (*ResourcePoolJob) MarshalTo 

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

func (*ResourcePoolJob) ProtoMessage 

func (*ResourcePoolJob) ProtoMessage()

func (*ResourcePoolJob) Reset 

func (m *ResourcePoolJob) Reset()

func (*ResourcePoolJob) Size 

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

func (*ResourcePoolJob) String 

func (m *ResourcePoolJob) String() string

func (*ResourcePoolJob) Unmarshal 

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

func (*ResourcePoolJob) XXX_DiscardUnknown 

func (m *ResourcePoolJob) XXX_DiscardUnknown()

func (*ResourcePoolJob) XXX_Marshal 

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

func (*ResourcePoolJob) XXX_Merge 

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

func (*ResourcePoolJob) XXX_Size 

func (m *ResourcePoolJob) XXX_Size() int

func (*ResourcePoolJob) XXX_Unmarshal 

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

type ResourceState 

type ResourceState int32

ResourceState the resource state 

const (
	// Running is serve state
	ResourceState_Running ResourceState = 0
	// Create is the destory state
	ResourceState_WaittingCreate ResourceState = 1
	// Removed is the destory state
	ResourceState_Removed ResourceState = 2
)

func (ResourceState) EnumDescriptor 

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

func (ResourceState) String 

func (x ResourceState) String() string

type ResourceStats 

type ResourceStats struct {
	// resource ID
	ResourceID uint64 `protobuf:"varint,1,opt,name=resourceID,proto3" json:"resourceID,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 resource
	ApproximateSize uint64 `protobuf:"varint,6,opt,name=approximateSize,proto3" json:"approximateSize,omitempty"`
	// approximate count of keys in the resource
	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:"-"`
}

ResourceStats resource stats

func (*ResourceStats) Descriptor 

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

func (*ResourceStats) GetApproximateKeys 

func (m *ResourceStats) GetApproximateKeys() uint64

func (*ResourceStats) GetApproximateSize 

func (m *ResourceStats) GetApproximateSize() uint64

func (*ResourceStats) GetInterval 

func (m *ResourceStats) GetInterval() *TimeInterval

func (*ResourceStats) GetReadBytes 

func (m *ResourceStats) GetReadBytes() uint64

func (*ResourceStats) GetReadKeys 

func (m *ResourceStats) GetReadKeys() uint64

func (*ResourceStats) GetResourceID 

func (m *ResourceStats) GetResourceID() uint64

func (*ResourceStats) GetWrittenBytes 

func (m *ResourceStats) GetWrittenBytes() uint64

func (*ResourceStats) GetWrittenKeys 

func (m *ResourceStats) GetWrittenKeys() uint64

func (*ResourceStats) Marshal 

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

func (*ResourceStats) MarshalTo 

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

func (*ResourceStats) ProtoMessage 

func (*ResourceStats) ProtoMessage()

func (*ResourceStats) Reset 

func (m *ResourceStats) Reset()

func (*ResourceStats) Size 

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

func (*ResourceStats) String 

func (m *ResourceStats) String() string

func (*ResourceStats) Unmarshal 

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

func (*ResourceStats) XXX_DiscardUnknown 

func (m *ResourceStats) XXX_DiscardUnknown()

func (*ResourceStats) XXX_Marshal 

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

func (*ResourceStats) XXX_Merge 

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

func (*ResourceStats) XXX_Size 

func (m *ResourceStats) XXX_Size() int

func (*ResourceStats) XXX_Unmarshal 

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