Struct SseRouteDef 

pub struct SseRouteDef {
    pub subject: String,
    pub reducer: Option<String>,
    pub anonymous: bool,
}

The NATS subject an event-stream route bridges, and the handler that turns each message into events.

Fields

subject: String

Dot-separated tokens starting dw.{tenant}.; a {name} token is the route’s path parameter of that name. * and > wildcards are allowed.

reducer: Option<String>

Exported handler reducing each message; without one every message is forwarded as a data-only event.

anonymous: bool

Streams to callers the route does not authenticate: required on a public or undeclared posture.

Implementations

impl SseRouteDef

pub const SUBJECT_PREFIX: &'static str = "dw.{tenant}."

Every subject starts with this: an event stream reads only its own tenant’s subjects.

pub const REDUCER_METHOD: &'static str = "SSE_EVENT"

The method of the request a reducer receives.

pub const RESERVED_TOKENS: &'static [&'static str]

Tokens after the prefix the platform itself publishes under (the tenant’s audit log), never bridged.

pub fn subject_violation(&self, params: Option<&[String]>) -> Option<String>

Why the subject cannot be bridged for a route whose path parameters are params (None on a legacy route, which has none): it must be dot-separated tokens under the prefix, name its events with a literal token that is not reserved, and bind every {name} but {tenant} to a path parameter.

pub fn anonymous_violation( &self, anonymous_posture: bool, ) -> Option<&'static str>

Why the stream cannot be served on a posture that admits anonymous callers (public or undeclared) unless it opts in.

pub fn placeholders(&self) -> impl Iterator<Item = &str>

The names of the template’s {name} tokens, tenant included.

pub fn resolve( &self, tenant: &str, params: &[(String, String)], ) -> Result<String, SseSubjectError>

The subject for tenant and the route’s path parameters.

Trait Implementations

impl Clone for SseRouteDef

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SseRouteDef

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SseRouteDef

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for SseRouteDef

impl PartialEq for SseRouteDef

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for SseRouteDef

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SseRouteDef