worker

Documentation

Index

• Variables
• type Worker
  • func (*Worker) Descriptor() ([]byte, []int)
  • func (x *Worker) GetAbility() *WorkerAbility
  • func (x *Worker) GetId() string
  • func (x *Worker) GetMetadata() *WorkerMetadata
  • func (x *Worker) GetState() WorkerState
  • func (*Worker) ProtoMessage()
  • func (x *Worker) ProtoReflect() protoreflect.Message
  • func (x *Worker) Reset()
  • func (x *Worker) String() string
• type WorkerAbility
  • func (*WorkerAbility) Descriptor() ([]byte, []int)
  • func (x *WorkerAbility) GetTaskDescription() string
  • func (x *WorkerAbility) GetTaskType() string
  • func (*WorkerAbility) ProtoMessage()
  • func (x *WorkerAbility) ProtoReflect() protoreflect.Message
  • func (x *WorkerAbility) Reset()
  • func (x *WorkerAbility) String() string
• type WorkerMetadata
  • func (*WorkerMetadata) Descriptor() ([]byte, []int)
  • func (x *WorkerMetadata) GetCpuUsage() float32
  • func (x *WorkerMetadata) GetIp() string
  • func (x *WorkerMetadata) GetMemUsage() float32
  • func (*WorkerMetadata) ProtoMessage()
  • func (x *WorkerMetadata) ProtoReflect() protoreflect.Message
  • func (x *WorkerMetadata) Reset()
  • func (x *WorkerMetadata) String() string
• type WorkerState
  • func (WorkerState) Descriptor() protoreflect.EnumDescriptor
  • func (x WorkerState) Enum() *WorkerState
  • func (WorkerState) EnumDescriptor() ([]byte, []int)
  • func (x WorkerState) Number() protoreflect.EnumNumber
  • func (x WorkerState) String() string
  • func (WorkerState) Type() protoreflect.EnumType

Variables

var (
	WorkerState_name = map[int32]string{
		0: "WORKER_STATE_UNKNOWN",
		1: "WORKER_STATE_READY",
		2: "WORKER_STATE_BUSY",
		3: "WORKER_STATE_ERROR",
	}
	WorkerState_value = map[string]int32{
		"WORKER_STATE_UNKNOWN": 0,
		"WORKER_STATE_READY":   1,
		"WORKER_STATE_BUSY":    2,
		"WORKER_STATE_ERROR":   3,
	}
)

Enum value maps for WorkerState.

var File_worker_v1_worker_proto protoreflect.FileDescriptor

Types

type Worker

type Worker struct {

	// worker id 可选
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// worker能力描述
	Ability *WorkerAbility `protobuf:"bytes,2,opt,name=ability,proto3" json:"ability,omitempty"`
	// worker状态
	Metadata *WorkerMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	State    WorkerState     `protobuf:"varint,4,opt,name=state,proto3,enum=conductor.api.worker.v1.WorkerState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*Worker) Descriptor

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

Deprecated: Use Worker.ProtoReflect.Descriptor instead.

func (*Worker) GetAbility

func (x *Worker) GetAbility() *WorkerAbility

func (*Worker) GetId

func (x *Worker) GetId() string

func (*Worker) GetMetadata

func (x *Worker) GetMetadata() *WorkerMetadata

func (*Worker) GetState

func (x *Worker) GetState() WorkerState

func (*Worker) ProtoMessage

func (*Worker) ProtoMessage()

func (*Worker) ProtoReflect

func (x *Worker) ProtoReflect() protoreflect.Message

func (*Worker) Reset

func (x *Worker) Reset()

func (*Worker) String

func (x *Worker) String() string

type WorkerAbility

type WorkerAbility struct {

	// worker提供的服务类型名
	TaskType string `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// worker提供的服务描述 可选
	TaskDescription string `protobuf:"bytes,2,opt,name=task_description,json=taskDescription,proto3" json:"task_description,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerAbility) Descriptor

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

Deprecated: Use WorkerAbility.ProtoReflect.Descriptor instead.

func (*WorkerAbility) GetTaskDescription

func (x *WorkerAbility) GetTaskDescription() string

func (*WorkerAbility) GetTaskType

func (x *WorkerAbility) GetTaskType() string

func (*WorkerAbility) ProtoMessage

func (*WorkerAbility) ProtoMessage()

func (*WorkerAbility) ProtoReflect

func (x *WorkerAbility) ProtoReflect() protoreflect.Message

func (*WorkerAbility) Reset

func (x *WorkerAbility) Reset()

func (*WorkerAbility) String

func (x *WorkerAbility) String() string

type WorkerMetadata

type WorkerMetadata struct {
	Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	// 当前cpu使用率
	CpuUsage float32 `protobuf:"fixed32,2,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`
	// 当前内存使用率
	MemUsage float32 `protobuf:"fixed32,3,opt,name=mem_usage,json=memUsage,proto3" json:"mem_usage,omitempty"`
	// contains filtered or unexported fields
}

worker 元数据

func (*WorkerMetadata) Descriptor

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

Deprecated: Use WorkerMetadata.ProtoReflect.Descriptor instead.

func (*WorkerMetadata) GetCpuUsage

func (x *WorkerMetadata) GetCpuUsage() float32

func (*WorkerMetadata) GetIp

func (x *WorkerMetadata) GetIp() string

func (*WorkerMetadata) GetMemUsage

func (x *WorkerMetadata) GetMemUsage() float32

func (*WorkerMetadata) ProtoMessage

func (*WorkerMetadata) ProtoMessage()

func (*WorkerMetadata) ProtoReflect

func (x *WorkerMetadata) ProtoReflect() protoreflect.Message

func (*WorkerMetadata) Reset

func (x *WorkerMetadata) Reset()

func (*WorkerMetadata) String

func (x *WorkerMetadata) String() string

type WorkerState

type WorkerState int32

const (
	WorkerState_WORKER_STATE_UNKNOWN WorkerState = 0
	WorkerState_WORKER_STATE_READY   WorkerState = 1
	WorkerState_WORKER_STATE_BUSY    WorkerState = 2
	WorkerState_WORKER_STATE_ERROR   WorkerState = 3
)

func (WorkerState) Descriptor

func (WorkerState) Descriptor() protoreflect.EnumDescriptor

func (WorkerState) Enum

func (x WorkerState) Enum() *WorkerState

func (WorkerState) EnumDescriptor

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

Deprecated: Use WorkerState.Descriptor instead.

func (WorkerState) Number

func (x WorkerState) Number() protoreflect.EnumNumber

func (WorkerState) String

func (x WorkerState) String() string

func (WorkerState) Type

func (WorkerState) Type() protoreflect.EnumType