workflows

Documentation

Index

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

Functions

func ValidatedWorkflowSpec

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

Types

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(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
}

func NewEngine

func NewEngine(lggr logger.Logger, registry types.CapabilitiesRegistry) (engine *Engine, err error)

func (*Engine) Close

func (e *Engine) Close() error

func (*Engine) Start

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