Struct OptimizedConsumerConfig 

pub struct OptimizedConsumerConfig {
    pub name: String,
    pub max_ack_pending: i64,
    pub max_deliver: i64,
    pub ack_wait: Duration,
    pub batch_size: usize,
    pub filter_subject: Option<String>,
    pub flow_control: FlowControlConfig,
}

Consumer configuration optimized for Phase 2 performance requirements

Fields

name: String

Consumer name

max_ack_pending: i64

Maximum messages to deliver without acknowledgment

max_deliver: i64

Maximum delivery attempts before dead letter

ack_wait: Duration

Acknowledgment wait time

batch_size: usize

Pull-based consumer batch size

filter_subject: Option<String>

Consumer filter subject (supports sharding)

flow_control: FlowControlConfig

Flow control settings

Implementations

impl OptimizedConsumerConfig

pub fn for_fs_read() -> Self

Create consumer config optimized for fs.read capability

pub fn for_http_fetch() -> Self

Create consumer config optimized for http.fetch capability

pub fn for_admission() -> Self

Create consumer config optimized for admission control

Trait Implementations

impl Clone for OptimizedConsumerConfig

fn clone(&self) -> OptimizedConsumerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OptimizedConsumerConfig

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

Formats the value using the given formatter.

impl Default for OptimizedConsumerConfig

fn default() -> Self

Returns the “default value” for a type.