workflows

package

Go to main page

Versions in this module

v0

v0.13.0

Aug 10, 2026

Changes in this version

type Store

+ func (s *Store) ClaimDueCronTriggers(ctx context.Context, now time.Time, limit int, ...) ([]*TriggerRow, error)

v0.12.1

Aug 9, 2026

v0.12.0

Aug 9, 2026

v0.11.0

Aug 9, 2026

Changes in this version

+ type SessionOriginRow struct

+ CreatedAt time.Time

+ FireID *string

+ Origin string

+ SessionID string

+ Title string

+ TriggerID *string

+ WorkspaceID string

type Store

+ func (s *Store) ListSessionOrigins(ctx context.Context, workspaceID string) ([]*SessionOriginRow, error)

+ func (s *Store) ListWorkflowRunsByWorkspace(ctx context.Context, workspaceID string) ([]*WorkflowRunRow, error)

+ func (s *Store) RecordSessionOrigin(ctx context.Context, row *SessionOriginRow) error

v0.10.0

Aug 9, 2026

Changes in this version

type Store

+ func (s *Store) GetLastRoutineResult(ctx context.Context, triggerID string) (json.RawMessage, error)

+ func (s *Store) GetRecentRoutineResults(ctx context.Context, triggerID string, limit int) ([]json.RawMessage, error)

+ func (s *Store) ListPendingRoutineFires(ctx context.Context, limit int) ([]*TriggerFireRow, error)

+ func (s *Store) UpdateTriggerFireResult(ctx context.Context, fireID string, result json.RawMessage, status string) error

type TriggerRow

+ Agent string

+ CaptureMode string

+ MemoryMaxRuns int

+ MemoryMode string

+ PreserveSession string

+ Prompt string

+ ScriptArgs []string

+ ScriptEnv json.RawMessage

+ ScriptPath string

+ WorkflowID *string

+ WorkspaceID *string

type TriggerUpdate

+ Agent *string

+ CaptureMode *string

+ MemoryMaxRuns *int

+ MemoryMode *string

+ PreserveSession *string

+ Prompt *string

+ ScriptArgs []string

+ ScriptEnv json.RawMessage

+ ScriptPath *string

+ WorkflowID *string

+ WorkspaceID *string

v0.9.1

Aug 8, 2026

Changes in this version

type Store

+ func (s *Store) GetOrCreateScriptWorkflow(ctx context.Context, trigger *TriggerRow, specJSON json.RawMessage, ...) (*WorkflowRow, error)

+ func (s *Store) GetWorkflowPolicy(ctx context.Context, workflowID string) (onMissing, ownerType, ownerID string, err error)

+ func (s *Store) UpdateRunWorkspace(ctx context.Context, runID, workspaceID string) error

+ func (s *Store) UpdateWebhookSecret(ctx context.Context, triggerID string, secretCipher []byte, keyVersion int) error

type WorkflowRow

+ OnMissingWorkspace string

type WorkflowUpdate

+ OnMissingWorkspace *string

v0.9.0

Aug 8, 2026

v0.8.13

Aug 7, 2026

v0.8.12

Aug 7, 2026

Changes in this version

+ func RecordNodeDuration(nodeType string, durationSeconds float64)

+ func RecordRunFinished(status, errorCode, ownerType string, durationSeconds float64)

+ func RecordRunStarted()

+ func RecordSchedulerTick(durationSeconds float64)

+ func RecordTriggerFire(source, status string)

+ func RecordWebhookDelivery(webhookID, status string)

type Store

+ func (s *Store) GetTriggerByID(ctx context.Context, triggerID string) (*TriggerRow, error)

v0.8.11

Aug 7, 2026

Changes in this version

+ var ErrConcurrentRun = errors.New("workflow: a run is already in flight for this workflow")

+ var ErrDedupConflict = errors.New("workflow: duplicate webhook delivery")

+ var ErrNotFound = errors.New("workflow: not found")

+ type AgentNodeData struct

+ Agent string

