Module mz_stash::postgres

Structs

ConsolidateRequest 🔒
Consolidator 🔒
The Consolidator receives since advancements on a channel and transactionally consolidates them. These can safely be done at a later time in a separate connection that doesn’t do leader or epoch checking because 1) having data that needs to be consolidated is not a correctness error and 2) the operations here are idempotent (can safely be run concurrently with a second stash).
CountedStatements 🔒
DebugStashFactory
Stash factory to use for tests that uses a random schema for a stash, which is re-used on all stash openings. The schema is dropped when this factory is dropped.
PreparedStatements 🔒
Stash
A Stash whose data is stored in a Postgres-compatible database. The format of the tables are not specified and should not be relied upon. The only promise is stability. Any changes to the table schemas will be accompanied by a clear migration path.
StashFactory
Factory type used to open new one or more Stash.