Class BroadcastManager

The Gossip Manager used to broadcast and receive gossip messages

Inheritance
System.Object
BroadcastManager
Implements
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Catalyst.Core.Lib.P2P.IO.Messaging.Broadcast
Assembly: Catalyst.Core.Lib.dll
Syntax
public sealed class BroadcastManager : IBroadcastManager

Constructors

| Improve this Doc View Source

BroadcastManager(IPeerRepository, IPeerSettings, IMemoryCache, IPeerClient, IKeySigner, ILogger)

Initializes a new instance of the BroadcastManager class.

Declaration
public BroadcastManager(IPeerRepository peers, IPeerSettings peerSettings, IMemoryCache memoryCache, IPeerClient peerClient, IKeySigner signer, ILogger logger)
Parameters
Type Name Description
IPeerRepository peers

The peers.
IPeerSettings peerSettings

Peer settings
IMemoryCache memoryCache

The memory cache.
IPeerClient peerClient

The peer client.
IKeySigner signer

The signature writer
ILogger logger

Properties

| Improve this Doc View Source

BroadcastOwnerMaximumGossipPeersPerRound

The maximum peers a broadcast originator can gossip to for a single message, per gossip cycle.

Declaration
public static int BroadcastOwnerMaximumGossipPeersPerRound { get; }
Property Value
Type Description
System.Int32
| Improve this Doc View Source

MaxGossipPeersPerRound

The maximum peers the node can gossip to for a single message, per gossip cycle

Declaration
public static int MaxGossipPeersPerRound { get; }
Property Value
Type Description
System.Int32

Methods

| Improve this Doc View Source

BroadcastAsync(ProtocolMessage)

Declaration
public Task BroadcastAsync(ProtocolMessage message)
Parameters
Type Name Description
ProtocolMessage message
Returns
Type Description
System.Threading.Tasks.Task
| Improve this Doc View Source

ReceiveAsync(ProtocolMessage)

Declaration
public Task ReceiveAsync(ProtocolMessage protocolSignedMessage)
Parameters
Type Name Description
ProtocolMessage protocolSignedMessage
Returns
Type Description
System.Threading.Tasks.Task
| Improve this Doc View Source

RemoveSignedBroadcastMessageData(ICorrelationId)

Declaration
public void RemoveSignedBroadcastMessageData(ICorrelationId correlationId)
Parameters
Type Name Description
ICorrelationId correlationId

Implements

See Also