#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoU64Antichain {
#[prost(int64, repeated, tag = "1")]
pub elements: ::prost::alloc::vec::Vec<i64>,
}
#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoU64Description {
#[prost(message, optional, tag = "1")]
pub lower: ::core::option::Option<ProtoU64Antichain>,
#[prost(message, optional, tag = "2")]
pub upper: ::core::option::Option<ProtoU64Antichain>,
#[prost(message, optional, tag = "3")]
pub since: ::core::option::Option<ProtoU64Antichain>,
}
#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoHollowBatchPart {
#[prost(message, optional, tag = "4")]
pub ts_rewrite: ::core::option::Option<ProtoU64Antichain>,
#[prost(uint64, tag = "2")]
pub encoded_size_bytes: u64,
#[prost(bytes = "bytes", tag = "3")]
pub key_lower: ::prost::bytes::Bytes,
#[prost(int64, optional, tag = "6")]
pub diffs_sum: ::core::option::Option<i64>,
#[prost(uint64, optional, tag = "9")]
pub schema_id: ::core::option::Option<u64>,
#[prost(bytes = "bytes", optional, tag = "536870906")]
pub key_stats: ::core::option::Option<::prost::bytes::Bytes>,
#[prost(oneof = "proto_hollow_batch_part::Kind", tags = "1, 5")]
pub kind: ::core::option::Option<proto_hollow_batch_part::Kind>,
#[prost(oneof = "proto_hollow_batch_part::Format", tags = "7, 8")]
pub format: ::core::option::Option<proto_hollow_batch_part::Format>,
}
pub mod proto_hollow_batch_part {
#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum Kind {
#[prost(string, tag = "1")]
Key(::prost::alloc::string::String),
#[prost(bytes, tag = "5")]
Inline(::prost::bytes::Bytes),
}
#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Oneof)]
pub enum Format {
#[prost(message, tag = "7")]
Row(()),
#[prost(uint64, tag = "8")]
RowAndColumnar(u64),
}
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoInlineBatchPart {
#[prost(message, optional, tag = "1")]
pub desc: ::core::option::Option<ProtoU64Description>,
#[prost(uint64, tag = "2")]
pub index: u64,
#[prost(message, optional, tag = "3")]
pub updates: ::core::option::Option<
::mz_persist::gen::persist::ProtoColumnarRecords,
>,
}
#[derive(serde::Serialize)]
#[derive(serde::Deserialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoHollowBatch {
#[prost(message, optional, tag = "1")]
pub desc: ::core::option::Option<ProtoU64Description>,
#[prost(message, repeated, tag = "4")]
pub parts: ::prost::alloc::vec::Vec<ProtoHollowBatchPart>,
#[prost(uint64, tag = "3")]
pub len: u64,
#[prost(uint64, repeated, tag = "5")]
pub runs: ::prost::alloc::vec::Vec<u64>,
#[prost(string, repeated, tag = "2")]
pub deprecated_keys: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ProtoSpineId {
#[prost(uint64, tag = "1")]
pub lo: u64,
#[prost(uint64, tag = "2")]
pub hi: u64,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoIdHollowBatch {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<ProtoSpineId>,
#[prost(message, optional, tag = "2")]
pub batch: ::core::option::Option<ProtoHollowBatch>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSpineBatch {
#[prost(uint64, tag = "1")]
pub level: u64,
#[prost(message, optional, tag = "2")]
pub desc: ::core::option::Option<ProtoU64Description>,
#[prost(message, repeated, tag = "3")]
pub parts: ::prost::alloc::vec::Vec<ProtoSpineId>,
#[prost(message, repeated, tag = "4")]
pub descs: ::prost::alloc::vec::Vec<ProtoU64Description>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoIdSpineBatch {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<ProtoSpineId>,
#[prost(message, optional, tag = "2")]
pub batch: ::core::option::Option<ProtoSpineBatch>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, Copy, PartialEq, ::prost::Message)]
pub struct ProtoCompaction {
#[prost(uint64, tag = "1")]
pub start_ms: u64,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoMerge {
#[prost(message, optional, tag = "1")]
pub since: ::core::option::Option<ProtoU64Antichain>,
#[prost(uint64, tag = "2")]
pub remaining_work: u64,
#[prost(message, optional, tag = "3")]
pub active_compaction: ::core::option::Option<ProtoCompaction>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoIdMerge {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<ProtoSpineId>,
#[prost(message, optional, tag = "2")]
pub merge: ::core::option::Option<ProtoMerge>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoHollowRollup {
#[prost(string, tag = "1")]
pub key: ::prost::alloc::string::String,
#[prost(uint64, optional, tag = "2")]
pub encoded_size_bytes: ::core::option::Option<u64>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoTrace {
#[prost(message, optional, tag = "1")]
pub since: ::core::option::Option<ProtoU64Antichain>,
#[prost(message, repeated, tag = "2")]
pub legacy_batches: ::prost::alloc::vec::Vec<ProtoHollowBatch>,
#[prost(message, repeated, tag = "3")]
pub hollow_batches: ::prost::alloc::vec::Vec<ProtoIdHollowBatch>,
#[prost(message, repeated, tag = "4")]
pub spine_batches: ::prost::alloc::vec::Vec<ProtoIdSpineBatch>,
#[prost(message, repeated, tag = "5")]
pub merges: ::prost::alloc::vec::Vec<ProtoIdMerge>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoLeasedReaderState {
#[prost(message, optional, tag = "1")]
pub since: ::core::option::Option<ProtoU64Antichain>,
#[prost(uint64, tag = "2")]
pub seqno: u64,
#[prost(uint64, tag = "3")]
pub last_heartbeat_timestamp_ms: u64,
#[prost(uint64, tag = "4")]
pub lease_duration_ms: u64,
#[prost(message, optional, tag = "5")]
pub debug: ::core::option::Option<ProtoHandleDebugState>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoCriticalReaderState {
#[prost(message, optional, tag = "1")]
pub since: ::core::option::Option<ProtoU64Antichain>,
#[prost(int64, tag = "2")]
pub opaque: i64,
#[prost(string, tag = "3")]
pub opaque_codec: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub debug: ::core::option::Option<ProtoHandleDebugState>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoWriterState {
#[prost(uint64, tag = "1")]
pub last_heartbeat_timestamp_ms: u64,
#[prost(uint64, tag = "2")]
pub lease_duration_ms: u64,
#[prost(string, tag = "3")]
pub most_recent_write_token: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub most_recent_write_upper: ::core::option::Option<ProtoU64Antichain>,
#[prost(message, optional, tag = "5")]
pub debug: ::core::option::Option<ProtoHandleDebugState>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoHandleDebugState {
#[prost(string, tag = "1")]
pub hostname: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub purpose: ::prost::alloc::string::String,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoVersionedData {
#[prost(uint64, tag = "1")]
pub seqno: u64,
#[prost(bytes = "bytes", tag = "2")]
pub data: ::prost::bytes::Bytes,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoInlinedDiffs {
#[prost(uint64, tag = "1")]
pub lower: u64,
#[prost(uint64, tag = "2")]
pub upper: u64,
#[prost(message, repeated, tag = "3")]
pub diffs: ::prost::alloc::vec::Vec<ProtoVersionedData>,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoEncodedSchemas {
#[prost(bytes = "bytes", tag = "1")]
pub key: ::prost::bytes::Bytes,
#[prost(bytes = "bytes", tag = "3")]
pub key_data_type: ::prost::bytes::Bytes,
#[prost(bytes = "bytes", tag = "2")]
pub val: ::prost::bytes::Bytes,
#[prost(bytes = "bytes", tag = "4")]
pub val_data_type: ::prost::bytes::Bytes,
}
#[derive(serde::Serialize)]
#[allow(missing_docs)]
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoRollup {
#[prost(string, tag = "11")]
pub applier_version: ::prost::alloc::string::String,
#[prost(string, tag = "1")]
pub shard_id: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub key_codec: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub val_codec: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub ts_codec: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub diff_codec: ::prost::alloc::string::String,
#[prost(uint64, tag = "6")]
pub seqno: u64,
#[prost(uint64, tag = "15")]
pub walltime_ms: u64,
#[prost(string, tag = "14")]
pub hostname: ::prost::alloc::string::String,
#[prost(uint64, tag = "10")]
pub last_gc_req: u64,
#[prost(btree_map = "uint64, message", tag = "16")]
pub rollups: ::prost::alloc::collections::BTreeMap<u64, ProtoHollowRollup>,
#[prost(message, optional, tag = "7")]
pub trace: ::core::option::Option<ProtoTrace>,
#[prost(btree_map = "string, message", tag = "8")]
pub leased_readers: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
ProtoLeasedReaderState,
>,
#[prost(btree_map = "string, message", tag = "13")]
pub critical_readers: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
ProtoCriticalReaderState,
>,
#[prost(btree_map = "string, message", tag = "9")]
pub writers: ::prost::alloc::collections::BTreeMap<
::prost::alloc::string::String,
ProtoWriterState,
>,
#[prost(btree_map = "uint64, message", tag = "18")]
pub schemas: ::prost::alloc::collections::BTreeMap<u64, ProtoEncodedSchemas>,
#[prost(message, optional, tag = "17")]
pub diffs: ::core::option::Option<ProtoInlinedDiffs>,
#[prost(btree_map = "uint64, string", tag = "12")]
pub deprecated_rollups: ::prost::alloc::collections::BTreeMap<
u64,
::prost::alloc::string::String,
>,
}