Struct apalis_core::layers::extensions::Extension

pub struct Extension<T>(pub T);

Available on crate feature extensions only.

Extension data for jobs.

forked from http::Extensions

In Context

This is commonly used to share state across jobs.

use apalis::{
    Extension,
    WorkerBuilder,
    JobContext
};
use std::sync::Arc;

// Some shared state used throughout our application
struct State {
    // ...
}

async fn email_service(email: Email, ctx: JobContext) {
    let state: &Arc<State> = ctx.data_opt().unwrap();
}

let state = Arc::new(State { /* ... */ });

let worker = WorkerBuilder::new("tasty-avocado")
    .layer(Extension(state))
    .with_storage(storage.clone())
    .build_fn(email_service);

Tuple Fields

0: T

Trait Implementations

impl<T: Clone> Clone for Extension<T>

fn clone(&self) -> Extension<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Extension<T>

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

Formats the value using the given formatter.

impl<S, T> Layer<S> for Extension<T>where T: Clone + Send + Sync + 'static,

type Service = AddExtension<S, T>

The wrapped service

fn layer(&self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.

impl<T: Copy> Copy for Extension<T>