+ EnforceStructuredOutput bool

+ OutputSchema json.RawMessage

+ Prompt string

+ Session string

+ SessionID string

+ System string

+ type ConditionCase struct

+ Expression string

+ ID string

+ type ConditionNodeData struct

+ Conditions []ConditionCase

+ type DefaultsBlock struct

+ MaxAttempts *int

+ Timeout string

+ type HTTPNodeData struct

+ Body string

+ Headers map[string]string

+ Method string

+ Timeout string

+ URL string

+ type ScriptNodeData struct

+ Handler string

+ Language string

+ type Spec struct

+ Edges []SpecEdge

+ Nodes []SpecNode

+ func ParseSpec(raw json.RawMessage) (*Spec, error)

+ type SpecEdge struct

+ Source string

+ SourceHandle string

+ Target string

+ type SpecNode struct

+ Data json.RawMessage

+ ID string

+ MaxAttempts int

+ Timeout string

+ Type string

+ type Store struct

+ func NewStore(pool *pgxpool.Pool) *Store

+ func (s *Store) ClaimQueuedRuns(ctx context.Context, limit int) ([]*WorkflowRunRow, error)

+ func (s *Store) CountTriggersByOwner(ctx context.Context, ownerType, ownerID string) (int, error)

+ func (s *Store) CountWorkflowsByOwner(ctx context.Context, ownerType, ownerID string) (int, error)

+ func (s *Store) CreateNodeRun(ctx context.Context, row *WorkflowNodeRunRow) error

+ func (s *Store) CreateTrigger(ctx context.Context, row *TriggerRow) error

+ func (s *Store) CreateTriggerFire(ctx context.Context, row *TriggerFireRow) error

+ func (s *Store) CreateWebhook(ctx context.Context, row *WebhookRow) error

+ func (s *Store) CreateWorkflow(ctx context.Context, row *WorkflowRow) error

+ func (s *Store) CreateWorkflowRun(ctx context.Context, row *WorkflowRunRow) error

+ func (s *Store) CreateWorkflowRunWithFire(ctx context.Context, fire *TriggerFireRow, run *WorkflowRunRow) error

+ func (s *Store) DeleteTrigger(ctx context.Context, ownerType, ownerID, triggerID string) error

+ func (s *Store) DeleteWorkflow(ctx context.Context, ownerType, ownerID, workflowID string) error

+ func (s *Store) DisableTrigger(ctx context.Context, triggerID string) error

+ func (s *Store) GetTrigger(ctx context.Context, ownerType, ownerID, triggerID string) (*TriggerRow, error)

+ func (s *Store) GetWebhook(ctx context.Context, webhookID string) (*WebhookRow, error)

+ func (s *Store) GetWebhookByTriggerID(ctx context.Context, triggerID string) (*WebhookRow, error)

+ func (s *Store) GetWorkflow(ctx context.Context, ownerType, ownerID, workflowID string) (*WorkflowRow, error)

+ func (s *Store) GetWorkflowRun(ctx context.Context, runID string) (*WorkflowRunRow, error)

+ func (s *Store) HasInFlightRun(ctx context.Context, workflowID string) (bool, error)

+ func (s *Store) IncrementTriggerFailures(ctx context.Context, triggerID string) (int, error)

+ func (s *Store) ListDueCronTriggers(ctx context.Context, now time.Time, limit int) ([]*TriggerRow, error)

+ func (s *Store) ListNodeRuns(ctx context.Context, workflowRunID string) ([]*WorkflowNodeRunRow, error)

+ func (s *Store) ListTriggerFires(ctx context.Context, triggerID string, limit, offset int) ([]*TriggerFireRow, error)

+ func (s *Store) ListTriggers(ctx context.Context, ownerType, ownerID string) ([]*TriggerRow, error)

+ func (s *Store) ListWorkflowRuns(ctx context.Context, workflowID string, limit, offset int) ([]*WorkflowRunRow, error)

+ func (s *Store) ListWorkflows(ctx context.Context, ownerType, ownerID string) ([]*WorkflowRow, error)

