database::async::stream_processor::stream_event Struct Reference

#include <async_operations.h>

Collaboration diagram for database::async::stream_processor::stream_event:

Public Attributes
stream_type	type
std::string	channel
std::string	payload
std::chrono::system_clock::time_point	timestamp
std::unordered_map< std::string, std::string >	metadata

Detailed Description

Definition at line 573 of file async_operations.h.

Member Data Documentation

channel

std::string database::async::stream_processor::stream_event::channel

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 575 of file async_operations.h.

Referenced by database::async::stream_processor::process_event(), and database::async::stream_processor::stream_thread().

metadata

std::unordered_map<std::string, std::string> database::async::stream_processor::stream_event::metadata

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 578 of file async_operations.h.

payload

std::string database::async::stream_processor::stream_event::payload

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 576 of file async_operations.h.

Referenced by database::async::stream_processor::stream_thread().

timestamp

std::chrono::system_clock::time_point database::async::stream_processor::stream_event::timestamp

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 577 of file async_operations.h.

Referenced by database::async::stream_processor::stream_thread().

type

stream_type database::async::stream_processor::stream_event::type

Examples

/home/runner/work/database_system/database_system/database/async/async_operations.h.

Definition at line 574 of file async_operations.h.

Referenced by database::async::stream_processor::stream_thread().

---

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

• database/async/async_operations.h