|
| followKafkaRequestProvider (decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler) |
|
| ~followKafkaRequestProvider () override=default |
|
void | processSources (const std::vector< std::string > &sources) override |
|
| followJsonRequestProvider (decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler) |
|
| ~followJsonRequestProvider () override=default |
|
| ~followRequestProvider () override=default |
|
bool | isFollowMode () const override |
|
void | processSources (const std::vector< std::string > &sources) override |
|
| requestProvider (decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler) |
| ! use only the file name part in the destination More...
|
|
virtual | ~requestProvider ()=default |
|
virtual void | prepareMappings (std::vector< std::string > &sources, std::string &destination) |
|
virtual void | printMappings (std::ostream &stream) |
|
|
static requestProvider * | newProvider (const std::string &choice, decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler) |
|
static void | addAllowedNamesToOption (options::single< std::string > &option) |
|
void | cleanupRenameEvents (copyRequest::clock_type::duration minAge) |
|
virtual void | processJson (const Json::Value &json) |
|
template<typename ... Types> |
void | enqueueOrAppend (const std::string &srcPath, copyRequest::fileInWork::slotTypes type, copyRequest::clock_type::time_point timestamp, Types ... args) |
|
virtual void | handleMove (const std::string &srcPath, const std::string &dstPath, const std::string &fromPath, const std::string &origPath, const singleMap &mapEntry, copyRequest::clock_type::time_point timestamp) |
|
virtual void | handleOther (const std::string &srcPath, const std::string &dstPath, const singleMap &mapEntry, copyRequest::clock_type::time_point timestamp, bool requestForRemoval) |
|
| followRequestProvider (decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler) |
|
virtual const singleMap & | getDstPath (const std::string &source, std::string &destination, bool baseNameOnly=false) |
| get detstination papth for a given source path More...
|
|
static std::string | getRequiredJsonValue (const Json::Value &json, const std::string &key) |
|
static std::map< std::string, factoryClass * > & | getFactoryMap () |
|
copyRequest::simpleQueue & | requests |
|
copyRequest::timedQueue & | delayedRequests |
|
bool | parents |
|
inputHandler::base * | InputHandler |
|
outputHandler::base * | OutputHandler |
|
static options::single< bool > | mayDelete |
|
static options::single< bool > | nullDelimiter |
|
static options::map< std::string, pathMapType > | pathMap |
|
static singleMap | badMapEntry |
|
Definition at line 5 of file followKafkaRequestProvider.h.