Packages

conduit

0.10.0
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 adapter.ex
Raw

lib/conduit/adapter.ex 

defmodule Conduit.Adapter do

  @moduledoc """

  Defines the behavior for an adapter.

  """



  @type broker :: module

  @type topology :: [{atom, binary, Keyword.t}]

  @type subscribers :: %{atom => {module, Keyword.t}}

  @type config :: Keyword.t

  @type opts :: Keyword.t



  @callback start_link(broker, topology, subscribers, config)

    :: GenServer.on_start

  @callback publish(Conduit.Message.t, config, opts)

    :: {:ok, Conduit.Message.t} | {:error, binary | atom}



  @doc """

  Defines the `use`ing module as implementing the `Conduit.Adapter` behavior.

  """

  defmacro __using__(_opts) do

    quote do

      @behaviour Conduit.Adapter

    end

  end

end