Module appkit 

Application kit: DaemonSession, pool, TurnRunner, and helpers.

Structs

ChatEventResult

Structured outcome of classifying one daemon event.

ClassifierConfig

Product-specific classifier knobs.

ClassifierConfigError

Error constructing an EventClassifier.

CompactImageOptions

Controls compact_image_attachment. Zero fields use defaults.

ConnectionPool

Manages daemon connections, one active slot per session id.

DaemonSession

Dual-socket session: stream + lazy RPC sidecar.

DaemonSessionOptions

Options for constructing a DaemonSession.

ErrPoolExhausted

Returned when no idle pool slot is immediately available.

ErrQueryBusy

Returned when an app key already has an in-flight query.

EventClassifier

Maps decoded daemon events into deliverable, streaming, or failed outcomes.

InMemorySessionStore

Process-local store.

InputOpts

Optional input knobs for TurnRunner.

PoolConfig

Pool configuration.

PoolStats

Pool stats snapshot.

PooledConn

One connection slot in the pool.

QueryGate

Enforces single-flight query execution per app key with daemon-first cancel.

SendTurnOptions

Options for send_turn.

SessionRecord

Persisted session record.

SseBroadcaster

Generic, string-keyed pub/sub fan-out for SSE-style event delivery.

SseEvent

One Server-Sent Event payload. The event type vocabulary (delta / complete / query_error / status_change / …) is app-defined.

TurnBoundary

Applies DaemonSession end rules to pool frames.

TurnChunk

One streamed turn chunk.

TurnConfig

Turn runner configuration.

TurnEventStats

Tracks per-turn stream filtering counters.

TurnLifecycleGate

Per-turn progress flags (DaemonSession parity; not shared across chats).

TurnRunner

Executes a turn against a pooled connection.

Enums

ChatEventTerminal

How a processed event should end the query loop.

TimeoutPolicy

Timeout policy for idle / query / stream-close.

Constants

TURN_END_IDLE

Completion event for gated status=idle.

TURN_END_STOPPED

Completion event for status=stopped after running.

TURN_END_STREAM_END

Completion event for turn-scoped soothe.stream.end.

Traits

SessionStore

Session ↔ loop persistence.

Functions

compact_attachments

Applies compact_image_attachment to each attachment map that carries mime_type + data.

compact_image_attachment

Downscales image/* payloads when either dimension exceeds CompactImageOptions::max_dim.

default_thinking_step_events

Default thinking-step event allowlist (overridable via ClassifierConfig).

extract_thinking_step

Maps an allowlisted progress event to one structured UI line.

input_message_for_loop

Build a protocol-1 loop_input notification envelope (Go InputMessageForLoop).

is_daemon_turn_end_event

True for TurnBoundary completion_event values (not phase deliverables).

should_drop_stream_chunk_early

Reports whether a chunk can be skipped before the turn pipeline.

Type Aliases

AppKey

Application conversation key used by super::ConnectionPool, super::QueryGate, super::TurnRunner, and super::SessionStore (e.g. Triarch chat_id).

CancelFn

Local cancel callback for an in-flight query (typically a timeout context cancel).

EarlyDropFn

Filters non-actionable stream chunks before yield (Go EarlyDropFn).

SendCancelFn

Async daemon-cancel sender (command_request cancel for the loop).