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 compile_route_definition_with_generation( &self, definition: RouteDefinition, generation: u64, ) -> Result<BoxProcessor, CamelError>

pub async fn remove_route_preserving_functions( &self, route_id: String, ) -> Result<(), 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 list_endpoints(&self) -> Result<Vec<String>, CamelError>

pub async fn routes_for_endpoint( &self, uri: impl Into<String>, ) -> Result<Vec<String>, CamelError>

pub async fn health_check_endpoint( &self, uri: impl Into<String>, ) -> Result<HealthStatus, 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_bind_exposure_acks( &self, acks: BindExposureAcks, ) -> Result<(), CamelError>

Install per-bind public-exposure acknowledgements (ADR-0061).

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 set_function_invoker( &self, invoker: Arc<dyn FunctionInvoker>, ) -> Result<(), CamelError>

pub async fn set_intercept_rules( &self, rules: InterceptRules, ) -> Result<(), CamelError>

Install route interception rules; the actor replies with the controller’s freeze-checked result.

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

Trip the intercept-rules freeze (context start marker).

pub fn try_set_function_invoker( &self, invoker: Arc<dyn FunctionInvoker>, ) -> 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.