WorkerRPCClient.hpp File Reference

#include <Identifiers/Identifiers.hpp>
#include <Runtime/QueryTerminationType.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <StatisticCollection/StatisticCache/AbstractStatisticCache.hpp>
#include <StatisticCollection/StatisticProbeHandling/AbstractStatisticProbeGenerator.hpp>
#include <Util/TimeMeasurement.hpp>
#include <WorkerRPCService.grpc.pb.h>
#include <WorkerRPCService.pb.h>
#include <grpcpp/grpcpp.h>
#include <string>
#include <thread>

Include dependency graph for WorkerRPCClient.hpp:

This graph shows which files directly or indirectly include this file:

Classes
struct	NES::RpcAsyncRequest
class	NES::WorkerRPCClient
struct	NES::WorkerRPCClient::AsyncClientCall< ReplayType >

Namespaces
	NES
	This exception represents a network error.
	NES::Monitoring
	NES::Spatial
	NES::Spatial::DataTypes
	NES::Spatial::DataTypes::Experimental

Typedefs
using	NES::ReconfigurationMarkerPtr = std::shared_ptr< ReconfigurationMarker >
using	NES::Monitoring::MonitoringPlanPtr = std::shared_ptr< MonitoringPlan >
using	NES::DecomposedQueryPlanPtr = std::shared_ptr< DecomposedQueryPlan >

Enumerations
enum class	NES::RpcClientMode : uint8_t {   NES::Register , NES::Unregister , NES::Start , NES::Stop ,   NES::Reconfiguration }