NATS Module for Helium

Module provides you with the following things:

• *nats.Conn represents a bare connection to a nats-server. It can send and receive []byte payloads
• stan.Conn represents a connection to the NATS Streaming subsystem. It can Publish and Subscribe to messages within the NATS Streaming cluster.

Configuration:

• yaml example

  nats:
  url: nats://<host>:<port>
  cluster_id: string
  client_id: string
  servers: [...server slice...]
  no_randomize: bool
  name: string
  verbose: bool
  pedantic: bool
  secure: bool
  allow_reconnect: bool
  max_reconnect: int
  reconnect_wait: duration
  timeout: duration
  flusher_timeout: duration
  ping_interval: duration
  max_pings_out: int
  reconnect_buf_size: int
  sub_chan_len: int
  user: string
  password: string
  token: string
  stan:
    connect_wait: duration
    pub_ack_wait: duration
    max_pub_acks_inflight: int
    ping_max_out: int
    ping_interval: int

• env example

  NATS_SERVERS_0=nats://<host>:<port>
  ...
  NATS_SERVERS_<N>=nats://<host>:<port>
  NATS_URL=nats://<host>:<port>
  NATS_CLUSTER_ID=string
  NATS_CLIENT_ID=string
  NATS_NO_RANDOMIZE=bool
  NATS_NAME=string
  NATS_VERBOSE=bool
  NATS_PEDANTIC=bool
  NATS_SECURE=bool
  NATS_ALLOW_RECONNECT=bool
  NATS_MAX_RECONNECT=int
  NATS_RECONNECT_WAIT=duration
  NATS_TIMEOUT=duration
  NATS_FLUSHER_TIMEOUT=duration
  NATS_PING_INTERVAL=duration
  NATS_MAX_PINGS_OUT=int
  NATS_RECONNECT_BUF_SIZE=int
  NATS_SUB_CHAN_LEN=int
  NATS_USER=string
  NATS_PASSWORD=string
  NATS_TOKEN=string
  NATS_STAN_CONNECT_WAIT=duration
  NATS_STAN_PUB_ACK_WAIT=duration
  NATS_STAN_MAX_PUB_ACKS_INFLIGHT=int
  NATS_STAN_PING_MAX_OUT=int
  NATS_STAN_PING_INTERVAL=int