Struct SupervisingRouteController 

pub struct SupervisingRouteController { /* private fields */ }

A route controller that automatically restarts crashed routes.

Wraps a DefaultRouteController and spawns a supervision loop that receives crash notifications and restarts routes with exponential backoff.

Implementations

impl SupervisingRouteController

pub fn new(registry: Arc<Mutex<Registry>>, config: SupervisionConfig) -> Self

Create a new supervising controller.

pub fn with_languages( registry: Arc<Mutex<Registry>>, config: SupervisionConfig, languages: SharedLanguageRegistry, ) -> Self

Create a new supervising controller with shared language registry.

pub fn with_metrics(self, metrics: Arc<dyn MetricsCollector>) -> Self

Set a metrics collector for the supervision loop.

Trait Implementations

impl RouteController for SupervisingRouteController

fn start_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Start a specific route by its ID.

fn stop_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stop a specific route by its ID.

fn restart_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Restart a specific route by its ID.

fn suspend_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Suspend a specific route by its ID.

fn resume_route<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Resume a suspended route by its ID.

fn start_all_routes<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start all routes in the context.

fn stop_all_routes<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop all routes in the context.

impl RouteControllerInternal for SupervisingRouteController

fn add_route(&mut self, def: RouteDefinition) -> Result<(), CamelError>

Add a route definition to the controller.

fn swap_pipeline( &self, route_id: &str, pipeline: BoxProcessor, ) -> Result<(), CamelError>

Atomically swap the pipeline of a running route (for hot-reload).

fn route_from_uri(&self, route_id: &str) -> Option<String>

Returns the from_uri of a route by ID.

fn set_error_handler(&mut self, config: ErrorHandlerConfig)

Set a global error handler applied to all routes.

fn set_self_ref(&mut self, self_ref: Arc<Mutex<dyn RouteController>>)

Set the self-reference needed to create ProducerContext.

fn set_runtime_handle(&mut self, runtime: Arc<dyn RuntimeHandle>)

Set runtime handle for ProducerContext command/query access.

fn route_count(&self) -> usize

Returns the number of routes in the controller.

fn route_ids(&self) -> Vec<String>

Returns all route IDs.

fn auto_startup_route_ids(&self) -> Vec<String>

Returns route IDs that should auto-start, sorted by startup order (ascending).

fn shutdown_route_ids(&self) -> Vec<String>

Returns route IDs sorted by shutdown order (startup order descending).

fn set_tracer_config(&mut self, config: &TracerConfig)

Configure tracing from a TracerConfig.

fn compile_route_definition( &self, def: RouteDefinition, ) -> Result<BoxProcessor, CamelError>

Compile a RouteDefinition into a BoxProcessor without inserting it into the route map. Used by hot-reload to prepare a new pipeline for atomic swap.

fn remove_route(&mut self, route_id: &str) -> Result<(), CamelError>

Remove a route from the controller map (route must be stopped first).

fn start_route_reload<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Start a route by ID (for use by hot-reload, where async_trait is required).

fn stop_route_reload<'life0, 'life1, 'async_trait>( &'life0 mut self, route_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stop a route by ID (for use by hot-reload, where async_trait is required).