sgns::processing::SubTaskResultStorageImpl

Handles subtask result storage.

#include <processing_subtask_result_storage_impl.hpp>

Inherits from sgns::processing::SubTaskResultStorage

Public Functions

	Name
	SubTaskResultStorageImpl(std::shared_ptr< crdt::GlobalDB > db, std::string topic)
	~SubTaskResultStorageImpl() override
virtual void	AddSubTaskResult(const SGProcessing::SubTaskResult & result) override
virtual void	RemoveSubTaskResult(const std::string & subTaskId) override
virtual std::vector< SGProcessing::SubTaskResult >	GetSubTaskResults(const std::set< std::string > & subTaskIds) override

Additional inherited members

Public Functions inherited from sgns::processing::SubTaskResultStorage

	Name
virtual	~SubTaskResultStorage() =default

Public Functions Documentation

function SubTaskResultStorageImpl

SubTaskResultStorageImpl(
    std::shared_ptr< crdt::GlobalDB > db,
    std::string topic
)

Parameters:

• db - CRDT GlobalDB to use.
• topic - Topic prefix for result keys.

Create a subtask storage.

function ~SubTaskResultStorageImpl

~SubTaskResultStorageImpl() override

function AddSubTaskResult

virtual void AddSubTaskResult(
    const SGProcessing::SubTaskResult & result
) override

Parameters:

• result - Result to add

Reimplements: sgns::processing::SubTaskResultStorage::AddSubTaskResult

Add a subtask result

function RemoveSubTaskResult

virtual void RemoveSubTaskResult(
    const std::string & subTaskId
) override

Parameters:

• subTaskId - Result ID to remove

Reimplements: sgns::processing::SubTaskResultStorage::RemoveSubTaskResult

Remove a subtask result

function GetSubTaskResults

virtual std::vector< SGProcessing::SubTaskResult > GetSubTaskResults(
    const std::set< std::string > & subTaskIds
) override

Parameters:

• subTaskIds - List of subtask IDs to get results for.

Reimplements: sgns::processing::SubTaskResultStorage::GetSubTaskResults

Get results for subtasks.

---

Updated on 2026-04-15 at 11:00:39 -0700