Apache Mesos
Classes | Namespaces | Functions
recordio.hpp File Reference
#include <queue>
#include <string>
#include <utility>
#include <mesos/mesos.hpp>
#include <process/defer.hpp>
#include <process/dispatch.hpp>
#include <process/http.hpp>
#include <process/loop.hpp>
#include <process/owned.hpp>
#include <process/pid.hpp>
#include <process/process.hpp>
#include <stout/lambda.hpp>
#include <stout/nothing.hpp>
#include <stout/recordio.hpp>
#include <stout/result.hpp>

Go to the source code of this file.

Classes

class  mesos::internal::recordio::internal::ReaderProcess< T >
 
class  mesos::internal::recordio::Reader< T >
 Provides RecordIO decoding on top of an http::Pipe::Reader. More...
 
class  mesos::internal::recordio::internal::ReaderProcess< T >
 

Namespaces

 mesos
 
 mesos::internal
 
 mesos::internal::recordio
 
 mesos::internal::recordio::internal
 

Functions

template<typename T >
process::Future< Nothingmesos::internal::recordio::transform (process::Owned< Reader< T >> &&reader, const std::function< std::string(const T &)> &func, process::http::Pipe::Writer writer)
 This is a helper function that reads records from a Reader, applies a transformation to the records and writes to the pipe. More...