models

Oct 25, 2024

Changes in this version

type ExecutionStateType

+ func (s ExecutionStateType) IsTerminal() bool

Oct 7, 2024

Changes in this version

+ const DetailsKeyErrorCode

+ const DetailsKeyNewState

+ const MetaClientInstallationID

+ const MetaClientInstanceID

+ const MetaServerInstallationID

+ const MetaServerInstanceID

+ var EngineNames = []string

+ var NoTimeout = time.Duration(math.MaxInt64).Truncate(time.Second)

+ var PublisherNames = []string

+ var StoragesNames = []string

+ type DebugInfo struct

+ Component string

+ Info interface{}

+ type DebugInfoProvider interface

+ GetDebugInfo func(ctx context.Context) (DebugInfo, error)

type Event

+ func (e *Event) GetJobStateIfPresent() (JobStateType, error)

+ func (e *Event) HasError() bool

+ func (e *Event) HasStateUpdate() bool

+ func (e *Event) WithErrorCode(errorCode string) *Event

+ type FailureInjectionConfig struct

+ IsBadActor bool

+ type JobEvent struct

+ EventName JobEventType

+ EventTime time.Time

+ ExecutionID string

+ JobID string

+ SourceNodeID string

+ Status string

+ TargetNodeID string

+ type JobEventType int

+ const JobEventBid

+ const JobEventBidAccepted

+ const JobEventBidRejected

+ const JobEventCanceled

+ const JobEventCompleted

+ const JobEventComputeError

+ const JobEventCreated

+ const JobEventError

+ const JobEventResultsAccepted

+ const JobEventResultsProposed

+ const JobEventResultsPublished

+ const JobEventResultsRejected

+ func JobEventTypes() []JobEventType

+ func ParseJobEventType(str string) (JobEventType, error)

+ func (i JobEventType) String() string

+ func (je *JobEventType) UnmarshalText(text []byte) (err error)

+ func (je JobEventType) IsTerminal() bool

+ func (je JobEventType) IsUndefined() bool

+ func (je JobEventType) MarshalText() ([]byte, error)

type JobHistory

+ SeqNum uint64

+ func (jh JobHistory) IsExecutionLevel() bool

+ func (jh JobHistory) IsJobLevel() bool

+ type JobSelectionDataLocality int64

+ const Anywhere

+ const Local

+ func ParseJobSelectionDataLocality(s string) (ret JobSelectionDataLocality, err error)

+ func (i *JobSelectionDataLocality) UnmarshalText(text []byte) error

+ func (i JobSelectionDataLocality) MarshalText() ([]byte, error)

+ func (i JobSelectionDataLocality) String() string

+ type JobSelectionPolicy struct

+ AcceptNetworkedJobs bool

+ Locality JobSelectionDataLocality

+ ProbeExec string

+ ProbeHTTP string

+ RejectStatelessJobs bool

type Plan

+ ExecutionEvents map[string][]Event

+ JobEvents []Event

+ UpdateMessage string

+ func (p *Plan) AppendExecutionEvent(executionID string, event Event)

+ func (p *Plan) AppendJobEvent(event Event)

type State

+ Details map[string]string

+ func (s State[T]) WithDetail(key, value string) State[T]

+ func (s State[T]) WithDetails(details map[string]string) State[T]

type TimeoutConfig

+ func (t *TimeoutConfig) ValidateSubmission() error

Jun 24, 2024

Changes in this version

+ const EvalTriggerJobTimeout

type Job

+ func (j *Job) IsExpired(expirationTime time.Time) bool

type JobStateType

+ const JobStateTypeQueued

type Plan

+ func (p *Plan) MarkJobQueued(event Event)

Jun 4, 2024

Changes in this version

+ const EvalTriggerJobQueue

type Evaluation

+ func (e *Evaluation) NewDelayedEvaluation(waitUntil time.Time) *Evaluation

+ func (e *Evaluation) WithJob(job *Job) *Evaluation

type JobStateType

+ func (s JobStateType) IsTerminal() bool

