workflow

type Participant interface {
	// WorkflowID returns the workflow this component participates in.
	// Returns empty string if component handles multiple workflows dynamically.
	WorkflowID() string

	// Phase returns the phase name this component represents in the workflow.
	Phase() string

	// StateManager returns the state manager for updating workflow state.
	StateManager() *StateManager
}

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

type State struct {
	// ID is the unique execution identifier.
	ID string `json:"id"`

	// WorkflowID identifies which workflow definition this execution follows.
	WorkflowID string `json:"workflow_id"`

	// Phase is the current execution phase/step name.
	Phase string `json:"phase"`

	// Iteration tracks loop count for retry/iteration patterns.
	Iteration int `json:"iteration"`

	// MaxIter is the maximum allowed iterations (0 = unlimited).
	MaxIter int `json:"max_iter,omitempty"`

	// StartedAt is when the execution started.
	StartedAt time.Time `json:"started_at"`

	// UpdatedAt is when the state was last updated.
	UpdatedAt time.Time `json:"updated_at"`

	// CompletedAt is when the execution completed (nil if still running).
	CompletedAt *time.Time `json:"completed_at,omitempty"`

	// Error holds the last error message if the execution failed.
	Error string `json:"error,omitempty"`

	// Context holds arbitrary workflow-specific context data.
	Context map[string]any `json:"context,omitempty"`
}

type StateEntry struct {
	State    *State
	Revision uint64
}

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