Struct FunctionRuntimeService 

pub struct FunctionRuntimeService { /* private fields */ }

Implementations

impl FunctionRuntimeService

pub fn with_fake_provider( config: FunctionConfig, provider: Arc<FakeProvider>, ) -> Self

pub fn with_container_provider( config: FunctionConfig, provider: ContainerProvider, ) -> Self

pub fn with_default_container_provider( config: FunctionConfig, ) -> Result<Self, ProviderError>

pub fn invoker(&self) -> Arc<dyn FunctionInvoker>

pub fn provider(&self) -> &ContainerProvider

pub fn runner_state(&self, runtime: &str) -> Option<RunnerState>

pub fn force_runner_failed(&self, runtime: &str, reason: &str)

Trait Implementations

impl Lifecycle for FunctionRuntimeService

fn name(&self) -> &str

Service name for logging

fn status(&self) -> ServiceStatus

Current status of the service.

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

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

Start service (called during CamelContext.start())

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

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

Stop service (called during CamelContext.stop())

fn as_function_invoker(&self) -> Option<Arc<dyn FunctionInvoker>>

fn as_metrics_collector(&self) -> Option<Arc<dyn MetricsCollector>>

Optional: expose MetricsCollector for auto-registration