Struct ServerConfig 

pub struct ServerConfig {
    pub listen_addr: SocketAddr,
    pub subscriber_channel_capacity: usize,
    pub grpc_output_buffer: usize,
    pub store_path: Option<PathBuf>,
    pub redelivery_interval_secs: u64,
    pub max_delivery_attempts: u32,
    pub retention_secs: u64,
    pub default_ack_timeout_secs: u32,
    pub default_max_in_flight: u32,
    pub gc_interval_secs: u64,
    pub redelivery_batch_size: u32,
}

Fields

listen_addr: SocketAddr

subscriber_channel_capacity: usize

Capacity of the broadcast (fanout) and mpsc (queue-group) channels inside the broker engine. This is the main buffer between publishers and subscribers.

grpc_output_buffer: usize

Capacity of the gRPC output mpsc channel per subscriber. This is a small decoupling buffer between the forwarding task and the gRPC write. Keep it small — back-pressure should be handled by the broadcast/mpsc channel above.

store_path: Option<PathBuf>

Path to the redb store file. None = fire-and-forget only, no durable mode.

redelivery_interval_secs: u64

How often the redelivery loop runs (seconds).

max_delivery_attempts: u32

Max delivery attempts before dead-lettering.

retention_secs: u64

How long to keep acked messages before GC (seconds).

default_ack_timeout_secs: u32

Default ack timeout for durable subscriptions (seconds).

default_max_in_flight: u32

Default max in-flight messages for durable subscriptions.

gc_interval_secs: u64

How often the GC loop runs (seconds).

redelivery_batch_size: u32

Max expired messages processed per consumer per redelivery cycle.

Implementations

impl ServerConfig

pub fn from_env() -> Self

Trait Implementations

impl Default for ServerConfig

fn default() -> Self

Returns the “default value” for a type.