loop

type CallOptionsBuilder interface {
	Build(temperature float32) []model.Option
}

type Config struct {
	MaxIterations    int           // cap on model calls; the loop never exceeds it
	StopCondition    StopCondition // when the loop ends on its own
	Temperature      float64       // below 0: not sent, so the provider's default applies
	IterationTimeout time.Duration // bound on one model call; zero: none
	TotalTimeout     time.Duration // bound on the whole run; zero: none

	Reflect               ReflectCondition // zero: off; reviews never count toward MaxIterations
	IterationReviewPrompt string           // ReflectOnIteration judge; empty: built-in
	FinishReviewPrompt    string           // ReflectOnFinish judge; empty: built-in
	MaxReopens            int              // ReflectOnFinish: re-opens after drift; zero: 1

	StreamEvents      bool          // false: only error and done events
	EventBuffer       int           // event channel capacity; zero: 64
	EventSink         EventSink     // optional
	DoneDeliveryGrace time.Duration // wait for a reader of the done event; zero: 5s

	Pauses map[string]pause.Handler // tool name → handler, in place of the ToolExecutor

	StopInstructions string // instructions for the stop condition

	AutoNudgeText    string // sent after a text-only reply in StopOnFinishTool; empty: built-in
	DisableAutoNudge bool

	RetryMaxAttempts int // extra attempts after a transient failure; zero: 1; -1: none
	ErrorClassifier  ErrorClassifier

	DisableStreaming                  bool          // call Generate instead of Stream
	IdleChunkTimeout                  time.Duration // longest gap between streamed chunks; zero: 30s
	DisableIterationTimeoutDecoupling bool          // each call inherits the run's remaining time

	HistoryCompactor HistoryCompactor
	CallOptions      CallOptionsBuilder
	ModelIdentity    ModelIdentifier
	CostEstimator    CostEstimator

	TranscriptLogLevel slog.Level // level for transcript lines (they contain prompt text)
}

type ConfigChange = state.Change

type CostEstimator interface {
	Estimate(provider, model string, inputTokens, outputTokens int) float64
}

type ErrorClassifier interface {
	IsTransient(err error) bool
}

type EventSink interface {
	Write(evt event.Event)
}

type HistoryCompactor interface {
	Compact(msgs []*schema.Message) []*schema.Message
}

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

type ModelIdentifier interface {
	Identity() (provider, model string)
}

type ReflectCondition int

type State = state.Status

type StopCondition int

type ToolExecutor interface {
	ExecuteTool(ctx context.Context, name, arguments string) (string, error)
}