Skip to main content

ingress

@totemsdk/edge

@totemsdk/edge / ingress

Function: ingress()

ingress(raw, context, opts): Promise<IngressResult>

Run the authenticated ingress pipeline. Returns the authenticated message and sender, or throws a typed error.

The replay claim is ATOMIC: two identical messages arriving concurrently cannot both observe "not present". Exactly one caller wins the claim.

Parameters​

raw​

unknown

context​

recipient​

string

sender​

string

opts​

IngressOptions

Returns​

Promise<IngressResult>