Struct PostgresMembershipStorage 

pub struct PostgresMembershipStorage { /* private fields */ }

MembershipStorage implementation to work with relational databases

Implementations

impl PostgresMembershipStorage

pub fn new(pool: PgPool) -> PostgresMembershipStorage

Builds a PostgresMembershipStorage from a sqlx’s PgPool

pub fn pool() -> PgPoolOptions

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

Example

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

Trait Implementations

impl Clone for PostgresMembershipStorage

fn clone(&self) -> PostgresMembershipStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresMembershipStorage

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

Formats the value using the given formatter.

impl MembershipStorage for PostgresMembershipStorage

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.

fn member_failures<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ip: &'life1 str, port: &'life2 str, ) -> Pin<Box<dyn Future<Output = MembershipResult<Vec<DateTime<Utc>>>> + Send + 'async_trait>>

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

TODO configure LIMIT

fn push<'life0, 'async_trait>( &'life0 self, member: Member, ) -> Pin<Box<dyn Future<Output = MembershipUnitResult> + Send + 'async_trait>>

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

Saves a new member to the storage

fn remove<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ip: &'life1 str, port: &'life2 str, ) -> Pin<Box<dyn Future<Output = MembershipUnitResult> + Send + 'async_trait>>

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

Remove a member by its public ip + port identification

fn set_is_active<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ip: &'life1 str, port: &'life2 str, is_active: bool, ) -> Pin<Box<dyn Future<Output = MembershipUnitResult> + Send + 'async_trait>>

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

Changes status for a given Member (lookup by public ip + port)

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

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

List all members in the storage

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

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

List of active members only

fn notify_failure<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ip: &'life1 str, port: &'life2 str, ) -> Pin<Box<dyn Future<Output = MembershipUnitResult> + Send + 'async_trait>>

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

Flag a failure to a given member. Note this method doesn’t change the member’s activity status

fn is_active<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ip: &'life1 str, port: &'life2 str, ) -> Pin<Box<dyn Future<Output = MembershipResult<bool>> + Send + 'async_trait>>

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

Tests a member inactive (loopkup by ip + port)

fn set_inactive<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ip: &'life1 str, port: &'life2 str, ) -> Pin<Box<dyn Future<Output = MembershipUnitResult> + Send + 'async_trait>>

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

Sets a member inactive (loopkup by ip + port)

fn set_active<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ip: &'life1 str, port: &'life2 str, ) -> Pin<Box<dyn Future<Output = MembershipUnitResult> + Send + 'async_trait>>

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

Sets a member active (loopkup by ip + port)