kcenon::monitoring::event_bus_config Struct Reference

Configuration for event bus. More...

#include <event_bus.h>

Collaboration diagram for kcenon::monitoring::event_bus_config:

Public Attributes
size_t	max_queue_size = 10000
size_t	worker_thread_count = 2
std::chrono::milliseconds	processing_interval {10}
bool	auto_start = false
bool	enable_back_pressure = true
size_t	back_pressure_threshold = 8000

Detailed Description

Configuration for event bus.

Examples

event_bus_example.cpp.

Definition at line 87 of file event_bus.h.

Member Data Documentation

auto_start

bool kcenon::monitoring::event_bus_config::auto_start = false

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/core/event_bus.h, and event_bus_example.cpp.

Definition at line 91 of file event_bus.h.

Referenced by kcenon::monitoring::event_bus::event_bus(), main(), EventBusTest::SetUp(), MonitoringThreadSafetyTest::SetUp(), and TEST_F().

back_pressure_threshold

size_t kcenon::monitoring::event_bus_config::back_pressure_threshold = 8000

Examples

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

Definition at line 93 of file event_bus.h.

Referenced by kcenon::monitoring::event_bus::get_stats(), and kcenon::monitoring::event_bus::publish_event_impl().

enable_back_pressure

bool kcenon::monitoring::event_bus_config::enable_back_pressure = true

Examples

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

Definition at line 92 of file event_bus.h.

Referenced by kcenon::monitoring::event_bus::publish_event_impl().

max_queue_size

size_t kcenon::monitoring::event_bus_config::max_queue_size = 10000

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/core/event_bus.h, and event_bus_example.cpp.

Definition at line 88 of file event_bus.h.

Referenced by main(), kcenon::monitoring::event_bus::publish_event_impl(), EventBusTest::SetUp(), MonitoringThreadSafetyTest::SetUp(), and TEST_F().

processing_interval

std::chrono::milliseconds kcenon::monitoring::event_bus_config::processing_interval {10}

Examples

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

Definition at line 90 of file event_bus.h.

{10};

Referenced by kcenon::monitoring::event_bus::process_events_worker().

worker_thread_count

size_t kcenon::monitoring::event_bus_config::worker_thread_count = 2

Examples

/home/runner/work/monitoring_system/monitoring_system/include/kcenon/monitoring/core/event_bus.h, and event_bus_example.cpp.

Definition at line 89 of file event_bus.h.

Referenced by main(), EventBusTest::SetUp(), MonitoringThreadSafetyTest::SetUp(), kcenon::monitoring::event_bus::start(), and TEST_F().

---

The documentation for this struct was generated from the following file:

• include/kcenon/monitoring/core/event_bus.h