observability

Documentation

Index

• type ExecutionTracker
  • func NewExecutionTracker(executions store.ExecutionStore, logs store.LogStore) *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)

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

func (t *ExecutionTracker) CancelExecution(ctx context.Context, executionID uuid.UUID) error

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.