followJsonRequestProvider.h

Go to the documentation of this file.

#ifndef __followJsonRequestProvider_h__
#define __followJsonRequestProvider_h__
#include "followRequestProvider.h"
#include "renameEventHandler.h"
 
namespace Json {
    class Value;
}
class followJsonRequestProvider: public followRequestProvider {
  private:
    static factoryTemplate<followJsonRequestProvider> factory;
 
    static options::single<int> jsonDelimiter;
    static options::single<std::string> pathKey;
    static options::single<std::string> operationKey;
    static options::single<std::string> timestampKey;
    static options::single<std::string> timestampFormat;
    static options::single<copyRequest::clock_type::duration> timestampOffset;
    static options::single<std::string> cookieKey;
    static options::single<std::string> copyOpValue;
    static options::single<std::string> deleteOpValue;
    static options::single<std::string> moveFromOpValue;
    static options::single<std::string> moveToOpValue;
    static options::single<std::regex> sourceMatchRegex;
    renameEventHandler renameHandler;
  protected:
    void cleanupRenameEvents(copyRequest::clock_type::duration minAge);
    void followStream(std::istream& stream) override;
    static std::string getRequiredJsonValue(const Json::Value& json,
                                            const std::string& key);
  protected:
    virtual void processJson(const Json::Value& json);
  public:
    followJsonRequestProvider(decltype(requests) aRequests,
                              decltype(delayedRequests) aDelayedRequests,
                              decltype(parents) aParents,
                              decltype(InputHandler) aInputHandler,
                              decltype(OutputHandler) aOutputHandler):
        followRequestProvider(aRequests, aDelayedRequests, aParents,
                              aInputHandler, aOutputHandler) {};
    ~followJsonRequestProvider() override = default;
};
 
 
 
#endif