cliout

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

type CoordinatorConfig struct {
	Policy     Policy
	Stderr     io.Writer
	StreamLogs bool
	Debounce   time.Duration
	// Progress, when set, arms the coordinator on its first published event so
	// the footer appears for progress-only work (no display-eligible log yet).
	Progress *Reporter
}

type DisplayStarter interface {
	Start(backlog []LogEntry, live *LogConsumer) (unpainted []LogEntry, err error)
}

type FingersCrossed struct {
	// Trigger is the level that arms the flush when observed.
	Trigger slog.Level
	// Tail is the number of most-recent entries (all captured levels) kept
	// for the flush.
	Tail int
}

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

type LogEntry struct {
	Time    time.Time
	Level   slog.Level
	Message string
	Attrs   []slog.Attr
}

type Policy struct {
	// Display is the level floor for the live view — typically chattier than
	// the durable floor, since the view is transient.
	Display slog.Leveler

	// KeepAtOrAbove re-emits entries at or above this level to the durable
	// sink on teardown, independent of the live display level.
	KeepAtOrAbove slog.Level

	// FingersCrossed, when set, retains a tail of recent entries at all
	// captured levels and flushes them to the durable sink if an error
	// occurs — so the context around a failure survives even though it was
	// never shown.
	FingersCrossed *FingersCrossed
}

type Progress struct {
	Done  int
	Total int
	Unit  string      // optional noun for rendering, e.g. "chunks"
	Note  string      // optional live status of the work in flight, e.g. "embedding 4 entries · 37 chunks"
	Phase model.Phase // active stage; drives the footer label and arms the coordinator
}

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

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