ankusa_nats

NATS JetStream sink adapter for the Ankusa webhook ingestion framework.

This package exists so ankusa core stays free of the :gnat dependency (and everything it pulls in: jason, nkeys, nimble_parsec). Only deployments that opt into a NATS sink need this package.

Installation

def deps do
  [
    {:ankusa, "~> 0.2"},
    {:ankusa_nats, "~> 0.2"}
  ]
end

Usage

See Ankusa.Sink.NATS moduledoc for configuration and semantics. The stream is yours to create. The sink publishes to a subject and never creates or updates a stream:

nats stream add ANKUSA --subjects="ankusa.>"

config :ankusa, :default,
  sinks: [
    {Ankusa.Sink.NATS,
     servers: ["localhost:4222"],
     subject: "ankusa.stripe"}
  ]

Testing

Requires a live NATS server with JetStream enabled:

docker compose up -d --wait
mix test
docker compose down -v

See https://hexdocs.pm/ankusa for the full Ankusa documentation.