Module state

Source

ModulesΒ§

proto_hollow_batch_part
Nested message and enum types in ProtoHollowBatchPart.

StructsΒ§

ActiveGc
A garbage collection request that is currently being computed.
ActiveRollup
A rollup that is currently being computed.
CriticalReaderState
EncodedSchemas
A key and val Codec::Schema encoded via Codec::encode_schema.
ExpiryMetrics
GcConfig
HandleDebugState
Debugging info for a reader or writer.
HollowBatch
A Batch but with the updates themselves stored externally.
HollowBatchPart
A subset of a HollowBatch corresponding 1:1 to a blob.
HollowRollup
A pointer to a rollup stored externally.
HollowRun
An ordered list of parts, generally stored as part of a larger run.
HollowRunRef
A reference to a HollowRun, including the key in the blob store and some denormalized metadata.
IdempotencyToken
A token to disambiguate state commands that could not otherwise be idempotent.
LeasedReaderState
MissingBlob
A blob was missing!
NoOpStateTransition
A sentinel for a state transition that was a no-op.
OpaqueState
ProtoActiveGc
ProtoActiveRollup
ProtoCompaction
ProtoCriticalReaderState
ProtoEncodedSchemas
ProtoHandleDebugState
ProtoHollowBatch
ProtoHollowBatchPart
ProtoHollowRollup
ProtoHollowRun
ProtoHollowRunRef
ProtoIdHollowBatch
ProtoIdMerge
ProtoIdSpineBatch
ProtoInlineBatchPart
ProtoInlinedDiffs
ProtoLeasedReaderState
ProtoMerge
ProtoRollup
ProtoRunMeta
Data that should be common across all parts in a run.
ProtoSpineBatch
ProtoSpineId
ProtoStateDiff
ProtoStateFieldDiffs
A columnar encoding of Vec<StateFieldDiff<K, V>> with heterogeneous K and V.
ProtoTrace
ProtoU64Antichain
ProtoU64Description
ProtoVersionedData
ProtoWriterState
RunId
RunMeta
Metadata shared across a run.
Since
Wrapper for Antichain that represents a Since
State
StateCollections
StateSizeMetrics
TypedState
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
WriterState

EnumsΒ§

BatchPart
Part of the updates in a Batch.
CompareAndAppendBreak
HollowBlobRef
A pointer to a blob stored externally.
ProtoRunOrder
ProtoStateField
ProtoStateFieldDiffType
RunOrder πŸ”’
What order are the parts in this run in?
RunPart
Part of the updates in a run.
SnapshotErr

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 πŸ”’