Struct OwpConfig

pub struct OwpConfig {

    pub bind: SocketAddr,
    pub server_id: String,
    pub system_label: String,
    pub schema: Option<String>,
    pub system_uuid: String,
    pub unwrap_ma_payloads: bool,
    pub xml_baseline: bool,
    pub max_frame_size: usize,
    pub max_connections: usize,
    pub max_subscriptions: usize,
    pub init_timeout: Option<Duration>,
    pub idle_timeout: Option<Duration>,
    pub allowed_origins: Vec<String>,
    pub validate: Mode,
    pub on_panic: OnPanic,
    pub reconnect: bool,
    pub reconnect_delay: Duration,
}

Settings for one OWP listener.

Self::schema is the INIT protocol version, not a UCI catalog. Self::system_uuid is minted per process by the host, not read from TOML.

Fields

bind: SocketAddr

Address already resolved by the host.

server_id: String

Server identity sent on INFO.

system_label: String

Human-readable label sent on INFO.

schema: Option<String>

When set, INIT.schema must match exactly. None skips the check.

system_uuid: String

System UUID sent on INFO. Generated per process, not configured.

unwrap_ma_payloads: bool

Peel A-GRA Rx/Tx hex wrappers on PUB and fan out wrapper + inner.

xml_baseline: bool

Convert OMS JSON ↔ UCI XML at the socket. Engine / ASB see XML.

max_frame_size: usize

Largest frame accepted from a client. Oversized frames end the session.

max_connections: usize

Connections served at once. Further ones are closed on accept.

max_subscriptions: usize

Subscriptions one connection may hold.

init_timeout: Option<Duration>

Deadline from an accepted WebSocket to a successful INIT. None disables it. Measured from the handshake, not reset by traffic: a peer that connects and never INITs is closed when this elapses.

idle_timeout: Option<Duration>

Longest gap with no frame in either direction on an active session. None disables it. Any client frame and any server frame resets it, so an active publisher or subscriber is never closed for being idle.

allowed_origins: Vec<String>

Exact Origin header values accepted at the WebSocket handshake. Empty (the default) accepts any origin, including none, which is the behavior before this list existed. When non-empty, a handshake whose Origin is not listed verbatim is refused with 403.

validate: Mode

What to do about a payload that does not follow the loaded schema. Has no effect without one: there is nothing to check against.

on_panic: OnPanic

Panic in the accept loop: abort run, or treat it as a failed session.

reconnect: bool

Rebind and accept again after the accept loop ends or panics.

reconnect_delay: Duration

Sleep between rebind attempts.

Trait Implementations

impl Clone for OwpConfig

fn clone(&self) -> OwpConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for OwpConfig

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

Formats the value using the given formatter.

impl Default for OwpConfig

fn default() -> Self

Returns the “default value” for a type.