Struct SopIngress 

pub struct SopIngress<'a> { /* private fields */ }

Borrowed, per-call adapter from transport deliveries into canonical SOP events.

This is the ingress boundary for untrusted fan-in sources. Transport adapters retain ownership of protocol parsing and identifiers; this adapter owns handle validation, source-interest gating, input capping, event stamping, dispatch, and headless result diagnostics. It borrows the daemon’s canonical engine and audit handles and does not cache config or SOP state.

Implementations

impl<'a> SopIngress<'a>

pub fn new( engine: Option<&'a Arc<Mutex<SopEngine>>>, audit: Option<&'a SopAuditLogger>, ) -> Self

pub fn with_driver_sink(self, sink: &'a SopDriverSink) -> Self

Attach the shared driver supervisor. Callers that omit this keep the previous behavior; callers whose triggers can start auto-mode runs (channel ingress) must attach it or their runs are created undriven.

pub async fn dispatch( &self, source: SopTriggerSource, topic: Option<&str>, payload: Option<&str>, target_sop: Option<&str>, dedup: Option<(String, bool)>, ) -> SopIngressOutcome

Lift one untrusted transport delivery into the shared SOP path.

pub async fn dispatch_deduplicated( &self, source: SopTriggerSource, topic: Option<&str>, payload: Option<&str>, target_sop: Option<&str>, dedup_key: String, ) -> SopIngressOutcome

Lift a fresh delivery with a semantic key shared across independent producers. If another producer already started the same SOP under this key and that run is still active, dispatch coalesces into it. This is intentionally distinct from AMQP redelivery idempotency: both callers are fresh and neither should mark the key ambiguous.