#pragma once

#include <yt/cpp/mapreduce/common/fwd.h>

#include <yt/cpp/mapreduce/http/requests.h>

#include <util/generic/ptr.h>
#include <util/system/thread.h>

namespace NYT {

////////////////////////////////////////////////////////////////////////////////

class TPingableTransaction;

////////////////////////////////////////////////////////////////////////////////

// Each registered transaction must be removed from pinger
// (using RemoveTransaction) before it is destroyed
class ITransactionPinger
    : public TThrRefBase
{
public:
    virtual ~ITransactionPinger() = default;

    virtual ITransactionPingerPtr GetChildTxPinger() = 0;

    virtual void RegisterTransaction(const TPingableTransaction& pingableTx) = 0;

    virtual bool HasTransaction(const TPingableTransaction& pingableTx) = 0;

    virtual void RemoveTransaction(const TPingableTransaction& pingableTx) = 0;
};

ITransactionPingerPtr CreateTransactionPinger(const TConfigPtr& config);

////////////////////////////////////////////////////////////////////////////////

} // namespace NYT