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

#include <cloud_output.h>

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

List of all members.

Public Member Functions

 CloudOutput (const std::string &uri="", size_t ringBufferSize=65536)
virtual std::shared_ptr< SinkcreateSink (const std::string &uri, bool append)

Detailed Description

Logger output that records its clouds into the cloud.

This works in the following manner: 1. Data is compressed as a stream. 2. Once data comes out the other end of the compression, it is both streamed into the cloud and written to a temporary file on disk. 3. When it is time for a log rotation, the two clouds are closed and the stream to the cloud closed. We then check that the cloud made it to the cloud; at which point we delete the log file. 4. When we restart, we look in the cache directory for any temporary files. If any are found, we complete the upload to the cloud and then delete that file from disk.

Definition at line 78 of file cloud_output.h.


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