|
NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <BaseUnitTest.hpp>#include <Reconfiguration/Metadata/DrainQueryMetadata.hpp>#include <Reconfiguration/Metadata/UpdateAndDrainQueryMetadata.hpp>#include <Reconfiguration/Metadata/UpdateQueryMetadata.hpp>#include <Reconfiguration/ReconfigurationMarker.hpp>#include <Reconfiguration/ReconfigurationMarkerSerializationUtil.hpp>#include <Util/Logger/Logger.hpp>#include <WorkerRPCService.grpc.pb.h>#include <WorkerRPCService.pb.h>#include <gtest/gtest.h>#include <iostream>Classes | |
| class | ReconfigurationMarkerSerializationUtilTest |
Functions | |
| TEST_F (ReconfigurationMarkerSerializationUtilTest, reconfigurationMarkerSerialization) | |
| TEST_F | ( | ReconfigurationMarkerSerializationUtilTest | , |
| reconfigurationMarkerSerialization | |||
| ) |
References NES::ReconfigurationMarker::create(), NES::ReconfigurationMarkerEvent::create(), NES::UpdateAndDrainQueryMetadata::decomposedQueryId, NES::UpdateQueryMetadata::decomposedQueryId, NES::UpdateAndDrainQueryMetadata::decomposedQueryPlanVersion, NES::UpdateQueryMetadata::decomposedQueryPlanVersion, NES::ReconfigurationMarkerSerializationUtil::deserialize(), NES::MARKED_FOR_MIGRATION, NES::MARKED_FOR_REDEPLOYMENT, NES::DrainQueryMetadata::numberOfSources, NES::UpdateAndDrainQueryMetadata::numberOfSources, NES::ReconfigurationMarkerSerializationUtil::serialize(), NES::UpdateAndDrainQueryMetadata::sharedQueryId, NES::UpdateQueryMetadata::sharedQueryId, NES::UpdateAndDrainQueryMetadata::workerId, and NES::UpdateQueryMetadata::workerId.