Apache Mesos
|
#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... | |