Packages

ex_esdb

0.0.9-alpha
0.11.0 0.10.0 0.9.0 0.8.0 0.7.8 0.7.7 0.7.6 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.1 0.6.0 0.5.1 0.5.0 0.4.8 0.4.7 0.4.6 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.3 0.3.2 0.3.1 0.3.0 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.20 0.0.19 0.0.18 0.0.17 0.0.16 0.0.15 0.0.14-alpha 0.0.13-alpha 0.0.12-alpha 0.0.11-alpha 0.0.10-alpha 0.0.9-alpha 0.0.8-alpha 0.0.6-alpha 0.0.5-alpha 0.0.4-alpha 0.0.3-alpha 0.0.2-alfa 0.0.1-alfa

ExESDB is a reincarnation of rabbitmq/khepri, specialized for use as a BEAM-native event store.

HexDocs

Current section

Files

Jump to
Readme
63 Versions
9 Dependencies
Dependants
Files
Activity
ex_esdb lib themes.ex
Raw

lib/themes.ex 

defmodule ExESDB.Themes do

  @moduledoc false

  alias BeamCampus.ColorFuncs, as: CF



  def app(pid),

    do: "ExESDB APP [#{CF.black_on_blue()}#{inspect(pid)}#{CF.reset()}]"



  def system(pid),

    do: "SYSTEM [#{CF.black_on_magenta()}#{inspect(pid)}#{CF.reset()}]"



  def store(pid),

    do: "STORE [#{CF.black_on_green()}#{inspect(pid)}#{CF.reset()}]"



  def cluster(pid),

    do: "CLUSTER [#{CF.yellow_on_red()}#{inspect(pid)}#{CF.reset()}]"



  def projector(pid),

    do: "PROJECTOR [#{CF.black_on_white()}#{inspect(pid)}#{CF.reset()}]"



  def monitor(pid),

    do: "MONITOR [#{CF.yellow_on_magenta()}#{inspect(pid)}#{CF.reset()}]"



  def emitter_pool(pid),

    do: "EMITTER_POOL [#{CF.black_on_yellow()}#{inspect(pid)}#{CF.reset()}]"



  def emitter_worker(pid),

    do: "EMITTER_WORKER [#{CF.yellow_on_black()}#{inspect(pid)}#{CF.reset()}]"



  def pubsub(pid),

    do: "PUBSUB [#{CF.black_on_cyan()}#{inspect(pid)}#{CF.reset()}]"



  ############ LEADER SYSTEM ##############

  def leader_system(pid),

    do: "LEADER_SYSTEM [#{CF.black_on_magenta()}#{inspect(pid)}#{CF.reset()}]"



  def leader_worker(pid),

    do: "LEADER_WORKER [#{CF.black_on_magenta()}#{inspect(pid)}#{CF.reset()}]"



  def subscriptions_tracker(msg),

    do: "SUBSCRIPTIONS_TRACKER [#{CF.black_on_magenta()}#{inspect(msg)}#{CF.reset()}]"



  ######## SUBSCRIPTIONS ############

  def subscriptions(msg),

    do: "SUBSCRIPTIONS [#{CF.black_on_white()}#{inspect(msg)}#{CF.reset()}]"



  def subscriptions_reader(msg),

    do: "SUBSCRIPTIONS_READER [#{CF.black_on_white()}#{inspect(msg)}#{CF.reset()}]"



  def subscriptions_writer(msg),

    do: "SUBSCRIPTIONS_WRITER [#{CF.black_on_white()}#{inspect(msg)}#{CF.reset()}]"



  ########## STREAMS ###############

  def streams(msg),

    do: "STREAMS [#{CF.bright_yellow_on_blue()}#{inspect(msg)}#{CF.reset()}]"



  def streams_reader(msg),

    do: "STREAMS_READER [#{CF.bright_yellow_on_blue()}#{inspect(msg)}#{CF.reset()}]"



  def streams_writer(msg),

    do: "STREAMS_WRITER [#{CF.bright_yellow_on_blue()}#{inspect(msg)}#{CF.reset()}]"



  ########## GATEWAY ###############

  def gateway(pid),

    do: "GATEWAY [#{CF.bright_cyan_on_black()}#{inspect(pid)}#{CF.reset()}]"



  ################ CONSUMER ################

  def consumer(pid),

    do: "CONSUMER [#{CF.bright_yellow_on_black()}#{inspect(pid)}#{CF.reset()}]"



  ################ PRODUCER ################

  def producer(pid),

    do: "PRODUCER [#{CF.bright_green_on_black()}#{inspect(pid)}#{CF.reset()}]"

end