Packages
ex_esdb
0.0.20
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 BCUtils.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: "KHEPRI CLUSTER [#{CF.yellow_on_red()}#{inspect(pid)}#{CF.reset()}]"
def cluster_coordinator(pid),
do: "CLUSTER_COORDINATOR [#{CF.white_on_red()}#{inspect(pid)}#{CF.reset()}]"
def cluster_system(pid),
do: "CLUSTER_SYSTEM [#{CF.bright_white_on_red()}#{inspect(pid)}#{CF.reset()}]"
def node_monitor(pid),
do: "NODE_MONITOR [#{CF.yellow_on_magenta()}#{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()}]"
################ SNAPSHOTS ################
def snapshots_system(pid),
do: "SNAPSHOT_SYSTEM [#{CF.blue_on_yellow()}#{inspect(pid)}#{CF.reset()}]"
def snapshots_reader(pid),
do: "SNAPSHOT_READER [#{CF.blue_on_yellow()}#{inspect(pid)}#{CF.reset()}]"
def snapshots_reader_pool(pid),
do: "SNAPSHOT_READER_POOL [#{CF.blue_on_yellow()}#{inspect(pid)}#{CF.reset()}]"
def snapshots_reader_worker(pid),
do: "SNAPSHOT_READER_WORKER [#{CF.blue_on_yellow()}#{inspect(pid)}#{CF.reset()}]"
def snapshots_writer(pid),
do: "SNAPSHOT_WRITER [#{CF.blue_on_yellow()}#{inspect(pid)}#{CF.reset()}]"
def snapshots_writer_pool(pid),
do: "SNAPSHOT_WRITER_POOL [#{CF.blue_on_yellow()}#{inspect(pid)}#{CF.reset()}]"
def snapshots_writer_worker(pid),
do: "SNAPSHOT_WRITER_WORKER [#{CF.blue_on_yellow()}#{inspect(pid)}#{CF.reset()}]"
end