catapult::subscribers Namespace Reference

Namespaces
	detail

Classes
class	AggregateBlockChangeSubscriber
	Aggregate block change subscriber. More...
class	AggregateNodeSubscriber
	Aggregate node subscriber. More...
class	AggregatePtChangeSubscriber
	Aggregate partial transactions change subscriber. More...
class	AggregateStateChangeSubscriber
	Aggregate state change subscriber. More...
class	AggregateTransactionStatusSubscriber
	Aggregate transaction status subscriber. More...
class	AggregateUtChangeSubscriber
	Aggregate unconfirmed transactions change subscriber. More...
class	BasicAggregateSubscriber
	Basic aggregate subscriber. More...
struct	MessageQueueDescriptor
	Describes a message queue. More...
class	NodeSubscriber
	Node subscriber. More...
struct	StateChangeInfo
	State change information. More...
class	StateChangeSubscriber
	State change subscriber. More...
class	SubscriptionManager
	A manager for subscribing to notifications. More...
class	TransactionStatusSubscriber
	Transaction status subscriber. More...

Typedefs
using	CacheChangesStorages = std::vector< std::unique_ptr< const cache::CacheChangesStorage > >
	Vector of cache changes storage unique pointers. More...

Enumerations
enum	BlockChangeOperationType : uint8_t { BlockChangeOperationType::Block, BlockChangeOperationType::Drop_Blocks_After }
	Block change operation type. More...
enum	PtChangeOperationType : uint8_t { PtChangeOperationType::Add_Partials, PtChangeOperationType::Remove_Partials, PtChangeOperationType::Add_Cosignature }
	Partial transactions change operation type. More...
enum	StateChangeOperationType : uint8_t { StateChangeOperationType::Score_Change, StateChangeOperationType::State_Change }
	State change operation type. More...
enum	UtChangeOperationType : uint8_t { UtChangeOperationType::Add, UtChangeOperationType::Remove }
	Unconfirmed transactions change operation type. More...

Functions
void	ReadNextBlockChange (io::InputStream &inputStream, io::BlockChangeSubscriber &subscriber)
	Reads next block change from inputStream and forwards it to subscriber. More...
template<typename TSubscriber , typename TMessageReader >
void	ReadAll (io::InputStream &inputStream, TSubscriber &subscriber, TMessageReader readNextMessage)
	Reads all messages from inputStream into subscriber using readNextMessage. More...
template<typename TSubscriber , typename TMessageReader >
void	ReadAll (io::FileQueueReader &reader, TSubscriber &subscriber, TMessageReader readNextMessage)
	Reads all messages from reader into subscriber using readNextMessage. More...
template<typename TSubscriber , typename TMessageReader >
void	ReadAll (const MessageQueueDescriptor &descriptor, TSubscriber &subscriber, TMessageReader readNextMessage)
	Reads all messages from queue described by descriptor into subscriber using readNextMessage. More...
void	ReadNextPtChange (io::InputStream &inputStream, cache::PtChangeSubscriber &subscriber)
	Reads next partial transactions change from inputStream and forwards it to subscriber. More...
void	ReadNextStateChange (io::InputStream &inputStream, const CacheChangesStorages &cacheChangesStorages, StateChangeSubscriber &subscriber)
	Reads next state change from inputStream and forwards it to subscriber using cacheChangesStorages for deserialization. More...
void	ReadNextTransactionStatus (io::InputStream &inputStream, TransactionStatusSubscriber &subscriber)
	Reads next transaction status from inputStream and forwards it to subscriber. More...
void	ReadNextUtChange (io::InputStream &inputStream, cache::UtChangeSubscriber &subscriber)
	Reads next unconfirmed transactions change from inputStream and forwards it to subscriber. More...

Typedef Documentation

CacheChangesStorages

using catapult::subscribers::CacheChangesStorages = typedef std::vector<std::unique_ptr<const cache::CacheChangesStorage> >

Vector of cache changes storage unique pointers.

Enumeration Type Documentation

BlockChangeOperationType

enum catapult::subscribers::BlockChangeOperationType : uint8_t

strong

Block change operation type.

Enumerator
Block	Block saved.
Drop_Blocks_After	Blocks dropped.

PtChangeOperationType

enum catapult::subscribers::PtChangeOperationType : uint8_t

strong

Partial transactions change operation type.

Enumerator
Add_Partials	Add partial transaction infos.
Remove_Partials	Remove partial transaction infos.
Add_Cosignature	Add cosignature.

StateChangeOperationType

enum catapult::subscribers::StateChangeOperationType : uint8_t

strong

State change operation type.

Enumerator
Score_Change	Score change.
State_Change	State change.

UtChangeOperationType

enum catapult::subscribers::UtChangeOperationType : uint8_t

strong

Unconfirmed transactions change operation type.

Enumerator
Add	Add transaction infos.
Remove	Remove transaction infos.

Function Documentation

ReadAll() [1/3]

template<typename TSubscriber , typename TMessageReader >

void catapult::subscribers::ReadAll	(	const MessageQueueDescriptor &	descriptor,
		TSubscriber &	subscriber,
		TMessageReader	readNextMessage
	)

Reads all messages from queue described by descriptor into subscriber using readNextMessage.

Here is the call graph for this function:

ReadAll() [2/3]

template<typename TSubscriber , typename TMessageReader >

void catapult::subscribers::ReadAll	(	io::FileQueueReader &	reader,
		TSubscriber &	subscriber,
		TMessageReader	readNextMessage
	)

Reads all messages from reader into subscriber using readNextMessage.

Here is the call graph for this function:

ReadAll() [3/3]

template<typename TSubscriber , typename TMessageReader >

void catapult::subscribers::ReadAll	(	io::InputStream &	inputStream,
		TSubscriber &	subscriber,
		TMessageReader	readNextMessage
	)

Reads all messages from inputStream into subscriber using readNextMessage.

Here is the call graph for this function:

Here is the caller graph for this function:

ReadNextBlockChange()

void catapult::subscribers::ReadNextBlockChange	(	io::InputStream &	inputStream,
		io::BlockChangeSubscriber &	subscriber
	)

Reads next block change from inputStream and forwards it to subscriber.

Here is the call graph for this function:

ReadNextPtChange()

void catapult::subscribers::ReadNextPtChange	(	io::InputStream &	inputStream,
		cache::PtChangeSubscriber &	subscriber
	)

Reads next partial transactions change from inputStream and forwards it to subscriber.

Here is the call graph for this function:

ReadNextStateChange()

void catapult::subscribers::ReadNextStateChange	(	io::InputStream &	inputStream,
		const CacheChangesStorages &	cacheChangesStorages,
		StateChangeSubscriber &	subscriber
	)

Reads next state change from inputStream and forwards it to subscriber using cacheChangesStorages for deserialization.

Here is the call graph for this function:

ReadNextTransactionStatus()

void catapult::subscribers::ReadNextTransactionStatus	(	io::InputStream &	inputStream,
		TransactionStatusSubscriber &	subscriber
	)

Reads next transaction status from inputStream and forwards it to subscriber.

Here is the call graph for this function:

ReadNextUtChange()

void catapult::subscribers::ReadNextUtChange	(	io::InputStream &	inputStream,
		cache::UtChangeSubscriber &	subscriber
	)

Reads next unconfirmed transactions change from inputStream and forwards it to subscriber.

Here is the call graph for this function: