#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSourceStatisticsUpdate {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
#[prost(uint64, tag = "2")]
pub messages_received: u64,
#[prost(uint64, tag = "3")]
pub updates_staged: u64,
#[prost(uint64, tag = "4")]
pub updates_committed: u64,
#[prost(uint64, tag = "5")]
pub bytes_received: u64,
#[prost(uint64, tag = "7")]
pub records_indexed: u64,
#[prost(uint64, tag = "6")]
pub bytes_indexed: u64,
#[prost(int64, optional, tag = "8")]
pub rehydration_latency_ms: ::core::option::Option<i64>,
#[prost(uint64, optional, tag = "9")]
pub snapshot_records_known: ::core::option::Option<u64>,
#[prost(uint64, optional, tag = "10")]
pub snapshot_records_staged: ::core::option::Option<u64>,
#[prost(bool, tag = "11")]
pub snapshot_committed: bool,
#[prost(uint64, optional, tag = "12")]
pub offset_known: ::core::option::Option<u64>,
#[prost(uint64, optional, tag = "13")]
pub offset_committed: ::core::option::Option<u64>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSinkStatisticsUpdate {
#[prost(message, optional, tag = "1")]
pub id: ::core::option::Option<::mz_repr::global_id::ProtoGlobalId>,
#[prost(uint64, tag = "2")]
pub messages_staged: u64,
#[prost(uint64, tag = "3")]
pub messages_committed: u64,
#[prost(uint64, tag = "4")]
pub bytes_staged: u64,
#[prost(uint64, tag = "5")]
pub bytes_committed: u64,
}