Struct TokioPostgresAdapter 

pub struct TokioPostgresAdapter { /* private fields */ }

Implementations

impl TokioPostgresAdapter

pub fn new(client: Client) -> Self

pub fn with_schema(client: Client, schema: DbSchema) -> Self

pub fn with_connection( connection: TokioPostgresConnection, schema: DbSchema, ) -> Self

pub fn connection(&self) -> &TokioPostgresConnection

Returns the shared client and transaction gate used by this adapter.

pub fn rate_limit_store(&self) -> TokioPostgresRateLimitStore

Builds a SQL-backed rate-limit store that shares this adapter’s client and transaction gate.

pub async fn connect(database_url: &str) -> Result<Self, RustAuthError>

Connects to Postgres and spawns the tokio-postgres connection driver.

pub async fn connect_with_schema( database_url: &str, schema: DbSchema, ) -> Result<Self, RustAuthError>

Connects to Postgres with a custom RustAuth schema.

The returned adapter owns the client handle and keeps the driver future running in a background task as required by tokio-postgres.

pub async fn plan_migrations( &self, schema: &DbSchema, ) -> Result<SchemaMigrationPlan, RustAuthError>

pub async fn compile_migrations( &self, schema: &DbSchema, ) -> Result<String, RustAuthError>

Trait Implementations

impl Clone for TokioPostgresAdapter

fn clone(&self) -> TokioPostgresAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DbAdapter for TokioPostgresAdapter

fn id(&self) -> &str

fn capabilities(&self) -> AdapterCapabilities

fn create<'a>(&'a self, query: Create) -> AdapterFuture<'a, DbRecord>

fn find_one<'a>(&'a self, query: FindOne) -> AdapterFuture<'a, Option<DbRecord>>

fn find_many<'a>(&'a self, query: FindMany) -> AdapterFuture<'a, Vec<DbRecord>>

fn count<'a>(&'a self, query: Count) -> AdapterFuture<'a, u64>

fn update<'a>(&'a self, query: Update) -> AdapterFuture<'a, Option<DbRecord>>

fn update_many<'a>(&'a self, query: UpdateMany) -> AdapterFuture<'a, u64>

fn delete<'a>(&'a self, query: Delete) -> AdapterFuture<'a, ()>

fn delete_many<'a>(&'a self, query: DeleteMany) -> AdapterFuture<'a, u64>

fn transaction<'a>( &'a self, callback: TransactionCallback<'a>, ) -> AdapterFuture<'a, ()>

fn create_schema<'a>( &'a self, schema: &'a DbSchema, _file: Option<&'a str>, ) -> AdapterFuture<'a, Option<SchemaCreation>>

fn run_migrations<'a>(&'a self, schema: &'a DbSchema) -> AdapterFuture<'a, ()>

fn run_plugin_migrations<'a>( &'a self, _migrations: &'a [PluginMigration], ) -> Pin<Box<dyn Future<Output = Result<(), RustAuthError>> + Send + 'a>>

impl Debug for TokioPostgresAdapter

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

Formats the value using the given formatter.

impl From<&TokioPostgresAdapter> for TokioPostgresRateLimitStore

fn from(adapter: &TokioPostgresAdapter) -> Self

Converts to this type from the input type.