Skip to main content

Metrics

Struct Metrics 

pub struct Metrics {
Show 36 fields pub records: u64, pub log_bytes: u64, pub flushes: u64, pub inline_flushes: u64, pub flushed_records: u64, pub flush_us_total: u64, pub steps_run: u64, pub steps_replayed: u64, pub runs_started: u64, pub runs_finished: u64, pub runs_parked: u64, pub parked_entries: u64, pub run_table_bytes: u64, pub loaded_bytes: u64, pub open_store_frames: u64, pub open_store_bytes: u64, pub open_us: u64, pub budget_parks: u64, pub object_compactions: u64, pub journal_frames_read: u64, pub journal_bytes_read: u64, pub runs_loaded: u64, pub checkpoints: u64, pub index_bases_built: u64, pub determinism_errors: u64, pub busy: u64, pub gate_waits: u64, pub gate_wait_us_total: u64, pub stalls: u64, pub max_tick_us: u64, pub max_flush_us: u64, pub volatile_timers: u64, pub log_writes: u64, pub log_device_bytes: u64, pub log_rolls: u64, pub log_owner: u64,
}
Expand description

Counters, per shard. Cheap to copy; exported by the engine.

Fields§

§records: u64§log_bytes: u64§flushes: u64§inline_flushes: u64§flushed_records: u64§flush_us_total: u64§steps_run: u64§steps_replayed: u64§runs_started: u64§runs_finished: u64§runs_parked: u64

Number of times a live workflow was parked since opening the engine.

§parked_entries: u64

Current run-store index entries, including completed entries retained on disk.

§run_table_bytes: u64

Heap bytes of the run table (every run’s entry and its indexes).

§loaded_bytes: u64

Bytes of run state held in memory by loaded runs (an estimate; see [RuntimeConfig::memory_budget]).

§open_store_frames: u64

The last open: run store frames and bytes it read (the persisted index, or every frame of the store prefix when it had none), and how long it took.

§open_store_bytes: u64§open_us: u64§budget_parks: u64

Runs parked early because loaded state exceeded the memory budget.

§object_compactions: u64

Keys of object types continued as new with a snapshot of their state (see crate::object).

§journal_frames_read: u64

Run store frames read to rebuild journals (a parked run’s newest frame and the Delta frames it extends), and their bytes.

§journal_bytes_read: u64§runs_loaded: u64§checkpoints: u64§index_bases_built: u64

Index bases written a frame at a time between checkpoints and then named by one (see [Inner::write_index]).

§determinism_errors: u64§busy: u64§gate_waits: u64§gate_wait_us_total: u64§stalls: u64

Ticks and flushes over the stall threshold (see [Stall]).

§max_tick_us: u64

Longest tick and flush seen while stall tracing is on.

§max_flush_us: u64§volatile_timers: u64

Current volatile timers (step timeouts, heartbeat timeouts, retry backoff), including cancelled ones the timer heap still holds.

§log_writes: u64

The shared log’s writes to its device, the bytes they put there (headers and padding included; against log_bytes, the records’), and its segment rolls, since it opened. One shard of a log reports them, so a sum over shards counts each once.

§log_device_bytes: u64§log_rolls: u64§log_owner: u64

1 when the shared log’s owner thread writes (Linux, io_uring).

Trait Implementations§

§

impl Clone for Metrics

§

fn clone(&self) -> Metrics

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
§

impl Debug for Metrics

§

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

Formats the value using the given formatter. Read more
§

impl Default for Metrics

§

fn default() -> Metrics

Returns the “default value” for a type. Read more
§

impl PartialEq for Metrics

§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

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

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

impl Serialize for Metrics

§

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

Serialize this value into the given Serde serializer. Read more
§

impl Copy for Metrics

§

impl Eq for Metrics

§

impl StructuralPartialEq for Metrics

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.