type NodeMembershipState

+ func (t NodeMembershipState) IsUndefined() bool

type Plan

+ NewEvaluations []*Evaluation

+ func (p *Plan) AppendEvaluation(eval *Evaluation)

+ func (p *Plan) IsJobFailed() bool

type Resources

+ func (r *Resources) Multiply(factor float64) *Resources

type TimeoutConfig

+ QueueTimeout int64

+ TotalTimeout int64

+ func (t *TimeoutConfig) GetQueueTimeout() time.Duration

+ func (t *TimeoutConfig) GetTotalTimeout() time.Duration

May 23, 2024

Changes in this version

+ const DetailsKeyFailsExecution

+ const DetailsKeyHint

+ const DetailsKeyIsError

+ const DetailsKeyRetryable

+ const EvalTriggerExecFailure

+ const EvalTriggerExecTimeout

+ var NodeMembership = membershipContainer

+ var NodeStates = livenessContainer

+ type BaseError struct

+ func NewBaseError(format string, a ...any) *BaseError

+ func (e *BaseError) Details() map[string]string

+ func (e *BaseError) Error() string

+ func (e *BaseError) FailsExecution() bool

+ func (e *BaseError) Hint() string

+ func (e *BaseError) Retryable() bool

+ func (e *BaseError) WithDetails(details map[string]string) *BaseError

+ func (e *BaseError) WithFailsExecution() *BaseError

+ func (e *BaseError) WithHint(hint string) *BaseError

+ func (e *BaseError) WithRetryable() *BaseError

type ComputeNodeInfo

+ QueueUsedCapacity Resources

type Evaluation

+ func NewEvaluation() *Evaluation

+ func (e *Evaluation) Normalize() *Evaluation

+ func (e *Evaluation) WithComment(comment string) *Evaluation

+ func (e *Evaluation) WithJobID(jobID string) *Evaluation

+ func (e *Evaluation) WithNamespace(namespace string) *Evaluation

+ func (e *Evaluation) WithPriority(priority int) *Evaluation

+ func (e *Evaluation) WithStatus(status string) *Evaluation

+ func (e *Evaluation) WithTriggeredBy(triggeredBy string) *Evaluation

+ func (e *Evaluation) WithType(jobType string) *Evaluation

+ func (e *Evaluation) WithWaitUntil(waitUntil time.Time) *Evaluation

+ type Event struct

+ Details map[string]string

+ Message string

+ Timestamp time.Time

+ Topic EventTopic

+ func EventFromError(topic EventTopic, err error) Event

+ func NewEvent(topic EventTopic) *Event

+ func (e *Event) WithDetail(key, value string) *Event

+ func (e *Event) WithDetails(details map[string]string) *Event

+ func (e *Event) WithError(err error) *Event

+ func (e *Event) WithFailsExecution(failsExecution bool) *Event

+ func (e *Event) WithHint(hint string) *Event

+ func (e *Event) WithMessage(message string) *Event

+ func (e *Event) WithRetryable(retryable bool) *Event

+ type EventTopic string

type Execution

+ func (e *Execution) IsExpired(expirationTime time.Time) bool

type ExecutionStateType

+ func (s ExecutionStateType) IsTermainl() bool

+ type HasDetails interface

+ Details func() map[string]string

+ type HasFailsExecution interface

+ FailsExecution func() bool

+ type HasHint interface

+ Hint func() string

+ type HasRetryable interface

+ Retryable func() bool

type JobHistory

+ Event Event

+ func (jh JobHistory) Occurred() time.Time

+ type NodeConnectionState struct

+ func ParseConnection(a any) NodeConnectionState

+ func (s *NodeConnectionState) UnmarshalJSON(b []byte) error

+ func (s NodeConnectionState) MarshalJSON() ([]byte, error)

+ func (t NodeConnectionState) IsValid() bool

+ func (t NodeConnectionState) String() string

+ type NodeMembershipState struct

+ func (t *NodeMembershipState) UnmarshalJSON(b []byte) error

+ func (t NodeMembershipState) IsValid() bool

