Packages

conduit

0.12.10
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 queue.ex
Raw

lib/conduit/topology/queue.ex 

defmodule Conduit.Topology.Queue do

  @moduledoc """

  Configuration for an queue

  """

  @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 Queue struct



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



  ## Examples



    iex> Conduit.Topology.Queue.new("my_app.event")

    %Conduit.Topology.Queue{name: "my_app.event", opts: []}

    iex> Conduit.Topology.Queue.new("my_app.event", from: ["my_app.event_queue"])

    %Conduit.Topology.Queue{name: "my_app.event", opts: [from: ["my_app.event_queue"]]}

    iex> Conduit.Topology.Queue.new(fn -> "dynamic.name" end, fn -> [from: ["my_app.event_queue"]] end)

    %Conduit.Topology.Queue{name: "dynamic.name", opts: [from: ["my_app.event_queue"]]}

  """

  @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