Struct PostgresAdapter 

pub struct PostgresAdapter { /* private fields */ }

PostgreSQL adapter implementing the DatabaseProvider port

Implementations

impl PostgresAdapter

pub fn new(host: String, port: u16, ssh_auth: AuthMethod) -> Self

Create a new PostgreSQL adapter

Arguments

• host - Database server hostname/IP
• port - PostgreSQL port (usually 5432)
• ssh_auth - SSH authentication method

pub fn from_env() -> PortResult<Self>

Create adapter from environment variables

Reads:

• POSTGRES_HOST - Database server hostname/IP
• POSTGRES_PORT - PostgreSQL port (default: 5432)
• POSTGRES_SSH_USER - SSH username (default: “root”)
• POSTGRES_SSH_KEY - SSH private key path (default: ~/.ssh/id_rsa)

Errors

Returns error if required environment variables are missing

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, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = PortResult<()>> + Send + 'async_trait>>

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

Drop/delete a database

fn list_databases<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = PortResult<Vec<String>>> + Send + 'async_trait>>

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

List all databases

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

where Self: 'async_trait, 'life0: 'async_trait, 'life1: '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, 'async_trait>( &'life0 self, username: &'life1 str, ) -> Pin<Box<dyn Future<Output = PortResult<()>> + Send + 'async_trait>>

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

Drop/delete a database user

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

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

Grant all privileges on a database to a user