Struct PostgresPersistence

pub struct PostgresPersistence { /* private fields */ }

Available on crate feature postgres only.

Expand description

PostgreSQL session persistence.

Implementations§

Connect to database without running migrations.

Use this when managing schema externally (production deployments).

Connect with custom configuration, without running migrations.

Connect and run migrations automatically.

Convenient for development and simple deployments.

Connect with custom configuration and run migrations.

Use an existing pool without running migrations.

Use an existing pool with custom configuration.

Run schema migration.

Verify schema integrity.

Get the underlying connection pool.

Get the configuration.

Trait Implementations§

Append a message to an existing session. Read more

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Returns the argument unchanged.

Attaches the provided Context to this type, returning a WithContext wrapper. Read more

Attaches the current Context to this type, returning a WithContext wrapper. Read more

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

Creates a shared type from an unshared type.

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

Should always be Self

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

PostgresPersistence

Struct PostgresPersistence Copy item path

Implementations§

impl PostgresPersistence

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

pub async fn connect_with_config( database_url: &str, config: PostgresConfig, ) -> Result<Self, Error>

pub async fn connect_and_migrate(database_url: &str) -> Result<Self, Error>

pub async fn connect_and_migrate_with_config( database_url: &str, config: PostgresConfig, ) -> Result<Self, Error>

pub fn from_pool(pool: Arc<PgPool>) -> Self

pub fn pool_and_config(pool: Arc<PgPool>, config: PostgresConfig) -> Self

pub async fn migrate(&self) -> Result<(), Error>

pub async fn verify_schema(&self) -> Result<Vec<SchemaIssue>, Error>

pub fn pool(&self) -> &PgPool

pub fn config(&self) -> &PostgresConfig

Trait Implementations§

impl Persistence for PostgresPersistence

fn name(&self) -> &str

fn save<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 Session, ) -> Pin<Box<dyn Future<Output = SessionResult<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn load<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<Option<Session>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<bool>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn list<'life0, 'life1, 'async_trait>( &'life0 self, tenant_id: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = SessionResult<Vec<SessionId>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn add_summary<'life0, 'async_trait>( &'life0 self, snapshot: SummarySnapshot, ) -> Pin<Box<dyn Future<Output = SessionResult<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn get_summaries<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<Vec<SummarySnapshot>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn enqueue<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, content: String, priority: i32, ) -> Pin<Box<dyn Future<Output = SessionResult<QueueItem>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn dequeue<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<Option<QueueItem>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn cancel_queued<'life0, 'async_trait>( &'life0 self, item_id: Uuid, ) -> Pin<Box<dyn Future<Output = SessionResult<bool>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn pending_queue<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<Vec<QueueItem>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn cleanup_expired<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = SessionResult<usize>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn add_message<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, message: SessionMessage, ) -> Pin<Box<dyn Future<Output = SessionResult<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Auto Trait Implementations§

impl Freeze for PostgresPersistence

impl !RefUnwindSafe for PostgresPersistence

impl Send for PostgresPersistence

impl Sync for PostgresPersistence

impl Unpin for PostgresPersistence

impl !UnwindSafe for PostgresPersistence

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unsharedwhere Shared: FromUnshared<Unshared>,

fn into_shared(self) -> Shared

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct PostgresPersistence

fn save<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 Session, ) -> Pin<Box<dyn Future<Output = SessionResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn load<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<Option<Session>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<bool>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn list<'life0, 'life1, 'async_trait>( &'life0 self, tenant_id: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = SessionResult<Vec<SessionId>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn add_summary<'life0, 'async_trait>( &'life0 self, snapshot: SummarySnapshot, ) -> Pin<Box<dyn Future<Output = SessionResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn get_summaries<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<Vec<SummarySnapshot>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn enqueue<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, content: String, priority: i32, ) -> Pin<Box<dyn Future<Output = SessionResult<QueueItem>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn dequeue<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<Option<QueueItem>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn cancel_queued<'life0, 'async_trait>( &'life0 self, item_id: Uuid, ) -> Pin<Box<dyn Future<Output = SessionResult<bool>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn pending_queue<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = SessionResult<Vec<QueueItem>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn cleanup_expired<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = SessionResult<usize>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn add_message<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, message: SessionMessage, ) -> Pin<Box<dyn Future<Output = SessionResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,