salsa  0.3.0
 All Classes Functions Variables Enumerations Pages
Salsa::Consumer Class Reference

Base Consumer class. More...

#include <Consumer.hh>

Inheritance diagram for Salsa::Consumer:
Salsa::Distributor Salsa::Object

Public Member Functions

 Consumer (std::string uuid, std::shared_ptr< Socket > pPipe, NodeManager *pNM)
 
virtual ~Consumer ()
 
virtual void onEnter (Message *pInMsg, std::vector< std::string > &out, std::string type)
 TODO Consumer action on ENTER event. More...
 
virtual void onExit (Message *pInMsg, std::vector< std::string > &out)
 TODO Consumer action on EXIT event. More...
 
virtual void onWhisper (Message *pInMsg, std::vector< std::string > &out)
 TODO Consumer action on WHISPER event. More...
 
std::string uuid () const
 Returns distributor's UUID. More...
 
std::shared_ptr< Socketpipe () const
 TODO Returns distributor's pipe? More...
 
void print () const
 TODO Prints distributor's state. More...
 
void addClient (std::string uuid, std::string type)
 
void removeClient (std::string uuid)
 
void addOther (std::string uuid, std::string type)
 
void removeOther (std::string uuid)
 
NodeInfo * nodeInfo () const
 

Static Public Member Functions

static std::shared_ptr
< spdlog::logger > 
getConsoleOutput ()
 Get console output.
 
static void setConsoleLevel (spdlog::level::level_enum level)
 Sets console log level.
 

Protected Attributes

std::string mUUID {}
 Self UUID.
 
std::shared_ptr< SocketmpPipe = nullptr
 Pipe for messages (net connector)
 
std::map< std::string,
std::string > 
mClients {}
 List of clients.
 
std::map< std::string,
std::string > 
mOthers {}
 List of others.
 
NodeManagermpNodeManager = nullptr
 Node Manager.
 
NodeInfo * mpNodeInfo {new NodeInfo()}
 Node Info.
 

Detailed Description

Constructor & Destructor Documentation

Salsa::Consumer::Consumer ( std::string  uuid,
std::shared_ptr< Socket pPipe,
NodeManager pNM 
)

Constructor

Definition at line 4 of file Consumer.cc.

Salsa::Consumer::~Consumer ( )
virtual

Destructor

Definition at line 10 of file Consumer.cc.

Member Function Documentation

void Salsa::Distributor::addClient ( std::string  uuid,
std::string  type 
)
inherited

Adds client

Definition at line 18 of file Distributor.cc.

References Salsa::Distributor::mClients.

void Salsa::Distributor::addOther ( std::string  uuid,
std::string  type 
)
inherited

Adds other

Definition at line 34 of file Distributor.cc.

References Salsa::Distributor::mOthers.

NodeInfo * Salsa::Distributor::nodeInfo ( ) const
inherited

Returns node info

Definition at line 92 of file Distributor.cc.

References Salsa::Distributor::mpNodeInfo.

Referenced by Salsa::Feeder::onWhisper().

void Salsa::Consumer::onEnter ( Message pInMsg,
std::vector< std::string > &  out,
std::string  type 
)
virtual

TODO Consumer action on ENTER event.

onEnter

Reimplemented from Salsa::Distributor.

Definition at line 17 of file Consumer.cc.

References Salsa::Message::content().

void Salsa::Consumer::onExit ( Message pInMsg,
std::vector< std::string > &  out 
)
virtual
void Salsa::Consumer::onWhisper ( Message pInMsg,
std::vector< std::string > &  out 
)
virtual
std::shared_ptr< Socket > Salsa::Distributor::pipe ( ) const
inherited

TODO Returns distributor's pipe?

Returns pipe socket

Definition at line 77 of file Distributor.cc.

References Salsa::Distributor::mpPipe.

Referenced by Salsa::Feeder::subscribe(), and Salsa::Feeder::terminateJob().

void Salsa::Distributor::print ( ) const
inherited

TODO Prints distributor's state.

Prints info

Definition at line 50 of file Distributor.cc.

References Salsa::Distributor::mClients, Salsa::Distributor::mOthers, and Salsa::Distributor::mpPipe.

void Salsa::Distributor::removeClient ( std::string  uuid)
inherited

Remove client

Definition at line 26 of file Distributor.cc.

References Salsa::Distributor::mClients.

void Salsa::Distributor::removeOther ( std::string  uuid)
inherited

Remove other

Definition at line 42 of file Distributor.cc.

References Salsa::Distributor::mOthers.

std::string Salsa::Distributor::uuid ( ) const
inherited

Returns distributor's UUID.

Returns uuid

Definition at line 84 of file Distributor.cc.

References Salsa::Distributor::mUUID.

Referenced by Salsa::Feeder::removeWorkerTask().


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