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