Struct RuntimeStatus

Source

pub struct RuntimeStatus {Show 22 fields
    pub pid: i32,
    pub hostname: String,
    pub pgsync_version: String,
    pub started_at: String,
    pub updated_at: String,
    pub stopped_at: Option<String>,
    pub age_seconds: f64,
    pub stale: bool,
    pub state: String,
    pub connection: String,
    pub received_lsn: Lsn,
    pub server_wal_end: Lsn,
    pub committed_lsn: Lsn,
    pub acked_lsn: Lsn,
    pub apply_lag_bytes: i64,
    pub txns_applied: i64,
    pub rows_applied: i64,
    pub txns_per_s: f64,
    pub rows_per_s: f64,
    pub reconnects: i64,
    pub rss_bytes: Option<i64>,
    pub last_apply_at: Option<String>,
}

Fields§

§pid: i32§hostname: String§pgsync_version: String§started_at: String§updated_at: String§stopped_at: Option<String>§age_seconds: f64

Seconds since the heartbeat row was last written.

§stale: bool

True when the row is older than three heartbeat intervals and the process did not record a clean stop: the process is probably gone.

§state: String§connection: String§received_lsn: Lsn§server_wal_end: Lsn§committed_lsn: Lsn§acked_lsn: Lsn§apply_lag_bytes: i64§txns_applied: i64§rows_applied: i64§txns_per_s: f64§rows_per_s: f64§reconnects: i64§rss_bytes: Option<i64>§last_apply_at: Option<String>

RuntimeStatus

Struct RuntimeStatus Copy item path

Fields§

Trait Implementations§

impl Serialize for RuntimeStatus

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

Auto Trait Implementations§

impl Freeze for RuntimeStatus

impl RefUnwindSafe for RuntimeStatus

impl Send for RuntimeStatus

impl Sync for RuntimeStatus

impl Unpin for RuntimeStatus

impl UnsafeUnpin for RuntimeStatus

impl UnwindSafe for RuntimeStatus

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> Same for T

type Output = 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 RuntimeStatus

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