ModulesΒ§
- proto_
hollow_ batch_ part - Nested message and enum types in
ProtoHollowBatchPart
.
StructsΒ§
- Active
Gc - A garbage collection request that is currently being computed.
- Active
Rollup - A rollup that is currently being computed.
- Critical
Reader State - Encoded
Schemas - A key and val Codec::Schema encoded via Codec::encode_schema.
- Expiry
Metrics - GcConfig
- Handle
Debug State - Debugging info for a reader or writer.
- Hollow
Batch - A Batch but with the updates themselves stored externally.
- Hollow
Batch Part - A subset of a HollowBatch corresponding 1:1 to a blob.
- Hollow
Rollup - A pointer to a rollup stored externally.
- Hollow
Run - An ordered list of parts, generally stored as part of a larger run.
- Hollow
RunRef - A reference to a HollowRun, including the key in the blob store and some denormalized metadata.
- Idempotency
Token - A token to disambiguate state commands that could not otherwise be idempotent.
- Leased
Reader State - Missing
Blob - A blob was missing!
- NoOp
State Transition - A sentinel for a state transition that was a no-op.
- Opaque
State - Proto
Active Gc - Proto
Active Rollup - Proto
Compaction - Proto
Critical Reader State - Proto
Encoded Schemas - Proto
Handle Debug State - Proto
Hollow Batch - Proto
Hollow Batch Part - Proto
Hollow Rollup - Proto
Hollow Run - Proto
Hollow RunRef - Proto
IdHollow Batch - Proto
IdMerge - Proto
IdSpine Batch - Proto
Inline Batch Part - Proto
Inlined Diffs - Proto
Leased Reader State - Proto
Merge - Proto
Rollup - Proto
RunMeta - Data that should be common across all parts in a run.
- Proto
Spine Batch - Proto
Spine Id - Proto
State Diff - Proto
State Field Diffs - A columnar encoding of Vec<StateFieldDiff<K, V>> with heterogeneous K and V.
- Proto
Trace - Proto
U64Antichain - Proto
U64Description - Proto
Versioned Data - Proto
Writer State - RunId
- RunMeta
- Metadata shared across a run.
- Since
- Wrapper for Antichain that represents a Since
- State
- State
Collections - State
Size Metrics - Typed
State - A newtype wrapper of State that guarantees the K, V, and D codecs match the ones in durable storage.
- Upper
- Wrapper for Antichain that represents an Upper
- Writer
State
EnumsΒ§
- Batch
Part - Part of the updates in a Batch.
- Compare
AndAppend Break - Hollow
Blob Ref - A pointer to a blob stored externally.
- Proto
RunOrder - Proto
State Field - Proto
State Field Diff Type - RunOrder π
- What order are the parts in this run in?
- RunPart
- Part of the updates in a run.
- Snapshot
Err
ConstantsΒ§
- ENABLE_
INCREMENTAL_ πCOMPACTION - GC_
FALLBACK_ πTHRESHOLD_ MS - Determines how long to wait before an active GC is considered βstuckβ and a new GC is started.
- GC_
MAX_ πVERSIONS - See the config description string.
- GC_
MIN_ πVERSIONS - See the config description string.
- GC_
USE_ πACTIVE_ GC - Feature flag the new active GC tracking mechanism. We musnβt enable this until we are fully deployed on the new version.
- ROLLUP_
FALLBACK_ πTHRESHOLD_ MS - Determines how long to wait before an active rollup is considered βstuckβ and a new rollup is started.
- ROLLUP_
THRESHOLD π - Determines how often to write rollups, assigning a maintenance task after
rollup_threshold
seqnos have passed since the last rollup. - ROLLUP_
USE_ πACTIVE_ ROLLUP - Feature flag the new active rollup tracking mechanism. We musnβt enable this until we are fully deployed on the new version.
FunctionsΒ§
- decode_
structured_ πlower - serialize_
diffs_ πsum - serialize_
lazy_ πproto - serialize_
part_ πbytes - serialize_
part_ πstats