Struct mz_persist_client::cfg::PersistParameters

pub struct PersistParameters {
    pub blob_target_size: Option<usize>,
    pub compaction_minimum_timeout: Option<Duration>,
    pub consensus_connect_timeout: Option<Duration>,
    pub consensus_tcp_user_timeout: Option<Duration>,
    pub next_listen_batch_retryer: Option<RetryParameters>,
    pub sink_minimum_batch_updates: Option<usize>,
    pub storage_sink_minimum_batch_updates: Option<usize>,
    pub stats_audit_percent: Option<usize>,
    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>,
}

Updates to values in PersistConfig.

These reflect updates made to LaunchDarkly. They’re passed from environmentd through storage and compute commands and applied to PersistConfig to change its values.

Parameters can be set (Some) or unset (None). Unset parameters should be interpreted to mean “use the previous value”.

Fields

blob_target_size: Option<usize>

Configures DynamicConfig::blob_target_size.

compaction_minimum_timeout: Option<Duration>

Configures DynamicConfig::compaction_minimum_timeout.

consensus_connect_timeout: Option<Duration>

Configures DynamicConfig::consensus_connect_timeout.

consensus_tcp_user_timeout: Option<Duration>

Configures DynamicConfig::consensus_tcp_user_timeout.

next_listen_batch_retryer: Option<RetryParameters>

Configures DynamicConfig::next_listen_batch_retry_params.

sink_minimum_batch_updates: Option<usize>

Configures PersistConfig::sink_minimum_batch_updates.

storage_sink_minimum_batch_updates: Option<usize>

Configures PersistConfig::storage_sink_minimum_batch_updates.

stats_audit_percent: Option<usize>

Configures DynamicConfig::stats_audit_percent.

stats_collection_enabled: Option<bool>

Configures DynamicConfig::stats_collection_enabled.

stats_filter_enabled: Option<bool>

Configures DynamicConfig::stats_filter_enabled.

pubsub_client_enabled: Option<bool>

Configures DynamicConfig::pubsub_client_enabled

pubsub_push_diff_enabled: Option<bool>

Configures DynamicConfig::pubsub_push_diff_enabled

Implementations

impl PersistParameters

pub fn update(&mut self, other: PersistParameters)

Update the parameter values with the set ones from other.

pub fn all_unset(&self) -> bool

Return whether all parameters are unset.

pub fn apply(&self, cfg: &PersistConfig)

Applies the parameter values to persist’s in-memory config object.

Note that these overrides are not all applied atomically: i.e. it’s possible for persist to race with this and see some but not all of the parameters applied.

Trait Implementations

impl Arbitrary for PersistParameters

type Parameters = (<Option<usize> as Arbitrary>::Parameters, <Option<Duration> as Arbitrary>::Parameters, <Option<Duration> as Arbitrary>::Parameters, <Option<Duration> as Arbitrary>::Parameters, <Option<RetryParameters> as Arbitrary>::Parameters, <Option<usize> as Arbitrary>::Parameters, <Option<usize> as Arbitrary>::Parameters, <Option<usize> as Arbitrary>::Parameters, <Option<bool> as Arbitrary>::Parameters, (<Option<bool> as Arbitrary>::Parameters, <Option<bool> as Arbitrary>::Parameters, <Option<bool> as Arbitrary>::Parameters))

The type of parameters that arbitrary_with accepts for configuration of the generated Strategy. Parameters must implement Default.

type Strategy = Map<(<Option<usize> as Arbitrary>::Strategy, <Option<Duration> as Arbitrary>::Strategy, <Option<Duration> as Arbitrary>::Strategy, <Option<Duration> as Arbitrary>::Strategy, <Option<RetryParameters> as Arbitrary>::Strategy, <Option<usize> as Arbitrary>::Strategy, <Option<usize> as Arbitrary>::Strategy, <Option<usize> as Arbitrary>::Strategy, <Option<bool> as Arbitrary>::Strategy, (<Option<bool> as Arbitrary>::Strategy, <Option<bool> as Arbitrary>::Strategy, <Option<bool> as Arbitrary>::Strategy)), fn(_: (Option<usize>, Option<Duration>, Option<Duration>, Option<Duration>, Option<RetryParameters>, Option<usize>, Option<usize>, Option<usize>, Option<bool>, (Option<bool>, Option<bool>, Option<bool>))) -> PersistParameters>

The type of Strategy used to generate values of type Self.

fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self). The strategy is passed the arguments given in args.

fn arbitrary() -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self).

impl Clone for PersistParameters

fn clone(&self) -> PersistParameters

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PersistParameters

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PersistParameters

fn default() -> PersistParameters

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PersistParameters

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq<PersistParameters> for PersistParameters

fn eq(&self, other: &PersistParameters) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl RustType<ProtoPersistParameters> for PersistParameters

fn into_proto(&self) -> ProtoPersistParameters

Convert a Self into a Proto value.

fn from_proto(proto: ProtoPersistParameters) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.

impl Serialize for PersistParameters

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for PersistParameters

impl StructuralEq for PersistParameters

impl StructuralPartialEq for PersistParameters