dfx 0.1.0
Linux-based dynamic dataflow executor
Loading...
Searching...
No Matches
MimeTypeRouter.hpp
1// SPDX-FileCopyrightText: 2025 Vincent Leroy
2// SPDX-License-Identifier: MIT
3//
4// This file is part of dfx.
5//
6// Licensed under the MIT License. See the LICENSE file in the project root
7// for full license information.
8
9#pragma once
10
11// Standard includes
12#include <unordered_map>
13
14// Project includes
15#include <dfx-core/Node.hpp>
16
17namespace dfx::Node
18{
19class MimeTypeRouter : public Core::Node
20{
21 DFX_NODE("MimeTypeRouter")
22
23public:
24 MimeTypeRouter(Id id, std::string name);
25
26protected:
27 void initializeImpl(nlohmann::json config) override;
28 void handleMessage(Core::InputPort const & port, Core::MessagePtr message) override;
29
30private:
31 std::unordered_map<std::string, std::string> _routes;
32 std::string _defaultPort;
33 bool _logDropped = false;
34};
35} // !namespace dfx::Node
Base class for all runtime-executed nodes in a dfx dataflow graph.
#define DFX_NODE(typeName)
Convenience macro to declare the node type string and metadata/schema hooks.
Definition Node.hpp:501
Incoming message endpoint attached to a node.
Definition InputPort.hpp:55
Abstract base class for all nodes in the dfx runtime.
Definition Node.hpp:91
uint32_t Id
Node identifier type (unique and stable within a graph instance).
Definition Node.hpp:113
nlohmann::json const & config() const noexcept
Get the node configuration.
Definition Node.hpp:138
std::string const & name() const noexcept
Get the node name.
Definition Node.hpp:134
void handleMessage(Core::InputPort const &port, Core::MessagePtr message) override
Handle an incoming message on an input port.
void initializeImpl(nlohmann::json config) override
Called by initialize; derived nodes must parse config here.
std::unique_ptr< Message > MessagePtr
Unique ownership handle for messages.
Definition Message.hpp:27
Definition MimeTypeRouter.hpp:18