+ func (t NodeMembershipState) MarshalJSON() ([]byte, error)

+ func (t NodeMembershipState) String() string

+ type NodeState struct

+ Connection NodeConnectionState

+ Info NodeInfo

+ Membership NodeMembershipState

+ type NodeStateProvider interface

+ GetNodeState func(ctx context.Context) NodeState

type Plan

+ Event Event

type PlanExecutionDesiredUpdate

+ Event Event

Mar 4, 2024

Changes in this version

+ const PublisherLocal

+ var NodeApprovals = approvalsContainer

+ func NewErrInvalidPagingToken(s string, msg string) error

+ type ExecutionLog struct

+ Line string

+ Type ExecutionLogType

+ type ExecutionLogType int

+ const ExecutionLogTypeSTDERR

+ const ExecutionLogTypeSTDOUT

type InputSource

+ func (a *InputSource) MarshalZerologObject(e *zerolog.Event)

+ type NodeApproval struct

+ func Parse(a any) NodeApproval

+ func (t *NodeApproval) UnmarshalJSON(b []byte) error

+ func (t NodeApproval) IsValid() bool

+ func (t NodeApproval) MarshalJSON() ([]byte, error)

+ func (t NodeApproval) String() string

type NodeInfo

+ Approval NodeApproval

+ type PagingToken struct

+ Limit uint32

+ Offset uint32

+ SortBy string

+ SortReverse bool

+ func NewPagingToken(params *PagingTokenParams) *PagingToken

+ func NewPagingTokenFromString(s string) (*PagingToken, error)

+ func (pagingToken *PagingToken) RawString() string

+ func (pagingToken *PagingToken) String() string

+ type PagingTokenParams struct

+ Limit uint32

+ Offset uint32

+ SortBy string

+ SortReverse bool

type SpecConfig

+ func (s *SpecConfig) MarshalZerologObject(e *zerolog.Event)

+ func (s *SpecConfig) MetricAttributes() []attribute.KeyValue

Jan 30, 2024

Changes in this version

+ const MetaDerivedFrom

+ const MetaTranslatedBy

+ const NetworkTypeLibp2p

+ const NetworkTypeNATS

+ func IsDefaultEngineType(kind string) bool

type Job

+ func (j *Job) MetricAttributes() []attribute.KeyValue

+ type LabelsProvider interface

+ GetLabels func(ctx context.Context) map[string]string

+ func MergeLabelsInOrder(providers ...LabelsProvider) LabelsProvider

type NodeInfo

+ NodeID string

+ type NodeInfoDecorator interface

+ DecorateNodeInfo func(ctx context.Context, nodeInfo NodeInfo) NodeInfo

+ type NoopNodeInfoDecorator struct

+ func (n NoopNodeInfoDecorator) DecorateNodeInfo(ctx context.Context, nodeInfo NodeInfo) NodeInfo

type Task

+ func (t *Task) MetricAttributes() []attribute.KeyValue

type TaskBuilder

+ func (b *TaskBuilder) Meta(key string, value string) *TaskBuilder

Dec 11, 2023

Changes in this version

+ type GPU struct

+ Index uint64

+ Memory uint64

+ Name string

+ PCIAddress string

+ Vendor GPUVendor

+ type GPUVendor string

+ const GPUVendorAMDATI

+ const GPUVendorIntel

+ const GPUVendorNvidia

type Resources

+ GPUs []GPU

Nov 9, 2023

Changes in this version

+ const StorageSourceS3PreSigned

type NodeInfo

+ func (n NodeInfo) ID() string

Nov 2, 2023

Changes in this version

type Plan

+ func (p *Plan) MarkJobRunningIfEligible()

Sep 25, 2023

Changes in this version

+ const MetaReservedPrefix

type Execution

+ func (e *Execution) GetCreateTime() time.Time

+ func (e *Execution) GetModifyTime() time.Time

type Job

+ func (j *Job) IsLongRunning() bool

+ func (j *Job) SanitizeSubmission() (warnings []string)

