CatapultServer  v0.5.0.1 (Elephant)
catapult::zeromq Namespace Reference

Classes

class  MessageGroup
 
struct  MessagingConfiguration
 Messaging configuration settings. More...
 
class  ZeroMqEntityPublisher
 A zeromq entity publisher. More...
 

Enumerations

enum  BlockMarker : uint64_t { BlockMarker::Block_Marker = 0x9FF2D8E480CA6A49, BlockMarker::Drop_Blocks_Marker = 0x5C20D68AEE25B0B0 }
 Markers for publishing block related messages. More...
 
enum  TransactionMarker : uint8_t {
  TransactionMarker::Transaction_Marker = 0x61, TransactionMarker::Unconfirmed_Transaction_Add_Marker = 0x75, TransactionMarker::Unconfirmed_Transaction_Remove_Marker = 0x72, TransactionMarker::Transaction_Status_Marker = 0x73,
  TransactionMarker::Partial_Transaction_Add_Marker = 0x70, TransactionMarker::Partial_Transaction_Remove_Marker = 0x71, TransactionMarker::Cosignature_Marker = 0x63
}
 Markers for publishing transaction related messages. More...
 

Functions

std::vector< uint8_t > CreateTopic (TransactionMarker marker, const UnresolvedAddress &address)
 Creates a topic around marker and address. More...
 
std::unique_ptr< io::BlockChangeSubscriberCreateZeroMqBlockChangeSubscriber (ZeroMqEntityPublisher &publisher)
 Creates a zeromq block change subscriber around an entity publisher. More...
 
std::unique_ptr< cache::PtChangeSubscriberCreateZeroMqPtChangeSubscriber (ZeroMqEntityPublisher &publisher)
 Creates a zeromq partial transactions subscriber around an entity publisher. More...
 
std::unique_ptr< subscribers::TransactionStatusSubscriberCreateZeroMqTransactionStatusSubscriber (ZeroMqEntityPublisher &publisher)
 Creates a zeromq transaction status subscriber around an entity publisher. More...
 
std::unique_ptr< cache::UtChangeSubscriberCreateZeroMqUtChangeSubscriber (ZeroMqEntityPublisher &publisher)
 Creates a zeromq unconfirmed transactions subscriber around an entity publisher. More...
 

Enumeration Type Documentation

◆ BlockMarker

enum catapult::zeromq::BlockMarker : uint64_t
strong

Markers for publishing block related messages.

Enumerator
Block_Marker 

A block.

Drop_Blocks_Marker 

A dropped block.

◆ TransactionMarker

enum catapult::zeromq::TransactionMarker : uint8_t
strong

Markers for publishing transaction related messages.

Enumerator
Transaction_Marker 

A confirmed transaction.

Unconfirmed_Transaction_Add_Marker 

An added unconfirmed transaction.

Unconfirmed_Transaction_Remove_Marker 

A removed unconfirmed transaction.

Transaction_Status_Marker 

A transaction status.

Partial_Transaction_Add_Marker 

An added partial transaction.

Partial_Transaction_Remove_Marker 

A removed partial transaction.

Cosignature_Marker 

A detached cosignature.

Function Documentation

◆ CreateTopic()

std::vector< uint8_t > catapult::zeromq::CreateTopic ( TransactionMarker  marker,
const UnresolvedAddress address 
)

Creates a topic around marker and address.

Here is the call graph for this function:
Here is the caller graph for this function:

◆ CreateZeroMqBlockChangeSubscriber()

std::unique_ptr< io::BlockChangeSubscriber > catapult::zeromq::CreateZeroMqBlockChangeSubscriber ( ZeroMqEntityPublisher publisher)

Creates a zeromq block change subscriber around an entity publisher.

◆ CreateZeroMqPtChangeSubscriber()

std::unique_ptr< cache::PtChangeSubscriber > catapult::zeromq::CreateZeroMqPtChangeSubscriber ( ZeroMqEntityPublisher publisher)

Creates a zeromq partial transactions subscriber around an entity publisher.

◆ CreateZeroMqTransactionStatusSubscriber()

std::unique_ptr< subscribers::TransactionStatusSubscriber > catapult::zeromq::CreateZeroMqTransactionStatusSubscriber ( ZeroMqEntityPublisher publisher)

Creates a zeromq transaction status subscriber around an entity publisher.

◆ CreateZeroMqUtChangeSubscriber()

std::unique_ptr< cache::UtChangeSubscriber > catapult::zeromq::CreateZeroMqUtChangeSubscriber ( ZeroMqEntityPublisher publisher)

Creates a zeromq unconfirmed transactions subscriber around an entity publisher.