dfx 0.1.0
Linux-based dynamic dataflow executor
Loading...
Searching...
No Matches
LocalSource.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 "SourceTransport.hpp"
13
14namespace dfx::Core
15{
28{
29public:
31
39 bool send(MessagePtr message)
40 { return transmitMessage(std::move(message)); }
41
42public:
43 void start(FdWatch::Poller &) override {}
44 void stop() noexcept override {}
45};
46} // !namespace dfx::Core
A synchronous, in-process source transport.
Definition LocalSource.hpp:28
SourceTransport(Endpoint endpoint, nlohmann::json config)
Constructs a SourceTransport with the Role::Source role.
Definition SourceTransport.hpp:31
bool send(MessagePtr message)
Synchronously pushes a message into the channel.
Definition LocalSource.hpp:39
void start(FdWatch::Poller &) override
Activates the transport and begins I/O operations.
Definition LocalSource.hpp:43
void stop() noexcept override
Deactivates the transport and releases system resources.
Definition LocalSource.hpp:44
SourceTransport(Endpoint endpoint, nlohmann::json config)
Constructs a SourceTransport with the Role::Source role.
Definition SourceTransport.hpp:31
bool transmitMessage(MessagePtr message)
Forwards a message to the attached Channel for orchestration.
Abstract interface for FD-based event polling.
Definition Poller.hpp:37
Definition Channel.hpp:25
std::unique_ptr< Message > MessagePtr
Unique ownership handle for messages.
Definition Message.hpp:27