metapb

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2022 License: Apache-2.0 Imports: 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 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",
	4: "ScalePeer",
}
View Source 
var ConfigChangeType_value = map[string]int32{
	"AddNode":        0,
	"RemoveNode":     1,
	"UpdateNode":     2,
	"AddLearnerNode": 3,
	"ScalePeer":      4,
}
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 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 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: "Creating",
	2: "Destroying",
	3: "Destroyed",
}
View Source 
var ResourceState_value = map[string]int32{
	"Running":    0,
	"Creating":   1,
	"Destroying": 2,
	"Destroyed":  3,
}

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 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"`
	MaxReplicaCount      uint32   `protobuf:"varint,2,opt,name=maxReplicaCount,proto3" json:"maxReplicaCount,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) GetMaxReplicaCount added in v0.2.0 

func (m *Cluster) GetMaxReplicaCount() 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 ConfigChangeType added in v0.2.0 

type ConfigChangeType int32

ConfigChangeType change replica type 

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

func (ConfigChangeType) EnumDescriptor added in v0.2.0 

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

func (ConfigChangeType) String added in v0.2.0 

func (x ConfigChangeType) String() string

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 destroy 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 DestroyingStatus added in v0.2.0 

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                ResourceState   `protobuf:"varint,3,opt,name=state,proto3,enum=metapb.ResourceState" 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 added in v0.2.0 

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

func (*DestroyingStatus) GetIndex added in v0.2.0 

func (m *DestroyingStatus) GetIndex() uint64

func (*DestroyingStatus) GetRemoveData added in v0.2.0 

func (m *DestroyingStatus) GetRemoveData() bool

func (*DestroyingStatus) GetReplicas added in v0.2.0 

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

func (*DestroyingStatus) GetState added in v0.2.0 

func (m *DestroyingStatus) GetState() ResourceState

func (*DestroyingStatus) Marshal added in v0.2.0 

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

func (*DestroyingStatus) MarshalTo added in v0.2.0 

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

func (*DestroyingStatus) ProtoMessage added in v0.2.0 

func (*DestroyingStatus) ProtoMessage()

func (*DestroyingStatus) Reset added in v0.2.0 

func (m *DestroyingStatus) Reset()

func (*DestroyingStatus) Size added in v0.2.0 

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

func (*DestroyingStatus) String added in v0.2.0 

func (m *DestroyingStatus) String() string

func (*DestroyingStatus) Unmarshal added in v0.2.0 

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

func (*DestroyingStatus) XXX_DiscardUnknown added in v0.2.0 

func (m *DestroyingStatus) XXX_DiscardUnknown()

func (*DestroyingStatus) XXX_Marshal added in v0.2.0 

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

func (*DestroyingStatus) XXX_Merge added in v0.2.0 

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

func (*DestroyingStatus) XXX_Size added in v0.2.0 

func (m *DestroyingStatus) XXX_Size() int

func (*DestroyingStatus) XXX_Unmarshal added in v0.2.0 

func (m *DestroyingStatus) 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 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"`
	Replicass            []Replica `protobuf:"bytes,2,rep,name=replicass,proto3" json:"replicass"`
	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) GetReplicass added in v0.2.0 

func (m *RemoveResourceJob) GetReplicass() []Replica

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 Replica added in v0.2.0 

type Replica 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                 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 resource

func (*Replica) Descriptor added in v0.2.0 

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

func (*Replica) GetContainerID added in v0.2.0 

func (m *Replica) GetContainerID() uint64

func (*Replica) GetID added in v0.2.0 

func (m *Replica) GetID() uint64

func (*Replica) GetInitialMember added in v0.2.0 

func (m *Replica) GetInitialMember() bool

func (*Replica) GetRole added in v0.2.0 

func (m *Replica) GetRole() ReplicaRole

func (*Replica) Marshal added in v0.2.0 

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

func (*Replica) MarshalTo added in v0.2.0 

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

func (*Replica) ProtoMessage added in v0.2.0 

func (*Replica) ProtoMessage()

func (*Replica) Reset added in v0.2.0 

func (m *Replica) Reset()

func (*Replica) Size added in v0.2.0 

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

func (*Replica) String added in v0.2.0 

func (m *Replica) String() string

func (*Replica) Unmarshal added in v0.2.0 

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

func (*Replica) XXX_DiscardUnknown added in v0.2.0 

func (m *Replica) XXX_DiscardUnknown()

func (*Replica) XXX_Marshal added in v0.2.0 

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

func (*Replica) XXX_Merge added in v0.2.0 

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

func (*Replica) XXX_Size added in v0.2.0 

func (m *Replica) XXX_Size() int

func (*Replica) XXX_Unmarshal added in v0.2.0 

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

type ReplicaRole added in v0.2.0 

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 added in v0.2.0 

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

func (ReplicaRole) String added in v0.2.0 

func (x ReplicaRole) String() string

type ReplicaStats added in v0.2.0 

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 added in v0.2.0 

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

func (*ReplicaStats) GetDownSeconds added in v0.2.0 

func (m *ReplicaStats) GetDownSeconds() uint64

func (*ReplicaStats) GetReplica added in v0.2.0 

func (m *ReplicaStats) GetReplica() Replica

