package mz_persist_client.internal.state

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: ProtoRollup

• uint64 seqno = 1

• uint64 start_ms = 2

Used in: ProtoRollup

• uint64 seqno = 1

• uint64 start_ms = 2

Used in: ProtoMerge

• uint64 start_ms = 1

Used in: ProtoRollup

• optional ProtoU64Antichain since = 1

• int64 opaque = 2

• string opaque_codec = 3

• optional ProtoHandleDebugState debug = 4

Used in: ProtoRollup

• bytes key = 1

• bytes key_data_type = 3

• bytes val = 2

• bytes val_data_type = 4

Used in: ProtoCriticalReaderState, ProtoLeasedReaderState, ProtoWriterState

• string hostname = 1

• string purpose = 2

Used in: batch.ProtoBatch, ProtoIdHollowBatch, ProtoTrace

• optional ProtoU64Description desc = 1

• repeated ProtoHollowBatchPart parts = 4

• uint64 len = 3

• repeated uint64 runs = 5

• repeated ProtoRunMeta run_meta = 6

• repeated string deprecated_keys = 2

Used in: batch.ProtoLeasedBatchPart, ProtoHollowBatch, ProtoHollowRun

• oneof kind

  • string key = 1

  • bytes inline = 5

  • ProtoHollowRunRef run_ref = 11

• optional ProtoU64Antichain ts_rewrite = 4

• uint64 encoded_size_bytes = 2

  Only set when Kind is Key or RunRef

• bytes key_lower = 3

• optional bytes structured_key_lower = 10

• optional int64 diffs_sum = 6

• oneof format

  • google.protobuf.Empty row = 7

  • uint64 row_and_columnar = 8

  • google.protobuf.Empty structured = 13

• optional uint64 schema_id = 12

• optional bytes key_stats = 536870906

• optional uint64 deprecated_schema_id = 9

Used in: ProtoRollup

• string key = 1

• optional uint64 encoded_size_bytes = 2

• repeated ProtoHollowBatchPart parts = 4

Used in: ProtoHollowBatchPart

• string key = 1

  The location of the run struct in the blob store.

• uint64 max_part_bytes = 2

  The largest size in bytes of any part in the run. This is useful to limit memory use during compaction.

Used in: ProtoTrace

• optional ProtoSpineId id = 1

• optional ProtoHollowBatch batch = 2

Used in: ProtoTrace

• optional ProtoSpineId id = 1

• optional ProtoMerge merge = 2

Used in: ProtoTrace

• optional ProtoSpineId id = 1

• optional ProtoSpineBatch batch = 2

• optional ProtoU64Description desc = 1

• uint64 index = 2

• optional mz_persist.gen.persist.ProtoColumnarRecords updates = 3

Used in: ProtoRollup

• uint64 lower = 1

• uint64 upper = 2

• repeated ProtoVersionedData diffs = 3

Used in: ProtoRollup

• optional ProtoU64Antichain since = 1

• uint64 seqno = 2

• uint64 last_heartbeat_timestamp_ms = 3

• uint64 lease_duration_ms = 4

• optional ProtoHandleDebugState debug = 5

Used in: ProtoIdMerge

• optional ProtoU64Antichain since = 1

• uint64 remaining_work = 2

• optional ProtoCompaction active_compaction = 3

• string applier_version = 11

• string shard_id = 1

• string key_codec = 2

• string val_codec = 3

• string ts_codec = 4

• string diff_codec = 5

• uint64 seqno = 6

• uint64 walltime_ms = 15

• string hostname = 14

• uint64 last_gc_req = 10

• optional ProtoActiveRollup active_rollup = 19

• optional ProtoActiveGC active_gc = 20

• map<uint64, ProtoHollowRollup> rollups = 16

• optional ProtoTrace trace = 7

• map<string, ProtoLeasedReaderState> leased_readers = 8

• map<string, ProtoCriticalReaderState> critical_readers = 13

• map<string, ProtoWriterState> writers = 9

• map<uint64, ProtoEncodedSchemas> schemas = 18

• optional ProtoInlinedDiffs diffs = 17

• map<uint64, string> deprecated_rollups = 12

  MIGRATION: We previously stored rollups as a `SeqNo -> string Key` map, but now the value is a `struct HollowRollup`.

Data that should be common across all parts in a run.

Used in: ProtoHollowBatch

• ProtoRunOrder order = 1

• optional uint64 schema_id = 3

• optional uint64 deprecated_schema_id = 2

Used in: ProtoRunMeta

• UNKNOWN = 0

  The ordering of the data is not available; it can only be determined heuristically once the part is fetched by inspecting the batch description.

• UNORDERED = 1

  No particular order.

• CODEC = 2

  Ordered by the codec-encoded bytes of the key, value, and timestamp.

• STRUCTURED = 3

  Ordered by the structured encoding of the key, value, and timestamp.

Used in: ProtoIdSpineBatch

• uint64 level = 1

• optional ProtoU64Description desc = 2

• repeated ProtoSpineId parts = 3

• repeated ProtoU64Description descs = 4

Used in: ProtoIdHollowBatch, ProtoIdMerge, ProtoIdSpineBatch, ProtoSpineBatch

• uint64 lo = 1

• uint64 hi = 2

Used in: ProtoRollup

• optional ProtoU64Antichain since = 1

• repeated ProtoHollowBatch legacy_batches = 2

• repeated ProtoIdHollowBatch hollow_batches = 3

• repeated ProtoIdSpineBatch spine_batches = 4

• repeated ProtoIdMerge merges = 5

Used in: batch.ProtoFetchBatchFilter, batch.ProtoFetchBatchFilterListen, ProtoCriticalReaderState, ProtoHollowBatchPart, ProtoLeasedReaderState, ProtoMerge, ProtoTrace, ProtoU64Description, ProtoWriterState

• repeated int64 elements = 1

Used in: batch.ProtoLeasedBatchPart, ProtoHollowBatch, ProtoInlineBatchPart, ProtoSpineBatch

• optional ProtoU64Antichain lower = 1

• optional ProtoU64Antichain upper = 2

• optional ProtoU64Antichain since = 3

Used in: ProtoInlinedDiffs

• uint64 seqno = 1

• bytes data = 2

Used in: ProtoRollup

• uint64 last_heartbeat_timestamp_ms = 1

• uint64 lease_duration_ms = 2

• string most_recent_write_token = 3

• optional ProtoU64Antichain most_recent_write_upper = 4

• optional ProtoHandleDebugState debug = 5