Conduit v0.8.0 Conduit.Adapter behaviour

Defines the behavior for an adapter.

Summary

Types

broker()

config()

opts()

subscribers()

topology()

Functions

__using__(opts)

Defines the useing module as implementing the Conduit.Adapter behavior

Callbacks

publish(arg0, config, opts)

start_link(broker, topology, subscribers, config)

Types

broker()

broker() :: module

config()

config() :: Keyword.t

opts()

opts() :: Keyword.t

subscribers()

subscribers() :: %{optional(atom) => {module, Keyword.t}}

topology()

topology() :: [{atom, binary, Keyword.t}]

Functions

__using__(opts) (macro)

Defines the useing module as implementing the Conduit.Adapter behavior.

Callbacks

publish(arg0, config, opts)

publish(Conduit.Message.t, config, opts) ::
  {:ok, Conduit.Message.t} |
  {:error, binary | atom}

start_link(broker, topology, subscribers, config)

start_link(broker, topology, subscribers, config) :: GenServer.on_start