Container for events with metadata. More...

#include <event_bus.h>

Collaboration diagram for kcenon::monitoring::event_envelope:

Public Member Functions
	event_envelope (std::type_index t, std::any p, event_priority pr)

bool	operator< (const event_envelope &other) const

Public Attributes
std::type_index	type

std::any	payload

event_priority	priority

std::chrono::steady_clock::time_point	timestamp

uint64_t	id

Static Private Member Functions
static uint64_t	generate_id ()

Detailed Description

Container for events with metadata.

Definition at line 41 of file event_bus.h.

Constructor & Destructor Documentation

◆ event_envelope()

kcenon::monitoring::event_envelope::event_envelope	(	std::type_index	t,
		std::any	p,
		event_priority	pr )

inline

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/core/event_bus.h.

Definition at line 48 of file event_bus.h.

        : type(t), payload(std::move(p)), priority(pr),
          timestamp(std::chrono::steady_clock::now()),
          id(generate_id()) {}

Member Function Documentation

◆ generate_id()

static uint64_t kcenon::monitoring::event_envelope::generate_id ( )

inlinestaticprivate

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/core/event_bus.h.

Definition at line 63 of file event_bus.h.

                                  {
        static std::atomic<uint64_t> counter{0};
        return counter.fetch_add(1, std::memory_order_relaxed);
    }

References kcenon::monitoring::counter.

◆ operator<()

bool kcenon::monitoring::event_envelope::operator< ( const event_envelope & other ) const

inline

Examples: /home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/core/event_bus.h.

Definition at line 53 of file event_bus.h.

                                                      {
        // Higher priority events come first
        if (priority != other.priority) {
            return static_cast<int>(priority) < static_cast<int>(other.priority);
        }
        // For same priority, older events come first
        return timestamp > other.timestamp;
    }