Struct PgConnectorConfigStore 

pub struct PgConnectorConfigStore { /* private fields */ }

Postgres-backed ConnectorConfigStore over connector_configs.

Implementations

impl PgConnectorConfigStore

pub fn new(pool: Pool, handle: Handle) -> Self

Build over the adapter’s async pool + captured runtime handle.

Trait Implementations

impl Clone for PgConnectorConfigStore

fn clone(&self) -> PgConnectorConfigStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConnectorConfigStore for PgConnectorConfigStore

fn list(&self, org_id: &str) -> Vec<ConnectorConfig>

All connector configs for org_id, sorted by name (stable).

fn get(&self, org_id: &str, id: &str) -> Option<ConnectorConfig>

One connector config by (org_id, id), or None if absent / in another org (cross-org reads return None, never another org’s row).

fn upsert(&self, config: ConnectorConfig)

Insert or update a connector config (keyed on (org_id, id)).

fn delete(&self, org_id: &str, id: &str) -> bool

Delete a connector config by (org_id, id). Returns whether a row was removed (so the API can 404 a delete of an absent / cross-org id).