Documentation
¶
Index ¶
- func Parse(yamlWorkflow string) (*workflow, error)
- func ValidatedWorkflowJobSpec(tomlString string) (job.Job, error)
- type Config
- type Delegate
- func (d *Delegate) AfterJobCreated(jb job.Job)
- func (d *Delegate) BeforeJobCreated(spec job.Job)
- func (d *Delegate) BeforeJobDeleted(spec job.Job)
- func (d *Delegate) JobType() job.Type
- func (d *Delegate) OnDeleteJob(context.Context, job.Job) error
- func (d *Delegate) ServicesForSpec(_ context.Context, spec job.Job) ([]job.ServiceCtx, error)
- type Engine
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶ added in v2.11.0
type Config struct {
Spec string
WorkflowID string
WorkflowOwner string
WorkflowName string
Lggr logger.Logger
Registry core.CapabilitiesRegistry
MaxWorkerLimit int
QueueSize int
NewWorkerTimeout time.Duration
MaxExecutionDuration time.Duration
GetLocalNode func(ctx context.Context) (capabilities.Node, error)
Store store.Store
// contains filtered or unexported fields
}
type Delegate ¶
type Delegate struct {
// contains filtered or unexported fields
}
func NewDelegate ¶
func (*Delegate) AfterJobCreated ¶
func (*Delegate) BeforeJobCreated ¶
func (*Delegate) BeforeJobDeleted ¶
func (*Delegate) ServicesForSpec ¶
ServicesForSpec satisfies the job.Delegate interface.
type Engine ¶
type Engine struct {
services.StateMachine
// contains filtered or unexported fields
}
Engine handles the lifecycle of a single workflow and its executions.
Click to show internal directories.
Click to hide internal directories.