NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
This is the complete list of members for NES::CoordinatorRPCServer, including all inherited members.
AddParent(ServerContext *context, const AddParentRequest *request, AddParentReply *reply) override | NES::CoordinatorRPCServer | |
CoordinatorRPCServer(RequestHandlerServicePtr requestHandlerService, TopologyPtr topology, Catalogs::Query::QueryCatalogPtr queryCatalog, Monitoring::MonitoringManagerPtr monitoringManager, QueryParsingServicePtr queryParsingService, CoordinatorHealthCheckServicePtr coordinatorHealthCheckService) | NES::CoordinatorRPCServer | explicit |
GetNodesInRange(ServerContext *, const GetNodesInRangeRequest *request, GetNodesInRangeReply *reply) override | NES::CoordinatorRPCServer | |
GetParents(ServerContext *, const GetParentsRequest *request, GetParentsReply *reply) override | NES::CoordinatorRPCServer | |
NotifyQueryFailure(ServerContext *context, const QueryFailureNotification *request, QueryFailureNotificationReply *reply) override | NES::CoordinatorRPCServer | |
NotifySoftStopCompleted(::grpc::ServerContext *context, const ::SoftStopCompletionMessage *request, ::SoftStopCompletionReply *response) override | NES::CoordinatorRPCServer | |
notifySourceStopTriggered(::grpc::ServerContext *context, const ::SoftStopTriggeredMessage *request, ::SoftStopTriggeredReply *response) override | NES::CoordinatorRPCServer | |
RegisterLogicalSource(ServerContext *context, const RegisterLogicalSourceRequest *request, RegisterLogicalSourceReply *reply) override | NES::CoordinatorRPCServer | |
RegisterPhysicalSource(ServerContext *context, const RegisterPhysicalSourcesRequest *request, RegisterPhysicalSourcesReply *reply) override | NES::CoordinatorRPCServer | |
RegisterWorker(ServerContext *context, const RegisterWorkerRequest *registrationRequest, RegisterWorkerReply *reply) override | NES::CoordinatorRPCServer | |
RelocateTopologyNode(ServerContext *, const NodeRelocationRequest *request, NodeRelocationReply *reply) override | NES::CoordinatorRPCServer | |
RemoveParent(ServerContext *context, const RemoveParentRequest *request, RemoveParentReply *reply) override | NES::CoordinatorRPCServer | |
ReplaceParent(ServerContext *context, const ReplaceParentRequest *request, ReplaceParentReply *reply) override | NES::CoordinatorRPCServer | |
RequestSoftStop(::grpc::ServerContext *context, const ::RequestSoftStopMessage *request, ::StopRequestReply *response) override | NES::CoordinatorRPCServer | |
SendErrors(ServerContext *, const SendErrorsMessage *request, ErrorReply *reply) override | NES::CoordinatorRPCServer | |
SendLocationUpdate(ServerContext *, const LocationUpdateRequest *request, LocationUpdateReply *reply) override | NES::CoordinatorRPCServer | |
SendScheduledReconnect(ServerContext *, const SendScheduledReconnectRequest *request, SendScheduledReconnectReply *reply) override | NES::CoordinatorRPCServer | |
UnregisterLogicalSource(ServerContext *context, const UnregisterLogicalSourceRequest *request, UnregisterLogicalSourceReply *reply) override | NES::CoordinatorRPCServer | |
UnregisterPhysicalSource(ServerContext *context, const UnregisterPhysicalSourceRequest *request, UnregisterPhysicalSourceReply *reply) override | NES::CoordinatorRPCServer | |
UnregisterWorker(ServerContext *context, const UnregisterWorkerRequest *request, UnregisterWorkerReply *reply) override | NES::CoordinatorRPCServer |