Interface: EventSink

Defined in: livelink.clients/livelink.agent/sources/data/Transport.ts:14

Anything events can be pushed into: an IngestionPipeline, a SceneIngestion, a test double, a tee forwarding to several sinks.

A Transport produces whole IngestEvents rather than (channel, payload) pairs, so what the source knows about an event — when it was actually produced, its offset, its QoS — has somewhere to go instead of being dropped at the boundary.

Methods

ingest()

ingest(event: IngestEvent): void | Promise<void>;

Defined in: livelink.clients/livelink.agent/sources/data/Transport.ts:19

Submit one event. Implementations must not throw: a failure to handle one event must not take the transport down.

Parameters

Parameter	Type
event	IngestEvent

Returns

void | Promise<void>