Struct ExecEndpoint 

pub struct ExecEndpoint { /* private fields */ }

An endpoint backed by a named exec profile.

Each exec:{name} URI resolves to one profile. The endpoint caches the global config Arc so every producer creation shares the same validated config state (including the startup-pinned canonical workspace root).

Implementations

impl ExecEndpoint

pub fn new( uri: String, profile_name: String, global: Arc<ExecGlobalConfig>, ) -> Self

Trait Implementations

impl Endpoint for ExecEndpoint

fn uri(&self) -> &str

The URI that identifies this endpoint.

fn create_consumer( &self, _rt: Arc<dyn RuntimeObservability>, ) -> Result<Box<dyn Consumer>, CamelError>

Create a consumer that reads from this endpoint.

fn create_producer( &self, rt: Arc<dyn RuntimeObservability>, ctx: &ProducerContext, ) -> Result<BoxProcessor, CamelError>

Create a producer that writes to this endpoint.

fn body_contract(&self) -> Option<BodyType>

Optional body type contract for the producer.

fn polling_consumer(&self) -> Option<Box<dyn PollingConsumer>>

Return a polling consumer for this endpoint, if supported.