func (*ReplicaStats) Marshal added in v0.2.0 

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

func (*ReplicaStats) MarshalTo added in v0.2.0 

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

func (*ReplicaStats) ProtoMessage added in v0.2.0 

func (*ReplicaStats) ProtoMessage()

func (*ReplicaStats) Reset added in v0.2.0 

func (m *ReplicaStats) Reset()

func (*ReplicaStats) Size added in v0.2.0 

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

func (*ReplicaStats) String added in v0.2.0 

func (m *ReplicaStats) String() string

func (*ReplicaStats) Unmarshal added in v0.2.0 

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

func (*ReplicaStats) XXX_DiscardUnknown added in v0.2.0 

func (m *ReplicaStats) XXX_DiscardUnknown()

func (*ReplicaStats) XXX_Marshal added in v0.2.0 

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

func (*ReplicaStats) XXX_Merge added in v0.2.0 

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

func (*ReplicaStats) XXX_Size added in v0.2.0 

func (m *ReplicaStats) XXX_Size() int

func (*ReplicaStats) XXX_Unmarshal added in v0.2.0 

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

type ResourceEpoch 

type ResourceEpoch struct {
	// Conf change version, auto increment when add or remove replica
	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 ResourceExtra added in v0.2.0 

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

ResourceExtra resource extra

func (*ResourceExtra) Descriptor added in v0.2.0 

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

func (*ResourceExtra) GetDestroyingStatus added in v0.2.0 

func (m *ResourceExtra) GetDestroyingStatus() *DestroyingStatus

func (*ResourceExtra) GetLabels added in v0.2.0 

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

func (*ResourceExtra) Marshal added in v0.2.0 

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

func (*ResourceExtra) MarshalTo added in v0.2.0 

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

func (*ResourceExtra) ProtoMessage added in v0.2.0 

func (*ResourceExtra) ProtoMessage()

func (*ResourceExtra) Reset added in v0.2.0 

func (m *ResourceExtra) Reset()

func (*ResourceExtra) Size added in v0.2.0 

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

func (*ResourceExtra) String added in v0.2.0 

func (m *ResourceExtra) String() string

func (*ResourceExtra) Unmarshal added in v0.2.0 

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

func (*ResourceExtra) XXX_DiscardUnknown added in v0.2.0 

func (m *ResourceExtra) XXX_DiscardUnknown()

func (*ResourceExtra) XXX_Marshal added in v0.2.0 

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

func (*ResourceExtra) XXX_Merge added in v0.2.0 

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

func (*ResourceExtra) XXX_Size added in v0.2.0 

func (m *ResourceExtra) XXX_Size() int

func (*ResourceExtra) XXX_Unmarshal added in v0.2.0 

func (m *ResourceExtra) 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,
	// this state provides read and write services to the public normally.
	ResourceState_Running ResourceState = 0
	// Creating is waiting to create state,
	// this state does not provide read and write services to the public.
	ResourceState_Creating ResourceState = 1
	// Destroying is waiting to destroy state,
	// this state normally cannot provide read and write services to the public,
	// and the destruction process of resources has not yet been completed.
	ResourceState_Destroying ResourceState = 2
	// Destroyed is the destroyed state,
	// this state is normally not available for external read and write services,
	// the resources have been destroyed in the whole cluster and cannot be used again.
	ResourceState_Destroyed ResourceState = 3
)

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 ScheduleGroupRule added in v0.2.0 

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 added in v0.2.0 

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

func (*ScheduleGroupRule) GetGroupByLabel added in v0.2.0 

func (m *ScheduleGroupRule) GetGroupByLabel() string

func (*ScheduleGroupRule) GetGroupID added in v0.2.0 

func (m *ScheduleGroupRule) GetGroupID() uint64

func (*ScheduleGroupRule) GetID added in v0.2.0 

func (m *ScheduleGroupRule) GetID() uint64

func (*ScheduleGroupRule) GetName added in v0.2.0 

func (m *ScheduleGroupRule) GetName() string

func (*ScheduleGroupRule) Marshal added in v0.2.0 

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

func (*ScheduleGroupRule) MarshalTo added in v0.2.0 

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

func (*ScheduleGroupRule) ProtoMessage added in v0.2.0 

func (*ScheduleGroupRule) ProtoMessage()

func (*ScheduleGroupRule) Reset added in v0.2.0 

func (m *ScheduleGroupRule) Reset()

func (*ScheduleGroupRule) Size added in v0.2.0 

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

func (*ScheduleGroupRule) String added in v0.2.0 

func (m *ScheduleGroupRule) String() string

func (*ScheduleGroupRule) Unmarshal added in v0.2.0 

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

func (*ScheduleGroupRule) XXX_DiscardUnknown added in v0.2.0 

func (m *ScheduleGroupRule) XXX_DiscardUnknown()

func (*ScheduleGroupRule) XXX_Marshal added in v0.2.0 

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

func (*ScheduleGroupRule) XXX_Merge added in v0.2.0 

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

func (*ScheduleGroupRule) XXX_Size added in v0.2.0 

func (m *ScheduleGroupRule) XXX_Size() int

func (*ScheduleGroupRule) XXX_Unmarshal added in v0.2.0 

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