NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
Public Member Functions | Static Public Member Functions | Public Attributes | List of all members
NES::NonBlockingMonotonicSeqQueueTest Class Reference
Collaboration diagram for NES::NonBlockingMonotonicSeqQueueTest:
[legend]

Public Member Functions

void SetUp () override
 
uint64_t emplaceInMockupQueue (const SequenceData &seqDataToInsert, const uint64_t value)
 Emplaces into a mock queue that is not concurrent thread-safe. More...
 
- Public Member Functions inherited from NES::Testing::BaseUnitTest
void SetUp () override
 
void TearDown () override
 
virtual void onFatalError (int signalNumber, std::string callstack) override
 onFatalError shall be called when a signal is caught More...
 
virtual void onFatalException (std::shared_ptr< std::exception > exception, std::string callstack) override
 onFatalException shall be called when an exception is caught More...
 
- Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this< ErrorListener >
 ~virtual_enable_shared_from_this () NES_NOEXCEPT(true) override=default
 
std::shared_ptr< T1 > shared_from_this ()
 
std::weak_ptr< T1 > weak_from_this ()
 
- Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this_base< true >
virtual ~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default
 
- Public Member Functions inherited from NES::Testing::detail::TestWaitingHelper
 TestWaitingHelper ()
 
void startWaitingThread (std::string testName)
 
void completeTest ()
 
void failTest ()
 

Static Public Member Functions

static void SetUpTestCase ()
 

Public Attributes

std::map< SequenceNumber, ChunkStateTest > seenSequenceData
 
std::vector< std::tuple< SequenceData, uint64_t > > watermarkBarriers
 
- Public Attributes inherited from NES::Testing::BaseUnitTest
detail::TestSourceNameHelper srcName
 

Member Function Documentation

◆ emplaceInMockupQueue()

uint64_t NES::NonBlockingMonotonicSeqQueueTest::emplaceInMockupQueue ( const SequenceData &  seqDataToInsert,
const uint64_t  value 
)
inline

Emplaces into a mock queue that is not concurrent thread-safe.

Parameters
seqDataToInsert
value
Returns
CurrentValue

References NES::SequenceData::chunkNumber, NES::SequenceData::lastChunk, NES::SequenceData::sequenceNumber, and magic_enum::detail::value().

Here is the call graph for this function:

◆ SetUp()

void NES::NonBlockingMonotonicSeqQueueTest::SetUp ( )
inlineoverride

◆ SetUpTestCase()

static void NES::NonBlockingMonotonicSeqQueueTest::SetUpTestCase ( )
inlinestatic

References NES::LOG_DEBUG, NES_DEBUG, and NES::Logger::setupLogging().

Here is the call graph for this function:

Member Data Documentation

◆ seenSequenceData

std::map<SequenceNumber, ChunkStateTest> NES::NonBlockingMonotonicSeqQueueTest::seenSequenceData

◆ watermarkBarriers

std::vector<std::tuple<SequenceData, uint64_t> > NES::NonBlockingMonotonicSeqQueueTest::watermarkBarriers
The documentation for this class was generated from the following file: