List-like structure for storing and retaining event backups. More...

Collaboration diagram for ProcessedEventsBackupList:

[legend]

Public Member Functions
void	storeEvent (std::unique_ptr< EvtMessage > evtMsg, const StoreObjPtr< EventMetaData > &evtMetaData, const unsigned int workerId)
	Add a new event backup with the given information. Takes ownership of the evt message.

void	removeEvent (const EventMetaData &evtMetaData)
	Remove all backups with the given event meta data (on confirmation)

int	checkForTimeout (const Duration &timeout) const
	Check the items for timeout. Returns -1 if no timeout happened and the worker id, if it did.

template<class AZMQClient >
void	sendWorkerBackupEvents (unsigned int worker, const AZMQClient &socket)
	Send all backups of a given worker directly to the multicast and delete them.

unsigned int	size () const
	Check the size.

Private Types
using	Duration = std::chrono::milliseconds
	Short for the class of a duration (always measured in milliseconds)

Private Attributes
std::vector< ProcessedEventBackup >	m_evtBackupVector
	The vector where the event backups are stored.

Detailed Description

List-like structure for storing and retaining event backups.

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

Public Member Functions