NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::WorkerRPCClient Member List

This is the complete list of members for NES::WorkerRPCClient, including all inherited members.

addReconfigurationMarker(const std::string &address, const SharedQueryId &sharedQueryId, const DecomposedQueryId &decomposedQueryId, const ReconfigurationMarkerPtr &reconfigurationMarker, const CompletionQueuePtr &cq)NES::WorkerRPCClient
bufferData(const std::string &address, DecomposedQueryId decomposedQueryId, uint64_t uniqueNetworkSinDescriptorId)NES::WorkerRPCClient
checkAsyncResult(const std::vector< RpcAsyncRequest > &rpcAsyncRequests)NES::WorkerRPCClient
checkHealth(const std::string &address, std::string healthServiceName)NES::WorkerRPCClient
create()NES::WorkerRPCClientstatic
getWaypoint(const std::string &address)NES::WorkerRPCClient
injectEpochBarrier(uint64_t timestamp, uint64_t queryId, const std::string &address)NES::WorkerRPCClient
registerDecomposedQuery(const std::string &address, const DecomposedQueryPlanPtr &decomposedQueryPlan)NES::WorkerRPCClient
registerDecomposedQueryAsync(const std::string &address, const DecomposedQueryPlanPtr &decomposedQueryPlan, const CompletionQueuePtr &cq)NES::WorkerRPCClient
registerMonitoringPlan(const std::string &address, const Monitoring::MonitoringPlanPtr &plan)NES::WorkerRPCClient
requestMonitoringData(const std::string &address)NES::WorkerRPCClient
startDecomposedQuery(const std::string &address, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId)NES::WorkerRPCClient
startDecomposedQueryAsync(const std::string &address, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, const CompletionQueuePtr &cq)NES::WorkerRPCClient
stopDecomposedQuery(const std::string &address, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, Runtime::QueryTerminationType terminationType)NES::WorkerRPCClient
stopDecomposedQueryAsync(const std::string &address, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, Runtime::QueryTerminationType terminationType, const CompletionQueuePtr &cq)NES::WorkerRPCClient
unregisterDecomposedQuery(const std::string &address, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId)NES::WorkerRPCClient
unregisterDecomposedQueryAsync(const std::string &address, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, const CompletionQueuePtr &cq)NES::WorkerRPCClient
updateNetworkSink(const std::string &address, uint64_t newNodeId, const std::string &newHostname, uint32_t newPort, DecomposedQueryId decomposedQueryId, uint64_t uniqueNetworkSinDescriptorId)NES::WorkerRPCClient