Ironflow Event Ingest Flow

Ironflow Event Ingest Flow A workflow diagram generated by Archify. 01 / External publisher 02 / Ironflow server EX / Redelivery Into the stream Consume and validate Ack outcome External system · publishes to NATS · External publisher › Into the stream External system publishes to NATS EVENTS stream · LimitsPolicy, size-bounded · Ironflow server › Into the stream · kept after ack EVENTS stream LimitsPolicy, size-bounded kept after ack EventRouter · durable, explicit ack · Ironflow server › Consume and validate · filter: events.ingest.> EventRouter durable, explicit ack filter: events.ingest.> Validate · unmarshal, name, schema · Ironflow server › Consume and validate Validate unmarshal, name, schema Insert + dispatch · dispatch shared with emit() · Ironflow server › Ack outcome Insert + dispatch dispatch shared with emit() Nak · 5 failures max · Redelivery › Consume and validate Nak 5 failures max Term · Dead Letters if env known · Redelivery › Ack outcome Term Dead Letters if env known consume events.ingest.{name} redeliver immediately transient error each delivery never becomes valid Ack Legend Server step Validation NATS stream Publisher / outcome