Struct 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, schema: Option<String>) -> Self

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

Trait Implementations

impl<D> Clone for PgKeyPoolStorage<D>

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

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

Returns a duplicate 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>, Option<String>: 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 = PgKeyPoolError<D>

async fn acquire_key<S>(&self, selector: S) -> Result<Self::Key, Self::Error>

where S: IntoSelector<Self::Key, Self::Domain>,

async fn acquire_many_keys<S>( &self, selector: S, number: i64, ) -> Result<Vec<Self::Key>, Self::Error>

where S: IntoSelector<Self::Key, Self::Domain>,

async fn timeout_key<S>( &self, selector: S, duration: Duration, ) -> Result<(), Self::Error>

where S: IntoSelector<Self::Key, Self::Domain>,

async fn store_key( &self, user_id: i32, key: String, domains: Vec<D>, ) -> Result<Self::Key, Self::Error>

async fn read_key<S>( &self, selector: S, ) -> Result<Option<Self::Key>, Self::Error>

where S: IntoSelector<Self::Key, Self::Domain>,

async fn read_keys<S>(&self, selector: S) -> Result<Vec<Self::Key>, Self::Error>

where S: IntoSelector<Self::Key, Self::Domain>,

async fn remove_key<S>(&self, selector: S) -> Result<Self::Key, Self::Error>

where S: IntoSelector<Self::Key, Self::Domain>,

async fn add_domain_to_key<S>( &self, selector: S, domain: D, ) -> Result<Self::Key, Self::Error>

where S: IntoSelector<Self::Key, Self::Domain>,

async fn remove_domain_from_key<S>( &self, selector: S, domain: D, ) -> Result<Self::Key, Self::Error>

where S: IntoSelector<Self::Key, Self::Domain>,

async fn set_domains_for_key<S>( &self, selector: S, domains: Vec<D>, ) -> Result<Self::Key, Self::Error>

where S: IntoSelector<Self::Key, Self::Domain>,