Module appkit 

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

Structs

ConnectionPool

Maps chat sessions to daemon loops.

DaemonSession

Dual-socket session: stream + lazy RPC sidecar.

DaemonSessionOptions

Options for constructing a DaemonSession.

ErrQueryBusy

Session already has an in-flight query.

EventClassifier

Classifies turn chunks for product backends.

InMemorySessionStore

Process-local store.

InputOpts

Optional input knobs for TurnRunner.

PoolConfig

Pool configuration.

PoolStats

Pool stats snapshot.

PooledConn

A pooled connection bound to a session.

QueryGate

Single-flight gate keyed by session id.

SendTurnOptions

Options for send_turn.

SessionRecord

Persisted session record.

TurnBoundary

Applies DaemonSession end rules to pool frames.

TurnChunk

One streamed turn chunk.

TurnConfig

Turn runner configuration.

TurnLifecycleGate

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

TurnRunner

Executes a turn against a pooled connection.

Enums

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

input_message_for_loop

Helper to build flat loop_input dict (coerced by callers to notification).

is_daemon_turn_end_event

True for TurnBoundary completion_event values (not phase deliverables).