#include <gtest/gtest.h>
#include <gmock/gmock.h>
#include <chrono>
#include <condition_variable>
#include <mutex>
#include <random>
#include <string>
#include <thread>
#include <map>
#include <aws/core/Aws.h>
#include <aws/core/utils/logging/ConsoleLogSystem.h>
#include <cloudwatch_metrics_common/metric_service.hpp>
#include <cloudwatch_metrics_common/metric_batcher.h>
#include <cloudwatch_metrics_common/metric_publisher.hpp>
#include <cloudwatch_metrics_common/definitions/definitions.h>
#include <file_management/file_upload/file_manager.h>
#include <dataflow_lite/dataflow/dataflow.h>
#include <dataflow_lite/task/task.h>
#include <dataflow_lite/utils/waiter.h>
Go to the source code of this file.
Classes | |
class | PipelineTest |
class | TestMetricFileManager |
class | TestPublisher |
Functions | |
MetricObject | createTestMetricObjectWithStatisticValues (const std::string &name, const double value=2.42, const std::string &unit="gigawatts", const int64_t timestamp=1234, const std::map< std::string, std::string > &dimensions=std::map< std::string, std::string >(), const int storage_resolution=60) |
MetricObject | createTestMetricObjectWithValue (const std::string &name, const double value=2.42, const std::string &unit="gigawatts", const int64_t timestamp=1234, const std::map< std::string, std::string > &dimensions=std::map< std::string, std::string >(), const int storage_resolution=60) |
int | main (int argc, char **argv) |
TEST (MetricPipelineTest, TestCreateMetricObject) | |
TEST_F (PipelineTest, Sanity) | |
TEST_F (PipelineTest, TestConvertToBatchedData) | |
TEST_F (PipelineTest, TestBatcherManualPublish) | |
TEST_F (PipelineTest, TestBatcherManualPublishMultipleItems) | |
TEST_F (PipelineTest, TestBatcherSize) | |
TEST_F (PipelineTest, TestSinglePublisherFailureToFileManager) | |
TEST_F (PipelineTest, TestInvalidDataNotPassedToFileManager) | |
TEST_F (PipelineTest, TestPublisherIntermittant) | |
TEST_F (PipelineTest, TestBatchDataTooFast) | |
MetricObject createTestMetricObjectWithStatisticValues | ( | const std::string & | name, |
const double | value = 2.42 , |
||
const std::string & | unit = "gigawatts" , |
||
const int64_t | timestamp = 1234 , |
||
const std::map< std::string, std::string > & | dimensions = std::map<std::string, std::string>() , |
||
const int | storage_resolution = 60 |
||
) |
Definition at line 194 of file metric_pipeline_test.cpp.
MetricObject createTestMetricObjectWithValue | ( | const std::string & | name, |
const double | value = 2.42 , |
||
const std::string & | unit = "gigawatts" , |
||
const int64_t | timestamp = 1234 , |
||
const std::map< std::string, std::string > & | dimensions = std::map<std::string, std::string>() , |
||
const int | storage_resolution = 60 |
||
) |
Definition at line 183 of file metric_pipeline_test.cpp.
int main | ( | int | argc, |
char ** | argv | ||
) |
Definition at line 513 of file metric_pipeline_test.cpp.
TEST | ( | MetricPipelineTest | , |
TestCreateMetricObject | |||
) |
Definition at line 215 of file metric_pipeline_test.cpp.
TEST_F | ( | PipelineTest | , |
Sanity | |||
) |
Definition at line 211 of file metric_pipeline_test.cpp.
TEST_F | ( | PipelineTest | , |
TestConvertToBatchedData | |||
) |
Definition at line 229 of file metric_pipeline_test.cpp.
TEST_F | ( | PipelineTest | , |
TestBatcherManualPublish | |||
) |
Simple Pipeline test to check that everything was hooked up correctly.
Definition at line 261 of file metric_pipeline_test.cpp.
TEST_F | ( | PipelineTest | , |
TestBatcherManualPublishMultipleItems | |||
) |
Simple Pipeline test to check that everything was hooked up correctly.
Definition at line 291 of file metric_pipeline_test.cpp.
TEST_F | ( | PipelineTest | , |
TestBatcherSize | |||
) |
Simple Pipeline test to check that everything was hooked up correctly.
Definition at line 320 of file metric_pipeline_test.cpp.
TEST_F | ( | PipelineTest | , |
TestSinglePublisherFailureToFileManager | |||
) |
Definition at line 354 of file metric_pipeline_test.cpp.
TEST_F | ( | PipelineTest | , |
TestInvalidDataNotPassedToFileManager | |||
) |
Definition at line 388 of file metric_pipeline_test.cpp.
TEST_F | ( | PipelineTest | , |
TestPublisherIntermittant | |||
) |
Definition at line 421 of file metric_pipeline_test.cpp.
TEST_F | ( | PipelineTest | , |
TestBatchDataTooFast | |||
) |
Definition at line 476 of file metric_pipeline_test.cpp.