Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterWorkflowServiceServer(s grpc.ServiceRegistrar, srv WorkflowServiceServer)
- type ActionMessage
- type ActionRequest
- func (*ActionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActionRequest) GetAgentAttributes() *AgentAttributes
- func (x *ActionRequest) GetAgentId() string
- func (*ActionRequest) ProtoMessage()
- func (x *ActionRequest) ProtoReflect() protoreflect.Message
- func (x *ActionRequest) Reset()
- func (x *ActionRequest) String() string
- type ActionResponse
- func (*ActionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ActionResponse) GetActionId() string
- func (x *ActionResponse) GetAgentId() string
- func (x *ActionResponse) GetCommand() []string
- func (x *ActionResponse) GetEnvironment() []string
- func (x *ActionResponse) GetImage() string
- func (x *ActionResponse) GetName() string
- func (x *ActionResponse) GetPid() string
- func (x *ActionResponse) GetTaskId() string
- func (x *ActionResponse) GetTimeout() int64
- func (x *ActionResponse) GetVolumes() []string
- func (x *ActionResponse) GetWorkflowId() string
- func (*ActionResponse) ProtoMessage()
- func (x *ActionResponse) ProtoReflect() protoreflect.Message
- func (x *ActionResponse) Reset()
- func (x *ActionResponse) String() string
- type ActionStatusRequest
- func (*ActionStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActionStatusRequest) GetActionId() string
- func (x *ActionStatusRequest) GetActionName() string
- func (x *ActionStatusRequest) GetActionState() ActionStatusRequest_StateType
- func (x *ActionStatusRequest) GetAgentId() string
- func (x *ActionStatusRequest) GetExecutionDuration() string
- func (x *ActionStatusRequest) GetExecutionStart() *timestamppb.Timestamp
- func (x *ActionStatusRequest) GetExecutionStop() *timestamppb.Timestamp
- func (x *ActionStatusRequest) GetMessage() *ActionMessage
- func (x *ActionStatusRequest) GetTaskId() string
- func (x *ActionStatusRequest) GetWorkflowId() string
- func (*ActionStatusRequest) ProtoMessage()
- func (x *ActionStatusRequest) ProtoReflect() protoreflect.Message
- func (x *ActionStatusRequest) Reset()
- func (x *ActionStatusRequest) String() string
- type ActionStatusRequest_StateType
- func (ActionStatusRequest_StateType) Descriptor() protoreflect.EnumDescriptor
- func (x ActionStatusRequest_StateType) Enum() *ActionStatusRequest_StateType
- func (ActionStatusRequest_StateType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ActionStatusRequest_StateType) Number() protoreflect.EnumNumber
- func (x ActionStatusRequest_StateType) String() string
- func (ActionStatusRequest_StateType) Type() protoreflect.EnumType
- type ActionStatusResponse
- type AgentAttributes
- func (*AgentAttributes) Descriptor() ([]byte, []int)deprecated
- func (x *AgentAttributes) GetBaseboard() *Baseboard
- func (x *AgentAttributes) GetBios() *BIOS
- func (x *AgentAttributes) GetBlock() []*Block
- func (x *AgentAttributes) GetChassis() *Chassis
- func (x *AgentAttributes) GetCpu() *CPU
- func (x *AgentAttributes) GetGpu() []*GPU
- func (x *AgentAttributes) GetMemory() *Memory
- func (x *AgentAttributes) GetNetwork() []*Network
- func (x *AgentAttributes) GetPci() []*PCI
- func (x *AgentAttributes) GetProduct() *Product
- func (*AgentAttributes) ProtoMessage()
- func (x *AgentAttributes) ProtoReflect() protoreflect.Message
- func (x *AgentAttributes) Reset()
- func (x *AgentAttributes) String() string
- type BIOS
- type Baseboard
- func (*Baseboard) Descriptor() ([]byte, []int)deprecated
- func (x *Baseboard) GetProduct() string
- func (x *Baseboard) GetSerialNumber() string
- func (x *Baseboard) GetVendor() string
- func (x *Baseboard) GetVersion() string
- func (*Baseboard) ProtoMessage()
- func (x *Baseboard) ProtoReflect() protoreflect.Message
- func (x *Baseboard) Reset()
- func (x *Baseboard) String() string
- type Block
- func (*Block) Descriptor() ([]byte, []int)deprecated
- func (x *Block) GetControllerType() string
- func (x *Block) GetDriveType() string
- func (x *Block) GetModel() string
- func (x *Block) GetName() string
- func (x *Block) GetPhysicalBlockSize() string
- func (x *Block) GetSize() string
- func (x *Block) GetVendor() string
- func (*Block) ProtoMessage()
- func (x *Block) ProtoReflect() protoreflect.Message
- func (x *Block) Reset()
- func (x *Block) String() string
- type CPU
- type Chassis
- type GPU
- func (*GPU) Descriptor() ([]byte, []int)deprecated
- func (x *GPU) GetClass() string
- func (x *GPU) GetDriver() string
- func (x *GPU) GetProduct() string
- func (x *GPU) GetVendor() string
- func (*GPU) ProtoMessage()
- func (x *GPU) ProtoReflect() protoreflect.Message
- func (x *GPU) Reset()
- func (x *GPU) String() string
- type Memory
- type Network
- func (*Network) Descriptor() ([]byte, []int)deprecated
- func (x *Network) GetEnabledCapabilities() []string
- func (x *Network) GetMac() string
- func (x *Network) GetName() string
- func (x *Network) GetSpeed() string
- func (*Network) ProtoMessage()
- func (x *Network) ProtoReflect() protoreflect.Message
- func (x *Network) Reset()
- func (x *Network) String() string
- type PCI
- func (*PCI) Descriptor() ([]byte, []int)deprecated
- func (x *PCI) GetClass() string
- func (x *PCI) GetDriver() string
- func (x *PCI) GetProduct() string
- func (x *PCI) GetVendor() string
- func (*PCI) ProtoMessage()
- func (x *PCI) ProtoReflect() protoreflect.Message
- func (x *PCI) Reset()
- func (x *PCI) String() string
- type PreconditionFailureViolation
- func (PreconditionFailureViolation) Descriptor() protoreflect.EnumDescriptor
- func (x PreconditionFailureViolation) Enum() *PreconditionFailureViolation
- func (PreconditionFailureViolation) EnumDescriptor() ([]byte, []int)deprecated
- func (x PreconditionFailureViolation) Number() protoreflect.EnumNumber
- func (x PreconditionFailureViolation) String() string
- func (PreconditionFailureViolation) Type() protoreflect.EnumType
- type Processor
- func (*Processor) Descriptor() ([]byte, []int)deprecated
- func (x *Processor) GetCapabilities() []string
- func (x *Processor) GetCores() uint32
- func (x *Processor) GetId() uint32
- func (x *Processor) GetModel() string
- func (x *Processor) GetThreads() uint32
- func (x *Processor) GetVendor() string
- func (*Processor) ProtoMessage()
- func (x *Processor) ProtoReflect() protoreflect.Message
- func (x *Processor) Reset()
- func (x *Processor) String() string
- type Product
- func (*Product) Descriptor() ([]byte, []int)deprecated
- func (x *Product) GetName() string
- func (x *Product) GetSerialNumber() string
- func (x *Product) GetVendor() string
- func (*Product) ProtoMessage()
- func (x *Product) ProtoReflect() protoreflect.Message
- func (x *Product) Reset()
- func (x *Product) String() string
- type UnimplementedWorkflowServiceServer
- type UnsafeWorkflowServiceServer
- type WorkflowServiceClient
- type WorkflowServiceServer
Constants ¶
const ( WorkflowService_GetAction_FullMethodName = "/proto.WorkflowService/GetAction" WorkflowService_ReportActionStatus_FullMethodName = "/proto.WorkflowService/ReportActionStatus" )
Variables ¶
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.
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.
var File_get_action_request_proto protoreflect.FileDescriptor
var File_get_action_response_proto protoreflect.FileDescriptor
var File_report_action_status_request_proto protoreflect.FileDescriptor
var File_report_action_status_response_proto protoreflect.FileDescriptor
var File_workflow_service_proto protoreflect.FileDescriptor
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 (x *ActionStatusRequest) GetActionState() ActionStatusRequest_StateType
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) Descriptor() protoreflect.EnumDescriptor
func (ActionStatusRequest_StateType) Enum ¶ added in v0.18.0
func (x ActionStatusRequest_StateType) Enum() *ActionStatusRequest_StateType
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 (x ActionStatusRequest_StateType) Number() protoreflect.EnumNumber
func (ActionStatusRequest_StateType) String ¶ added in v0.18.0
func (x ActionStatusRequest_StateType) String() string
func (ActionStatusRequest_StateType) Type ¶ added in v0.18.0
func (ActionStatusRequest_StateType) Type() protoreflect.EnumType
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) GetReleaseDate ¶
func (*BIOS) GetVersion ¶
func (*BIOS) ProtoMessage ¶
func (*BIOS) ProtoMessage()
func (*BIOS) ProtoReflect ¶
func (x *BIOS) ProtoReflect() protoreflect.Message
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) GetProduct ¶
func (*Baseboard) GetSerialNumber ¶ added in v0.18.0
func (*Baseboard) GetVersion ¶
func (*Baseboard) ProtoMessage ¶
func (*Baseboard) ProtoMessage()
func (*Baseboard) ProtoReflect ¶
func (x *Baseboard) ProtoReflect() protoreflect.Message
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) GetControllerType ¶
func (*Block) GetDriveType ¶
func (*Block) GetPhysicalBlockSize ¶
func (*Block) ProtoMessage ¶
func (*Block) ProtoMessage()
func (*Block) ProtoReflect ¶
func (x *Block) ProtoReflect() protoreflect.Message
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) GetProcessors ¶
func (*CPU) GetTotalCores ¶
func (*CPU) GetTotalThreads ¶
func (*CPU) ProtoMessage ¶
func (*CPU) ProtoMessage()
func (*CPU) ProtoReflect ¶
func (x *CPU) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*Chassis) ProtoMessage()
func (*Chassis) ProtoReflect ¶
func (x *Chassis) ProtoReflect() protoreflect.Message
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) GetProduct ¶
func (*GPU) ProtoMessage ¶
func (*GPU) ProtoMessage()
func (*GPU) ProtoReflect ¶
func (x *GPU) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*Memory) ProtoMessage()
func (*Memory) ProtoReflect ¶
func (x *Memory) ProtoReflect() protoreflect.Message
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) GetEnabledCapabilities ¶
func (*Network) ProtoMessage ¶
func (*Network) ProtoMessage()
func (*Network) ProtoReflect ¶
func (x *Network) ProtoReflect() protoreflect.Message
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) GetProduct ¶
func (*PCI) ProtoMessage ¶
func (*PCI) ProtoMessage()
func (*PCI) ProtoReflect ¶
func (x *PCI) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
func (PreconditionFailureViolation) Enum ¶ added in v0.18.0
func (x PreconditionFailureViolation) Enum() *PreconditionFailureViolation
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 (x PreconditionFailureViolation) Number() protoreflect.EnumNumber
func (PreconditionFailureViolation) String ¶ added in v0.18.0
func (x PreconditionFailureViolation) String() string
func (PreconditionFailureViolation) Type ¶ added in v0.18.0
func (PreconditionFailureViolation) Type() protoreflect.EnumType
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) GetCapabilities ¶
func (*Processor) GetThreads ¶
func (*Processor) ProtoMessage ¶
func (*Processor) ProtoMessage()
func (*Processor) ProtoReflect ¶
func (x *Processor) ProtoReflect() protoreflect.Message
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) GetSerialNumber ¶ added in v0.18.0
func (*Product) ProtoMessage ¶
func (*Product) ProtoMessage()
func (*Product) ProtoReflect ¶
func (x *Product) ProtoReflect() protoreflect.Message
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) GetAction(context.Context, *ActionRequest) (*ActionResponse, error)
func (UnimplementedWorkflowServiceServer) ReportActionStatus ¶
func (UnimplementedWorkflowServiceServer) ReportActionStatus(context.Context, *ActionStatusRequest) (*ActionStatusResponse, error)
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
func NewWorkflowServiceClient ¶
func NewWorkflowServiceClient(cc grpc.ClientConnInterface) WorkflowServiceClient
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