sgns::processing::ProcessingSubTaskQueueChannel

More...

#include <processing_subtask_queue_channel.hpp>

Inherited by sgns::processing::ProcessingSubTaskQueueChannelPubSub

Public Functions

	Name
virtual	~ProcessingSubTaskQueueChannel() =default
virtual void	RequestQueueOwnership(const std::string & nodeId) =0
virtual void	PublishQueue(std::shared_ptr< SGProcessing::SubTaskQueue > queue) =0
virtual size_t	GetActiveNodesCount() const =0
virtual std::vector< libp2p::peer::PeerId >	GetActiveNodes() const =0

Detailed Description

class sgns::processing::ProcessingSubTaskQueueChannel;

Subtask queue channel interface which is used for in-memory queue synchronization

Public Functions Documentation

function ~ProcessingSubTaskQueueChannel

virtual ~ProcessingSubTaskQueueChannel() =default

function RequestQueueOwnership

virtual void RequestQueueOwnership(
    const std::string & nodeId
) =0

Reimplemented by: sgns::processing::ProcessingSubTaskQueueChannelPubSub::RequestQueueOwnership

Sends a request for queue ownership nodeId - requestor node id

function PublishQueue

virtual void PublishQueue(
    std::shared_ptr< SGProcessing::SubTaskQueue > queue
) =0

Reimplemented by: sgns::processing::ProcessingSubTaskQueueChannelPubSub::PublishQueue

Publishes queue to all queue consumers queue = subtask queue

function GetActiveNodesCount

virtual size_t GetActiveNodesCount() const =0

Return: number of nodes in the channel

Reimplemented by: sgns::processing::ProcessingSubTaskQueueChannelPubSub::GetActiveNodesCount

Returns the number of active nodes in the channel

function GetActiveNodes

virtual std::vector< libp2p::peer::PeerId > GetActiveNodes() const =0

Return: vector of nodes in the channel

Reimplemented by: sgns::processing::ProcessingSubTaskQueueChannelPubSub::GetActiveNodes

Get the number of active nodes in the channel

---

Updated on 2026-03-04 at 13:10:43 -0800