StatisticSinkTest.cpp File Reference

#include <BaseIntegrationTest.hpp>
#include <Configurations/Worker/WorkerConfiguration.hpp>
#include <Runtime/NesThread.hpp>
#include <Runtime/NodeEngine.hpp>
#include <Runtime/NodeEngineBuilder.hpp>
#include <Runtime/WorkerContext.hpp>
#include <Sinks/Formats/StatisticCollection/StatisticFormatFactory.hpp>
#include <Sinks/Mediums/SinkMedium.hpp>
#include <Sinks/Mediums/StatisticSink.hpp>
#include <Sinks/SinkCreator.hpp>
#include <StatisticIdentifiers.hpp>
#include <Statistics/Synopses/CountMinStatistic.hpp>
#include <Statistics/Synopses/HyperLogLogStatistic.hpp>
#include <Util/TestUtils.hpp>
#include <gmock/gmock-matchers.h>

Include dependency graph for StatisticSinkTest.cpp:

Classes
class	NES::StatisticSinkTest

Namespaces
	NES
	This exception represents a network error.

Functions
	NES::TEST_P (StatisticSinkTest, testCountMin)
	Tests if our statistic sink can put CountMin-Sketches into the StatisticStore. More...
	NES::TEST_P (StatisticSinkTest, testHyperLogLog)
	Tests if our statistic sink can put HyperLogLog-Sketches into the StatisticStore. More...
	NES::INSTANTIATE_TEST_CASE_P (testStatisticSink, StatisticSinkTest, ::testing::Combine(::testing::Values(1, 2, 10, 5000), ::testing::ValuesIn(magic_enum::enum_values< Statistic::StatisticDataCodec >())), [](const testing::TestParamInfo< StatisticSinkTest::ParamType > &info) { const auto param=info.param;return std::to_string(std::get< 0 >(param))+"_Statistics"+std::string(magic_enum::enum_name(std::get< 1 >(param)));})