Struct PgWatermarkStore 

pub struct PgWatermarkStore { /* private fields */ }

Implementations

impl PgWatermarkStore

pub fn new(pool: PgPool, config: PgWatermarkStoreConfig) -> Self

pub async fn connect( pool: PgPool, config: PgWatermarkStoreConfig, ) -> Result<Self>

pub async fn prepare_schema( pool: &PgPool, config: &PgWatermarkStoreConfig, ) -> Result<()>

pub fn schema_sql(config: &PgWatermarkStoreConfig) -> String

Trait Implementations

impl Clone for PgWatermarkStore

fn clone(&self) -> PgWatermarkStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl WatermarkStore for PgWatermarkStore

async fn load_watermark(&self, key: &str) -> Result<Option<DateTime<Utc>>>

async fn save_watermark(&self, key: &str, ts: DateTime<Utc>) -> Result<()>