Versions in this module Expand all Collapse all v0 v0.3.1 Aug 18, 2026 v0.3.0 Aug 11, 2026 Changes in this version + type NodeExecution struct + BranchName string + CreatedAt time.Time + FinishedAt *time.Time + ID uuid.UUID + InputSnapshot map[string]any + IterationIndex *int + Kind string + Metadata map[string]any + NodeID string + NodeSnapshot json.RawMessage + OutputSnapshot map[string]any + ParentNodeExecutionID uuid.UUID + StartedAt *time.Time + Status NodeExecutionStatus + Trace map[string]any + WorkflowExecutionID uuid.UUID + func GetNodeExecutionByID(ctx context.Context, db bun.IDB, id uuid.UUID) (*NodeExecution, error) + func (n *NodeExecution) Delete(ctx context.Context, db bun.IDB) error + func (n *NodeExecution) Insert(ctx context.Context, db bun.IDB) error + func (n *NodeExecution) Update(ctx context.Context, db bun.IDB) error + func (n *NodeExecution) Validate() error + func (n NodeExecution) GetCursor() string + func (n NodeExecution) GetSortField() string + func (n NodeExecution) GetSortValue() interface{} + func (n NodeExecution) GetUniqueField() string + func (n NodeExecution) GetUniqueValue() interface{} + type NodeExecutionStatus string + const NodeExecutionStatusBlocked + const NodeExecutionStatusCanceled + const NodeExecutionStatusFailed + const NodeExecutionStatusQueued + const NodeExecutionStatusRunning + const NodeExecutionStatusSucceeded + func (s *NodeExecutionStatus) UnmarshalJSON(b []byte) error + func (s NodeExecutionStatus) MarshalJSON() ([]byte, error) + func (s NodeExecutionStatus) Validate() error + type WorkflowExecution struct + CreatedAt time.Time + FinishedAt *time.Time + ID uuid.UUID + InputSnapshot map[string]any + Metadata map[string]any + OutputSnapshot map[string]any + ProjectDir string + StartedAt *time.Time + Status WorkflowExecutionStatus + WorkflowID uuid.UUID + WorkflowSlug string + WorkflowSnapshot json.RawMessage + WorkflowVersion string + func GetWorkflowExecutionByID(ctx context.Context, db bun.IDB, id uuid.UUID) (*WorkflowExecution, error) + func (w *WorkflowExecution) Delete(ctx context.Context, db bun.IDB) error + func (w *WorkflowExecution) Insert(ctx context.Context, db bun.IDB) error + func (w *WorkflowExecution) Update(ctx context.Context, db bun.IDB) error + func (w *WorkflowExecution) Validate() error + func (w WorkflowExecution) GetCursor() string + func (w WorkflowExecution) GetSortField() string + func (w WorkflowExecution) GetSortValue() interface{} + func (w WorkflowExecution) GetUniqueField() string + func (w WorkflowExecution) GetUniqueValue() interface{} + type WorkflowExecutionStatus string + const WorkflowExecutionStatusBlocked + const WorkflowExecutionStatusCanceled + const WorkflowExecutionStatusFailed + const WorkflowExecutionStatusQueued + const WorkflowExecutionStatusRunning + const WorkflowExecutionStatusSucceeded + func (s *WorkflowExecutionStatus) UnmarshalJSON(b []byte) error + func (s WorkflowExecutionStatus) MarshalJSON() ([]byte, error) + func (s WorkflowExecutionStatus) Validate() error
Go to main page