Struct LaserstreamConfig 

pub struct LaserstreamConfig {
    pub api_key: String,
    pub endpoint: String,
    pub max_reconnect_attempts: Option<u32>,
    pub channel_options: ChannelOptions,
    pub replay: bool,
}

Fields

api_key: String

API Key for authentication.

endpoint: String

The Laserstream endpoint URL.

max_reconnect_attempts: Option<u32>

Maximum number of reconnection attempts. Defaults to 10. A hard cap of 240 attempts (20 minutes / 5 seconds) is enforced internally.

channel_options: ChannelOptions

gRPC channel options

replay: bool

When true, enable replay on reconnects (uses from_slot and internal slot tracking). When false, no replay - start from current slot on reconnects. Default: true

Implementations

impl LaserstreamConfig

pub fn new(endpoint: String, api_key: String) -> Self

pub fn with_max_reconnect_attempts(self, attempts: u32) -> Self

Sets the maximum number of reconnection attempts.

pub fn with_channel_options(self, options: ChannelOptions) -> Self

Sets custom channel options.

pub fn with_replay(self, replay: bool) -> Self

Sets replay behavior on reconnects. When true (default), uses from_slot and internal slot tracking for replay. When false, starts from current slot on reconnects (no replay).

Trait Implementations

impl Clone for LaserstreamConfig

fn clone(&self) -> LaserstreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LaserstreamConfig

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

Formats the value using the given formatter.

impl Default for LaserstreamConfig

fn default() -> Self

Returns the “default value” for a type.