![]() |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
#include <compressing_output.h>
Classes | |
struct | Sink |
Public Member Functions | |
CompressingOutput (size_t ringBufferSize=65536, Compressor::FlushLevel compressorFlushLevel=Compressor::FLUSH_AVAILABLE) | |
void | open (std::shared_ptr< Sink > sink, const std::string &compression, int compressionLevel) |
void | closeCompressor () |
Public Attributes | |
boost::function< void(std::string, std::size_t)> | onFileWrite |
Protected Member Functions | |
virtual void | implementLogMessage (const std::string &channel, const std::string &message) |
Protected Attributes | |
Compressor::FlushLevel | compressorFlushLevel |
std::shared_ptr< Sink > | sink |
std::shared_ptr< Compressor > | compressor |
std::function< size_t(const char *, size_t) | onData ) |
LogOutput implementation that compresses data before passing it off somewhere else to be actually written.
Definition at line 98 of file compressing_output.h.
Datacratic::CompressingOutput::CompressingOutput | ( | size_t | ringBufferSize = 65536 , |
Compressor::FlushLevel | flushLevel = Compressor::FLUSH_AVAILABLE |
||
) |
LogOutput implementation that compresses data before passing it off somewhere else to be actually written.
Definition at line 187 of file compressing_output.cc.