Struct Route 

pub struct Route { /* private fields */ }

A Route defines a message flow: from a source endpoint, through a composed Tower Service pipeline.

Implementations

impl Route

pub fn new(from_uri: impl Into<String>, pipeline: BoxProcessor) -> Self

Create a new route from the given source URI and processor pipeline.

pub fn from_uri(&self) -> &str

The source endpoint URI.

pub fn into_pipeline(self) -> BoxProcessor

Consume the route and return its pipeline.

pub fn with_concurrency(self, model: ConcurrencyModel) -> Self

Set a concurrency model override for this route.

pub fn concurrency_override(&self) -> Option<&ConcurrencyModel>

Get the concurrency model override, if any.

pub fn into_parts(self) -> (BoxProcessor, Option<ConcurrencyModel>)

Consume the route, returning the pipeline and optional concurrency override.