Struct ExecutionTimeObserverConfig

pub struct ExecutionTimeObserverConfig {
    pub observation_channel_capacity: Option<NonZeroUsize>,
    pub observation_cache_size: Option<NonZeroUsize>,
    pub object_debt_channel_capacity: Option<NonZeroUsize>,
    pub object_utilization_cache_size: Option<NonZeroUsize>,
    pub report_object_utilization_metric: Option<bool>,
    pub observation_sharing_object_utilization_threshold: Option<Duration>,
    pub observation_sharing_diff_threshold: Option<f64>,
    pub observation_sharing_min_interval: Option<Duration>,
    pub observation_sharing_rate_limit: Option<NonZeroU32>,
    pub observation_sharing_burst_limit: Option<NonZeroU32>,
}

Fields

observation_channel_capacity: Option<NonZeroUsize>

Size of the channel used for buffering local execution time observations.

If unspecified, this will default to 1_024.

observation_cache_size: Option<NonZeroUsize>

Size of the LRU cache used for storing local execution time observations.

If unspecified, this will default to 10_000.

object_debt_channel_capacity: Option<NonZeroUsize>

Size of the channel used for buffering object debt updates from consensus handler.

If unspecified, this will default to 128.

object_utilization_cache_size: Option<NonZeroUsize>

Size of the LRU cache used for tracking object utilization.

If unspecified, this will default to 50_000.

report_object_utilization_metric: Option<bool>

If true, the execution time observer will report per-object utilization metrics. Warning: This metric may have very large cardinality.

If unspecified, this will default to false.

observation_sharing_object_utilization_threshold: Option<Duration>

Unless target object utilization is exceeded by at least this amount, no observation will be shared with consensus.

If unspecified, this will default to 100 milliseconds.

observation_sharing_diff_threshold: Option<f64>

Unless the current local observation differs from the last one we shared by at least this percentage, no observation will be shared with consensus.

If unspecified, this will default to 0.05.

observation_sharing_min_interval: Option<Duration>

Minimum interval between sharing multiple observations of the same key.

If unspecified, this will default to 5 seconds.

observation_sharing_rate_limit: Option<NonZeroU32>

Global per-second rate limit for sharing observations. This is a safety valve and should not trigger during normal operation.

If unspecified, this will default to 10 observations per second.

observation_sharing_burst_limit: Option<NonZeroU32>

Global burst limit for sharing observations.

If unspecified, this will default to 100 observations.

Implementations

impl ExecutionTimeObserverConfig

pub fn observation_channel_capacity(&self) -> NonZeroUsize

pub fn observation_cache_size(&self) -> NonZeroUsize

pub fn object_debt_channel_capacity(&self) -> NonZeroUsize

pub fn object_utilization_cache_size(&self) -> NonZeroUsize

pub fn report_object_utilization_metric(&self) -> bool

pub fn observation_sharing_object_utilization_threshold(&self) -> Duration

pub fn observation_sharing_diff_threshold(&self) -> f64

pub fn observation_sharing_min_interval(&self) -> Duration

pub fn observation_sharing_rate_limit(&self) -> NonZeroU32

pub fn observation_sharing_burst_limit(&self) -> NonZeroU32

Trait Implementations

impl Clone for ExecutionTimeObserverConfig

fn clone(&self) -> ExecutionTimeObserverConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionTimeObserverConfig

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

Formats the value using the given formatter.

impl Default for ExecutionTimeObserverConfig

fn default() -> ExecutionTimeObserverConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExecutionTimeObserverConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExecutionTimeObserverConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.