followKafkaRequestProvider Member List

This is the complete list of members for followKafkaRequestProvider, including all inherited members.

addAllowedNamesToOption(options::single< std::string > &option)	requestProvider	static
badMapEntry	requestProvider	protectedstatic
cleanupRenameEvents(copyRequest::clock_type::duration minAge)	followJsonRequestProvider	protected
cookieKey	followJsonRequestProvider	privatestatic
copyOpValue	followJsonRequestProvider	privatestatic
delayedRequests	requestProvider	protected
deleteOpValue	followJsonRequestProvider	privatestatic
enqueueOrAppend(const std::string &srcPath, copyRequest::fileInWork::slotTypes type, copyRequest::clock_type::time_point timestamp, Types ... args)	followRequestProvider	inlineprotected
factory	followKafkaRequestProvider	privatestatic
followJsonRequestProvider(decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)	followJsonRequestProvider	inline
followKafkaRequestProvider(decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)	followKafkaRequestProvider	inline
followRequestProvider(decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)	followRequestProvider	protected
followStream(std::istream &stream) override	followKafkaRequestProvider	privatevirtual
getDstPath(const std::string &source, std::string &destination, bool baseNameOnly=false)	requestProvider	protectedvirtual
getFactoryMap()	requestProvider	protectedstatic
getRequiredJsonValue(const Json::Value &json, const std::string &key)	followJsonRequestProvider	protectedstatic
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)	followRequestProvider	protectedvirtual
handleOther(const std::string &srcPath, const std::string &dstPath, const singleMap &mapEntry, copyRequest::clock_type::time_point timestamp, bool requestForRemoval)	followRequestProvider	protectedvirtual
InputHandler	requestProvider	protected
isFollowMode() const override	followRequestProvider	inlinevirtual
jsonDelimiter	followJsonRequestProvider	privatestatic
kafkaInQueue	followKafkaRequestProvider	privatestatic
mayDelete	followRequestProvider	protectedstatic
moveFromOpValue	followJsonRequestProvider	privatestatic
moveToOpValue	followJsonRequestProvider	privatestatic
newProvider(const std::string &choice, decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)	requestProvider	static
nullDelimiter	followRequestProvider	protectedstatic
operationKey	followJsonRequestProvider	privatestatic
OutputHandler	requestProvider	protected
parents	requestProvider	protected
pathKey	followJsonRequestProvider	privatestatic
pathMap	requestProvider	protectedstatic
pathMapType typedef	requestProvider	private
prepareMappings(std::vector< std::string > &sources, std::string &destination)	requestProvider	virtual
printMappings(std::ostream &stream)	requestProvider	virtual
processJson(const Json::Value &json)	followJsonRequestProvider	protectedvirtual
processSources(const std::vector< std::string > &sources) override	followKafkaRequestProvider	virtual
renameHandler	followJsonRequestProvider	private
requestProvider(decltype(requests) aRequests, decltype(delayedRequests) aDelayedRequests, decltype(parents) aParents, decltype(InputHandler) aInputHandler, decltype(OutputHandler) aOutputHandler)	requestProvider	inline
requests	requestProvider	protected
sourceMatchRegex	followJsonRequestProvider	privatestatic
timestampFormat	followJsonRequestProvider	privatestatic
timestampKey	followJsonRequestProvider	privatestatic
timestampOffset	followJsonRequestProvider	privatestatic
~followJsonRequestProvider() override=default	followJsonRequestProvider
~followKafkaRequestProvider() override=default	followKafkaRequestProvider
~followRequestProvider() override=default	followRequestProvider
~requestProvider()=default	requestProvider	virtual