Struct PostgresAdapter 

pub struct PostgresAdapter;

PostgreSQL adapter implementing the DatabaseProvider port

This adapter is stateless and accepts connection details via request parameters.

Implementations

impl PostgresAdapter

pub fn new() -> Self

Create a new PostgreSQL adapter

Trait Implementations

impl DatabaseProvider for PostgresAdapter

fn create_database<'life0, 'async_trait>( &'life0 self, request: DatabaseCreateRequest, ) -> Pin<Box<dyn Future<Output = PortResult<CreatedDatabase>> + Send + 'async_trait>>

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

Create a new database

fn drop_database<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, name: &'life1 str, host: &'life2 str, port: u16, ssh_key_path: &'life3 str, ) -> Pin<Box<dyn Future<Output = PortResult<()>> + Send + 'async_trait>>

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

Drop/delete a database

fn list_databases<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, host: &'life1 str, port: u16, ssh_key_path: &'life2 str, ) -> Pin<Box<dyn Future<Output = PortResult<Vec<String>>> + Send + 'async_trait>>

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

List all databases

fn database_exists<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, name: &'life1 str, host: &'life2 str, port: u16, ssh_key_path: &'life3 str, ) -> Pin<Box<dyn Future<Output = PortResult<bool>> + Send + 'async_trait>>

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

Check if a database exists

fn create_user<'life0, 'async_trait>( &'life0 self, request: DatabaseUserRequest, ) -> Pin<Box<dyn Future<Output = PortResult<DatabaseUser>> + Send + 'async_trait>>

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

Create a database user

fn drop_user<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, username: &'life1 str, host: &'life2 str, port: u16, ssh_key_path: &'life3 str, ) -> Pin<Box<dyn Future<Output = PortResult<()>> + Send + 'async_trait>>

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

Drop/delete a database user

fn grant_privileges<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, database: &'life1 str, username: &'life2 str, host: &'life3 str, port: u16, ssh_key_path: &'life4 str, ) -> Pin<Box<dyn Future<Output = PortResult<()>> + Send + 'async_trait>>

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

Grant all privileges on a database to a user