Struct BrokerConfig 

pub struct BrokerConfig {

    pub adapter: String,
    pub name: String,
    pub enabled: bool,
    pub retries: u32,
    pub retry_backoff: u64,
    pub request_timeout: Option<u64>,
    pub delivery_guarantee: DeliveryGuarantee,
    pub commit_strategy: CommitStrategy,
    pub dlq: DlqPolicy,
    pub max_in_flight: usize,
    pub consumer_group: Option<String>,
    pub topics: Vec<String>,
    pub subscriptions: Vec<String>,
}

Configuration shared by all message-broker adapters.

Concrete broker configs embed this struct so generic code can work through BrokerConfigExt without knowing adapter-specific fields.

Fields

adapter: String

Adapter name used for registry selection.

name: String

Logical name for this configuration.

enabled: bool

Whether this configuration is enabled.

retries: u32

Number of retries for failed requests.

retry_backoff: u64

Backoff between retry attempts in milliseconds.

request_timeout: Option<u64>

Request timeout in milliseconds (None = use broker default).

delivery_guarantee: DeliveryGuarantee

Requested delivery semantics.

commit_strategy: CommitStrategy

Offset/ack commit behavior.

dlq: DlqPolicy

Dead-letter queue policy.

max_in_flight: usize

Maximum number of in-flight messages.

consumer_group: Option<String>

Broker-neutral consumer group name.

topics: Vec<String>

Broker-neutral topic declarations.

subscriptions: Vec<String>

Broker-neutral subscription subjects/topics. Empty means the consumer chooses at runtime.

Implementations

impl BrokerConfig

pub fn new(adapter: impl Into<String>) -> Self

Create a broker config with the provided adapter name and shared defaults.

pub fn request_timeout_duration(&self) -> Option<Duration>

Return the request timeout as a Duration, if configured.

pub const fn retry_backoff_duration(&self) -> Duration

Return retry backoff as a Duration.

pub fn validate(&self) -> AppResult<()>

Validate shared broker-neutral configuration.

Trait Implementations

impl Clone for BrokerConfig

fn clone(&self) -> BrokerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BrokerConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BrokerConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BrokerConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for BrokerConfig

impl PartialEq for BrokerConfig

fn eq(&self, other: &BrokerConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for BrokerConfig