Packages
ex_esdb
0.0.14-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.
Current section
Files
Jump to
Current section
Files
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.yellow_on_black()}#{inspect(pid)}#{CF.reset()}]"
def emitter_worker(pid),
do: "EMITTER_WORKER [#{CF.yellow_on_black()}#{inspect(pid)}#{CF.reset()}]"
def persistent_emitter_worker(pid),
do: "PERSISTENT_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()}]"
############## STREAMS_READER ##############
def streams_reader(msg),
do: "STREAMS_READER [#{CF.bright_yellow_on_blue()}#{inspect(msg)}#{CF.reset()}]"
def streams_reader_pool(msg),
do: "STREAMS_READER_POOL [#{CF.bright_yellow_on_blue()}#{inspect(msg)}#{CF.reset()}]"
def streams_reader_worker(msg),
do: "STREAMS_READER_WORKER [#{CF.bright_yellow_on_blue()}#{inspect(msg)}#{CF.reset()}]"
############## STREAMS_WRITER ##############
def streams_writer(msg),
do: "STREAMS_WRITER [#{CF.bright_yellow_on_red()}#{inspect(msg)}#{CF.reset()}]"
def streams_writer_pool(msg),
do: "STREAMS_WRITER_POOL [#{CF.bright_yellow_on_red()}#{inspect(msg)}#{CF.reset()}]"
def streams_writer_system(msg),
do: "STREAMS_WRITER_SYSTEM [#{CF.bright_yellow_on_red()}#{inspect(msg)}#{CF.reset()}]"
def streams_writer_worker(msg),
do: "STREAMS_WRITER_WORKER [#{CF.bright_yellow_on_red()}#{inspect(msg)}#{CF.reset()}]"
########## GATEWAY ###############
def gateway_worker(pid),
do: "GATEWAY_WORKER [#{CF.bright_cyan_on_black()}#{inspect(pid)}#{CF.reset()}]"
def gateway_supervisor(pid),
do: "GATEWAY_SUPERVISOR [#{CF.bright_cyan_on_black()}#{inspect(pid)}#{CF.reset()}]"
def gateway_api(pid),
do: "GATEWAY_API [#{CF.bright_cyan_on_black()}#{inspect(pid)}#{CF.reset()}]"
################ OBSERVER ################
def observer(pid),
do: "OBSERVER [#{CF.bright_yellow_on_black()}#{inspect(pid)}#{CF.reset()}]"
def observed(msg),
do: "OBSERVED [#{CF.bright_green_on_black()}#{inspect(msg)}#{CF.reset()}]"
############# SUBSCRIBER ##############
def subscriber(pid),
do: "SUBSCRIBER [#{CF.bright_yellow_on_green()}#{inspect(pid)}#{CF.reset()}]"
def subscription_received(subscription_name, msg),
do:
"SUBSCRIPTION_RECEIVED [#{CF.bright_green_on_black()}#{inspect(subscription_name)} #{inspect(msg)}#{CF.reset()}]"
################ PRODUCER ################
def producer(pid),
do: "PRODUCER [#{CF.bright_green_on_black()}#{inspect(pid)}#{CF.reset()}]"
def appended(msg),
do: "APPENDED [#{CF.bright_yellow_on_black()}#{inspect(msg)}#{CF.reset()}]"
end