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.