Classes | |
class | BasicTask |
class | InputStage |
class | IObservedQueue |
class | IPublisher |
class | MaskFactory |
class | MultiStatusConditionMonitor |
class | ObservedBlockingQueue |
class | ObservedQueue |
class | ObservedSynchronizedQueue |
class | OutputStage |
struct | PriorityOptions |
class | QueueDemux |
class | QueueMonitor |
class | Sink |
class | Source |
class | StatusMonitor |
class | Task |
class | ThreadMonitor |
struct | UploaderOptions |
Typedefs | |
template<typename Status , typename T > | |
using | UploadStatusFunction = std::function< void(const Status &upload_status, const T &message)> |
Enumerations | |
enum | PriorityLevel : uint { LOWEST_PRIORITY = 0, LOW_PRIORITY, MEDIUM_PRIORITY, HIGH_PRIORITY, HIGHEST_PRIORITY } |
enum | Status : uint { UNAVAILABLE = 0, AVAILABLE } |
enum | UploadStatus { UNKNOWN, FAIL, SUCCESS, INVALID_DATA } |
Functions | |
template<typename T , class O > | |
std::enable_if< std::is_base_of< Sink< T >, O >::value, std::shared_ptr< O > >::type | operator>> (OutputStage< T > &output_stage, std::shared_ptr< O > sink) |
template<typename T , class O > | |
std::enable_if< std::is_base_of< QueueDemux< T >, O >::value, std::shared_ptr< O > >::type | operator>> (std::tuple< std::shared_ptr< ObservedQueue< T >>, PriorityOptions > observed_queue, std::shared_ptr< O > sink) |
template<typename T > | |
std::tuple< std::shared_ptr< ObservedQueue< T > >, PriorityOptions > | operator>> (std::shared_ptr< ObservedQueue< T >> observed_queue, PriorityLevel level) |
template<typename O , class T , class = typename std::enable_if<std::is_base_of<Source<T>, O>::value, std::shared_ptr<O>>::type> | |
InputStage< T > & | operator>> (std::shared_ptr< O > source, InputStage< T > &inputStage) |
Variables | |
static constexpr UploaderOptions | kDefaultUploaderOptions {50, 5, 1024, SIZE_MAX, 3} |
using Aws::DataFlow::UploadStatusFunction = typedef std::function<void (const Status& upload_status, const T &message)> |
enum Aws::DataFlow::PriorityLevel : uint |
Enumerator | |
---|---|
LOWEST_PRIORITY | |
LOW_PRIORITY | |
MEDIUM_PRIORITY | |
HIGH_PRIORITY | |
HIGHEST_PRIORITY |
Definition at line 21 of file priority_options.h.
enum Aws::DataFlow::Status : uint |
|
inline |
Definition at line 34 of file dataflow.h.
|
inline |
Definition at line 46 of file dataflow.h.
|
inline |
Definition at line 57 of file dataflow.h.
|
inline |
Definition at line 68 of file dataflow.h.
|
static |
Definition at line 48 of file uploader_options.h.