nats_streaming

v0.0.1

nats_streaming v0.0.1 Gnat.Streaming.Client

Link to this section Summary

Types

t()

Functions

pub(streaming_client, subject, payload, options \\ [])
pub_info(streaming_client)
start_link(settings, options \\ [])
sub_info(streaming_client)

Link to this section Types

Link to this type

t()

Specs

t() :: %Gnat.Streaming.Client{
  client_id: String.t(),
  close_subject: String.t() | nil,
  conn_id: String.t(),
  connection_name: atom(),
  connection_pid: pid() | nil,
  heartbeat_subject: term(),
  pub_subject: String.t() | nil,
  sub_subject: String.t() | nil,
  unsub_subject: String.t() | nil
}

Link to this section Functions

Link to this function

pub(streaming_client, subject, payload, options \\ [])

Specs

pub(GenServer.server(), String.t(), binary(), keyword()) ::
  :ok | {:error, term()}
Link to this function

pub_info(streaming_client)

Specs

pub_info(GenServer.server()) ::
  {:ok, {String.t(), String.t(), pid()}} | {:error, term()}
Link to this function

start_link(settings, options \\ [])

Link to this function

sub_info(streaming_client)

Specs

sub_info(GenServer.server()) ::
  {:ok, {String.t(), String.t(), pid()}} | {:error, term()}