Conduit v0.3.0 Conduit.Adapter behaviour

Defines the behavior for an adapter.

Summary

Types

subscribers()

topology()

Callbacks

publish(arg0, arg1)

start_link(topology, subscribers, arg2)

Types

subscribers()

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

topology()

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

Callbacks

publish(arg0, arg1)

publish(Conduit.Message.t, Keyword.t) ::
  {:ok, Conduit.Message.t} |
  {:error, binary}

start_link(topology, subscribers, arg2)

start_link(topology, subscribers, Keyword.t) :: pid