Add registers a new child process

mustExec executes a statement and fails the test on error

Transpile converts a PostgreSQL SQL statement to DuckDB-compatible SQL. It classifies the query first to skip unnecessary work: - Tier 0: No PG-specif

New creates a Transpiler with the given configuration. It registers all transforms appropriate for the config.

logQueryStarted records a query handing off to a worker. Pairs with logQueryFinished at every termination point so logs and traces can be cross-refere

Create creates a Duckling CR named exactly `name`. The name comes from the warehouse row's duckling_name (authoritative; the control plane never deriv

Open returns a reader for the cached data and counts a cache hit. Caller must close the reader.

DefaultConfig returns a Config with sensible defaults for simple queries.

Open decrypts a stored secret statement from the (org, user, name) row.

SharedState returns the additive shared worker lifecycle metadata for this worker. The zero value normalizes to an idle, unassigned worker.

runQueryTests runs multiple query tests

setTxError marks the transaction as failed if we're in a transaction. This should be called when a query fails within a transaction.

logQuery builds a QueryLogEntry from the connection context and sends it to the logger.

ResolveEffective layers CLI inputs on top of env vars on top of YAML on top of built-in defaults to produce the runtime config every duckgres binary b

extractArrowValue extracts a Go value from an Arrow array at the given row index.

Get fetches the named Duckling CR and parses its status.

NormalizedLifecycle treats the zero value as an idle, unassigned worker so existing worker structs can adopt this model without extra initialization.

Flush drains the in-process counter into the durable buffer once. Best-effort: on error it logs and returns; the unflushed counts stay in the counter

AppendValue appends a value to an Arrow array builder with type coercion. It first asks any registered Appender hooks (see RegisterAppender), then fal

Equal reports whether two profiles match (nil == zero == default).

openDuckgresConn opens a fresh connection to the test Duckgres server. Each connection gets its own in-memory DuckDB instance.

SetSharedState updates the additive shared worker lifecycle metadata without changing existing session scheduling behavior.

isTransactionConflict checks if an error is a DuckLake transaction conflict.

DB returns the underlying *sql.DB (for credential refresh and other direct access).

NewSessionManager creates a new session manager.

logw returns a logger pre-scoped with the worker's identity attrs (see workerLogAttrs), resolved by id. For workers no longer tracked locally it still

newTestProxy wires a CacheProxy with no peers and a tempdir-backed store.

Delete removes the named Duckling CR.

Regression tests for Classify wiring gaps: queries whose only PG-ism used a spelling the classifier's substring tokens missed (CAST vs ::, newline/tab

Image returns the worker image the lease was minted against. Surfaced so lifecycle-transition metrics can label the operation by image without an extr

--- Observation helpers --- observeLifecycleTransition records one transition attempt on duckgres_worker_lifecycle_transitions_total. Inputs are norma

NewWorkerLifecycle wires the service. cleanup may be nil if the caller only needs durable CAS transitions and no physical cleanup (e.g. tests that ass

NewFlightWorkerPool creates a new worker pool.

recoverConnection issues a ROLLBACK to reset a connection stuck in an aborted DuckLake metadata transaction state (cascading from a conflict).

isAbortedTransaction checks if the error is a cascading failure from a prior DuckLake transaction conflict where the metadata PostgreSQL connection is

counterVecLabelValue returns the value of a CounterVec series labelled with the given values. Returns 0 if the series has never been touched (matching

WorkerID returns the worker id this lease is for.

newTestServer returns an httptest origin plus a proxy that rewrites inbound forward-proxy-style requests to target that origin. DuckDB sends absolute-

Get returns the cached data for the given key, or nil if not found.

writeMessage writes a message to the client

doForwardProxyRequest sends a request through the proxy in forward-proxy form (absolute URI in the request line). httptest's serve path preserves the