Aws::DataFlow Namespace Reference

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}

Typedef Documentation

template<typename Status , typename T >

using Aws::DataFlow::UploadStatusFunction = typedef std::function<void (const Status& upload_status, const T &message)>

Function callback when a message has attempted an upload to the cloud.

Definition at line 56 of file task.h.

Enumeration Type Documentation

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

Status.

Enumerator
UNAVAILABLE
AVAILABLE

Definition at line 31 of file status_monitor.h.

enum Aws::DataFlow::UploadStatus

Upload status for some data that was attempted to be published

Enumerator
UNKNOWN
FAIL
SUCCESS
INVALID_DATA

Definition at line 33 of file task.h.

Function Documentation

template<typename T , class O >

std::enable_if<std::is_base_of<Sink<T>, O>::value, std::shared_ptr<O> >::type Aws::DataFlow::operator>> ( OutputStage< T > &  output_stage, std::shared_ptr< O >  sink  )

inline

Definition at line 34 of file dataflow.h.

template<typename T , class O >

std::enable_if<std::is_base_of<QueueDemux<T>, O>::value, std::shared_ptr<O> >::type Aws::DataFlow::operator>> ( std::tuple< std::shared_ptr< ObservedQueue< T >>, PriorityOptions >  observed_queue, std::shared_ptr< O >  sink  )

inline

Definition at line 46 of file dataflow.h.

template<typename T >

std::tuple<std::shared_ptr<ObservedQueue<T> >, PriorityOptions> Aws::DataFlow::operator>> ( std::shared_ptr< ObservedQueue< T >>  observed_queue, PriorityLevel  level  )

inline

Definition at line 57 of file dataflow.h.

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>& Aws::DataFlow::operator>> ( std::shared_ptr< O >  source, InputStage< T > &  inputStage  )

inline

Definition at line 68 of file dataflow.h.

Variable Documentation

constexpr UploaderOptions Aws::DataFlow::kDefaultUploaderOptions {50, 5, 1024, SIZE_MAX, 3}

static

Definition at line 48 of file uploader_options.h.