RTBKit  0.9
Open-source framework to create real-time ad bidding systems.
Datacratic::CompressingOutput Member List
This is the complete list of members for Datacratic::CompressingOutput, including all inherited members.
clearStats()Datacratic::WorkerThreadOutput [virtual]
close()=0Datacratic::LogOutput [pure virtual]
closeCompressor() (defined in Datacratic::CompressingOutput)Datacratic::CompressingOutput
CompressingOutput(size_t ringBufferSize=65536, Compressor::FlushLevel compressorFlushLevel=Compressor::FLUSH_AVAILABLE)Datacratic::CompressingOutput
compressor (defined in Datacratic::CompressingOutput)Datacratic::CompressingOutput [protected]
compressorFlushLevel (defined in Datacratic::CompressingOutput)Datacratic::CompressingOutput [protected]
dutyDatacratic::WorkerThreadOutput [protected]
implementLogMessage(const std::string &channel, const std::string &message) (defined in Datacratic::CompressingOutput)Datacratic::CompressingOutput [protected, virtual]
logMessage(const std::string &channel, const std::string &message)Datacratic::WorkerThreadOutput [virtual]
LogOutput() (defined in Datacratic::LogOutput)Datacratic::LogOutput [inline]
logThreadDatacratic::WorkerThreadOutput [protected]
MessageType enum nameDatacratic::WorkerThreadOutput [protected]
MT_END enum valueDatacratic::WorkerThreadOutput [protected]
MT_LOG enum valueDatacratic::WorkerThreadOutput [protected]
MT_OP enum valueDatacratic::WorkerThreadOutput [protected]
MT_SHUTDOWN enum value (defined in Datacratic::WorkerThreadOutput)Datacratic::WorkerThreadOutput [protected]
onData (defined in Datacratic::CompressingOutput)Datacratic::CompressingOutput [protected]
onFileWrite (defined in Datacratic::CompressingOutput)Datacratic::CompressingOutput
open(std::shared_ptr< Sink > sink, const std::string &compression, int compressionLevel) (defined in Datacratic::CompressingOutput)Datacratic::CompressingOutput
pushOperation(const std::function< void()> &op)Datacratic::WorkerThreadOutput [protected]
ringBuffer (defined in Datacratic::WorkerThreadOutput)Datacratic::WorkerThreadOutput [protected]
runLogThread()Datacratic::WorkerThreadOutput [protected]
shutdown_ (defined in Datacratic::WorkerThreadOutput)Datacratic::WorkerThreadOutput [protected]
sink (defined in Datacratic::CompressingOutput)Datacratic::CompressingOutput [protected]
startWorkerThread() (defined in Datacratic::WorkerThreadOutput)Datacratic::WorkerThreadOutput [protected]
stats() const Datacratic::WorkerThreadOutput [virtual]
stopWorkerThread() (defined in Datacratic::WorkerThreadOutput)Datacratic::WorkerThreadOutput [protected]
up_ (defined in Datacratic::WorkerThreadOutput)Datacratic::WorkerThreadOutput [protected]
WorkerThreadOutput(size_t ringBufferSize=65536) (defined in Datacratic::WorkerThreadOutput)Datacratic::WorkerThreadOutput
~CompressingOutput() (defined in Datacratic::CompressingOutput)Datacratic::CompressingOutput [virtual]
~LogOutput() (defined in Datacratic::LogOutput)Datacratic::LogOutput [inline, virtual]
~WorkerThreadOutput() (defined in Datacratic::WorkerThreadOutput)Datacratic::WorkerThreadOutput [virtual]
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator