Struct ContainerConsumer 

pub struct ContainerConsumer { /* private fields */ }

Consumer for receiving Docker container events or logs.

This consumer subscribes to Docker events or container logs and forwards them to the route as exchanges. It implements automatic reconnection on connection failures.

Implementations

impl ContainerConsumer

pub fn new( config: ContainerConfig, runtime: Arc<dyn RuntimeObservability>, ) -> Self

Trait Implementations

impl Consumer for ContainerConsumer

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

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

Start consuming messages, sending them through the provided context.

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 consuming messages and clean up all resources.

fn concurrency_model(&self) -> ConcurrencyModel

Declares this consumer’s natural concurrency model.

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

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

Temporarily suspend consuming messages without fully stopping.

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

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

Resume consuming after a previous suspension.

fn background_task_handle( &mut self, ) -> Option<JoinHandle<Result<(), CamelError>>>

Return a handle to the consumer’s long-running background task so the runtime can monitor it for unexpected exits after start() returns Ok.

fn set_security_context(&mut self, _ctx: SecurityContext)

Set the security context for this consumer.