Message handler for Data Quality (DQ) subsystem messages. More...
#include <dq_message_handler.hpp>
Inheritance diagram for dq_message_handler:
Collaboration diagram for dq_message_handler:
Public Types | |
| using | handler_result = boost::asio::awaitable< std::expected< std::vector< std::byte >, ores::utility::serialization::error_code > > |
Public Member Functions | |
| dq_message_handler (database::context ctx, std::shared_ptr< comms::service::auth_session_service > sessions, std::shared_ptr< iam::service::authorization_service > auth_service) | |
| Construct a DQ message handler. | |
| handler_result | handle_message (comms::messaging::message_type type, std::span< const std::byte > payload, const std::string &remote_address) override |
| Handle a DQ subsystem message. | |
Detailed Description
Message handler for Data Quality (DQ) subsystem messages.
Processes messages in the DQ subsystem range (0x6000-0x6FFF). Currently handles change management messages:
- Change management: categories and reasons CRUD
- Data organization: catalogs and subject areas CRUD
- Datasets and methodologies CRUD
- Coding schemes CRUD
Constructor & Destructor Documentation
◆ dq_message_handler()
| dq_message_handler | ( | database::context | ctx, |
| std::shared_ptr< comms::service::auth_session_service > | sessions, | ||
| std::shared_ptr< iam::service::authorization_service > | auth_service | ||
| ) |
Construct a DQ message handler.
- Parameters
-
ctx Database context for repository access sessions Shared auth session service for authentication auth_service Authorization service for permission checks
Member Function Documentation
◆ handle_message()
|
overridevirtual |
Handle a DQ subsystem message.
- Parameters
-
type The message type (must be in range 0x6000-0x6FFF) payload The message payload remote_address The remote endpoint address of the client connection
- Returns
- Expected containing response payload, or error code
Implements message_handler.
