proto

package
v0.16.0 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 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 (
	StateType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "PENDING",
		2: "RUNNING",
		3: "FAILED",
		4: "TIMEOUT",
		5: "SUCCESS",
	}
	StateType_value = map[string]int32{
		"UNSPECIFIED": 0,
		"PENDING":     1,
		"RUNNING":     2,
		"FAILED":      3,
		"TIMEOUT":     4,
		"SUCCESS":     5,
	}
)

Enum value maps for 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 worker that is requesting the action
	WorkerId *string `protobuf:"bytes,1,opt,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	// Attributes of the worker, this enables more sophisticated server-side Workflow selection and creation capabilities
	WorkerAttributes *WorkerAttributes `protobuf:"bytes,2,opt,name=worker_attributes,json=workerAttributes" json:"worker_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) GetWorkerAttributes 

func (x *ActionRequest) GetWorkerAttributes() *WorkerAttributes

func (*ActionRequest) GetWorkerId 

func (x *ActionRequest) GetWorkerId() 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"`
	// worker_id is the id of the worker that is executing the action
	WorkerId *string `protobuf:"bytes,3,opt,name=worker_id,json=workerId" json:"worker_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) 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) GetWorkerId 

func (x *ActionResponse) GetWorkerId() 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 worker id
	WorkerId *string `protobuf:"bytes,2,opt,name=worker_id,json=workerId" json:"worker_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 *StateType `protobuf:"varint,6,opt,name=action_state,json=actionState,enum=proto.StateType" json:"action_state,omitempty"`
	// 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() StateType

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) GetWorkerId 

func (x *ActionStatusRequest) GetWorkerId() 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 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 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"`
	// 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) 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              *uint64 `protobuf:"varint,4,opt,name=size" json:"size,omitempty"`
	PhysicalBlockSize *uint64 `protobuf:"varint,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() uint64

func (*Block) GetSize 

func (x *Block) GetSize() uint64

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  *uint64 `protobuf:"varint,1,opt,name=total" json:"total,omitempty"`
	Usable *uint64 `protobuf:"varint,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() uint64

func (*Memory) GetUsable 

func (x *Memory) GetUsable() uint64

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 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"`
	// 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) 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 StateType 

type 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.
	StateType_UNSPECIFIED StateType = 0
	// A workflow is in pending state when it is waiting for the hardware to pick
	// it up and start the execution.
	StateType_PENDING StateType = 1
	// A workflow is in a running state when the tink-worker started the
	// exeuction of it, and it is currently in execution inside the device
	// itself.
	StateType_RUNNING 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.
	StateType_FAILED 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.
	StateType_TIMEOUT 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.
	StateType_SUCCESS StateType = 5
)

func (StateType) Descriptor 

func (StateType) Descriptor() protoreflect.EnumDescriptor

func (StateType) Enum 

func (x StateType) Enum() *StateType

func (StateType) EnumDescriptor deprecated 

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

Deprecated: Use StateType.Descriptor instead.

func (StateType) Number 

func (x StateType) Number() protoreflect.EnumNumber

func (StateType) String 

func (x StateType) String() string

func (StateType) Type 

func (StateType) Type() protoreflect.EnumType

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 WorkerAttributes 

type WorkerAttributes 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 (*WorkerAttributes) Descriptor deprecated 

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

Deprecated: Use WorkerAttributes.ProtoReflect.Descriptor instead.

func (*WorkerAttributes) GetBaseboard 

func (x *WorkerAttributes) GetBaseboard() *Baseboard

func (*WorkerAttributes) GetBios 

func (x *WorkerAttributes) GetBios() *BIOS

func (*WorkerAttributes) GetBlock 

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

func (*WorkerAttributes) GetChassis 

func (x *WorkerAttributes) GetChassis() *Chassis

func (*WorkerAttributes) GetCpu 

func (x *WorkerAttributes) GetCpu() *CPU

func (*WorkerAttributes) GetGpu 

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

func (*WorkerAttributes) GetMemory 

func (x *WorkerAttributes) GetMemory() *Memory

func (*WorkerAttributes) GetNetwork 

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

func (*WorkerAttributes) GetPci 

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

func (*WorkerAttributes) GetProduct 

func (x *WorkerAttributes) GetProduct() *Product

func (*WorkerAttributes) ProtoMessage 

func (*WorkerAttributes) ProtoMessage()

func (*WorkerAttributes) ProtoReflect 

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

func (*WorkerAttributes) Reset 

func (x *WorkerAttributes) Reset()

func (*WorkerAttributes) String 

func (x *WorkerAttributes) String() string

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

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.