Struct PgPersonalSessionRepository

pub struct PgPersonalSessionRepository<'c> { /* private fields */ }

An implementation of [PersonalSessionRepository] for a PostgreSQL connection

Implementations

impl<'c> PgPersonalSessionRepository<'c>

pub fn new(conn: &'c mut PgConnection) -> Self

Create a new PgPersonalSessionRepository from an active PostgreSQL connection

Trait Implementations

impl PersonalSessionRepository for PgPersonalSessionRepository<'_>

type Error = DatabaseError

The error type returned by the repository

fn lookup<'life0, 'async_trait>( &'life0 mut self, id: Ulid, ) -> Pin<Box<dyn Future<Output = Result<Option<PersonalSession>, Self::Error>> + Send + 'async_trait>>

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

Lookup a Personal session by its ID

fn add<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, rng: &'life1 mut (dyn RngCore + Send), clock: &'life2 dyn Clock, owner: PersonalSessionOwner, actor_user: &'life3 User, human_name: String, scope: Scope, ) -> Pin<Box<dyn Future<Output = Result<PersonalSession, Self::Error>> + Send + 'async_trait>>

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

Start a new Personal session

fn revoke<'life0, 'life1, 'async_trait>( &'life0 mut self, clock: &'life1 dyn Clock, session: PersonalSession, ) -> Pin<Box<dyn Future<Output = Result<PersonalSession, Self::Error>> + Send + 'async_trait>>

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

End a Personal session

fn revoke_bulk<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, clock: &'life1 dyn Clock, filter: PersonalSessionFilter<'life2>, ) -> Pin<Box<dyn Future<Output = Result<usize, Self::Error>> + Send + 'async_trait>>

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

Revoke all the [PersonalSession]s matching the given filter.

fn list<'life0, 'life1, 'async_trait>( &'life0 mut self, filter: PersonalSessionFilter<'life1>, pagination: Pagination, ) -> Pin<Box<dyn Future<Output = Result<Page<(PersonalSession, Option<PersonalAccessToken>)>, Self::Error>> + Send + 'async_trait>>

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

List [PersonalSession]s matching the given filter and pagination parameters

fn count<'life0, 'life1, 'async_trait>( &'life0 mut self, filter: PersonalSessionFilter<'life1>, ) -> Pin<Box<dyn Future<Output = Result<usize, Self::Error>> + Send + 'async_trait>>

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

Count [PersonalSession]s matching the given filter

fn record_batch_activity<'life0, 'async_trait>( &'life0 mut self, activities: Vec<(Ulid, DateTime<Utc>, Option<IpAddr>)>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Record a batch of [PersonalSession] activity