proto

package
v0.18.0 Latest Latest
Warning

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

Go to latest
Published: May 24, 2025 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

View Source
const (
	WorkflowService_GetAction_FullMethodName          = "/proto.WorkflowService/GetAction"
	WorkflowService_ReportActionStatus_FullMethodName = "/proto.WorkflowService/ReportActionStatus"
)

Variables

View Source
var (
	PreconditionFailureViolation_name = map[int32]string{
		0: "PRECONDITION_FAILURE_VIOLATION_UNSPECIFIED",
		1: "PRECONDITION_FAILURE_VIOLATION_NO_ACTION_AVAILABLE",
	}
	PreconditionFailureViolation_value = map[string]int32{
		"PRECONDITION_FAILURE_VIOLATION_UNSPECIFIED":         0,
		"PRECONDITION_FAILURE_VIOLATION_NO_ACTION_AVAILABLE": 1,
	}
)

Enum value maps for PreconditionFailureViolation.

View Source
var (
	ActionStatusRequest_StateType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "PENDING",
		2: "RUNNING",
		3: "FAILED",
		4: "TIMEOUT",
		5: "SUCCESS",
	}
	ActionStatusRequest_StateType_value = map[string]int32{
		"UNSPECIFIED": 0,
		"PENDING":     1,
		"RUNNING":     2,
		"FAILED":      3,
		"TIMEOUT":     4,
		"SUCCESS":     5,
	}
)

Enum value maps for ActionStatusRequest_StateType.

View Source
var File_get_action_request_proto protoreflect.FileDescriptor
View Source
var File_get_action_response_proto protoreflect.FileDescriptor
View Source
var File_report_action_status_request_proto protoreflect.FileDescriptor
View Source
var File_report_action_status_response_proto protoreflect.FileDescriptor
View Source
var File_workflow_service_proto protoreflect.FileDescriptor
View Source
var WorkflowService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.WorkflowService",
	HandlerType: (*WorkflowServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAction",
			Handler:    _WorkflowService_GetAction_Handler,
		},
		{
			MethodName: "ReportActionStatus",
			Handler:    _WorkflowService_ReportActionStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "workflow_service.proto",
}

WorkflowService_ServiceDesc is the grpc.ServiceDesc for WorkflowService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWorkflowServiceServer

func RegisterWorkflowServiceServer(s grpc.ServiceRegistrar, srv WorkflowServiceServer)

Types

type ActionMessage

type ActionMessage struct {

	// Message is the human readable message that can be used to describe the status of the action
	Message *string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	// contains filtered or unexported fields
}

ActionMessage to report the status of a single action, it's an object so it can be extended

func (*ActionMessage) Descriptor deprecated

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

Deprecated: Use ActionMessage.ProtoReflect.Descriptor instead.

func (*ActionMessage) GetMessage

func (x *ActionMessage) GetMessage() string

func (*ActionMessage) ProtoMessage

func (*ActionMessage) ProtoMessage()

func (*ActionMessage) ProtoReflect

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

func (*ActionMessage) Reset

func (x *ActionMessage) Reset()

func (*ActionMessage) String

func (x *ActionMessage) String() string

type ActionRequest

