reckon_db_naming (reckon_db v1.2.6)

View Source

Process naming utilities for reckon-db

Provides consistent naming conventions for all processes and registered names throughout the system.

Summary

Functions

Cluster supervisor name for a store

Store coordinator worker name

Core supervisor name for a store

Discovery worker name

Emitter group key (for event distribution via pg)

Emitter pool name for a subscription

Emitter supervisor name for a store

Gateway supervisor name for a store

Gateway worker name for a store

Leader worker name

Leader supervisor name for a store

Leader tracker worker name

Node monitor worker name

Notification supervisor name for a store

Persistence supervisor name for a store

Persistence worker name

Process group name for a store feature

Reader pool name for a store

Snapshots store worker name

Store manager worker name

Khepri store name (this is the atom used for khepri operations)

Store worker name (the gen_server that starts Khepri) NOTE: This is different from store_name/1 (Khepri operations) and store_mgr_name/1 (store lifecycle coordination).

Streams supervisor name for a store

Subscriptions store worker name

System supervisor name for a store

Tracker group key (for subscription tracking via pg)

Writer pool name for a store

Functions

cluster_sup_name(StoreId)

-spec cluster_sup_name(atom()) -> atom().

Cluster supervisor name for a store

coordinator_name(StoreId)

-spec coordinator_name(atom()) -> atom().

Store coordinator worker name

core_sup_name(StoreId)

-spec core_sup_name(atom()) -> atom().

Core supervisor name for a store

discovery_name(StoreId)

-spec discovery_name(atom()) -> atom().

Discovery worker name

emitter_group_key(StoreId, SubscriptionId)

-spec emitter_group_key(atom(), binary()) -> term().

Emitter group key (for event distribution via pg)

emitter_pool_name(StoreId, SubscriptionId)

-spec emitter_pool_name(atom(), binary()) -> atom().

Emitter pool name for a subscription

emitter_sup_name(StoreId)

-spec emitter_sup_name(atom()) -> atom().

Emitter supervisor name for a store

gateway_sup_name(StoreId)

-spec gateway_sup_name(atom()) -> atom().

Gateway supervisor name for a store

gateway_worker_name(StoreId)

-spec gateway_worker_name(atom()) -> atom().

Gateway worker name for a store

leader_name(StoreId)

-spec leader_name(atom()) -> atom().

Leader worker name

leader_sup_name(StoreId)

-spec leader_sup_name(atom()) -> atom().

Leader supervisor name for a store

leader_tracker_name(StoreId)

-spec leader_tracker_name(atom()) -> atom().

Leader tracker worker name

node_monitor_name(StoreId)

-spec node_monitor_name(atom()) -> atom().

Node monitor worker name

notification_sup_name(StoreId)

-spec notification_sup_name(atom()) -> atom().

Notification supervisor name for a store

persistence_sup_name(StoreId)

-spec persistence_sup_name(atom()) -> atom().

Persistence supervisor name for a store

persistence_worker_name(StoreId)

-spec persistence_worker_name(atom()) -> atom().

Persistence worker name

pg_group_name(StoreId, Feature)

-spec pg_group_name(atom(), atom()) -> term().

Process group name for a store feature

reader_pool_name(StoreId)

-spec reader_pool_name(atom()) -> atom().

Reader pool name for a store

snapshots_store_name(StoreId)

-spec snapshots_store_name(atom()) -> atom().

Snapshots store worker name

store_mgr_name(StoreId)

-spec store_mgr_name(atom()) -> atom().

Store manager worker name

store_name(StoreId)

-spec store_name(atom()) -> atom().

Khepri store name (this is the atom used for khepri operations)

store_worker_name(StoreId)

-spec store_worker_name(atom()) -> atom().

Store worker name (the gen_server that starts Khepri) NOTE: This is different from store_name/1 (Khepri operations) and store_mgr_name/1 (store lifecycle coordination).

streams_sup_name(StoreId)

-spec streams_sup_name(atom()) -> atom().

Streams supervisor name for a store

subscriptions_store_name(StoreId)

-spec subscriptions_store_name(atom()) -> atom().

Subscriptions store worker name

system_sup_name(StoreId)

-spec system_sup_name(atom()) -> atom().

System supervisor name for a store

tracker_group_key(StoreId, Feature)

-spec tracker_group_key(atom(), atom()) -> integer().

Tracker group key (for subscription tracking via pg)

writer_pool_name(StoreId)

-spec writer_pool_name(atom()) -> atom().

Writer pool name for a store