legacy

Documentation

Index

• type AskForBidRequest
• type AskForBidResponse
• type BidAcceptedRequest
• type BidAcceptedResponse
• type BidRejectedRequest
• type BidRejectedResponse
• type BidResult
• type CancelExecutionRequest
• type CancelExecutionResponse
• type CancelResult
• type ComputeError
  • func (e ComputeError) Error() string
• type ExecutionMetadata
  • func NewExecutionMetadata(execution *models.Execution) ExecutionMetadata
• type RoutingMetadata
• type RunResult

Types

type AskForBidRequest

type AskForBidRequest struct {
	RoutingMetadata
	// Execution specifies the job to be executed.
	Execution *models.Execution
	// WaitForApproval specifies whether the compute node should wait for the requester to approve the bid.
	// if set to true, the compute node will not start the execution until the requester approves the bid.
	// If set to false, the compute node will automatically start the execution after bidding and when resources are available.
	WaitForApproval bool
}

type AskForBidResponse

type AskForBidResponse struct {
	ExecutionMetadata
}

type BidAcceptedRequest

type BidAcceptedRequest struct {
	RoutingMetadata
	ExecutionID   string
	Accepted      bool
	Justification string
}

type BidAcceptedResponse

type BidAcceptedResponse struct {
	ExecutionMetadata
}

type BidRejectedRequest

type BidRejectedRequest struct {
	RoutingMetadata
	ExecutionID   string
	Justification string
}

type BidRejectedResponse

type BidRejectedResponse struct {
	ExecutionMetadata
}

type BidResult

type BidResult struct {
	RoutingMetadata
	ExecutionMetadata
	Accepted bool
	Wait     bool
	Event    models.Event
}

BidResult is the result of the compute node bidding on a job that is returned to the caller through a Callback.

type CancelExecutionRequest

type CancelExecutionRequest struct {
	RoutingMetadata
	ExecutionID   string
	Justification string
}

type CancelExecutionResponse

type CancelExecutionResponse struct {
	ExecutionMetadata
}

type CancelResult

type CancelResult struct {
	RoutingMetadata
	ExecutionMetadata
}

type ComputeError

type ComputeError struct {
	RoutingMetadata
	ExecutionMetadata
	Event models.Event
}

func (ComputeError) Error

func (e ComputeError) Error() string

type ExecutionMetadata

type ExecutionMetadata struct {
	ExecutionID string
	JobID       string
}

func NewExecutionMetadata

func NewExecutionMetadata(execution *models.Execution) ExecutionMetadata

type RoutingMetadata

type RoutingMetadata struct {
	SourcePeerID string
	TargetPeerID string
}

type RunResult

type RunResult struct {
	RoutingMetadata
	ExecutionMetadata
	PublishResult    *models.SpecConfig
	RunCommandResult *models.RunCommandResult
}