dfx 0.1.0
Linux-based dynamic dataflow executor
Loading...
Searching...
No Matches
NullSink.hpp
1// SPDX-FileCopyrightText: 2026 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 NullSink : public Core::Node
17{
18 DFX_NODE("NullSink")
19
20public:
21 NullSink(Id id, std::string name);
22
23protected:
24 void initializeImpl(nlohmann::json config) override;
25
27};
28} // !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:569
Incoming message endpoint attached to a node.
Definition InputPort.hpp:57
Abstract base class for all nodes in the dfx runtime.
Definition Node.hpp:94
uint32_t Id
Node identifier type (unique and stable within a graph instance).
Definition Node.hpp:116
nlohmann::json const & config() const noexcept
Get the node configuration.
Definition Node.hpp:141
std::string const & name() const noexcept
Get the node name.
Definition Node.hpp:137
void initializeImpl(nlohmann::json config) override
Called by initialize; derived nodes must parse config here.
void handleMessage(Core::InputPort const &, Core::MessagePtr) override
Handle an incoming message on an input port.
Definition NullSink.hpp:26
std::unique_ptr< Message > MessagePtr
Unique ownership handle for messages.
Definition Message.hpp:27
Definition MimeTypeRouter.hpp:18