Reactive Interaction Gateway v3.0.0-alpha.2

Rig.BrokerConnection behaviour (Reactive Interaction Gateway v3.0.0-alpha.2) View Source

Interface to any publish-subscribe capable broker service.

Link to this section Summary

Types

callback()
connection()
subscription_id()
topic()

Callbacks

publish(connection, topic, key, arg4)
subscribe(connection, topic, callback)
unsubscribe(subscription_id)

Link to this section Types

Link to this type

callback()

View Source

Specs

callback() :: (RigCloudEvents.CloudEvent.t() -> :ok | {:error, any()})
Link to this type

connection()

View Source

Specs

connection() :: any()
Link to this type

subscription_id()

View Source

Specs

subscription_id() :: any()
Link to this type

topic()

View Source

Specs

topic() :: String.t()

Link to this section Callbacks

Link to this callback

publish(connection, topic, key, arg4)

View Source

Specs

publish(connection(), topic(), key :: String.t(), RigCloudEvents.CloudEvent.t()) ::
  :ok
Link to this callback

subscribe(connection, topic, callback)

View Source

Specs

subscribe(connection(), topic(), callback()) ::
  {:ok, subscription_id()} | {:error, any()}
Link to this callback

unsubscribe(subscription_id)

View Source

Specs

unsubscribe(subscription_id()) :: :ok