Struct RouteControllerHandle 

pub struct RouteControllerHandle { /* private fields */ }

Implementations

impl RouteControllerHandle

pub async fn start_route( &self, route_id: impl Into<String>, ) -> Result<(), CamelError>

pub async fn stop_route( &self, route_id: impl Into<String>, ) -> Result<(), CamelError>

pub async fn restart_route( &self, route_id: impl Into<String>, ) -> Result<(), CamelError>

pub async fn suspend_route( &self, route_id: impl Into<String>, ) -> Result<(), CamelError>

pub async fn resume_route( &self, route_id: impl Into<String>, ) -> Result<(), CamelError>

pub async fn start_all_routes(&self) -> Result<(), CamelError>

pub async fn stop_all_routes(&self) -> Result<(), CamelError>

pub async fn add_route( &self, definition: RouteDefinition, ) -> Result<(), CamelError>

pub async fn remove_route( &self, route_id: impl Into<String>, ) -> Result<(), CamelError>

pub async fn swap_pipeline( &self, route_id: impl Into<String>, pipeline: BoxProcessor, ) -> Result<(), CamelError>

pub async fn compile_route_definition( &self, definition: RouteDefinition, ) -> Result<BoxProcessor, CamelError>

pub async fn route_from_uri( &self, route_id: impl Into<String>, ) -> Result<Option<String>, CamelError>

pub async fn route_count(&self) -> Result<usize, CamelError>

pub async fn in_flight_count( &self, route_id: impl Into<String>, ) -> Result<Option<u64>, CamelError>

pub async fn route_exists( &self, route_id: impl Into<String>, ) -> Result<bool, CamelError>

pub async fn route_ids(&self) -> Result<Vec<String>, CamelError>

pub async fn auto_startup_route_ids(&self) -> Result<Vec<String>, CamelError>

pub async fn shutdown_route_ids(&self) -> Result<Vec<String>, CamelError>

pub async fn start_route_reload( &self, route_id: impl Into<String>, ) -> Result<(), CamelError>

pub async fn stop_route_reload( &self, route_id: impl Into<String>, ) -> Result<(), CamelError>

pub async fn get_pipeline( &self, route_id: impl Into<String>, ) -> Result<Option<BoxProcessor>, CamelError>

pub async fn set_error_handler( &self, config: ErrorHandlerConfig, ) -> Result<(), CamelError>

pub async fn set_tracer_config( &self, config: TracerConfig, ) -> Result<(), CamelError>

pub async fn set_runtime_handle( &self, runtime: Arc<dyn RuntimeHandle>, ) -> Result<(), CamelError>

pub fn try_set_runtime_handle( &self, runtime: Arc<dyn RuntimeHandle>, ) -> Result<(), CamelError>

pub async fn route_source_hash( &self, route_id: impl Into<String>, ) -> Option<u64>

pub async fn shutdown(&self) -> Result<(), CamelError>

Trait Implementations

impl Clone for RouteControllerHandle

fn clone(&self) -> RouteControllerHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.