A "generic" Argo EventSource implementation supporting NATS Jetstream
See: https://argoproj.github.io/argo-events/eventsources/generic/
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.
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.
In order to re-generate the EventSource generic.proto (if it changes), your environment will need:
protoc(Protocol Buffers compiler)protoc-gen-gopluginprotoc-gen-go-grpcplugin
Re-generate and commit the protobuf/grpc code:
go generate