include/xrpl/nodestore/Scheduler.h

#pragma once
 
#include <xrpl/nodestore/Task.h>
 
#include <chrono>
 
namespace xrpl::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 xrpl::NodeStore