type JobStateType

+ func JobStateTypes() []JobStateType

+ func (s *JobStateType) UnmarshalText(text []byte) (err error)

+ func (s JobStateType) MarshalText() ([]byte, error)

type NodeType

+ func (e *NodeType) UnmarshalText(text []byte) (err error)

+ func (e NodeType) MarshalText() ([]byte, error)

type SpecConfig

+ func (s *SpecConfig) IsEmpty() bool

+ func (s *SpecConfig) ValidateAllowBlank() error

type Task

+ func (t *Task) ValidateSubmission() error

Sep 12, 2023

Changes in this version

+ const DefaultNamespace

+ const DownloadCIDsFolderName

+ const DownloadFilePerm

+ const DownloadFilenameExitCode

+ const DownloadFilenameStderr

+ const DownloadFilenameStdout

+ const DownloadFolderPerm

+ const EngineDocker

+ const EngineNoop

+ const EngineWasm

+ const EvalStatusBlocked

+ const EvalStatusCancelled

+ const EvalStatusComplete

+ const EvalStatusFailed

+ const EvalStatusPending

+ const EvalTriggerExecUpdate

+ const EvalTriggerJobCancel

+ const EvalTriggerJobRegister

+ const EvalTriggerRetryFailedExec

+ const JobTypeBatch

+ const JobTypeDaemon

+ const JobTypeOps

+ const JobTypeService

+ const MetaClientID

+ const MetaRequesterID

+ const MetaRequesterPublicKey

+ const PublisherIPFS

+ const PublisherNoop

+ const PublisherS3

+ const ShortIDLength

+ const StorageSourceIPFS

+ const StorageSourceInline

+ const StorageSourceLocalDirectory

+ const StorageSourceNoop

+ const StorageSourceRepoClone

+ const StorageSourceRepoCloneLFS

+ const StorageSourceS3

+ const StorageSourceURL

+ func CopySlice(slice []T) []T

+ func FromLabelSelectorRequirements(requirements ...*LabelSelectorRequirement) ([]labels.Requirement, error)

+ func NormalizeSlice(slice []T)

+ func ValidateSlice(slice []T) error

+ type AllocatedResources struct

+ Tasks map[string]*Resources

+ func (a *AllocatedResources) Copy() *AllocatedResources

+ func (a *AllocatedResources) Total() *Resources

+ type BuildVersionInfo struct

+ BuildDate time.Time

+ GOARCH string

+ GOOS string

+ GitCommit string

+ GitVersion string

+ Major string

+ Minor string

+ type ComputeNodeInfo struct

+ AvailableCapacity Resources

+ EnqueuedExecutions int

+ ExecutionEngines []string

+ MaxCapacity Resources

+ MaxJobRequirements Resources

+ Publishers []string

+ RunningExecutions int

+ StorageSources []string

+ type ComputeNodeInfoProvider interface

+ GetComputeInfo func(ctx context.Context) ComputeNodeInfo

+ type Copyable interface

+ Copy func() T

+ type Evaluation struct

+ Comment string

+ CreateTime int64

+ ID string

+ JobID string

+ ModifyTime int64

+ Namespace string

+ Priority int

+ Status string

+ TriggeredBy string

+ Type string

+ WaitUntil time.Time

+ func (e *Evaluation) Copy() *Evaluation

+ func (e *Evaluation) ShouldEnqueue() bool

+ func (e *Evaluation) String() string

+ func (e *Evaluation) TerminalStatus() bool

+ func (e *Evaluation) UpdateModifyTime()

+ type EvaluationReceipt struct

+ Evaluation *Evaluation

+ ReceiptHandle string

+ type Execution struct

+ AllocatedResources *AllocatedResources

+ ComputeState State[ExecutionStateType]

+ CreateTime int64

+ DesiredState State[ExecutionDesiredStateType]

+ EvalID string

+ FollowupEvalID string

+ ID string

+ Job *Job

+ JobID string

+ ModifyTime int64

+ Name string

+ Namespace string

+ NextExecution string

