Struct Metrics

Source

pub struct Metrics {Show 16 fields
    pub events_received: AtomicU64,
    pub bytes_received: AtomicU64,
    pub txns_applied: AtomicU64,
    pub txns_skipped: AtomicU64,
    pub rows_applied: AtomicU64,
    pub rows_copied: AtomicU64,
    pub bytes_copied: AtomicU64,
    pub feedback_sent: AtomicU64,
    pub reconnects: AtomicU64,
    pub last_received_lsn: AtomicU64,
    pub server_wal_end: AtomicU64,
    pub committed_lsn: AtomicU64,
    pub acked_lsn: AtomicU64,
    pub inflight_items: AtomicU64,
    pub inflight_bytes: AtomicU64,
    pub last_apply_unix_micros: AtomicU64,
    /* private fields */
}

Fields§

§events_received: AtomicU64§bytes_received: AtomicU64§txns_applied: AtomicU64§txns_skipped: AtomicU64§rows_applied: AtomicU64§rows_copied: AtomicU64§bytes_copied: AtomicU64§feedback_sent: AtomicU64§reconnects: AtomicU64§last_received_lsn: AtomicU64§server_wal_end: AtomicU64§committed_lsn: AtomicU64§acked_lsn: AtomicU64§inflight_items: AtomicU64§inflight_bytes: AtomicU64§last_apply_unix_micros: AtomicU64

Unix microseconds of the last target commit (0 = none yet).

Struct Metrics Copy item path

Fields§

Implementations§

impl Metrics

pub fn new() -> Self

pub fn set_state(&self, s: JobState)

pub fn state(&self) -> JobState

pub fn set_connection(&self, c: ConnectionState)

pub fn connection(&self) -> ConnectionState

pub fn mark_applied_now(&self)

pub fn add(&self, counter: &AtomicU64, n: u64)

pub fn set_lsn(&self, slot: &AtomicU64, lsn: Lsn)

pub fn snapshot(&self) -> MetricsSnapshot

Trait Implementations§

impl Default for Metrics

fn default() -> Self

Auto Trait Implementations§

impl !Freeze for Metrics

impl RefUnwindSafe for Metrics

impl Send for Metrics

impl Sync for Metrics

impl Unpin for Metrics

impl UnsafeUnpin for Metrics

impl UnwindSafe for Metrics

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

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

fn into(self) -> U

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

type Error = !

fn try_from(value: U) -> Result<T, !>

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

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

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

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Struct Metrics

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

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

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

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

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

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

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,