Module peek_client 

Structs

ExecutionLogging 🔒

The session task’s slot for the end-of-execution obligation of the statement it is running. One slot is held for the whole SessionClient::execute call and there is exactly one retirement site.

PeekClient

Clients needed for peek sequencing in the Adapter Frontend.

StatementLoggingGuard 🔒

RAII guard owning a frontend statement-logging lifecycle.

Enums

CollectionLookupError

Errors arising during collection lookup in peek client operations.

TakeOver 🔒

Which statement the session task is taking the log entry over for.

Functions

count_statement 🔒

Bumps the per-statement counters Coordinator::handle_execute maintains.

end_reason 🔒

Maps an execution outcome to the reason to record for it.

terminates_elsewhere 🔒

Whether someone else logs the end of execution for response: the coordinator for a registered peek, the protocol layer for a subscribe, a FETCH or a COPY FROM. The dispatch sites that produce these defuse the slot, so an armed slot alongside one of them means a dispatch site did not.

Type Aliases

StorageCollectionsHandle

Storage collections trait alias we need to consult for since/frontiers.