RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
#include <cloud_output.h>
Public Member Functions | |
CloudOutput (const std::string &uri="", size_t ringBufferSize=65536) | |
virtual std::shared_ptr< Sink > | createSink (const std::string &uri, bool append) |
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.