include/xrpl/nodestore/Scheduler.h

#ifndef XRPL_NODESTORE_SCHEDULER_H_INCLUDED
#define XRPL_NODESTORE_SCHEDULER_H_INCLUDED
 
#include <xrpl/nodestore/Task.h>
 
#include <chrono>
 
namespace ripple {
namespace NodeStore {
 
enum class FetchType { synchronous, async };
 
struct FetchReport
{
    explicit FetchReport(FetchType fetchType_) : fetchType(fetchType_)
    {
    }
 
    std::chrono::milliseconds elapsed;
    FetchType const fetchType;
    bool wasFound = false;
};
 
struct BatchWriteReport
{
    explicit BatchWriteReport() = default;
 
    std::chrono::milliseconds elapsed;
    int writeCount;
};
 
class Scheduler
{
public:
    virtual ~Scheduler() = default;
 
    virtual void
    scheduleTask(Task& task) = 0;
 
    virtual void
    onFetch(FetchReport const& report) = 0;
 
    virtual void
    onBatchWrite(BatchWriteReport const& report) = 0;
};
 
}  // namespace NodeStore
}  // namespace ripple
 
#endif