dfx 0.1.0
Linux-based dynamic dataflow executor
Loading...
Searching...
No Matches
Switch.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// Project includes
12#include <dfx-core/Node.hpp>
13
14namespace dfx::Node
15{
16class Switch : public Core::Node
17{
18 DFX_NODE("Switch")
19
20public:
21 Switch(Id id, std::string name);
22
23protected:
24 void initializeImpl(nlohmann::json config) override;
25 void handleMessage(Core::InputPort const & port, Core::MessagePtr message) override;
26
27private:
28 std::string _currentOutput;
29};
30} // !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 initializeImpl(nlohmann::json config) override
Called by initialize; derived nodes must parse config here.
void handleMessage(Core::InputPort const &port, Core::MessagePtr message) override
Handle an incoming message on an input port.
std::unique_ptr< Message > MessagePtr
Unique ownership handle for messages.
Definition Message.hpp:27
Definition MimeTypeRouter.hpp:18