+ NodeID string

+ PreviousExecution string

+ PublishedResult *SpecConfig

+ Revision uint64

+ RunOutput *RunCommandResult

+ func (e *Execution) AllocateResources(taskID string, resources Resources)

+ func (e *Execution) Copy() *Execution

+ func (e *Execution) IsDiscarded() bool

+ func (e *Execution) IsTerminalComputeState() bool

+ func (e *Execution) IsTerminalDesiredState() bool

+ func (e *Execution) IsTerminalState() bool

+ func (e *Execution) JobNamespacedID() NamespacedID

+ func (e *Execution) Normalize()

+ func (e *Execution) String() string

+ func (e *Execution) TotalAllocatedResources() *Resources

+ func (e *Execution) Validate() error

+ type ExecutionDesiredStateType int

+ const ExecutionDesiredStatePending

+ const ExecutionDesiredStateRunning

+ const ExecutionDesiredStateStopped

+ func (i ExecutionDesiredStateType) String() string

+ type ExecutionStateType int

+ const ExecutionStateAskForBid

+ const ExecutionStateAskForBidAccepted

+ const ExecutionStateAskForBidRejected

+ const ExecutionStateBidAccepted

+ const ExecutionStateBidRejected

+ const ExecutionStateCancelled

+ const ExecutionStateCompleted

+ const ExecutionStateFailed

+ const ExecutionStateNew

+ const ExecutionStateUndefined

+ func (i ExecutionStateType) String() string

+ func (s ExecutionStateType) IsUndefined() bool

+ type InputSource struct

+ Alias string

+ Source *SpecConfig

+ Target string

+ func (a *InputSource) Copy() *InputSource

+ func (a *InputSource) Normalize()

+ func (a *InputSource) Validate() error

+ type Job struct

+ Constraints []*LabelSelectorRequirement

+ Count int

+ CreateTime int64

+ ID string

+ Labels map[string]string

+ Meta map[string]string

+ ModifyTime int64

+ Name string

+ Namespace string

+ Priority int

+ Revision uint64

+ State State[JobStateType]

+ Tasks []*Task

+ Type string

+ Version uint64

+ func (j *Job) AllStorageTypes() []string

+ func (j *Job) Copy() *Job

+ func (j *Job) GetCreateTime() time.Time

+ func (j *Job) GetModifyTime() time.Time

+ func (j *Job) IsTerminal() bool

+ func (j *Job) NamespacedID() NamespacedID

+ func (j *Job) Normalize()

+ func (j *Job) String() string

+ func (j *Job) Task() *Task

+ func (j *Job) Validate() error

+ func (j *Job) ValidateSubmission() error

+ type JobHistory struct

+ Comment string

+ ExecutionID string

+ ExecutionState *StateChange[ExecutionStateType]

+ JobID string

+ JobState *StateChange[JobStateType]

+ NewRevision uint64

+ NodeID string

+ Time time.Time

+ Type JobHistoryType

+ type JobHistoryType int

+ const JobHistoryTypeExecutionLevel

+ const JobHistoryTypeJobLevel

+ const JobHistoryTypeUndefined

+ func (i JobHistoryType) String() string

+ func (s *JobHistoryType) UnmarshalText(text []byte) (err error)

+ func (s JobHistoryType) MarshalText() ([]byte, error)

+ type JobStateType int

+ const JobStateTypeCompleted

+ const JobStateTypeFailed

+ const JobStateTypePending

+ const JobStateTypeRunning

+ const JobStateTypeStopped

+ const JobStateTypeUndefined

+ func (i JobStateType) String() string

+ func (s JobStateType) IsUndefined() bool

+ type LabelSelectorRequirement struct

+ Key string

+ Operator selection.Operator

+ Values []string

+ func ToLabelSelectorRequirements(requirements ...labels.Requirement) []LabelSelectorRequirement

+ func (r *LabelSelectorRequirement) Copy() *LabelSelectorRequirement

+ func (r *LabelSelectorRequirement) String() string

+ func (r *LabelSelectorRequirement) Validate() error

