headgateworkflow

Documentation

Overview

Package headgateworkflow implements durable DAG dependencies as an opt-in layer over headgate's ordinary pending jobs. It adds no driver dependency to core.

Index

• Constants
• func RegisterCoordinator(registry *headgate.Registry, inspect headgate.InspectStore, poll time.Duration) error
• type CoordinatorArgs
  • func (CoordinatorArgs) Kind() string
• type Workflow
  • func New(id string) *Workflow
  • func (w *Workflow) Add(name string, env headgate.Envelope, deps ...string) *Workflow
  • func (w *Workflow) CoordinatorQueue(queue string) *Workflow
  • func (w *Workflow) Prepare() ([]headgate.Envelope, error)
  • func (w *Workflow) Retention(d time.Duration) error

Constants

const (
	CoordinatorKind = "headgate:workflow"
)

Functions

func RegisterCoordinator

func RegisterCoordinator(registry *headgate.Registry, inspect headgate.InspectStore, poll time.Duration) error

RegisterCoordinator installs the durable dependency resolver. Each tick performs one bounded point read per node; it never scans queue depth.

Types

type CoordinatorArgs

type CoordinatorArgs struct {
	WorkflowID string     `json:"workflow_id"`
	Nodes      []nodeSpec `json:"nodes"`
}

func (CoordinatorArgs) Kind

func (CoordinatorArgs) Kind() string

type Workflow

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

Workflow is a validated DAG builder. Prepare returns one atomic enqueue batch: the durable coordinator followed by every child in pending state.

func New

func New(id string) *Workflow

func (*Workflow) Add

func (w *Workflow) Add(name string, env headgate.Envelope, deps ...string) *Workflow

func (*Workflow) CoordinatorQueue

func (w *Workflow) CoordinatorQueue(queue string) *Workflow

func (*Workflow) Prepare

func (w *Workflow) Prepare() ([]headgate.Envelope, error)

func (*Workflow) Retention

func (w *Workflow) Retention(d time.Duration) error