1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146

#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoStorageParameters {
    #[prost(uint64, tag = "4")]
    pub keep_n_source_status_history_entries: u64,
    #[prost(message, optional, tag = "5")]
    pub upsert_rocksdb_tuning_config: ::core::option::Option<
        ::mz_rocksdb_types::config::ProtoRocksDbTuningParameters,
    >,
    #[prost(bool, tag = "6")]
    pub finalize_shards: bool,
    #[prost(uint64, tag = "7")]
    pub keep_n_sink_status_history_entries: u64,
    #[prost(message, optional, tag = "8")]
    pub tracing: ::core::option::Option<::mz_tracing::params::ProtoTracingParameters>,
    #[prost(message, optional, tag = "9")]
    pub upsert_auto_spill_config: ::core::option::Option<ProtoUpsertAutoSpillConfig>,
    #[prost(message, optional, tag = "10")]
    pub storage_dataflow_max_inflight_bytes_config: ::core::option::Option<
        ProtoStorageMaxInflightBytesConfig,
    >,
    #[prost(message, optional, tag = "11")]
    pub grpc_client: ::core::option::Option<
        ::mz_service::params::ProtoGrpcClientParameters,
    >,
    #[prost(uint64, tag = "13")]
    pub shrink_upsert_unused_buffers_by_ratio: u64,
    #[prost(message, optional, tag = "16")]
    pub pg_source_tcp_timeouts: ::core::option::Option<ProtoPgSourceTcpTimeouts>,
    #[prost(message, optional, tag = "17")]
    pub pg_source_snapshot_statement_timeout: ::core::option::Option<
        ::mz_proto::ProtoDuration,
    >,
    #[prost(bool, tag = "18")]
    pub record_namespaced_errors: bool,
    #[prost(uint64, tag = "19")]
    pub keep_n_privatelink_status_history_entries: u64,
    #[prost(message, optional, tag = "20")]
    pub ssh_timeout_config: ::core::option::Option<ProtoSshTimeoutConfig>,
    #[prost(message, optional, tag = "21")]
    pub kafka_timeout_config: ::core::option::Option<ProtoKafkaTimeouts>,
    #[prost(message, optional, tag = "22")]
    pub statistics_interval: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "23")]
    pub statistics_collection_interval: ::core::option::Option<
        ::mz_proto::ProtoDuration,
    >,
    #[prost(message, optional, tag = "24")]
    pub pg_snapshot_config: ::core::option::Option<ProtoPgSourceSnapshotConfig>,
    #[prost(bool, tag = "27")]
    pub enable_dependency_read_hold_asserts: bool,
    #[prost(message, optional, tag = "28")]
    pub user_storage_managed_collections_batch_duration: ::core::option::Option<
        ::mz_proto::ProtoDuration,
    >,
    #[prost(message, optional, tag = "29")]
    pub mysql_source_timeouts: ::core::option::Option<ProtoMySqlSourceTimeouts>,
    #[prost(message, optional, tag = "31")]
    pub pg_source_wal_sender_timeout: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "30")]
    pub dyncfg_updates: ::core::option::Option<::mz_dyncfg::ConfigUpdates>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPgSourceTcpTimeouts {
    #[prost(message, optional, tag = "1")]
    pub connect_timeout: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(uint32, optional, tag = "2")]
    pub keepalives_retries: ::core::option::Option<u32>,
    #[prost(message, optional, tag = "3")]
    pub keepalives_idle: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "4")]
    pub keepalives_interval: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "5")]
    pub tcp_user_timeout: ::core::option::Option<::mz_proto::ProtoDuration>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoPgSourceSnapshotConfig {
    #[prost(bool, tag = "1")]
    pub collect_strict_count: bool,
    #[prost(bool, tag = "2")]
    pub fallback_to_strict_count: bool,
    #[prost(bool, tag = "3")]
    pub wait_for_count: bool,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoMySqlSourceTimeouts {
    #[prost(message, optional, tag = "1")]
    pub tcp_keepalive: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "2")]
    pub snapshot_max_execution_time: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "3")]
    pub snapshot_lock_wait_timeout: ::core::option::Option<::mz_proto::ProtoDuration>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoKafkaTimeouts {
    #[prost(bool, tag = "1")]
    pub keepalive: bool,
    #[prost(message, optional, tag = "2")]
    pub socket_timeout: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "5")]
    pub transaction_timeout: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "3")]
    pub socket_connection_setup_timeout: ::core::option::Option<
        ::mz_proto::ProtoDuration,
    >,
    #[prost(message, optional, tag = "4")]
    pub fetch_metadata_timeout: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "7")]
    pub progress_record_fetch_timeout: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "8")]
    pub default_metadata_fetch_interval: ::core::option::Option<
        ::mz_proto::ProtoDuration,
    >,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoSshTimeoutConfig {
    #[prost(message, optional, tag = "1")]
    pub check_interval: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "2")]
    pub connect_timeout: ::core::option::Option<::mz_proto::ProtoDuration>,
    #[prost(message, optional, tag = "3")]
    pub keepalives_idle: ::core::option::Option<::mz_proto::ProtoDuration>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoUpsertAutoSpillConfig {
    #[prost(bool, tag = "1")]
    pub allow_spilling_to_disk: bool,
    #[prost(uint64, tag = "2")]
    pub spill_to_disk_threshold_bytes: u64,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ProtoStorageMaxInflightBytesConfig {
    #[prost(uint64, optional, tag = "1")]
    pub max_in_flight_bytes_default: ::core::option::Option<u64>,
    #[prost(bool, tag = "4")]
    pub disk_only: bool,
    #[prost(double, optional, tag = "6")]
    pub max_in_flight_bytes_cluster_size_fraction: ::core::option::Option<f64>,
}