crdt/broadcaster.hpp

Namespaces

Name
sgns
sgns::crdt

Classes

	Name
class	sgns::crdt::Broadcaster A Broadcaster provides a way to send (notify) an opaque payload to all replicas and to retrieve payloads broadcasted.

Source code

#ifndef SUPERGENIUS_BROADCASTER_HPP
#define SUPERGENIUS_BROADCASTER_HPP

#include "base/buffer.hpp"
#include <libp2p/peer/peer_info.hpp>
#include <boost/optional.hpp>
#include <chrono>
#include <thread>
#include <tuple>
#include <string>
#include <optional>

namespace sgns::crdt
{
    class Broadcaster
    {
    public:
        virtual ~Broadcaster() = default;

        enum class ErrorCode
        {
            Success            = 0, /*> 0 should not represent an error */
            ErrNoMoreBroadcast = 1, /*> no more data to broadcast */
        };

        virtual outcome::result<void> Broadcast( const base::Buffer                     &buff,
                                                 std::string                             topic,
                                                 boost::optional<libp2p::peer::PeerInfo> peerInfo = boost::none ) = 0;

        virtual outcome::result<base::Buffer> Next() = 0;

        virtual void WaitForNext( std::chrono::milliseconds timeout )
        {
            std::this_thread::sleep_for( timeout );
        }

        virtual void CancelWait()
        {
        }

        virtual bool HasTopic( const std::string &topic ) = 0;

        virtual std::shared_ptr<void> GetDagSyncer() const
        {
            return nullptr;
        }
    };
} // namespace sgns::crdt

#endif // SUPERGENIUS_BROADCASTER_HPP

---

Updated on 2026-08-28 at 01:08:43 +0000