justinisrael/argo-natsjs-eventsource repository overview

⁠Argo NATS Jetstream EventSource

A "generic" Argo EventSource implementation supporting NATS Jetstream

See: https://argoproj.github.io/argo-events/eventsources/generic/⁠

⁠Purpose

At the time this was implemented, Argo Events does not provide an EventSource implementation that supports Nats Jetstream. It only supports Nats core messaging. This generic EventSource will be maintained until hopefully the implementation can be adopted as a 1st-class EventSource.

https://github.com/argoproj/argo-events/issues/3160⁠

⁠Implementation

An instance of this service is referenced by the generic EventSource definition url. A config is then also specified to be passed to the service when the EventSource proxy is created and requests to begin streaming messages. For each EventSource that is defined, a new Nats connection is started, and a Consumer is created/updated based on the config. When the stream ends, the Nats connection is closed.

⁠Development

https://github.com/justinfx/argo-natsjs-eventsource⁠