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

#include <cloud_output.h>

Inheritance diagram for Datacratic::CloudSink:
Datacratic::CompressingOutput::Sink

List of all members.

Public Member Functions

 CloudSink (const std::string &uri="", bool append=true, bool disambiguate=true)
void open (const std::string &uri, bool append, bool disambiguate)
virtual void close ()
virtual size_t write (const char *data, size_t size)
virtual size_t flush (FileFlushLevel flushLevel)

Public Attributes

std::string currentUri_
 Uri of cloud we're writing to.
std::string tmpFileDir_
ML::filter_ostream cloudStream
 Current stream to the cloud (TM)
ML::filter_ostream fileStream

Detailed Description

Class that writes to a cloud.

Definition at line 28 of file cloud_output.h.


Member Function Documentation

void Datacratic::CloudSink::close ( ) [virtual]

Function that closes the given sink.

Implements Datacratic::CompressingOutput::Sink.

Definition at line 50 of file cloud_output.cc.

size_t Datacratic::CloudSink::flush ( FileFlushLevel  flushLevel) [virtual]

Function that should be overwritten when the stream needs to be flushed to make sure that the data gets to disk.

Implements Datacratic::CompressingOutput::Sink.

Definition at line 71 of file cloud_output.cc.

size_t Datacratic::CloudSink::write ( const char *  data,
size_t  size 
) [virtual]

Function that should be overwritten to write data when it's output by the compressor.

Implements Datacratic::CompressingOutput::Sink.

Definition at line 61 of file cloud_output.cc.


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