storage-kit 0.0.1

Portable database and transactional state-store Kit.
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use crate::StateStoreError;

use super::store::PostgresErrorContext;

pub(crate) struct PostgresSchema;

impl PostgresSchema {
    pub(crate) async fn initialize(
        client: &tokio_postgres::Client,
        timeout_ms: u64,
    ) -> Result<(), StateStoreError> {
        client
            .batch_execute(
                "
                CREATE TABLE IF NOT EXISTS storage_kit_state_records (
                  namespace TEXT NOT NULL,
                  key TEXT NOT NULL,
                  revision BIGINT NOT NULL CHECK (revision > 0),
                  value_json TEXT,
                  deleted BOOLEAN NOT NULL,
                  created_at_ms BIGINT NOT NULL,
                  updated_at_ms BIGINT NOT NULL,
                  PRIMARY KEY(namespace, key),
                  CHECK (
                    (deleted = TRUE AND value_json IS NULL)
                    OR
                    (deleted = FALSE AND value_json IS NOT NULL)
                  )
                );

                CREATE INDEX IF NOT EXISTS storage_kit_state_records_list_idx
                  ON storage_kit_state_records(namespace, deleted, key);
                ",
            )
            .await
            .map_err(|error| PostgresErrorContext::new("schema", timeout_ms).postgres(error))?;
        Ok(())
    }
}