NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::Network::ChannelId Class Reference

#include <ChannelId.hpp>

Public Member Functions

 ChannelId (NesPartition nesPartition, WorkerThreadId workerThreadId)
 
NesPartition getNesPartition () const
 
WorkerThreadId getThreadId () const
 
std::string toString () const
 

Friends

std::ostream & operator<< (std::ostream &os, const ChannelId &channelId)
 

Constructor & Destructor Documentation

◆ ChannelId()

NES::Network::ChannelId::ChannelId ( NesPartition  nesPartition,
WorkerThreadId  workerThreadId 
)
inlineexplicit

Member Function Documentation

◆ getNesPartition()

NesPartition NES::Network::ChannelId::getNesPartition ( ) const
inline

Referenced by NES::Network::detail::createNetworkChannel(), NES::Network::ExchangeProtocol::onClientAnnouncement(), NES::Network::ExchangeProtocol::onEndOfStream(), and NES::Network::TEST_F().

Here is the caller graph for this function:

◆ getThreadId()

WorkerThreadId NES::Network::ChannelId::getThreadId ( ) const
inline

◆ toString()

std::string NES::Network::ChannelId::toString ( ) const
inline

Referenced by NES::Network::ExchangeProtocol::onClientAnnouncement(), and NES::Network::ExchangeProtocol::onEndOfStream().

Here is the caller graph for this function:

Friends And Related Function Documentation

◆ operator<<

std::ostream& operator<< ( std::ostream &  os,
const ChannelId channelId 
)
friend

The documentation for this class was generated from the following file: