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< Nothing >	mesos::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...