Struct ReactiveProcessorHealth 

pub struct ReactiveProcessorHealth {

    pub processor_name: String,
    pub enabled: bool,
    pub running: bool,
    pub checkpoint_seq: u64,
    pub head_seq: u64,
    pub lag_commits: u64,
    pub runs_total: u64,
    pub processed_events_total: u64,
    pub failures_total: u64,
    pub retries_total: u64,
    pub dead_lettered_total: u64,
    pub last_processed_seq: u64,
    pub last_error: Option<String>,
    pub last_run_started_micros: Option<u64>,
    pub last_run_completed_micros: Option<u64>,
    pub last_success_micros: Option<u64>,
    pub last_failure_micros: Option<u64>,
    pub last_retry_micros: Option<u64>,
    pub last_sleep_ms: u64,
    pub last_batch_events: u64,
}

Fields

processor_name: String

enabled: bool

running: bool

checkpoint_seq: u64

head_seq: u64

lag_commits: u64

runs_total: u64

processed_events_total: u64

failures_total: u64

retries_total: u64

dead_lettered_total: u64

last_processed_seq: u64

last_error: Option<String>

last_run_started_micros: Option<u64>

last_run_completed_micros: Option<u64>

last_success_micros: Option<u64>

last_failure_micros: Option<u64>

last_retry_micros: Option<u64>

last_sleep_ms: u64

last_batch_events: u64

Trait Implementations

impl Clone for ReactiveProcessorHealth

fn clone(&self) -> ReactiveProcessorHealth

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReactiveProcessorHealth

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

Formats the value using the given formatter.

impl PartialEq for ReactiveProcessorHealth

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

Tests for self and other values to be equal, and is used by ==.

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 Eq for ReactiveProcessorHealth

impl StructuralPartialEq for ReactiveProcessorHealth