+ type NamespacedID struct

+ ID string

+ Namespace string

+ func NewNamespacedID(id, ns string) NamespacedID

+ func (n NamespacedID) String() string

+ type Network int

+ const NetworkFull

+ const NetworkHTTP

+ const NetworkNone

+ func ParseNetwork(s string) (Network, error)

+ func (i Network) String() string

+ func (n *Network) UnmarshalText(text []byte) (err error)

+ func (n Network) MarshalText() ([]byte, error)

+ type NetworkConfig struct

+ Domains []string

+ Type Network

+ func (n *NetworkConfig) Copy() *NetworkConfig

+ func (n *NetworkConfig) Disabled() bool

+ func (n *NetworkConfig) DomainSet() []string

+ func (n *NetworkConfig) Normalize()

+ func (n *NetworkConfig) Validate() (err error)

+ type NetworkConfigBuilder struct

+ func NewNetworkConfigBuilder() *NetworkConfigBuilder

+ func NewNetworkConfigBuilderFromNetwork(network *NetworkConfig) *NetworkConfigBuilder

+ func (b *NetworkConfigBuilder) Build() (*NetworkConfig, error)

+ func (b *NetworkConfigBuilder) BuildOrDie() *NetworkConfig

+ func (b *NetworkConfigBuilder) Domains(domains ...string) *NetworkConfigBuilder

+ func (b *NetworkConfigBuilder) Type(typ Network) *NetworkConfigBuilder

+ type NodeInfo struct

+ BacalhauVersion BuildVersionInfo

+ ComputeNodeInfo *ComputeNodeInfo

+ Labels map[string]string

+ NodeType NodeType

+ PeerInfo peer.AddrInfo

+ func (n NodeInfo) IsComputeNode() bool

+ type NodeInfoProvider interface

+ GetNodeInfo func(ctx context.Context) NodeInfo

+ type NodeType int

+ const NodeTypeCompute

+ const NodeTypeRequester

+ func ParseNodeType(s string) (NodeType, error)

+ func (i NodeType) String() string

+ type Normalizable interface

+ Normalize func()

+ type Plan struct

+ Comment string

+ DesiredJobState JobStateType

+ Eval *Evaluation

+ EvalID string

+ EvalReceipt string

+ Job *Job

+ NewExecutions []*Execution

+ Priority int

+ UpdatedExecutions map[string]*PlanExecutionDesiredUpdate

+ func NewPlan(eval *Evaluation, job *Job) *Plan

+ func (p *Plan) AppendApprovedExecution(execution *Execution)

+ func (p *Plan) AppendExecution(execution *Execution)

+ func (p *Plan) AppendStoppedExecution(execution *Execution, comment string)

+ func (p *Plan) MarkJobCompleted()

+ func (p *Plan) MarkJobFailed(comment string)

+ type PlanExecutionDesiredUpdate struct

+ Comment string

+ DesiredState ExecutionDesiredStateType

+ Execution *Execution

+ type Resources struct

+ CPU float64

+ Disk uint64

+ GPU uint64

+ Memory uint64

+ func (r *Resources) Add(other Resources) *Resources

+ func (r *Resources) Copy() *Resources

+ func (r *Resources) IsZero() bool

+ func (r *Resources) LessThan(other Resources) bool

+ func (r *Resources) LessThanEq(other Resources) bool

+ func (r *Resources) Max(other Resources) *Resources

+ func (r *Resources) Merge(other Resources) *Resources

+ func (r *Resources) String() string

+ func (r *Resources) Sub(other Resources) *Resources

+ func (r *Resources) Validate() error

+ type ResourcesConfig struct

+ CPU string

+ Disk string

+ GPU string

+ Memory string

+ func (r *ResourcesConfig) Copy() *ResourcesConfig

+ func (r *ResourcesConfig) Normalize()

+ func (r *ResourcesConfig) ToResources() (*Resources, error)

+ func (r *ResourcesConfig) Validate() error

+ type ResourcesConfigBuilder struct

