observability

const (
	OutcomeOK             = "ok"
	OutcomeError          = "error"
	OutcomeBudgetExceeded = "budget_exceeded"
	// OutcomeWatchdogHalt is a turn the behavioral watchdog stopped
	// under --watchdog=enforce. Distinct from error because it is the
	// backstop working, and distinct from budget_exceeded because the
	// session has runway left — an alert on this one should page
	// differently from either.
	OutcomeWatchdogHalt = "watchdog_halt"
)

const (
	TokenKindPrompt     = "prompt"
	TokenKindCandidates = "candidates"
)

const (
	MarkerOpMark  = "mark"  // MarkInterrupted (beginDrain / late-start mark)
	MarkerOpClear = "clear" // ClearInterrupted (clean finish during drain)
	MarkerOpPause = "pause" // PauseGate on a planned stop with --pause-sessions
)

const (
	GatePauseOperator    = "operator"     // POST /pause (incl. hard pause)
	GatePausePlannedStop = "planned_stop" // drain mark with --pause-sessions
)

const (
	// TimedPauseResumed: the timer drove a resume/consume to completion.
	TimedPauseResumed = "resumed"
	// TimedPauseSkipped: the fire was a benign no-op — an operator
	// resumed first, or the daemon was draining when the timer fired.
	TimedPauseSkipped = "skipped"
	// TimedPauseError: the resume/consume the timer attempted failed;
	// the timer is rescheduled and will retry.
	TimedPauseError = "error"
)

const (
	// ScheduledFireRan: the tick drove a turn to completion.
	ScheduledFireRan = "ran"
	// ScheduledFireSkipped: the tick came due while the daemon was
	// draining, so no turn was started. Not an error and not retried —
	// the next tick is the retry.
	ScheduledFireSkipped = "skipped"
	// ScheduledFireError: the turn the tick started failed. The cadence
	// is unaffected; the next tick fires on schedule.
	ScheduledFireError = "error"
	// ScheduledFireMissed: the tick passed with nobody to run it — the
	// daemon was down, or a previous run overran the interval — and was
	// coalesced away rather than caught up. Incremented once per
	// skipped tick, so a crash-looping daemon is visible as a rising
	// missed count rather than as silence.
	ScheduledFireMissed = "missed"
)

const (
	// AutoResumeResumed: a continuation turn ran to completion and the
	// interruption marker was cleared.
	AutoResumeResumed = "resumed"
	// AutoResumeCleared: the trailing event was already a clean model
	// turn (stale marker / clear race); the marker was cleared without
	// running a turn.
	AutoResumeCleared = "cleared"
	// AutoResumeSkippedStale: the interruption is older than the
	// freshness window; the marker was left for an operator.
	AutoResumeSkippedStale = "skipped_stale"
	// AutoResumeSkippedAmbiguous: the session carries a dangling mutating
	// intent (ambiguous effect); left for an operator ack.
	AutoResumeSkippedAmbiguous = "skipped_ambiguous"
	// AutoResumeSkippedLoopbreak: the per-session attempt breaker or the
	// per-boot cap tripped.
	AutoResumeSkippedLoopbreak = "skipped_loopbreak"
	// AutoResumeSkippedSuperseded: a concurrent turn advanced the session
	// after the scan (M1 TOCTOU recheck).
	AutoResumeSkippedSuperseded = "skipped_superseded"
	// AutoResumeSkippedUnsupported: a shape slice-1 does not drive
	// (non-coordinator dispatch, dangling sub-agent delegation, or a
	// multi-event repair).
	AutoResumeSkippedUnsupported = "skipped_unsupported"
	// AutoResumeError: the continuation turn was attempted and failed;
	// the marker was left in place.
	AutoResumeError = "error"
)

const (
	A2ATaskSubmitted     = "submitted"
	A2ATaskWorking       = "working"
	A2ATaskInputRequired = "input-required"
	A2ATaskCompleted     = "completed"
	A2ATaskFailed        = "failed"
	A2ATaskCanceled      = "canceled"
	A2ATaskRejected      = "rejected"
)

const (
	AGUIRunSuccess     = "success"
	AGUIRunInterrupted = "interrupted"
	AGUIRunError       = "error"
	AGUIRunAborted     = "aborted"
	AGUIRunRejected    = "rejected"
)