Helper class for registering entity-to-event mappings. More...

#include <registrar.hpp>

Collaboration diagram for registrar:

Static Public Member Functions
template<typename Event >
static void	register_mapping (postgres_event_source &source, const std::string &entity_name, const std::string &channel_name)
	Register a single entity-to-event mapping.

template<domain::has_event_traits Event>
static void	register_mapping (postgres_event_source &source, const std::string &entity_name, const std::string &channel_name, event_channel_registry &registry, const std::string &description)
	Register a single entity-to-event mapping with channel registry.

Detailed Description

Helper class for registering entity-to-event mappings.

Each component should call register_mapping() with their event types during application initialization.

Usage:

// In ores.risk registration code:
eventing::service::registrar::register_mapping<currency_changed_event>(
    source, "ores.refdata.currency", "ores_currencies");

Member Function Documentation

◆ register_mapping() [1/2]

template<typename Event >

static void register_mapping	(	postgres_event_source &	source,
		const std::string &	entity_name,
		const std::string &	channel_name
	)

static

Register a single entity-to-event mapping.

Template Parameters

Event The domain event type to publish.

Parameters

source	The postgres event source to configure.
entity_name	The fully qualified entity name.
channel_name	The PostgreSQL channel to listen on.

◆ register_mapping() [2/2]

template<domain::has_event_traits Event>

static void register_mapping	(	postgres_event_source &	source,
		const std::string &	entity_name,
		const std::string &	channel_name,
		event_channel_registry &	registry,
		const std::string &	description
	)

static

Register a single entity-to-event mapping with channel registry.

This overload also registers the event channel with the provided registry, enabling clients to discover available event channels.