batchData(const D &data_to_batch) | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | virtual |
batchData(const D &data_to_batch, const std::chrono::milliseconds &milliseconds) | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | virtual |
batcher_ | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | protected |
CloudWatchService(std::shared_ptr< Publisher< std::list< T >>> publisher, std::shared_ptr< DataBatcher< T >> batcher) | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | |
convertInputToBatched(const Utils::MetricObject &input, const std::chrono::milliseconds &milliseconds) override | Aws::CloudWatchMetrics::MetricService | inline |
convertInputToBatched(const Utils::MetricObject &input) override | Aws::CloudWatchMetrics::MetricService | inline |
CloudWatchService< Utils::MetricObject, MetricDatum >::convertInputToBatched(const D &input, const std::chrono::milliseconds &milliseconds)=0 | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | protectedpure virtual |
CloudWatchService< Utils::MetricObject, MetricDatum >::convertInputToBatched(const D &input)=0 | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | protectedpure virtual |
dequeue_duration_ | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | protected |
file_upload_streamer_ | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | protected |
getCurrentTimestamp() | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | virtual |
getDequeueDuration() | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | virtual |
getNumberDequeued() | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | |
getSource() | InputStage< TaskPtr< std::list< T > > > | |
getState() | Service | |
getStatusString() override | RunnableService | virtual |
isConnected() | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | virtual |
isRunning() | RunnableService | virtual |
join() | RunnableService | |
MetricService(std::shared_ptr< Publisher< MetricDatumCollection >> publisher, std::shared_ptr< DataBatcher< MetricDatum >> batcher, std::shared_ptr< Aws::FileManagement::FileUploadStreamer< MetricDatumCollection >> file_upload_streamer=nullptr) | Aws::CloudWatchMetrics::MetricService | inline |
publishBatchedData() | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | virtual |
publisher_ | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | protected |
run() | RunnableService | protectedvirtual |
RunnableService() | RunnableService | |
Service() | Service | |
setDequeueDuration(std::chrono::milliseconds new_value) | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | virtual |
setSource(std::shared_ptr< Source< TaskPtr< std::list< T > > >> source) | InputStage< TaskPtr< std::list< T > > > | |
setState(ServiceState new_state) | Service | protected |
shutdown() | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | virtual |
start() override | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | virtual |
startWorkerThread() | RunnableService | protectedvirtual |
stopWorkerThread() | RunnableService | protectedvirtual |
waitForShutdown() | RunnableService | |
waitForShutdown(std::chrono::milliseconds millis) | RunnableService | |
work() | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | protectedvirtual |
~CloudWatchService()=default | Aws::CloudWatch::CloudWatchService< Utils::MetricObject, MetricDatum > | |
~RunnableService() override=default | RunnableService | |
~Service()=default | Service | virtual |