NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Classes | |
class | AccessNonLockedResourceException |
This exception is raised, in case a request tries to access a resource via the storage handler without having locked it before. More... | |
class | ExecutionNodeNotFoundException |
This exception indicates, that a lookup for an execution node in the global execution plan failed. More... | |
class | QueryUndeploymentException |
this exception indicates an error during the undeployment of a query More... | |
class | ResourceLockingException |
class | RpcException |
This exception indicates the failure of an rpc. More... | |
class | RPCQueryUndeploymentException |
This exception indicates that an rpc to undeploy a query from a worker has failed. More... | |
class | StorageHandlerAcquireResourcesException |
class | ErrorListener |
This is an error interceptor suitable for signals and exceptions. More... | |
class | NotImplementedException |
class | RequestExecutionException |
This is the base class for exceptions thrown during the execution of coordinator side requests which indicate an error that possibly require a rollback or other kinds of specific error handling. More... | |
class | RuntimeException |
Exception to be used to report errors and stacktraces This is meant to be used for NES-related errors, wrap std exceptions with their own stacktrace, etc.. More... | |
Functions | |
void | invokeErrorHandlers (int signal, std::string &&stacktrace) |
calls to this function will pass the signal to all system-wide error listeners More... | |
void | invokeErrorHandlers (std::shared_ptr< std::exception > exception, std::string &&stacktrace) |
calls to this function will pass an exception to all system-wide error listeners More... | |
void | invokeErrorHandlers (const std::string &buffer, std::string &&stacktrace) |
calls to this function will create a RuntimeException that is passed to all system-wide error listeners More... | |
void | installGlobalErrorListener (std::shared_ptr< ErrorListener > const &listener) |
make an error listener system-wide More... | |
void | removeGlobalErrorListener (const std::shared_ptr< ErrorListener > &listener) |
remove an error listener system-wide More... | |
void NES::Exceptions::installGlobalErrorListener | ( | std::shared_ptr< ErrorListener > const & | listener | ) |
make an error listener system-wide
listener | the error listener to make system-wide |
References NES_TRACE.
Referenced by main(), NES::Testing::BaseUnitTest::SetUp(), and NES::NesCoordinator::startCoordinator().
void NES::Exceptions::invokeErrorHandlers | ( | const std::string & | buffer, |
std::string && | stacktrace | ||
) |
calls to this function will create a RuntimeException that is passed to all system-wide error listeners
buffer | the message of the exception |
stacktrace | the stacktrace of where the error was raised |
References invokeErrorHandlers(), backward::details::move(), and NES_TRACE.
void NES::Exceptions::invokeErrorHandlers | ( | int | signal, |
std::string && | stacktrace | ||
) |
calls to this function will pass the signal to all system-wide error listeners
signal | which indicates the error |
stacktrace | the stacktrace of where the error was raised |
References NES::Logger::getInstance().
Referenced by invokeErrorHandlers(), NES::Runtime::detail::nesErrorHandler(), NES::Runtime::detail::nesTerminateHandler(), and NES::Runtime::detail::nesUnexpectedException().
void NES::Exceptions::invokeErrorHandlers | ( | std::shared_ptr< std::exception > | exception, |
std::string && | stacktrace | ||
) |
calls to this function will pass an exception to all system-wide error listeners
exception | which indicates the error |
stacktrace | the stacktrace of where the error was raised |
References NES::Logger::getInstance().
void NES::Exceptions::removeGlobalErrorListener | ( | const std::shared_ptr< ErrorListener > & | listener | ) |
remove an error listener system-wide
listener | the error listener to remove system-wide |
References NES_TRACE.
Referenced by NES::Testing::BaseUnitTest::TearDown().