View Source nats_msg (enats_msg v1.0.0)

Summary

Types

encode_param/0

-type encode_param() ::
          ping | pong | ok | error |
          {info, iodata()} |
          {connect, iodata()} |
          error_param() |
          pub_param() |
          hpub_param() |
          sub_param() |
          unsub_param() |
          msg_param() |
          hmsg_param().

error_param/0

-type error_param() ::
          {error, unknown_operation} |
          {error, auth_violation} |
          {error, auth_timeout} |
          {error, parser_error} |
          {error, stale_connection} |
          {error, slow_consumer} |
          {error, max_payload} |
          {error, invalid_subject}.

hmsg_param/0

-type hmsg_param() ::
          {hmsg,
           {Subject :: iodata(),
            Sid :: iodata(),
            ReplyTo :: iodata() | undefined,
            Header :: iodata(),
            Payload :: iodata()}}.

hpub_param/0

-type hpub_param() ::
          {hpub,
           {Subject :: iodata(),
            ReplyTo :: iodata() | undefined,
            Header :: iodata(),
            Payload :: iodata()}}.

msg_param/0

-type msg_param() ::
          {msg,
           {Subject :: iodata(), Sid :: iodata(), ReplyTo :: iodata() | undefined, Payload :: iodata()}}.

pub_param/0

-type pub_param() :: {pub, {Subject :: iodata(), ReplyTo :: iodata() | undefined, Payload :: iodata()}}.

sub_param/0

-type sub_param() :: {sub, {Subject :: iodata(), QueueGrp :: iodata() | undefined, Sid :: iodata()}}.

unsub_param/0

-type unsub_param() :: {unsub, {Sid :: iodata(), MaxMsg :: integer() | undefined}}.

Functions

connect(Info)

decode(Param)

-spec decode(Param :: iodata()) -> {term(), binary()}.

decode(OrigMsg, CbFunState)

decode_all(Bin)

encode(Param)

-spec encode(Param :: encode_param()) -> iolist().

err(Msg)

hmsg(Subject, Sid)

hmsg(Subject, Sid, Header, Payload)

hmsg(Subject, Sid, ReplyTo, Header, Payload)

hpub(Subject)

hpub(Subject, Header, Payload)

hpub(Subject, ReplyTo, Header, Payload)

info(Info)

init()

msg(Subject, Sid)

msg(Subject, Sid, ReplyTo, Payload)

ok()

ping()

pong()

pub(Subject)

pub(Subject, ReplyTo, Payload)

sub(Subject, Sid)

sub(Subject, QueueGrp, Sid)

unsub(Sid)

unsub(Sid, MaxMsg)