turnrunner

type Config struct {
	IdleTimeout time.Duration
	HardCeiling time.Duration
	TraceStore  turntrace.Store

	// DelegationBudgetMax is the delegation count threshold for budget warnings.
	// Zero means use default (15).
	DelegationBudgetMax int
}

type Executor interface {
	RunStreamingDetailed(
		ctx context.Context,
		sessionID, input string,
		onChunk adk.ChunkCallback,
		opts ...adk.RunOption,
	) (adk.RunReport, error)
}

type Request struct {
	SessionKey string
	Input      string
	Entrypoint string
	OnChunk    func(string)
	OnWarning  func(elapsed, hardCeiling time.Duration)

	// OnDelegation is called when a delegation event is observed in the trace.
	// from/to are agent names, reason is optional context.
	OnDelegation func(from, to, reason string)

	// OnBudgetWarning is called when delegation count approaches the threshold.
	OnBudgetWarning func(used, max int)

	// OnToolCall is called when a tool invocation begins.
	OnToolCall func(callID, toolName string, params map[string]any)

	// OnToolResult is called when a tool invocation completes.
	OnToolResult func(callID, toolName string, success bool, duration time.Duration, preview string)

	// OnThinking is called when thinking/reasoning is detected via genai.Part.Thought.
	// started=true means thinking began (summary is the thought text);
	// started=false means thinking ended.
	OnThinking func(agentName string, started bool, summary string)
}

type Result struct {
	ResponseText    string
	Outcome         TurnOutcome
	TraceID         string
	UserMessage     string
	Elapsed         time.Duration
	ErrorCode       string
	CauseClass      string
	CauseDetail     string
	OperatorSummary string
	Summary         string
}

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

type Sanitizer interface {
	Enabled() bool
	Sanitize(string) string
}

type TurnCallback func(sessionKey string)

type TurnOutcome = turntrace.Outcome