Struct RouteDefinition 

pub struct RouteDefinition { /* private fields */ }

An unresolved route definition. “to” URIs have not been resolved to producers yet.

Implementations

impl RouteDefinition

pub fn new(from_uri: impl Into<String>, steps: Vec<BuilderStep>) -> Self

Create a new route definition with the required route ID.

pub fn from_uri(&self) -> &str

The source endpoint URI.

pub fn steps(&self) -> &[BuilderStep]

The steps in this route definition.

pub fn with_error_handler(self, config: ErrorHandlerConfig) -> Self

Set a per-route error handler, overriding the global one.

pub fn with_circuit_breaker(self, config: CircuitBreakerConfig) -> Self

Set a circuit breaker for this route.

pub fn circuit_breaker_config(&self) -> Option<&CircuitBreakerConfig>

Get the circuit breaker config, if set.

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

User-specified concurrency override, if any.

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

Override the consumer’s concurrency model for this route.

pub fn route_id(&self) -> &str

Get the route ID.

pub fn auto_startup(&self) -> bool

Whether this route should start automatically when the context starts.

pub fn startup_order(&self) -> i32

Order in which routes are started. Lower values start first.

pub fn with_route_id(self, id: impl Into<String>) -> Self

Set a unique identifier for this route.

pub fn with_auto_startup(self, auto: bool) -> Self

Set whether this route should start automatically.

pub fn with_startup_order(self, order: i32) -> Self

Set the startup order. Lower values start first.

pub fn to_info(&self) -> RouteDefinitionInfo

Extract the metadata fields needed for introspection. This is used by RouteController to store route info without the non-Sync steps.