Packages

conduit

0.12.6
0.12.10 0.12.9 0.12.8 0.12.7 0.12.6 0.12.5 0.12.4 0.12.3 0.12.2 0.12.1 0.12.0 0.11.0 0.10.8 0.10.7 0.10.6 0.10.5 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.1 0.1.0

Message queue framework, with support for middleware and multiple adapters.

HexDocs

Current section

Files

Jump to
Readme
39 Versions
3 Dependencies
5 Dependants
Files
Activity
conduit lib conduit topology exchange.ex
Raw

lib/conduit/topology/exchange.ex 

defmodule Conduit.Topology.Exchange do

  @moduledoc """

  Configuration for an exchange

  """

  @type t :: %__MODULE__{

          name: String.t(),

          opts: Keyword.t()

        }

  @type name :: String.t() | (() -> String.t())

  @type opts :: Keyword.t() | (() -> Keyword.t())



  defstruct name: nil, opts: []



  @doc """

  Creates a new Exchange struct



  If functions are passed to either argument, they will be evaluated before returning the struct.



  ## Examples



      iex> Conduit.Topology.Exchange.new("topic")

      %Conduit.Topology.Exchange{name: "topic", opts: []}

      iex> Conduit.Topology.Exchange.new("topic", type: :fanout)

      %Conduit.Topology.Exchange{name: "topic", opts: [type: :fanout]}

      iex> Conduit.Topology.Exchange.new(fn -> "dynamic.name" end, fn -> [type: :fanout] end)

      %Conduit.Topology.Exchange{name: "dynamic.name", opts: [type: :fanout]}

  """

  @spec new(name, opts) :: t()

  def new(name, opts \\ [])

  def new(name, opts) when is_function(name), do: new(name.(), opts)

  def new(name, opts) when is_function(opts), do: new(name, opts.())



  def new(name, opts) when is_binary(name) and is_list(opts) do

    %__MODULE__{name: name, opts: opts}

  end

end