type ActionRequest struct {

	// The ID of the Agent that is requesting the action
	AgentId *string `protobuf:"bytes,1,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	// Attributes of the Agent, this enables more sophisticated server-side Workflow selection and creation capabilities
	AgentAttributes *AgentAttributes `protobuf:"bytes,2,opt,name=agent_attributes,json=agentAttributes" json:"agent_attributes,omitempty"`
	// contains filtered or unexported fields
}

ActionRequest

func (*ActionRequest) Descriptor deprecated

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

Deprecated: Use ActionRequest.ProtoReflect.Descriptor instead.

func (*ActionRequest) GetAgentAttributes added in v0.18.0

func (x *ActionRequest) GetAgentAttributes() *AgentAttributes

func (*ActionRequest) GetAgentId added in v0.18.0

func (x *ActionRequest) GetAgentId() string

func (*ActionRequest) ProtoMessage

func (*ActionRequest) ProtoMessage()

func (*ActionRequest) ProtoReflect

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

func (*ActionRequest) Reset

func (x *ActionRequest) Reset()

func (*ActionRequest) String

func (x *ActionRequest) String() string

type ActionResponse

type ActionResponse struct {

	// The workflow id
	WorkflowId *string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId" json:"workflow_id,omitempty"`
	// The name of the task to which the action belongs
	TaskId *string `protobuf:"bytes,2,opt,name=task_id,json=taskId" json:"task_id,omitempty"`
	// agent_id is the id of the worker that is executing the action
	AgentId *string `protobuf:"bytes,3,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	// Action id
	ActionId *string `protobuf:"bytes,4,opt,name=action_id,json=actionId" json:"action_id,omitempty"`
	// The name of the action
	Name *string `protobuf:"bytes,5,opt,name=name" json:"name,omitempty"`
	// The docker/oci image the action starts from
	Image *string `protobuf:"bytes,6,opt,name=image" json:"image,omitempty"`
	// Every action has a timeout, after that the execution stops and the action
	// gets in a timeout state.
	Timeout *int64 `protobuf:"varint,7,opt,name=timeout" json:"timeout,omitempty"`
	// You can override the command executed for the container
	Command []string `protobuf:"bytes,8,rep,name=command" json:"command,omitempty"`
	// You can mount directory from your host to the running action, mainly to
	// share files, or state
	Volumes []string `protobuf:"bytes,9,rep,name=volumes" json:"volumes,omitempty"`
	// Set environment variables usable from the action itself.
	Environment []string `protobuf:"bytes,10,rep,name=environment" json:"environment,omitempty"`
	// Set the namespace that the process IDs will be in.
	Pid *string `protobuf:"bytes,11,opt,name=pid" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

ActionResponse

func (*ActionResponse) Descriptor deprecated

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

Deprecated: Use ActionResponse.ProtoReflect.Descriptor instead.

func (*ActionResponse) GetActionId

func (x *ActionResponse) GetActionId() string

func (*ActionResponse) GetAgentId added in v0.18.0

func (x *ActionResponse) GetAgentId() string

func (*ActionResponse) GetCommand

func (x *ActionResponse) GetCommand() []string

func (*ActionResponse) GetEnvironment

func (x *ActionResponse) GetEnvironment() []string

func (*ActionResponse) GetImage

func (x *ActionResponse) GetImage() string

func (*ActionResponse) GetName

func (x *ActionResponse) GetName() string

func (*ActionResponse) GetPid

func (x *ActionResponse) GetPid() string

func (*ActionResponse) GetTaskId

func (x *ActionResponse) GetTaskId() string

func (*ActionResponse) GetTimeout

func (x *ActionResponse) GetTimeout() int64

func (*ActionResponse) GetVolumes

func (x *ActionResponse) GetVolumes() []string

func (*ActionResponse) GetWorkflowId

func (x *ActionResponse) GetWorkflowId() string

func (*ActionResponse) ProtoMessage

func (*ActionResponse) ProtoMessage()

func (*ActionResponse) ProtoReflect

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

func (*ActionResponse) Reset

func (x *ActionResponse) Reset()

func (*ActionResponse) String

func (x *ActionResponse) String() string

type ActionStatusRequest

type ActionStatusRequest struct {

	// The workflow id
	WorkflowId *string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId" json:"workflow_id,omitempty"`
	// The agent id
	AgentId *string `protobuf:"bytes,2,opt,name=agent_id,json=agentId" json:"agent_id,omitempty"`
	// The name of the task this action is part of
	TaskId *string `protobuf:"bytes,3,opt,name=task_id,json=taskId" json:"task_id,omitempty"`
	// The action id
	ActionId *string `protobuf:"bytes,4,opt,name=action_id,json=actionId" json:"action_id,omitempty"`
	// The name of the action
	ActionName *string `protobuf:"bytes,5,opt,name=action_name,json=actionName" json:"action_name,omitempty"`
	// The state of the action. Those are the same described for workflow as
	// well. pending, running, successful and so on.
	ActionState *ActionStatusRequest_StateType `` /* 129-byte string literal not displayed */
	// This is the time when the action started the execution
	ExecutionStart *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=execution_start,json=executionStart" json:"execution_start,omitempty"`
	// This is the time when the action stopped the execution
	ExecutionStop *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=execution_stop,json=executionStop" json:"execution_stop,omitempty"`
	// The execution duration time for the action
	ExecutionDuration *string `protobuf:"bytes,9,opt,name=execution_duration,json=executionDuration" json:"execution_duration,omitempty"`
	// The message returned from the action.
	Message *ActionMessage `protobuf:"bytes,10,opt,name=message" json:"message,omitempty"`
	// contains filtered or unexported fields
}

ActionStatusRequest is the state of a single Workflow Action

func (*ActionStatusRequest) Descriptor deprecated

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

Deprecated: Use ActionStatusRequest.ProtoReflect.Descriptor instead.

func (*ActionStatusRequest) GetActionId

func (x *ActionStatusRequest) GetActionId() string

func (*ActionStatusRequest) GetActionName

func (x *ActionStatusRequest) GetActionName() string

func (*ActionStatusRequest) GetActionState

func (*ActionStatusRequest) GetAgentId added in v0.18.0

func (x *ActionStatusRequest) GetAgentId() string

func (*ActionStatusRequest) GetExecutionDuration

func (x *ActionStatusRequest) GetExecutionDuration() string

func (*ActionStatusRequest) GetExecutionStart

func (x *ActionStatusRequest) GetExecutionStart() *timestamppb.Timestamp

func (*ActionStatusRequest) GetExecutionStop

func (x *ActionStatusRequest) GetExecutionStop() *timestamppb.Timestamp

func (*ActionStatusRequest) GetMessage

func (x *ActionStatusRequest) GetMessage() *ActionMessage

func (*ActionStatusRequest) GetTaskId

func (x *ActionStatusRequest) GetTaskId() string

func (*ActionStatusRequest) GetWorkflowId

func (x *ActionStatusRequest) GetWorkflowId() string

func (*ActionStatusRequest) ProtoMessage

func (*ActionStatusRequest) ProtoMessage()

func (*ActionStatusRequest) ProtoReflect

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

func (*ActionStatusRequest) Reset

func (x *ActionStatusRequest) Reset()

func (*ActionStatusRequest) String

func (x *ActionStatusRequest) String() string

type ActionStatusRequest_StateType added in v0.18.0

type ActionStatusRequest_StateType int32

The various state a workflow can be

const (
	// Unspecified is the default state of a workflow. It means that the state of
	// the workflow is not known.
	ActionStatusRequest_UNSPECIFIED ActionStatusRequest_StateType = 0
	// A workflow is in pending state when it is waiting for the hardware to pick
	// it up and start the execution.
	ActionStatusRequest_PENDING ActionStatusRequest_StateType = 1
	// A workflow is in a running state when the Agent started the
	// execution of it, and it is currently in execution inside the device
	// itself.
	ActionStatusRequest_RUNNING ActionStatusRequest_StateType = 2
	// Failed is a final state. Something wrong happened during the execution of
	// the workflow inside the target. Have a look at the logs to see if you can
	// spot what is going on.
	ActionStatusRequest_FAILED ActionStatusRequest_StateType = 3
	// Timeout is final state, almost like FAILED but it communicate to you that
	// an action or the overall workflow reached the specified timeout.
	ActionStatusRequest_TIMEOUT ActionStatusRequest_StateType = 4
	// This is the state we all deserve. The execution of the workflow is over
	// and everything is just fine. Sit down, and enjoy your great work.
	ActionStatusRequest_SUCCESS ActionStatusRequest_StateType = 5
)

func (ActionStatusRequest_StateType) Descriptor added in v0.18.0

func (ActionStatusRequest_StateType) Enum added in v0.18.0

func (ActionStatusRequest_StateType) EnumDescriptor deprecated added in v0.18.0

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

Deprecated: Use ActionStatusRequest_StateType.Descriptor instead.

func (ActionStatusRequest_StateType) Number added in v0.18.0

func (ActionStatusRequest_StateType) String added in v0.18.0

func (ActionStatusRequest_StateType) Type added in v0.18.0

type ActionStatusResponse

type ActionStatusResponse struct {
	// contains filtered or unexported fields
}

func (*ActionStatusResponse) Descriptor deprecated

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

Deprecated: Use ActionStatusResponse.ProtoReflect.Descriptor instead.

func (*ActionStatusResponse) ProtoMessage

func (*ActionStatusResponse) ProtoMessage()

func (*ActionStatusResponse) ProtoReflect

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

func (*ActionStatusResponse) Reset

func (x *ActionStatusResponse) Reset()

func (*ActionStatusResponse) String

func (x *ActionStatusResponse) String() string

type AgentAttributes added in v0.18.0

type AgentAttributes struct {
	Cpu       *CPU       `protobuf:"bytes,1,opt,name=cpu" json:"cpu,omitempty"`
	Memory    *Memory    `protobuf:"bytes,2,opt,name=memory" json:"memory,omitempty"`
	Block     []*Block   `protobuf:"bytes,3,rep,name=block" json:"block,omitempty"`
	Network   []*Network `protobuf:"bytes,4,rep,name=network" json:"network,omitempty"`
	Pci       []*PCI     `protobuf:"bytes,5,rep,name=pci" json:"pci,omitempty"`
	Gpu       []*GPU     `protobuf:"bytes,6,rep,name=gpu" json:"gpu,omitempty"`
	Chassis   *Chassis   `protobuf:"bytes,7,opt,name=chassis" json:"chassis,omitempty"`
	Bios      *BIOS      `protobuf:"bytes,8,opt,name=bios" json:"bios,omitempty"`
	Baseboard *Baseboard `protobuf:"bytes,9,opt,name=baseboard" json:"baseboard,omitempty"`
	Product   *Product   `protobuf:"bytes,10,opt,name=product" json:"product,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentAttributes) Descriptor deprecated added in v0.18.0

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

Deprecated: Use AgentAttributes.ProtoReflect.Descriptor instead.

func (*AgentAttributes) GetBaseboard added in v0.18.0

func (x *AgentAttributes) GetBaseboard() *Baseboard

func (*AgentAttributes) GetBios added in v0.18.0

func (x *AgentAttributes) GetBios() *BIOS

func (*AgentAttributes) GetBlock added in v0.18.0

func (x *AgentAttributes) GetBlock() []*Block

func (*AgentAttributes) GetChassis added in v0.18.0

func (x *AgentAttributes) GetChassis() *Chassis

func (*AgentAttributes) GetCpu added in v0.18.0

func (x *AgentAttributes) GetCpu() *CPU

func (*AgentAttributes) GetGpu added in v0.18.0

func (x *AgentAttributes) GetGpu() []*GPU

func (*AgentAttributes) GetMemory added in v0.18.0

func (x *AgentAttributes) GetMemory() *Memory

func (*AgentAttributes) GetNetwork added in v0.18.0

func (x *AgentAttributes) GetNetwork() []*Network

func (*AgentAttributes) GetPci added in v0.18.0

func (x *AgentAttributes) GetPci() []*PCI

func (*AgentAttributes) GetProduct added in v0.18.0

func (x *AgentAttributes) GetProduct() *Product

func (*AgentAttributes) ProtoMessage added in v0.18.0

func (*AgentAttributes) ProtoMessage()

func (*AgentAttributes) ProtoReflect added in v0.18.0

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

func (*AgentAttributes) Reset added in v0.18.0

func (x *AgentAttributes) Reset()

func (*AgentAttributes) String added in v0.18.0

func (x *AgentAttributes) String() string

type BIOS

type BIOS struct {
	Vendor      *string `protobuf:"bytes,1,opt,name=vendor" json:"vendor,omitempty"`
	Version     *string `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
	ReleaseDate *string `protobuf:"bytes,3,opt,name=release_date,json=releaseDate" json:"release_date,omitempty"`
	// contains filtered or unexported fields
}

func (*BIOS) Descriptor deprecated

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

Deprecated: Use BIOS.ProtoReflect.Descriptor instead.

func (*BIOS) GetReleaseDate

func (x *BIOS) GetReleaseDate() string

func (*BIOS) GetVendor

func (x *BIOS) GetVendor() string

func (*BIOS) GetVersion

func (x *BIOS) GetVersion() string

func (*BIOS) ProtoMessage

func (*BIOS) ProtoMessage()

func (*BIOS) ProtoReflect

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

func (*BIOS) Reset

func (x *BIOS) Reset()

func (*BIOS) String

func (x *BIOS) String() string

type Baseboard

type Baseboard struct {
	Vendor       *string `protobuf:"bytes,1,opt,name=vendor" json:"vendor,omitempty"`
	Product      *string `protobuf:"bytes,2,opt,name=product" json:"product,omitempty"`
	Version      *string `protobuf:"bytes,3,opt,name=version" json:"version,omitempty"`
	SerialNumber *string `protobuf:"bytes,4,opt,name=serial_number,json=serialNumber" json:"serial_number,omitempty"`
	// contains filtered or unexported fields
}

func (*Baseboard) Descriptor deprecated

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

Deprecated: Use Baseboard.ProtoReflect.Descriptor instead.

func (*Baseboard) GetProduct

func (x *Baseboard) GetProduct() string

func (*Baseboard) GetSerialNumber added in v0.18.0

func (x *Baseboard) GetSerialNumber() string

func (*Baseboard) GetVendor

func (x *Baseboard) GetVendor() string

func (*Baseboard) GetVersion

func (x *Baseboard) GetVersion() string

func (*Baseboard) ProtoMessage

func (*Baseboard) ProtoMessage()

func (*Baseboard) ProtoReflect

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

func (*Baseboard) Reset

func (x *Baseboard) Reset()

func (*Baseboard) String

func (x *Baseboard) String() string

type Block

type Block struct {
	Name              *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	ControllerType    *string `protobuf:"bytes,2,opt,name=controller_type,json=controllerType" json:"controller_type,omitempty"`
	DriveType         *string `protobuf:"bytes,3,opt,name=drive_type,json=driveType" json:"drive_type,omitempty"`
	Size              *string `protobuf:"bytes,4,opt,name=size" json:"size,omitempty"`
	PhysicalBlockSize *string `protobuf:"bytes,5,opt,name=physical_block_size,json=physicalBlockSize" json:"physical_block_size,omitempty"`
	Vendor            *string `protobuf:"bytes,6,opt,name=vendor" json:"vendor,omitempty"`
	Model             *string `protobuf:"bytes,7,opt,name=model" json:"model,omitempty"`
	// contains filtered or unexported fields
}

func (*Block) Descriptor deprecated

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

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetControllerType

func (x *Block) GetControllerType() string

func (*Block) GetDriveType

func (x *Block) GetDriveType() string

func (*Block) GetModel

func (x *Block) GetModel() string

func (*Block) GetName

func (x *Block) GetName() string

func (*Block) GetPhysicalBlockSize

func (x *Block) GetPhysicalBlockSize() string

func (*Block) GetSize

func (x *Block) GetSize() string

func (*Block) GetVendor

func (x *Block) GetVendor() string

func (*Block) ProtoMessage

func (*Block) ProtoMessage()

func (*Block) ProtoReflect

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

func (*Block) Reset

func (x *Block) Reset()

func (*Block) String

func (x *Block) String() string

type CPU

type CPU struct {
	TotalCores   *uint32      `protobuf:"varint,1,opt,name=total_cores,json=totalCores" json:"total_cores,omitempty"`
	TotalThreads *uint32      `protobuf:"varint,2,opt,name=total_threads,json=totalThreads" json:"total_threads,omitempty"`
	Processors   []*Processor `protobuf:"bytes,3,rep,name=processors" json:"processors,omitempty"`
	// contains filtered or unexported fields
}

func (*CPU) Descriptor deprecated

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

Deprecated: Use CPU.ProtoReflect.Descriptor instead.

func (*CPU) GetProcessors

func (x *CPU) GetProcessors() []*Processor

func (*CPU) GetTotalCores

func (x *CPU) GetTotalCores() uint32

func (*CPU) GetTotalThreads

func (x *CPU) GetTotalThreads() uint32

func (*CPU) ProtoMessage

func (*CPU) ProtoMessage()

func (*CPU) ProtoReflect

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

func (*CPU) Reset

func (x *CPU) Reset()

func (*CPU) String

func (x *CPU) String() string

type Chassis

type Chassis struct {
	Serial *string `protobuf:"bytes,1,opt,name=serial" json:"serial,omitempty"`
	Vendor *string `protobuf:"bytes,2,opt,name=vendor" json:"vendor,omitempty"`
	// contains filtered or unexported fields
}

func (*Chassis) Descriptor deprecated

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

Deprecated: Use Chassis.ProtoReflect.Descriptor instead.

func (*Chassis) GetSerial

func (x *Chassis) GetSerial() string

func (*Chassis) GetVendor

func (x *Chassis) GetVendor() string

func (*Chassis) ProtoMessage

func (*Chassis) ProtoMessage()

func (*Chassis) ProtoReflect

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

func (*Chassis) Reset

func (x *Chassis) Reset()

func (*Chassis) String

func (x *Chassis) String() string

type GPU

type GPU struct {
	Vendor  *string `protobuf:"bytes,1,opt,name=vendor" json:"vendor,omitempty"`
	Product *string `protobuf:"bytes,2,opt,name=product" json:"product,omitempty"`
	Class   *string `protobuf:"bytes,3,opt,name=class" json:"class,omitempty"`
	Driver  *string `protobuf:"bytes,4,opt,name=driver" json:"driver,omitempty"`
	// contains filtered or unexported fields
}

func (*GPU) Descriptor deprecated

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

Deprecated: Use GPU.ProtoReflect.Descriptor instead.

func (*GPU) GetClass

func (x *GPU) GetClass() string

func (*GPU) GetDriver

func (x *GPU) GetDriver() string

func (*GPU) GetProduct

func (x *GPU) GetProduct() string

func (*GPU) GetVendor

func (x *GPU) GetVendor() string

func (*GPU) ProtoMessage

func (*GPU) ProtoMessage()

func (*GPU) ProtoReflect

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

func (*GPU) Reset

func (x *GPU) Reset()

func (*GPU) String

func (x *GPU) String() string

type Memory

type Memory struct {
	Total  *string `protobuf:"bytes,1,opt,name=total" json:"total,omitempty"`
	Usable *string `protobuf:"bytes,2,opt,name=usable" json:"usable,omitempty"`
	// contains filtered or unexported fields
}

func (*Memory) Descriptor deprecated

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

Deprecated: Use Memory.ProtoReflect.Descriptor instead.

func (*Memory) GetTotal

func (x *Memory) GetTotal() string

func (*Memory) GetUsable

func (x *Memory) GetUsable() string

func (*Memory) ProtoMessage

func (*Memory) ProtoMessage()

func (*Memory) ProtoReflect

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

func (*Memory) Reset

func (x *Memory) Reset()

func (*Memory) String

func (x *Memory) String() string

type Network

type Network struct {
	Name                *string  `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Mac                 *string  `protobuf:"bytes,2,opt,name=mac" json:"mac,omitempty"`
	Speed               *string  `protobuf:"bytes,3,opt,name=speed" json:"speed,omitempty"`
	EnabledCapabilities []string `protobuf:"bytes,4,rep,name=enabled_capabilities,json=enabledCapabilities" json:"enabled_capabilities,omitempty"`
	// contains filtered or unexported fields
}

func (*Network) Descriptor deprecated

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

Deprecated: Use Network.ProtoReflect.Descriptor instead.

func (*Network) GetEnabledCapabilities

func (x *Network) GetEnabledCapabilities() []string

func (*Network) GetMac

func (x *Network) GetMac() string

func (*Network) GetName

func (x *Network) GetName() string

func (*Network) GetSpeed

func (x *Network) GetSpeed() string

func (*Network) ProtoMessage

func (*Network) ProtoMessage()

func (*Network) ProtoReflect

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

func (*Network) Reset

func (x *Network) Reset()

func (*Network) String

func (x *Network) String() string

type PCI

type PCI struct {
	Vendor  *string `protobuf:"bytes,1,opt,name=vendor" json:"vendor,omitempty"`
	Product *string `protobuf:"bytes,2,opt,name=product" json:"product,omitempty"`
	Class   *string `protobuf:"bytes,3,opt,name=class" json:"class,omitempty"`
	Driver  *string `protobuf:"bytes,4,opt,name=driver" json:"driver,omitempty"`
	// contains filtered or unexported fields
}

func (*PCI) Descriptor deprecated

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

Deprecated: Use PCI.ProtoReflect.Descriptor instead.

func (*PCI) GetClass

func (x *PCI) GetClass() string

func (*PCI) GetDriver

func (x *PCI) GetDriver() string

func (*PCI) GetProduct

func (x *PCI) GetProduct() string

func (*PCI) GetVendor

func (x *PCI) GetVendor() string

func (*PCI) ProtoMessage

func (*PCI) ProtoMessage()

func (*PCI) ProtoReflect

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

func (*PCI) Reset

func (x *PCI) Reset()

func (*PCI) String

func (x *PCI) String() string

type PreconditionFailureViolation added in v0.18.0

type PreconditionFailureViolation int32
const (
	PreconditionFailureViolation_PRECONDITION_FAILURE_VIOLATION_UNSPECIFIED         PreconditionFailureViolation = 0
	PreconditionFailureViolation_PRECONDITION_FAILURE_VIOLATION_NO_ACTION_AVAILABLE PreconditionFailureViolation = 1
)

func (PreconditionFailureViolation) Descriptor added in v0.18.0

func (PreconditionFailureViolation) Enum added in v0.18.0

func (PreconditionFailureViolation) EnumDescriptor deprecated added in v0.18.0

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

Deprecated: Use PreconditionFailureViolation.Descriptor instead.

func (PreconditionFailureViolation) Number added in v0.18.0

func (PreconditionFailureViolation) String added in v0.18.0

func (PreconditionFailureViolation) Type added in v0.18.0

type Processor

type Processor struct {
	Id           *uint32  `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Cores        *uint32  `protobuf:"varint,2,opt,name=cores" json:"cores,omitempty"`
	Threads      *uint32  `protobuf:"varint,3,opt,name=threads" json:"threads,omitempty"`
	Vendor       *string  `protobuf:"bytes,4,opt,name=vendor" json:"vendor,omitempty"`
	Model        *string  `protobuf:"bytes,5,opt,name=model" json:"model,omitempty"`
	Capabilities []string `protobuf:"bytes,6,rep,name=capabilities" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

func (*Processor) Descriptor deprecated

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

Deprecated: Use Processor.ProtoReflect.Descriptor instead.

func (*Processor) GetCapabilities

func (x *Processor) GetCapabilities() []string

func (*Processor) GetCores

func (x *Processor) GetCores() uint32

func (*Processor) GetId

func (x *Processor) GetId() uint32

func (*Processor) GetModel

func (x *Processor) GetModel() string

func (*Processor) GetThreads

func (x *Processor) GetThreads() uint32

func (*Processor) GetVendor

func (x *Processor) GetVendor() string

func (*Processor) ProtoMessage

func (*Processor) ProtoMessage()

func (*Processor) ProtoReflect

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

func (*Processor) Reset

func (x *Processor) Reset()

func (*Processor) String

func (x *Processor) String() string

type Product

type Product struct {
	Name         *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Vendor       *string `protobuf:"bytes,2,opt,name=vendor" json:"vendor,omitempty"`
	SerialNumber *string `protobuf:"bytes,3,opt,name=serial_number,json=serialNumber" json:"serial_number,omitempty"`
	// contains filtered or unexported fields
}

func (*Product) Descriptor deprecated

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

Deprecated: Use Product.ProtoReflect.Descriptor instead.

func (*Product) GetName

func (x *Product) GetName() string

func (*Product) GetSerialNumber added in v0.18.0

func (x *Product) GetSerialNumber() string

func (*Product) GetVendor

func (x *Product) GetVendor() string

func (*Product) ProtoMessage

func (*Product) ProtoMessage()

func (*Product) ProtoReflect

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

func (*Product) Reset

func (x *Product) Reset()

func (*Product) String

func (x *Product) String() string

type UnimplementedWorkflowServiceServer

type UnimplementedWorkflowServiceServer struct{}

UnimplementedWorkflowServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedWorkflowServiceServer) GetAction

func (UnimplementedWorkflowServiceServer) ReportActionStatus

type UnsafeWorkflowServiceServer

type UnsafeWorkflowServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkflowServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkflowServiceServer will result in compilation errors.

type WorkflowServiceClient

type WorkflowServiceClient interface {
	GetAction(ctx context.Context, in *ActionRequest, opts ...grpc.CallOption) (*ActionResponse, error)
	ReportActionStatus(ctx context.Context, in *ActionStatusRequest, opts ...grpc.CallOption) (*ActionStatusResponse, error)
}

WorkflowServiceClient is the client API for WorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

WorkflowService for getting actions and reporting the status of the actions

type WorkflowServiceServer

type WorkflowServiceServer interface {
	GetAction(context.Context, *ActionRequest) (*ActionResponse, error)
	ReportActionStatus(context.Context, *ActionStatusRequest) (*ActionStatusResponse, error)
	// contains filtered or unexported methods
}

WorkflowServiceServer is the server API for WorkflowService service. All implementations must embed UnimplementedWorkflowServiceServer for forward compatibility.

WorkflowService for getting actions and reporting the status of the actions

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL