Struct mz_persist_client::cfg::ProtoPersistParameters
source · pub struct ProtoPersistParameters {Show 22 fields
pub blob_target_size: Option<u64>,
pub compaction_minimum_timeout: Option<ProtoDuration>,
pub consensus_connect_timeout: Option<ProtoDuration>,
pub sink_minimum_batch_updates: Option<u64>,
pub storage_sink_minimum_batch_updates: Option<u64>,
pub storage_source_decode_fuel: Option<u64>,
pub next_listen_batch_retryer: Option<ProtoRetryParameters>,
pub txns_data_shard_retryer: Option<ProtoRetryParameters>,
pub stats_audit_percent: Option<u64>,
pub stats_collection_enabled: Option<bool>,
pub stats_filter_enabled: Option<bool>,
pub pubsub_client_enabled: Option<bool>,
pub pubsub_push_diff_enabled: Option<bool>,
pub consensus_tcp_user_timeout: Option<ProtoDuration>,
pub rollup_threshold: Option<u64>,
pub blob_cache_mem_limit_bytes: Option<u64>,
pub consensus_connection_pool_ttl: Option<ProtoDuration>,
pub consensus_connection_pool_ttl_stagger: Option<ProtoDuration>,
pub reader_lease_duration: Option<ProtoDuration>,
pub stats_budget_bytes: Option<u64>,
pub stats_untrimmable_columns: Option<ProtoUntrimmableColumns>,
pub config_updates: Option<ConfigUpdates>,
}
Fields§
§blob_target_size: Option<u64>
§compaction_minimum_timeout: Option<ProtoDuration>
§consensus_connect_timeout: Option<ProtoDuration>
§sink_minimum_batch_updates: Option<u64>
§storage_sink_minimum_batch_updates: Option<u64>
§storage_source_decode_fuel: Option<u64>
§next_listen_batch_retryer: Option<ProtoRetryParameters>
§txns_data_shard_retryer: Option<ProtoRetryParameters>
§stats_audit_percent: Option<u64>
§stats_collection_enabled: Option<bool>
§stats_filter_enabled: Option<bool>
§pubsub_client_enabled: Option<bool>
§pubsub_push_diff_enabled: Option<bool>
§consensus_tcp_user_timeout: Option<ProtoDuration>
§rollup_threshold: Option<u64>
§blob_cache_mem_limit_bytes: Option<u64>
§consensus_connection_pool_ttl: Option<ProtoDuration>
§consensus_connection_pool_ttl_stagger: Option<ProtoDuration>
§reader_lease_duration: Option<ProtoDuration>
§stats_budget_bytes: Option<u64>
§stats_untrimmable_columns: Option<ProtoUntrimmableColumns>
§config_updates: Option<ConfigUpdates>
TODO(cfg): Replace ProtoPersistParameters entirely with this.
Implementations§
source§impl ProtoPersistParameters
impl ProtoPersistParameters
sourcepub fn blob_target_size(&self) -> u64
pub fn blob_target_size(&self) -> u64
Returns the value of blob_target_size
, or the default value if blob_target_size
is unset.
sourcepub fn sink_minimum_batch_updates(&self) -> u64
pub fn sink_minimum_batch_updates(&self) -> u64
Returns the value of sink_minimum_batch_updates
, or the default value if sink_minimum_batch_updates
is unset.
sourcepub fn stats_collection_enabled(&self) -> bool
pub fn stats_collection_enabled(&self) -> bool
Returns the value of stats_collection_enabled
, or the default value if stats_collection_enabled
is unset.
sourcepub fn stats_filter_enabled(&self) -> bool
pub fn stats_filter_enabled(&self) -> bool
Returns the value of stats_filter_enabled
, or the default value if stats_filter_enabled
is unset.
sourcepub fn storage_sink_minimum_batch_updates(&self) -> u64
pub fn storage_sink_minimum_batch_updates(&self) -> u64
Returns the value of storage_sink_minimum_batch_updates
, or the default value if storage_sink_minimum_batch_updates
is unset.
sourcepub fn stats_audit_percent(&self) -> u64
pub fn stats_audit_percent(&self) -> u64
Returns the value of stats_audit_percent
, or the default value if stats_audit_percent
is unset.
sourcepub fn pubsub_client_enabled(&self) -> bool
pub fn pubsub_client_enabled(&self) -> bool
Returns the value of pubsub_client_enabled
, or the default value if pubsub_client_enabled
is unset.
sourcepub fn pubsub_push_diff_enabled(&self) -> bool
pub fn pubsub_push_diff_enabled(&self) -> bool
Returns the value of pubsub_push_diff_enabled
, or the default value if pubsub_push_diff_enabled
is unset.
sourcepub fn rollup_threshold(&self) -> u64
pub fn rollup_threshold(&self) -> u64
Returns the value of rollup_threshold
, or the default value if rollup_threshold
is unset.
sourcepub fn blob_cache_mem_limit_bytes(&self) -> u64
pub fn blob_cache_mem_limit_bytes(&self) -> u64
Returns the value of blob_cache_mem_limit_bytes
, or the default value if blob_cache_mem_limit_bytes
is unset.
sourcepub fn stats_budget_bytes(&self) -> u64
pub fn stats_budget_bytes(&self) -> u64
Returns the value of stats_budget_bytes
, or the default value if stats_budget_bytes
is unset.
sourcepub fn storage_source_decode_fuel(&self) -> u64
pub fn storage_source_decode_fuel(&self) -> u64
Returns the value of storage_source_decode_fuel
, or the default value if storage_source_decode_fuel
is unset.
Trait Implementations§
source§impl Clone for ProtoPersistParameters
impl Clone for ProtoPersistParameters
source§fn clone(&self) -> ProtoPersistParameters
fn clone(&self) -> ProtoPersistParameters
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for ProtoPersistParameters
impl Debug for ProtoPersistParameters
source§impl Default for ProtoPersistParameters
impl Default for ProtoPersistParameters
source§impl Message for ProtoPersistParameters
impl Message for ProtoPersistParameters
source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
source§fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
Self: Sized,
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>where B: BufMut, Self: Sized,
source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere Self: Sized,
source§fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
Self: Sized,
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>where B: BufMut, Self: Sized,
source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere Self: Sized,
source§fn decode<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
fn decode<B>(buf: B) -> Result<Self, DecodeError>where B: Buf, Self: Default,
source§fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>where B: Buf, Self: Default,
source§fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>where B: Buf, Self: Sized,
self
. Read moresource§fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>where B: Buf, Self: Sized,
self
.source§impl PartialEq for ProtoPersistParameters
impl PartialEq for ProtoPersistParameters
source§fn eq(&self, other: &ProtoPersistParameters) -> bool
fn eq(&self, other: &ProtoPersistParameters) -> bool
self
and other
values to be equal, and is used
by ==
.source§impl RustType<ProtoPersistParameters> for PersistParameters
impl RustType<ProtoPersistParameters> for PersistParameters
source§fn into_proto(&self) -> ProtoPersistParameters
fn into_proto(&self) -> ProtoPersistParameters
Self
into a Proto
value.source§fn from_proto(proto: ProtoPersistParameters) -> Result<Self, TryFromProtoError>
fn from_proto(proto: ProtoPersistParameters) -> Result<Self, TryFromProtoError>
impl StructuralPartialEq for ProtoPersistParameters
Auto Trait Implementations§
impl RefUnwindSafe for ProtoPersistParameters
impl Send for ProtoPersistParameters
impl Sync for ProtoPersistParameters
impl Unpin for ProtoPersistParameters
impl UnwindSafe for ProtoPersistParameters
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
RustType::into_proto
.