View Source Sorcery.PubSub.Behaviour behaviour (Sorcery v0.1.0)

Summary

Types

subscription()

Callbacks

publish(events)
start(opts)
subscribe()
subscribe(subscription, opts)

Types

subscription()

@type subscription() :: %{domain: String.t(), instance_id: String.t()}

Callbacks

publish(events)

@callback publish(events :: term()) :: :ok

start(opts)

@callback start(opts :: Keyword.t()) :: {:ok, pid()} | {:error, term()}

subscribe()

@callback subscribe() :: :ok | {:error, term()}

subscribe(subscription, opts)

@callback subscribe(subscription :: term(), opts :: Keyword.t()) ::
  {:ok, pid()} | {:error, term()}