Struct PostgresObjectPlacement 

pub struct PostgresObjectPlacement { /* private fields */ }

Implementations

impl PostgresObjectPlacement

pub fn new(pool: PgPool) -> Self

pub fn pool() -> PgPoolOptions

Pool builder, so one doesn’t need to include sqlx as a dependency

Example

let pool = PostgresObjectPlacement::pool()
    .connect("sqlite::memory:")
    .await
    .expect("Connection failure");
let object_placement = PostgresObjectPlacement::new(pool);

Trait Implementations

impl Clone for PostgresObjectPlacement

fn clone(&self) -> PostgresObjectPlacement

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresObjectPlacement

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

Formats the value using the given formatter.

impl ObjectPlacement for PostgresObjectPlacement

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

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

Run the schema/data migrations for this membership storage.

For now, the Rio server doesn’t run this at start-up and it needs to be invoked on manually in the server’s setup.

fn update<'life0, 'async_trait>( &'life0 self, object_placement: ObjectPlacementItem, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Insert or update the object placement

fn lookup<'life0, 'life1, 'async_trait>( &'life0 self, object_id: &'life1 ObjectId, ) -> Pin<Box<dyn Future<Output = Option<String>> + Send + 'async_trait>>

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

Find the server address for a given object

fn clean_server<'life0, 'async_trait>( &'life0 self, address: String, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Unassign all objects for a given server

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, object_id: &'life1 ObjectId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Unassign a single object by its ID