Struct ExecutorLayer 

pub struct ExecutorLayer<E> { /* private fields */ }

A Tower layer that delegates request processing to an executor.

This layer wraps a service and spawns each request’s processing as a new task on the provided executor. This enables parallel processing of requests across multiple executor threads.

Example

use tower_resilience_executor::ExecutorLayer;
use tokio::runtime::Handle;

// Use the current runtime
let layer = ExecutorLayer::new(Handle::current());

Implementations

impl<E> ExecutorLayer<E>

where E: Executor,

pub fn new(executor: E) -> Self

Creates a new executor layer with the given executor.

pub fn builder() -> ExecutorLayerBuilder<E>

Creates a builder for configuring the executor layer.

impl ExecutorLayer<Handle>

pub fn current() -> Self

Creates an executor layer using the current tokio runtime.

Panics

Panics if called from outside a tokio runtime.

Trait Implementations

impl<E: Clone> Clone for ExecutorLayer<E>

fn clone(&self) -> ExecutorLayer<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, E> Layer<S> for ExecutorLayer<E>

where E: Clone,

type Service = ExecutorService<S, E>

The wrapped service

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

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