Struct MetricsSnapshot

Source

pub struct MetricsSnapshot {Show 21 fields
    pub state: JobState,
    pub uptime_secs: u64,
    pub events_received: u64,
    pub bytes_received: u64,
    pub txns_applied: u64,
    pub txns_skipped: u64,
    pub rows_applied: u64,
    pub rows_copied: u64,
    pub bytes_copied: u64,
    pub feedback_sent: u64,
    pub reconnects: u64,
    pub last_received_lsn: Lsn,
    pub server_wal_end: Lsn,
    pub committed_lsn: Lsn,
    pub acked_lsn: Lsn,
    pub apply_lag_bytes: u64,
    pub inflight_items: u64,
    pub inflight_bytes: u64,
    pub rss_bytes: Option<u64>,
    pub last_apply_unix_micros: Option<u64>,
    pub connection: ConnectionState,
}

Fields§

§state: JobState§uptime_secs: u64§events_received: u64§bytes_received: u64§txns_applied: u64§txns_skipped: u64§rows_applied: u64§rows_copied: u64§bytes_copied: u64§feedback_sent: u64§reconnects: u64§last_received_lsn: Lsn§server_wal_end: Lsn§committed_lsn: Lsn§acked_lsn: Lsn§apply_lag_bytes: u64

server_wal_end - acked_lsn, bytes: WAL the server has produced that this job has not yet durably covered (applied, or acknowledged as carrying nothing for it).

§inflight_items: u64§inflight_bytes: u64§rss_bytes: Option<u64>§last_apply_unix_micros: Option<u64>§connection: ConnectionState

MetricsSnapshot

Struct MetricsSnapshot Copy item path

Fields§

Trait Implementations§

impl Clone for MetricsSnapshot

fn clone(&self) -> Self

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

impl Debug for MetricsSnapshot

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

impl Serialize for MetricsSnapshot

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

Auto Trait Implementations§

impl Freeze for MetricsSnapshot

impl RefUnwindSafe for MetricsSnapshot

impl Send for MetricsSnapshot

impl Sync for MetricsSnapshot

impl Unpin for MetricsSnapshot

impl UnsafeUnpin for MetricsSnapshot

impl UnwindSafe for MetricsSnapshot

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> CloneToUninit for Twhere T: Clone,

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

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> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

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

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 MetricsSnapshot

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

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> CloneToUninit for T
where T: Clone,

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

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

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>,