RTBKit  0.9
Open-source framework to create real-time ad bidding systems.
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator
Classes | Public Member Functions | Public Attributes | Protected Member Functions | Protected Attributes
Datacratic::CompressingOutput Struct Reference

#include <compressing_output.h>

Inheritance diagram for Datacratic::CompressingOutput:
Datacratic::WorkerThreadOutput Datacratic::LogOutput Datacratic::NamedOutput Datacratic::CloudOutput Datacratic::FileOutput

List of all members.

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< Sinksink
std::shared_ptr< Compressorcompressor
std::function< size_t(const
char *, size_t) 
onData )

Detailed Description

LogOutput implementation that compresses data before passing it off somewhere else to be actually written.

Definition at line 98 of file compressing_output.h.


Constructor & Destructor Documentation

LogOutput implementation that compresses data before passing it off somewhere else to be actually written.

Definition at line 187 of file compressing_output.cc.


The documentation for this struct was generated from the following files:
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator