WorkerStore

Struct WorkerStore 

Source
pub struct WorkerStore<S: Store> { /* private fields */ }
Expand description

A store wrapper for worker-specific operations with namespace isolation.

WorkerStore provides a simplified interface for workers to interact with the main store, automatically applying a consistent namespace prefix to all operations. This ensures that different workers can operate on isolated sections of the store without conflicts.

Implementations§

Source§

impl<S: Store> WorkerStore<S>

Source

pub fn new<T: Into<String>>(store: &S, prefix: T) -> Self

Creates a new WorkerStore with the specified store and unique prefix key.

The prefix serves as a namespace that is automatically applied to all store operations, isolating this worker’s data from other parts of the system.

Source

pub async fn set_asset_info(&self, asset: AssetInfo) -> Result<(), S::Error>

Sets the asset information for a specific asset.

This method automatically applies the worker’s namespace prefix when storing the asset information in the underlying store.

§Errors

Returns the underlying store’s error type if the operation fails

Source

pub async fn set_batch_asset_info( &self, assets: Vec<AssetInfo>, ) -> Result<(), S::Error>

Sets multiple asset information entries in a single batch operation.

This method provides an optimized way to store multiple asset entries at once, while automatically applying the worker’s namespace prefix.

§Errors

Returns the underlying store’s error type if the operation fails

Trait Implementations§

Source§

impl<S: Clone + Store> Clone for WorkerStore<S>

Source§

fn clone(&self) -> WorkerStore<S>

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more

Auto Trait Implementations§

§

impl<S> Freeze for WorkerStore<S>
where S: Freeze,

§

impl<S> RefUnwindSafe for WorkerStore<S>
where S: RefUnwindSafe,

§

impl<S> Send for WorkerStore<S>

§

impl<S> Sync for WorkerStore<S>

§

impl<S> Unpin for WorkerStore<S>
where S: Unpin,

§

impl<S> UnwindSafe for WorkerStore<S>
where S: UnwindSafe,

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FromRef<T> for T
where T: Clone,

Source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
Source§

impl<T> FutureExt for T

Source§

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

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

fn with_current_context(self) -> WithContext<Self>

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

impl<T> Instrument for T

Source§

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

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

fn in_current_span(self) -> Instrumented<Self>

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

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

Source§

fn into(self) -> U

Calls U::from(self).

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

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

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