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

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

AddParent(ServerContext *context, const AddParentRequest *request, AddParentReply *reply) overrideNES::CoordinatorRPCServer
CoordinatorRPCServer(RequestHandlerServicePtr requestHandlerService, TopologyPtr topology, Catalogs::Query::QueryCatalogPtr queryCatalog, Monitoring::MonitoringManagerPtr monitoringManager, QueryParsingServicePtr queryParsingService, CoordinatorHealthCheckServicePtr coordinatorHealthCheckService)NES::CoordinatorRPCServerexplicit
GetNodesInRange(ServerContext *, const GetNodesInRangeRequest *request, GetNodesInRangeReply *reply) overrideNES::CoordinatorRPCServer
GetParents(ServerContext *, const GetParentsRequest *request, GetParentsReply *reply) overrideNES::CoordinatorRPCServer
NotifyQueryFailure(ServerContext *context, const QueryFailureNotification *request, QueryFailureNotificationReply *reply) overrideNES::CoordinatorRPCServer
NotifySoftStopCompleted(::grpc::ServerContext *context, const ::SoftStopCompletionMessage *request, ::SoftStopCompletionReply *response) overrideNES::CoordinatorRPCServer
notifySourceStopTriggered(::grpc::ServerContext *context, const ::SoftStopTriggeredMessage *request, ::SoftStopTriggeredReply *response) overrideNES::CoordinatorRPCServer
RegisterLogicalSource(ServerContext *context, const RegisterLogicalSourceRequest *request, RegisterLogicalSourceReply *reply) overrideNES::CoordinatorRPCServer
RegisterPhysicalSource(ServerContext *context, const RegisterPhysicalSourcesRequest *request, RegisterPhysicalSourcesReply *reply) overrideNES::CoordinatorRPCServer
RegisterWorker(ServerContext *context, const RegisterWorkerRequest *registrationRequest, RegisterWorkerReply *reply) overrideNES::CoordinatorRPCServer
RelocateTopologyNode(ServerContext *, const NodeRelocationRequest *request, NodeRelocationReply *reply) overrideNES::CoordinatorRPCServer
RemoveParent(ServerContext *context, const RemoveParentRequest *request, RemoveParentReply *reply) overrideNES::CoordinatorRPCServer
ReplaceParent(ServerContext *context, const ReplaceParentRequest *request, ReplaceParentReply *reply) overrideNES::CoordinatorRPCServer
RequestSoftStop(::grpc::ServerContext *context, const ::RequestSoftStopMessage *request, ::StopRequestReply *response) overrideNES::CoordinatorRPCServer
SendErrors(ServerContext *, const SendErrorsMessage *request, ErrorReply *reply) overrideNES::CoordinatorRPCServer
SendLocationUpdate(ServerContext *, const LocationUpdateRequest *request, LocationUpdateReply *reply) overrideNES::CoordinatorRPCServer
SendScheduledReconnect(ServerContext *, const SendScheduledReconnectRequest *request, SendScheduledReconnectReply *reply) overrideNES::CoordinatorRPCServer
UnregisterLogicalSource(ServerContext *context, const UnregisterLogicalSourceRequest *request, UnregisterLogicalSourceReply *reply) overrideNES::CoordinatorRPCServer
UnregisterPhysicalSource(ServerContext *context, const UnregisterPhysicalSourceRequest *request, UnregisterPhysicalSourceReply *reply) overrideNES::CoordinatorRPCServer
UnregisterWorker(ServerContext *context, const UnregisterWorkerRequest *request, UnregisterWorkerReply *reply) overrideNES::CoordinatorRPCServer