salsa  0.4.15
Public Member Functions | Static Public Member Functions | Protected Attributes | Static Private Attributes | List of all members
Salsa::Distributor Class Reference

Base Distributor class. More...

#include <Distributor.hh>

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

Public Member Functions

 Distributor (std::string uuid, std::shared_ptr< Socket > pPipe, NodeManager *pNM)
 
virtual ~Distributor ()
 
std::string uuid () const
 Returns distributor's UUID. More...
 
std::shared_ptr< Socket > pipe () 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
 
virtual void onEnter (Message *pInMsg, std::vector< std::string > &out, std::string type)
 TODO Three horsemen of apocalypse. More...
 
virtual void onExit (Message *pInMsg, std::vector< std::string > &out)
 
virtual void onWhisper (Message *pInMsg, std::vector< std::string > &out)
 
Json::Value jsonValueNodeInfo () const
 Returns json value.
 
virtual void upadateJsonValueNodeInfo ()
 

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< Socket > mpPipe = 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.
 
NodeManager * mpNodeManager = nullptr
 Node Manager.
 
NodeInfo * mpNodeInfo {new NodeInfo()}
 Node Info.
 
Json::Value mJsonValue
 Node Info as json value.
 
TaskInfo mTaskInfoCache {}
 Task Info cache.
 

Static Private Attributes

static std::shared_ptr< spdlog::logger > mspConsoleLogger = spdlog::stdout_color_mt("salsa")
 Pointer to spd logger.
 

Detailed Description

Base Distributor class.

Author
Matej Fedor matej.nosp@m..fed.nosp@m.or.mf.nosp@m.@gma.nosp@m.il.co.nosp@m.m
Martin Vala mvala.nosp@m.@cer.nosp@m.n.ch
Branislav Beke bbeke.nosp@m.@bad.nosp@m.haven.nosp@m..dev

Definition at line 19 of file Distributor.hh.

Constructor & Destructor Documentation

◆ Distributor()

Salsa::Distributor::Distributor ( std::string  uuid,
std::shared_ptr< Socket >  pPipe,
NodeManager *  pNM 
)

Constructor

Definition at line 3 of file Distributor.cc.

◆ ~Distributor()

Salsa::Distributor::~Distributor ( )
virtual

Destructor

Definition at line 10 of file Distributor.cc.

References mpNodeInfo.

Member Function Documentation

◆ addClient()

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

Adds client

Definition at line 18 of file Distributor.cc.

References mClients, and uuid().

◆ addOther()

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

Adds other

Definition at line 34 of file Distributor.cc.

References mOthers, and uuid().

◆ nodeInfo()

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

Returns node info

Definition at line 92 of file Distributor.cc.

References mpNodeInfo.

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

◆ onEnter()

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

TODO Three horsemen of apocalypse.

onEnter

Reimplemented in Salsa::Worker, Salsa::Feeder, and Salsa::Consumer.

Definition at line 58 of file Distributor.cc.

◆ onExit()

void Salsa::Distributor::onExit ( Message *  pInMsg,
std::vector< std::string > &  out 
)
virtual

onExit

Reimplemented in Salsa::Worker, Salsa::Feeder, and Salsa::Consumer.

Definition at line 64 of file Distributor.cc.

◆ onWhisper()

void Salsa::Distributor::onWhisper ( Message *  pInMsg,
std::vector< std::string > &  out 
)
virtual

onWhisper

Reimplemented in Salsa::Worker, Salsa::Feeder, and Salsa::Consumer.

Definition at line 70 of file Distributor.cc.

◆ pipe()

std::shared_ptr< Socket > Salsa::Distributor::pipe ( ) const

TODO Returns distributor's pipe?

Returns pipe socket

Definition at line 77 of file Distributor.cc.

References mpPipe.

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

◆ print()

void Salsa::Distributor::print ( ) const

TODO Prints distributor's state.

Prints info

Definition at line 50 of file Distributor.cc.

References mClients, mOthers, and mpPipe.

◆ removeClient()

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

Remove client

Definition at line 26 of file Distributor.cc.

References mClients, and uuid().

◆ removeOther()

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

Remove other

Definition at line 42 of file Distributor.cc.

References mOthers, and uuid().

◆ upadateJsonValueNodeInfo()

void Salsa::Distributor::upadateJsonValueNodeInfo ( )
virtual

Updates json value with node info

Definition at line 100 of file Distributor.cc.

References mJsonValue, and mpNodeInfo.

Referenced by Salsa::Feeder::onExit(), and Salsa::Feeder::onWhisper().

◆ uuid()

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

Returns distributor's UUID.

Returns uuid

Definition at line 84 of file Distributor.cc.

References mUUID.

Referenced by addClient(), addOther(), removeClient(), removeOther(), Salsa::Feeder::removeWorkerTask(), Salsa::Feeder::subscribe(), and Salsa::Feeder::terminateJob().

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