workflows

Documentation

Index

• func GenerateJsonSchema() ([]byte, error)
• func Parse(yamlWorkflow string) (*workflow, error)
• func ParseWorkflowSpecYaml(data string) (workflowSpec, error)
• func ValidatedWorkflowSpec(tomlString string) (job.Job, error)
• type Config
• type Delegate
  • func NewDelegate(logger logger.Logger, registry types.CapabilitiesRegistry, ...) *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(ctx context.Context, jb job.Job, q pg.Queryer) error
  • func (d *Delegate) ServicesForSpec(ctx context.Context, spec job.Job) ([]job.ServiceCtx, error)
• type Engine
  • func NewEngine(cfg Config) (engine *Engine, err error)
  • func (e *Engine) Close() error
  • func (e *Engine) Start(ctx context.Context) error

Functions

func GenerateJsonSchema

func GenerateJsonSchema() ([]byte, error)

func Parse

func Parse(yamlWorkflow string) (*workflow, error)

func ParseWorkflowSpecYaml

func ParseWorkflowSpecYaml(data string) (workflowSpec, error)

func ValidatedWorkflowSpec

func ValidatedWorkflowSpec(tomlString string) (job.Job, error)

Types

type Config

type Config struct {
	Spec             string
	WorkflowID       string
	Lggr             logger.Logger
	Registry         types.CapabilitiesRegistry
	MaxWorkerLimit   int
	QueueSize        int
	NewWorkerTimeout time.Duration
}

type Delegate

type Delegate struct {
	// contains filtered or unexported fields
}

func NewDelegate

func NewDelegate(logger logger.Logger, registry types.CapabilitiesRegistry, legacyEVMChains legacyevm.LegacyChainContainer) *Delegate

func (*Delegate) AfterJobCreated

func (d *Delegate) AfterJobCreated(jb job.Job)

func (*Delegate) BeforeJobCreated

func (d *Delegate) BeforeJobCreated(spec job.Job)

func (*Delegate) BeforeJobDeleted

func (d *Delegate) BeforeJobDeleted(spec job.Job)

func (*Delegate) JobType

func (d *Delegate) JobType() job.Type

func (*Delegate) OnDeleteJob

func (d *Delegate) OnDeleteJob(ctx context.Context, jb job.Job, q pg.Queryer) error

func (*Delegate) ServicesForSpec

func (d *Delegate) ServicesForSpec(ctx context.Context, spec job.Job) ([]job.ServiceCtx, error)

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.

func NewEngine

func NewEngine(cfg Config) (engine *Engine, err error)

func (*Engine) Close

func (e *Engine) Close() error

func (*Engine) Start

func (e *Engine) Start(ctx context.Context) error