pub struct ExpireInactiveUserSessionsJob { /* private fields */ }
Expand description
Expire inactive user sessions
Implementations§
Source§impl ExpireInactiveUserSessionsJob
impl ExpireInactiveUserSessionsJob
Sourcepub fn new(threshold: DateTime<Utc>) -> Self
pub fn new(threshold: DateTime<Utc>) -> Self
Create a new job to expire inactive user/browser sessions
§Parameters
threshold
- The threshold to expire sessions at
Sourcepub fn pagination(&self, batch_size: usize) -> Pagination
pub fn pagination(&self, batch_size: usize) -> Pagination
Get the pagination cursor
Sourcepub fn next(&self, page: &Page<BrowserSession>) -> Option<Self>
pub fn next(&self, page: &Page<BrowserSession>) -> Option<Self>
Get the next job given the page returned by the database
Trait Implementations§
Source§impl<'de> Deserialize<'de> for ExpireInactiveUserSessionsJob
impl<'de> Deserialize<'de> for ExpireInactiveUserSessionsJob
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl InsertableJob for ExpireInactiveUserSessionsJob
impl InsertableJob for ExpireInactiveUserSessionsJob
Source§const QUEUE_NAME: &'static str = "expire-inactive-user-sessions"
const QUEUE_NAME: &'static str = "expire-inactive-user-sessions"
The name of the queue this job belongs to
Auto Trait Implementations§
impl Freeze for ExpireInactiveUserSessionsJob
impl RefUnwindSafe for ExpireInactiveUserSessionsJob
impl Send for ExpireInactiveUserSessionsJob
impl Sync for ExpireInactiveUserSessionsJob
impl Unpin for ExpireInactiveUserSessionsJob
impl UnwindSafe for ExpireInactiveUserSessionsJob
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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