Struct mas_storage_pg::PgRepository

pub struct PgRepository<C = Transaction<'static, Postgres>> { /* private fields */ }

An implementation of the [Repository] trait backed by a PostgreSQL transaction.

Implementations

impl PgRepository

pub async fn from_pool(pool: &PgPool) -> Result<Self, DatabaseError>

Create a new PgRepository from a PostgreSQL connection pool, starting a transaction.

Errors

Returns a DatabaseError if the transaction could not be started.

pub fn boxed(self) -> BoxRepository

Transform the repository into a type-erased [BoxRepository]

impl<C> PgRepository<C>

pub fn from_conn(conn: C) -> Self

Create a new PgRepository from an existing PostgreSQL connection with a transaction

pub fn into_inner(self) -> C

Consume this PgRepository, returning the underlying connection.

Trait Implementations

impl<C> AsMut<C> for PgRepository<C>

fn as_mut(&mut self) -> &mut C

Converts this type into a mutable reference of the (usually inferred) input type.

impl<C> AsRef<C> for PgRepository<C>

fn as_ref(&self) -> &C

Converts this type into a shared reference of the (usually inferred) input type.

impl<C> Deref for PgRepository<C>

type Target = C

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<C> DerefMut for PgRepository<C>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<C> RepositoryAccess for PgRepository<C>

where C: AsMut<PgConnection> + Send,

type Error = DatabaseError

The backend-specific error type used by each repository.

fn upstream_oauth_link<'c>( &'c mut self, ) -> Box<dyn UpstreamOAuthLinkRepository<Error = Self::Error> + 'c>

Get an [UpstreamOAuthLinkRepository]

fn upstream_oauth_provider<'c>( &'c mut self, ) -> Box<dyn UpstreamOAuthProviderRepository<Error = Self::Error> + 'c>

Get an [UpstreamOAuthProviderRepository]

fn upstream_oauth_session<'c>( &'c mut self, ) -> Box<dyn UpstreamOAuthSessionRepository<Error = Self::Error> + 'c>

Get an [UpstreamOAuthSessionRepository]

fn user<'c>(&'c mut self) -> Box<dyn UserRepository<Error = Self::Error> + 'c>

Get an [UserRepository]

fn user_email<'c>( &'c mut self, ) -> Box<dyn UserEmailRepository<Error = Self::Error> + 'c>

Get an [UserEmailRepository]

fn user_password<'c>( &'c mut self, ) -> Box<dyn UserPasswordRepository<Error = Self::Error> + 'c>

Get an [UserPasswordRepository]

fn user_recovery<'c>( &'c mut self, ) -> Box<dyn UserRecoveryRepository<Error = Self::Error> + 'c>

Get an [UserRecoveryRepository]

fn user_terms<'c>( &'c mut self, ) -> Box<dyn UserTermsRepository<Error = Self::Error> + 'c>

Get an [UserTermsRepository]

fn browser_session<'c>( &'c mut self, ) -> Box<dyn BrowserSessionRepository<Error = Self::Error> + 'c>

Get a [BrowserSessionRepository]

fn app_session<'c>( &'c mut self, ) -> Box<dyn AppSessionRepository<Error = Self::Error> + 'c>

Get a [AppSessionRepository]

fn oauth2_client<'c>( &'c mut self, ) -> Box<dyn OAuth2ClientRepository<Error = Self::Error> + 'c>

Get an [OAuth2ClientRepository]

fn oauth2_authorization_grant<'c>( &'c mut self, ) -> Box<dyn OAuth2AuthorizationGrantRepository<Error = Self::Error> + 'c>

Get an [OAuth2AuthorizationGrantRepository]

fn oauth2_session<'c>( &'c mut self, ) -> Box<dyn OAuth2SessionRepository<Error = Self::Error> + 'c>

Get an [OAuth2SessionRepository]

fn oauth2_access_token<'c>( &'c mut self, ) -> Box<dyn OAuth2AccessTokenRepository<Error = Self::Error> + 'c>

Get an [OAuth2AccessTokenRepository]

fn oauth2_refresh_token<'c>( &'c mut self, ) -> Box<dyn OAuth2RefreshTokenRepository<Error = Self::Error> + 'c>

Get an [OAuth2RefreshTokenRepository]

fn oauth2_device_code_grant<'c>( &'c mut self, ) -> Box<dyn OAuth2DeviceCodeGrantRepository<Error = Self::Error> + 'c>

Get an [OAuth2DeviceCodeGrantRepository]

fn compat_session<'c>( &'c mut self, ) -> Box<dyn CompatSessionRepository<Error = Self::Error> + 'c>

Get a [CompatSessionRepository]

fn compat_sso_login<'c>( &'c mut self, ) -> Box<dyn CompatSsoLoginRepository<Error = Self::Error> + 'c>

Get a [CompatSsoLoginRepository]

fn compat_access_token<'c>( &'c mut self, ) -> Box<dyn CompatAccessTokenRepository<Error = Self::Error> + 'c>

Get a [CompatAccessTokenRepository]

fn compat_refresh_token<'c>( &'c mut self, ) -> Box<dyn CompatRefreshTokenRepository<Error = Self::Error> + 'c>

Get a [CompatRefreshTokenRepository]

fn job<'c>(&'c mut self) -> Box<dyn JobRepository<Error = Self::Error> + 'c>

Get a [JobRepository]

impl RepositoryTransaction for PgRepository

type Error = DatabaseError

The error type used by the [Self::save] and [Self::cancel] functions

fn save(self: Box<Self>) -> BoxFuture<'static, Result<(), Self::Error>>

Commit the transaction

fn cancel(self: Box<Self>) -> BoxFuture<'static, Result<(), Self::Error>>

Rollback the transaction

impl Repository<DatabaseError> for PgRepository