Documentation
¶
Index ¶
- type ExecutionTracker
- func (t *ExecutionTracker) CancelExecution(ctx context.Context, executionID uuid.UUID) error
- func (t *ExecutionTracker) CompleteExecution(ctx context.Context, executionID uuid.UUID, output json.RawMessage) error
- func (t *ExecutionTracker) FailExecution(ctx context.Context, executionID uuid.UUID, execErr error) error
- func (t *ExecutionTracker) LogWriter(workflowID uuid.UUID, executionID uuid.UUID, level store.LogLevel) io.Writer
- func (t *ExecutionTracker) RecordStep(ctx context.Context, executionID uuid.UUID, step *store.ExecutionStep) error
- func (t *ExecutionTracker) StartExecution(ctx context.Context, workflowID uuid.UUID, triggerType string, ...) (uuid.UUID, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecutionTracker ¶
type ExecutionTracker struct {
// contains filtered or unexported fields
}
ExecutionTracker wraps execution lifecycle to record executions, steps, and logs.
func NewExecutionTracker ¶
func NewExecutionTracker(executions store.ExecutionStore, logs store.LogStore) *ExecutionTracker
NewExecutionTracker creates a new ExecutionTracker.
func (*ExecutionTracker) CancelExecution ¶
CancelExecution marks an execution as cancelled.
func (*ExecutionTracker) CompleteExecution ¶
func (t *ExecutionTracker) CompleteExecution(ctx context.Context, executionID uuid.UUID, output json.RawMessage) error
CompleteExecution marks an execution as successfully completed.
func (*ExecutionTracker) FailExecution ¶
func (t *ExecutionTracker) FailExecution(ctx context.Context, executionID uuid.UUID, execErr error) error
FailExecution marks an execution as failed.
func (*ExecutionTracker) LogWriter ¶
func (t *ExecutionTracker) LogWriter(workflowID uuid.UUID, executionID uuid.UUID, level store.LogLevel) io.Writer
LogWriter returns an io.Writer that appends logs to the store at the given level.
func (*ExecutionTracker) RecordStep ¶
func (t *ExecutionTracker) RecordStep(ctx context.Context, executionID uuid.UUID, step *store.ExecutionStep) error
RecordStep records a step within an execution.
func (*ExecutionTracker) StartExecution ¶
func (t *ExecutionTracker) StartExecution(ctx context.Context, workflowID uuid.UUID, triggerType string, data json.RawMessage) (uuid.UUID, error)
StartExecution begins tracking a new workflow execution.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.