Struct PostgresBackend 

pub struct PostgresBackend { /* private fields */ }

PostgreSQL storage backend with schema-per-tenant isolation.

Each tenant maps to a dedicated Postgres schema. All queries qualify their tables as "{tenant}".kv_store / "{tenant}".kv_history. The tenant name is interpolated into SQL (a schema identifier cannot be a bind parameter), so the [a-z0-9_-]+ validation in PostgresBackend::connect is the single anti-injection barrier.

Implementations

impl PostgresBackend

pub async fn connect( database_url: &str, tenant: &str, ) -> Result<Self, StorageError>

Connects to Postgres and prepares the tenant schema.

Arguments

• database_url - Postgres connection URL
• tenant - Tenant identifier (must match [a-z0-9_-]+)

Errors

Returns an error if the tenant name is invalid, the connection fails, or the schema migration fails.

pub fn with_actor(self, actor: impl Into<String>) -> Self

Sets the actor for audit logging.

Returns a new instance with the actor set. All operations performed with this instance will be logged with this actor.

pub fn current_actor(&self) -> Option<String>

Returns the current actor, if set.

Trait Implementations

impl Clone for PostgresBackend

fn clone(&self) -> PostgresBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StorageBackend for PostgresBackend

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, StorageError>> + Send + 'async_trait>>

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

Get a value by key.

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, value: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Put a value with a key.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Delete a value by key.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StorageError>> + Send + 'async_trait>>

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

List keys with a prefix.

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

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

Check if a key exists.