Struct torn_key_pool::postgres::PgKeyPoolStorage

pub struct PgKeyPoolStorage<D>
where
    D: Serialize + DeserializeOwned + Send + Sync + 'static,
{ /* private fields */ }

Implementations

impl<D> PgKeyPoolStorage<D>

where D: PgKeyDomain,

pub fn new(pool: PgPool, limit: i16) -> Self

pub async fn initialise(&self) -> Result<(), PgStorageError<D>>

Trait Implementations

impl<D> Clone for PgKeyPoolStorage<D>

where D: Serialize + DeserializeOwned + Send + Sync + 'static + Clone,

fn clone(&self) -> PgKeyPoolStorage<D>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<D> Debug for PgKeyPoolStorage<D>

where D: Serialize + DeserializeOwned + Send + Sync + 'static + Debug,

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

Formats the value using the given formatter.

impl<'a, R: Row, D> FromRow<'a, R> for PgKeyPoolStorage<D>

where D: Serialize + DeserializeOwned + Send + Sync + 'static, &'a str: ColumnIndex<R>, PgPool: Decode<'a, R::Database> + Type<R::Database>, i16: Decode<'a, R::Database> + Type<R::Database>, PhantomData<D>: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(row: &'a R) -> Result<Self>

impl<D> KeyPoolStorage for PgKeyPoolStorage<D>

where D: PgKeyDomain,

type Key = PgKey<D>

type Domain = D

type Error = PgStorageError<D>

fn acquire_key<'life0, 'async_trait, S>( &'life0 self, selector: S ) -> Pin<Box<dyn Future<Output = Result<Self::Key, Self::Error>> + Send + 'async_trait>>

where S: IntoSelector<Self::Key, Self::Domain> + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn acquire_many_keys<'life0, 'async_trait, S>( &'life0 self, selector: S, number: i64 ) -> Pin<Box<dyn Future<Output = Result<Vec<Self::Key>, Self::Error>> + Send + 'async_trait>>

where S: IntoSelector<Self::Key, Self::Domain> + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn flag_key<'life0, 'async_trait>( &'life0 self, key: Self::Key, code: u8 ) -> Pin<Box<dyn Future<Output = Result<bool, Self::Error>> + Send + 'async_trait>>

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

fn store_key<'life0, 'async_trait>( &'life0 self, user_id: i32, key: String, domains: Vec<D> ) -> Pin<Box<dyn Future<Output = Result<Self::Key, Self::Error>> + Send + 'async_trait>>

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

fn read_key<'life0, 'async_trait, S>( &'life0 self, selector: S ) -> Pin<Box<dyn Future<Output = Result<Option<Self::Key>, Self::Error>> + Send + 'async_trait>>

where S: IntoSelector<Self::Key, Self::Domain> + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn read_keys<'life0, 'async_trait, S>( &'life0 self, selector: S ) -> Pin<Box<dyn Future<Output = Result<Vec<Self::Key>, Self::Error>> + Send + 'async_trait>>

where S: IntoSelector<Self::Key, Self::Domain> + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn remove_key<'life0, 'async_trait, S>( &'life0 self, selector: S ) -> Pin<Box<dyn Future<Output = Result<Self::Key, Self::Error>> + Send + 'async_trait>>

where S: IntoSelector<Self::Key, Self::Domain> + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn add_domain_to_key<'life0, 'async_trait, S>( &'life0 self, selector: S, domain: D ) -> Pin<Box<dyn Future<Output = Result<Self::Key, Self::Error>> + Send + 'async_trait>>

where S: IntoSelector<Self::Key, Self::Domain> + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn remove_domain_from_key<'life0, 'async_trait, S>( &'life0 self, selector: S, domain: D ) -> Pin<Box<dyn Future<Output = Result<Self::Key, Self::Error>> + Send + 'async_trait>>

where S: IntoSelector<Self::Key, Self::Domain> + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn set_domains_for_key<'life0, 'async_trait, S>( &'life0 self, selector: S, domains: Vec<D> ) -> Pin<Box<dyn Future<Output = Result<Self::Key, Self::Error>> + Send + 'async_trait>>

where S: IntoSelector<Self::Key, Self::Domain> + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,