tai v0.0.75

Tai.SystemBus (tai v0.0.75)

A core pubsub bus for async message communication. The following subsystems depend on this module.

  • boot
  • stream connection
  • product, fees, position & account hydration
  • order book changesets
  • metrics

NOTE: To ensure maximum performance you should not publish custom messages or subscribe to system topics

Link to this section Summary

Types

partitions()
topic()
topics()

Functions

broadcast(topic, message)
child_spec(opts)
start_link(partitions)
subscribe(topics)
unsubscribe(topics)

Link to this section Types

Link to this type

partitions()

Specs

partitions() :: pos_integer()
Link to this type

topic()

Specs

topic() :: atom() | tuple()
Link to this type

topics()

Specs

topics() :: [topic()]

Link to this section Functions

Link to this function

broadcast(topic, message)

Specs

broadcast(topic(), term()) :: :ok
Link to this function

child_spec(opts)

Specs

child_spec(opts :: term()) :: Supervisor.child_spec()
Link to this function

start_link(partitions)

Specs

start_link(partitions()) :: {:ok, pid()} | {:error, term()}
Link to this function

subscribe(topics)

Specs

subscribe(topic() | topics()) :: :ok
Link to this function

unsubscribe(topics)

Specs

unsubscribe(topic() | topics()) :: :ok