+ func NewResourcesConfigBuilder() *ResourcesConfigBuilder

+ func (r *ResourcesConfigBuilder) Build() (*ResourcesConfig, error)

+ func (r *ResourcesConfigBuilder) BuildOrDie() *ResourcesConfig

+ func (r *ResourcesConfigBuilder) CPU(cpu string) *ResourcesConfigBuilder

+ func (r *ResourcesConfigBuilder) Disk(disk string) *ResourcesConfigBuilder

+ func (r *ResourcesConfigBuilder) GPU(gpu string) *ResourcesConfigBuilder

+ func (r *ResourcesConfigBuilder) Memory(memory string) *ResourcesConfigBuilder

+ type ResultPath struct

+ Name string

+ Path string

+ func (p *ResultPath) Copy() *ResultPath

+ func (p *ResultPath) Normalize()

+ func (p *ResultPath) Validate() error

+ type RunCommandResult struct

+ ErrorMsg string

+ ExitCode int

+ STDERR string

+ STDOUT string

+ StderrTruncated bool

+ StdoutTruncated bool

+ func NewRunCommandResult() *RunCommandResult

+ type SpecConfig struct

+ Params map[string]interface{}

+ Type string

+ func NewSpecConfig(t string) *SpecConfig

+ func (s *SpecConfig) Copy() *SpecConfig

+ func (s *SpecConfig) IsType(t string) bool

+ func (s *SpecConfig) Normalize()

+ func (s *SpecConfig) Validate() error

+ func (s *SpecConfig) WithParam(key string, value interface{}) *SpecConfig

+ type State struct

+ Message string

+ StateType T

+ func NewExecutionDesiredState(stateType ExecutionDesiredStateType) State[ExecutionDesiredStateType]

+ func NewExecutionState(stateType ExecutionStateType) State[ExecutionStateType]

+ func NewJobState(stateType JobStateType) State[JobStateType]

+ func (s State[T]) WithMessage(message string) State[T]

+ type StateChange struct

+ New StateType

+ Previous StateType

+ type Task struct

+ Engine *SpecConfig

+ Env map[string]string

+ InputSources []*InputSource

+ Meta map[string]string

+ Name string

+ Network *NetworkConfig

+ Publisher *SpecConfig

+ ResourcesConfig *ResourcesConfig

+ ResultPaths []*ResultPath

+ Timeouts *TimeoutConfig

+ func (t *Task) AllStorageTypes() []string

+ func (t *Task) Copy() *Task

+ func (t *Task) Normalize()

+ func (t *Task) ToBuilder() *TaskBuilder

+ func (t *Task) Validate() error

+ type TaskBuilder struct

+ func NewTaskBuilder() *TaskBuilder

+ func NewTaskBuilderFromTask(task *Task) *TaskBuilder

+ func (b *TaskBuilder) Build() (*Task, error)

+ func (b *TaskBuilder) BuildOrDie() *Task

+ func (b *TaskBuilder) Engine(engine *SpecConfig) *TaskBuilder

+ func (b *TaskBuilder) InputSources(inputSources ...*InputSource) *TaskBuilder

+ func (b *TaskBuilder) Name(name string) *TaskBuilder

+ func (b *TaskBuilder) Network(network *NetworkConfig) *TaskBuilder

+ func (b *TaskBuilder) Publisher(publisher *SpecConfig) *TaskBuilder

+ func (b *TaskBuilder) ResourcesConfig(resourcesConfig *ResourcesConfig) *TaskBuilder

+ func (b *TaskBuilder) ResultPaths(resultPaths ...*ResultPath) *TaskBuilder

+ func (b *TaskBuilder) Timeouts(timeouts *TimeoutConfig) *TaskBuilder

+ type TimeoutConfig struct

+ ExecutionTimeout int64

+ func (t *TimeoutConfig) Copy() *TimeoutConfig

+ func (t *TimeoutConfig) GetExecutionTimeout() time.Duration

+ func (t *TimeoutConfig) Validate() error

+ type Validatable interface

+ Validate func() error