reusex::pipeline::IJobStore Class Reference

Persistence for job records. Implementations must be thread-safe. More...

#include <JobStore.hpp>

Inheritance diagram for reusex::pipeline::IJobStore:

Public Member Functions
virtual	~IJobStore ()=default
virtual void	save (std::string_view queue, const JobRecord &record)=0
	Insert record under queue, or replace the record with the same id.
virtual std::optional< JobRecord >	find (std::string_view queue, std::string_view id) const =0
	One record, or nullopt when id is unknown in queue (or was evicted by the store's retention policy).
virtual std::vector< JobRecord >	list (std::string_view queue) const =0
	Every retained record of queue, most recently submitted first.
virtual void	forget (std::string_view queue)=0
	Drop every record of queue (its case was deleted, and a new case may reuse the key).

Detailed Description

Persistence for job records. Implementations must be thread-safe.

Definition at line 35 of file JobStore.hpp.

Constructor & Destructor Documentation

~IJobStore()

virtual reusex::pipeline::IJobStore::~IJobStore ( )

virtualdefault

Member Function Documentation

find()

virtual std::optional< JobRecord > reusex::pipeline::IJobStore::find ( std::string_view queue, std::string_view id ) const

pure virtual

One record, or nullopt when id is unknown in queue (or was evicted by the store's retention policy).

Implemented in reusex::pipeline::InMemoryJobStore.

forget()

virtual void reusex::pipeline::IJobStore::forget ( std::string_view queue )

pure virtual

Drop every record of queue (its case was deleted, and a new case may reuse the key).

Unknown queues are ignored.

Implemented in reusex::pipeline::InMemoryJobStore.

list()

virtual std::vector< JobRecord > reusex::pipeline::IJobStore::list ( std::string_view queue ) const

pure virtual

Every retained record of queue, most recently submitted first.

Implemented in reusex::pipeline::InMemoryJobStore.

save()

virtual void reusex::pipeline::IJobStore::save ( std::string_view queue, const JobRecord & record )

pure virtual

Insert record under queue, or replace the record with the same id.

Called at every state transition, never for progress ticks.

Implemented in reusex::pipeline::InMemoryJobStore.

---

The documentation for this class was generated from the following file:

• libs/reusex/include/pipeline/JobStore.hpp