Enum StreamMatcher 

pub enum StreamMatcher {
    Literal {
        text: String,
        case_sensitive: bool,
        window_bytes: u64,
    },
    Regex {
        pattern: String,
        dialect: RegexDialect,
        window_bytes: u64,
        timeout_ms: u64,
    },
    Marker {
        marker_id: MarkerId,
        marker_version: MarkerVersion,
    },
    HostMatcher {
        matcher_ref: MatcherEngineRef,
        risk_policy_ref: Option<PolicyRef>,
    },
}

Enumerates the finite stream matcher cases. Serialized names are part of the SDK contract; update fixtures when variants change.

Variants

Literal

Use this variant when the contract needs to represent literal; selecting it has no side effect by itself.

Fields

text: String

Text used by this record or request.

case_sensitive: bool

Whether case sensitive is enabled. Policy, validation, or routing code uses this flag to choose the explicit behavior.

window_bytes: u64

window bytes used for bounds checks, summaries, or truncation evidence.

Regex

Use this variant when the contract needs to represent regex; selecting it has no side effect by itself.

Fields

pattern: String

Search pattern supplied by the caller. The grep executor compiles it under regex and output bounds before reading files.

dialect: RegexDialect

Schema dialect used to interpret the output schema. Validators use it to select the supported JSON-schema subset and compatibility rules.

window_bytes: u64

window bytes used for bounds checks, summaries, or truncation evidence.

timeout_ms: u64

Timeout budget in milliseconds for the requested operation.

Marker

Use this variant when the contract needs to represent marker; selecting it has no side effect by itself.

Fields

marker_id: MarkerId

Stable marker id used for typed lineage, lookup, or dedupe.

marker_version: MarkerVersion

Version string for this capability, package, or protocol surface. Use it for compatibility checks during package or adapter resolution.

HostMatcher

Use this variant when the contract needs to represent host matcher; selecting it has no side effect by itself.

Fields

matcher_ref: MatcherEngineRef

Typed matcher ref reference. Resolving or executing it is a separate policy-gated step.

risk_policy_ref: Option<PolicyRef>

Typed risk policy ref reference. Resolving or executing it is a separate policy-gated step.

Implementations

impl StreamMatcher

pub fn literal( text: impl Into<String>, case_sensitive: bool, window_bytes: u64, ) -> Self

Builds the literal value with the documented defaults. This is data-only and does not perform I/O, call host ports, append journals, publish events, or start processes.

pub fn regex_with_limits( pattern: impl Into<String>, window_bytes: u64, timeout_ms: u64, ) -> Self

Builds the regex with limits value with the documented defaults. This is data-only and does not perform I/O, call host ports, append journals, publish events, or start processes.

pub fn marker(marker_id: impl Into<String>) -> Self

Marker. This is data-only and does not perform I/O, call host ports, append journals, publish events, or start processes.

pub fn window_bytes(&self) -> u64

Builds the window bytes value with the documented defaults. This is data-only and does not perform I/O, call host ports, append journals, publish events, or start processes.

pub fn kind_name(&self) -> &'static str

Returns the kind name currently held by this value. This is data-only and does not perform I/O, call host ports, append journals, publish events, or start processes.

pub fn validate(&self) -> Result<(), AgentError>

Validates the records::stream invariants and returns a typed error on failure. Validation is pure and does not perform I/O, dispatch, journal appends, or adapter calls.

Trait Implementations

impl Clone for StreamMatcher

fn clone(&self) -> StreamMatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamMatcher

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamMatcher

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for StreamMatcher

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for StreamMatcher

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for StreamMatcher

impl StructuralPartialEq for StreamMatcher