Skip to main content

JournalOffsetStore

atomr_patterns::outbox

Struct JournalOffsetStore

pub struct JournalOffsetStore<J: Journal> { /* private fields */ }

Expand description

Durable offset store backed by any Journal backend.

Plug it into super::OutboxBuilder::offset_store when you want outbox progress to survive process restarts. Pick the same backend you use for aggregate journals to keep the operational surface small (one connection pool, one schema migration).

Implementations§

impl<J: Journal> JournalOffsetStore<J>

pub async fn new(journal: Arc<J>, outbox_name: impl Into<String>) -> Self

Construct against journal, scoping offsets under outbox::<outbox_name>::offsets. Eagerly hydrates the cache from the journal — call from an async context.

Trait Implementations§

impl<J: Journal> OutboxOffsetStore for JournalOffsetStore<J>

fn load(&self) -> HashMap<String, u64>

fn save(&self, offsets: &HashMap<String, u64>)

Auto Trait Implementations§

impl<J> !Freeze for JournalOffsetStore<J>

impl<J> !RefUnwindSafe for JournalOffsetStore<J>

impl<J> Send for JournalOffsetStore<J>

impl<J> Sync for JournalOffsetStore<J>

impl<J> Unpin for JournalOffsetStore<J>

impl<J> UnsafeUnpin for JournalOffsetStore<J>

impl<J> UnwindSafe for JournalOffsetStore<J>
where J: RefUnwindSafe,

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

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

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

fn in_current_span(self) -> Instrumented<Self>

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

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

fn into(self) -> U

Calls U::from(self).

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

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<T> WithSubscriber for T

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

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

fn with_current_subscriber(self) -> WithDispatch<Self>

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

impl<T> Extension for T
where T: Any + Send + Sync,