Conduit

v0.12.9

Conduit

Conduit v0.12.9 Conduit.Adapter behaviour View Source

Defines the behavior for an adapter.

Link to this section Summary

Types

broker()
config()
opts()
subscribers()
topology()

Callbacks

publish(arg0, config, opts)
publish(module, arg1, config, opts)
start_link(broker, topology, subscribers, config)

Link to this section Types

Link to this type subscribers() View Source 
subscribers() :: %{optional(atom()) => {module(), Keyword.t()}}
Link to this type topology() View Source 
topology() :: [{atom(), binary(), Keyword.t()}]

Link to this section Callbacks

Link to this callback publish(arg0, config, opts) View Source 
publish(Conduit.Message.t(), config(), opts()) ::
  {:ok, Conduit.Message.t()} | {:error, binary() | atom()} | no_return()
Link to this callback publish(module, arg1, config, opts) View Source 
publish(module(), Conduit.Message.t(), config(), opts()) ::
  {:ok, Conduit.Message.t()} | {:error, term()}
Link to this callback start_link(broker, topology, subscribers, config) View Source 
start_link(broker(), topology(), subscribers(), config()) ::
  GenServer.on_start()