Packages

gnat

1.10.2-rc1
1.16.0 1.15.2 1.15.1 1.15.0 1.14.1 1.14.0 1.14.0-rc1 1.14.0-rc0 1.13.1 1.13.0 1.12.1 1.12.0 1.11.1 1.11.0 1.10.2 1.10.2-rc1 1.10.2-rc0 1.10.1 1.10.0 1.9.1 1.9.0 1.8.5 1.8.4 1.8.3 1.8.2 1.8.1 1.7.1 1.7.0 1.6.0 1.5.2 1.5.1 1.5.0 1.4.0 1.3.0 1.3.0-rc0 1.2.1 1.2.0 1.1.3 1.1.2 1.1.1 1.1.0 1.0.1 1.0.0 0.7.0 0.6.1 0.6.0 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.2 0.4.1 0.4.0 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.0 0.1.3 0.1.2 0.1.1 0.1.0

A nats client in pure elixir. Resilience, Performance, Ease-of-Use.

HexDocs

Current section

Files

Jump to
Readme
65 Versions
6 Dependencies
7 Dependants
Files
Activity
gnat lib gnat jetstream pull_consumer connection_options.ex
Raw

lib/gnat/jetstream/pull_consumer/connection_options.ex 

defmodule Gnat.Jetstream.PullConsumer.ConnectionOptions do

  @moduledoc false



  @default_retry_timeout 1000

  @default_retries 10



  @enforce_keys [

    :connection_name,

    :stream_name,

    :consumer_name,

    :connection_retry_timeout,

    :connection_retries,

    :inbox_prefix,

    :domain

  ]



  defstruct @enforce_keys



  def validate!(connection_options) do

    struct!(

      __MODULE__,

      Keyword.validate!(connection_options, [

        :connection_name,

        :stream_name,

        :consumer_name,

        connection_retry_timeout: @default_retry_timeout,

        connection_retries: @default_retries,

        inbox_prefix: nil,

        domain: nil

      ])

    )

  end

end