Struct PostgresDriver 

pub struct PostgresDriver { /* private fields */ }

PostgreSQL driver for durable external-service storage.

Implementations

impl PostgresDriver

pub fn new(connection_string: impl Into<String>) -> Self

Creates a new PostgreSQL driver using default options.

pub fn with_options(options: PostgresDriverOptions) -> Self

Creates a new PostgreSQL driver with explicit options.

pub const fn options(&self) -> &PostgresDriverOptions

Returns the configured options.

pub const fn schema(&self) -> PostgresDriverStorageSchema

Returns the storage schema.

Trait Implementations

impl Clone for PostgresDriver

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresDriver

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Driver for PostgresDriver

fn name(&self) -> &'static str

Stable driver name.

fn capabilities(&self) -> Capabilities

Reports supported driver behaviour.

fn initialise<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Prepares the driver for use.

fn finalise<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Releases driver resources.

fn get<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, namespace: &'life1 Namespace, collection: &'life2 CollectionName, key: &'life3 Key, options: &'life4 ReadOptions, ) -> Pin<Box<dyn Future<Output = Result<Option<StoredValue>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Reads a stored value.

fn set<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, namespace: &'life1 Namespace, collection: &'life2 CollectionName, key: &'life3 Key, value: StoredValue, options: &'life4 WriteOptions, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Writes a stored value.

fn delete<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, namespace: &'life1 Namespace, collection: &'life2 CollectionName, key: &'life3 Key, options: &'life4 DeleteOptions, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Deletes a stored value and returns whether a value was removed.

fn exists<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, namespace: &'life1 Namespace, collection: &'life2 CollectionName, key: &'life3 Key, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Returns whether a stored value exists.

fn scan_prefix<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, namespace: &'life1 Namespace, collection: &'life2 CollectionName, options: &'life3 ScanOptions, ) -> Pin<Box<dyn Future<Output = Result<Vec<(Key, StoredValue)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Scans values by key prefix.

fn batch<'life0, 'async_trait>( &'life0 self, batch: Batch, ) -> Pin<Box<dyn Future<Output = Result<BatchResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Applies a batch of write operations.