Struct ServerPulse 

pub struct ServerPulse {
    pub conn: Connection,
}

Access to the pulse row.

Fields

conn: Connection

Implementations

impl ServerPulse

pub fn new() -> Result<Self>

Opens the database; the table comes from the migrations.

pub fn record_accepted( &mut self, at: DateTime<Utc>, next_at: DateTime<Utc>, state: AgentState, stale_after_seconds: i64, clock_skew_seconds: i64, ) -> Result<()>

Records a pulse the server accepted.

pub fn record_failed( &mut self, at: DateTime<Utc>, next_at: DateTime<Utc>, error: &str, ) -> Result<()>

Records an attempt that did not arrive, and why.

pub fn last(&self) -> Result<Option<PulseRecord>>

The latest attempt, or None when there has been none since the pulse was last turned on.

pub fn clear(&mut self) -> Result<()>

Forgets the record, so what is reported next belongs to a pulse sent after this moment rather than to one from before it was turned off.