Struct ProducerContext 

pub struct ProducerContext { /* private fields */ }

Context provided to producers for dependency injection.

ProducerContext holds references to shared infrastructure components that producers may need access to during message production.

Extensible via default_headers (headers injected into every outgoing message) and timeout_ms (per-producer timeout override).

Implementations

impl ProducerContext

pub fn new() -> ProducerContext

Creates a new empty ProducerContext.

pub fn with_runtime(self, runtime: Arc<dyn RuntimeHandle>) -> ProducerContext

Attaches a runtime command/query handle.

pub fn runtime(&self) -> Option<&Arc<dyn RuntimeHandle>>

Returns the runtime command/query handle, if configured.

pub fn with_default_header( self, key: impl Into<String>, value: impl Into<String>, ) -> ProducerContext

Sets a default header that will be injected into every outgoing message.

pub fn default_headers(&self) -> &HashMap<String, String>

Returns the default headers map.

pub fn with_timeout_ms(self, timeout_ms: u64) -> ProducerContext

Sets a timeout in milliseconds for producer operations.

pub fn timeout_ms(&self) -> Option<u64>

Returns the configured timeout in milliseconds, if any.

Trait Implementations

impl Clone for ProducerContext

fn clone(&self) -> ProducerContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ProducerContext

fn default() -> ProducerContext

Returns the “default value” for a type.