worker

type Config struct {
	// Driver is the storage backend for persisting nodes.
	Driver storage.Driver

	// Publisher is an optional event publisher for newly inserted nodes.
	// If nil, publishing is disabled.
	Publisher publisher.Publisher

	// NumWorkers is the number of background workers in the pool.
	NumWorkers uint

	// QueueSize is the capacity of the buffered job channel (defaults to 256).
	QueueSize uint

	// Project is the git repository or project name to tag on stored nodes.
	Project string

	// Logger is the provided logger
	Logger *slog.Logger
}

type Job struct {
	Provider  string
	AgentName string
	// ThreadID is the harness sub-thread that fired this call ("" for
	// the main thread), captured at the wire and stamped onto the
	// turn's nodes as non-hashed metadata.
	ThreadID string
	Req      *llm.ChatRequest
	Resp     *llm.ChatResponse

	// Session is the optional session-tracking envelope attached to
	// the turn at the ingest HTTP boundary. When non-nil and the
	// driver supports session-aware ingest (Postgres), the worker
	// pool runs the transactional path: a `sessions` row is UPSERTed,
	// nodes are inserted with a non-NULL session_id FK, and counters
	// are rolled up — all in one Tx. When nil OR when the driver does
	// not implement that capability (e.g. inmemory), the legacy
	// per-node Put loop runs and session metadata is dropped on the
	// floor — this keeps the local CLI proxy and unit tests working
	// without a Postgres backend.
	Session *sessions.IngestEnvelope
}

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