Struct ChannelUri 

pub struct ChannelUri {}

Represents the Aeron URI parser and handler.

Implementations

impl ChannelUri

pub const AERON_SCHEME: &'static str = "aeron"

pub const SPY_QUALIFIER: &'static str = "aeron-spy"

pub const MAX_URI_LENGTH: usize = 4095

pub fn add_session_id(channel: &str, session_id: i32) -> String

Return channel with a session-id param added (replacing any existing one).

Mirrors Java’s ChannelUri.addSessionId — the standard way to build a channel that joins a specific session, e.g. when subscribing to an archive replay:

assert_eq!(
    ChannelUri::add_session_id("aeron:ipc", 42),
    "aeron:ipc?session-id=42"
);
assert_eq!(
    ChannelUri::add_session_id("aeron:udp?endpoint=localhost:20121", -123),
    "aeron:udp?endpoint=localhost:20121|session-id=-123"
);

pub fn set_param(channel: &str, key: &str, value: &str) -> String

Return channel with URI param key=value set, replacing an existing key param if present. Other params keep their relative order; key goes last.