cronoq-store-postgres 0.2.0

PostgreSQL store for cronoq: durable state, leader election and fencing
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

//! The shared store conformance tests, against a throwaway PostgreSQL server.

mod common;

use std::time::Duration;

use async_trait::async_trait;
use cronoq_store_postgres::{PgStore, PgStoreConfig};

struct Pg(common::TestPg);

#[async_trait]
impl cronoq_store_tests::Harness for Pg {
    type Store = PgStore;
    async fn open(&self) -> PgStore {
        let cfg = PgStoreConfig {
            lock_poll: Duration::from_millis(50),
            keepalive: Duration::from_millis(100),
            ..Default::default()
        };
        PgStore::connect_with(&self.0.url, cfg).await.unwrap()
    }
}

cronoq_store_tests::suite!(async { common::TestPg::start().map(Pg) });