+ func (s *Store) RecordWebhookDelivery(ctx context.Context, webhookID, dedupKey string) error

+ func (s *Store) ResetTriggerFailures(ctx context.Context, triggerID string) error

+ func (s *Store) UpdateNodeRunStatus(ctx context.Context, nodeRunID, status string, output json.RawMessage, ...) error

+ func (s *Store) UpdateTrigger(ctx context.Context, ownerType, ownerID, triggerID string, upd *TriggerUpdate) (*TriggerRow, error)

+ func (s *Store) UpdateTriggerFireTimestamps(ctx context.Context, triggerID string, lastFiredAt time.Time, ...) error

+ func (s *Store) UpdateWorkflow(ctx context.Context, ownerType, ownerID, workflowID string, ...) (*WorkflowRow, error)

+ func (s *Store) UpdateWorkflowRunStatus(ctx context.Context, runID, status string, errorCode *string, ...) error

+ type TriggerFireRow struct

+ ActionResult json.RawMessage

+ ActionType string

+ CompletedAt *time.Time

+ FiredAt time.Time

+ ID string

+ InputEnvelope json.RawMessage

+ SourceType string

+ Status string

+ TriggerID string

+ type TriggerRow struct

+ AutoDisableAfter int

+ ConsecutiveFailures int

+ CreatedAt time.Time

+ Description string

+ Enabled bool

+ ID string

+ LastFiredAt *time.Time

+ Name string

+ NextFireAt *time.Time

+ OwnerID string

+ OwnerType string

+ SourceConfig json.RawMessage

+ SourceType string

+ TargetConfig json.RawMessage

+ TargetType string

+ UpdatedAt time.Time

+ type TriggerUpdate struct

+ AutoDisableAfter *int

+ Description *string

+ Enabled *bool

+ Name *string

+ SourceConfig json.RawMessage

+ TargetConfig json.RawMessage

+ TargetType *string

+ type ValidationError struct

+ Code string

+ Detail string

+ NodeID string

+ func ValidateSpec(spec *Spec, predecessorSchemas map[string]json.RawMessage, ...) []ValidationError

+ func (e ValidationError) Error() string

+ type WebhookRow struct

+ AllowedIPs []string

+ CreatedAt time.Time

+ ID string

+ IdempotencyHeader string

+ IdempotencyMode string

+ KeyVersion int

+ SecretCipher []byte

+ TriggerID string

+ type WorkflowNodeRunRow struct

+ Attempt int

+ Branch *string

+ Error json.RawMessage

+ ErrorCode *string

+ FinishedAt *time.Time

+ ID string

+ Input json.RawMessage

+ NodeID string

+ NodeType string

+ Output json.RawMessage

+ StartedAt time.Time

+ Status string

+ WorkflowRunID string

+ type WorkflowRow struct

+ CreatedAt time.Time

+ Defaults json.RawMessage

+ Description string

+ ID string

+ InputSchema json.RawMessage

+ Name string

+ OwnerID string

+ OwnerType string

+ Slug string

+ SpecJSON json.RawMessage

+ SpecYAML string

+ Status string

+ TargetWorkspaceID *string

+ UpdatedAt time.Time

+ type WorkflowRunRow struct

+ CreatedAt time.Time

+ Error json.RawMessage

+ ErrorCode *string

+ FinishedAt *time.Time

+ ID string

+ Input json.RawMessage

+ Output json.RawMessage

+ SpecSnapshot json.RawMessage

+ StartedAt *time.Time

+ Status string

+ TriggerFireID *string

+ TriggerID *string

+ UpdatedAt time.Time

+ WorkflowID string

+ WorkspaceID string

+ type WorkflowUpdate struct

+ Defaults json.RawMessage

+ Description *string

+ InputSchema json.RawMessage

+ Name *string

+ Slug *string

+ SpecJSON json.RawMessage

+ SpecYAML *string

+ Status *string

+ TargetWorkspaceID *string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL