Packages

jetstream

0.0.1-pre1
0.0.9 retired 0.0.8 retired 0.0.8-alpha2 retired 0.0.8-alpha1 retired 0.0.7 retired 0.0.6 retired 0.0.5 retired 0.0.4 retired 0.0.3 retired 0.0.2 retired 0.0.1 retired 0.0.1-pre2 retired 0.0.1-pre1 retired 0.0.1-pre0 retired

A Jetstream client in pure Elixir.

Retired package: Renamed - Merged into the main nats.ex (gnat) library. Use Gnat.Jetstream from the :gnat package instead.
HexDocs

Current section

Files

Jump to
Readme
14 Versions
2 Dependencies
Dependants
Files
Activity
jetstream lib jetstream.ex
Raw

lib/jetstream.ex 

defmodule Jetstream do

  @moduledoc """

  Provides functions for interacting with a [NATS Jetstream](https://github.com/nats-io/jetstream) server.



  > Note: Jetstream is currently considered a beta feature of the NATS project, it is not available by default.

  > Any APIs you see here are liable to change in a way that is outside the normal versioning scheme.

  """



  @spec ack(Gnat.message()) :: :ok

  def ack(%{gnat: gnat, reply_to: reply_to}) do

    Gnat.pub(gnat, reply_to, "")

  end



  @spec nack(Gnat.message()) :: :ok

  def nack(%{gnat: gnat, reply_to: reply_to}) do

    Gnat.pub(gnat, reply_to, "-NAK")

  end

end