Class PeerMessageCorrelationManager

Inheritance
System.Object
MessageCorrelationManagerBase
PeerMessageCorrelationManager
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.Correlation
Assembly: Catalyst.Core.Lib.dll
Syntax
public sealed class PeerMessageCorrelationManager : MessageCorrelationManagerBase, IPeerMessageCorrelationManager, IMessageCorrelationManager, IDisposable

Constructors

| Improve this Doc View Source

PeerMessageCorrelationManager(IReputationManager, Extensions.Caching.Memory.IMemoryCache, ILogger, IChangeTokenProvider, IScheduler)

Declaration
public PeerMessageCorrelationManager(IReputationManager reputationManager, Extensions.Caching.Memory.IMemoryCache cache, ILogger logger, IChangeTokenProvider changeTokenProvider, IScheduler scheduler = null)
Parameters
Type Name Description
IReputationManager reputationManager
Microsoft.Extensions.Caching.Memory.IMemoryCache cache
ILogger logger
IChangeTokenProvider changeTokenProvider
IScheduler scheduler

Properties

| Improve this Doc View Source

EvictionEventStream

Declaration
public IObservable<KeyValuePair<ICorrelationId, PeerId>> EvictionEventStream { get; }
Property Value
Type Description
System.IObservable<System.Collections.Generic.KeyValuePair<ICorrelationId, PeerId>>
| Improve this Doc View Source

ReputationEventStream

Declaration
public IObservable<IPeerReputationChange> ReputationEventStream { get; }
Property Value
Type Description
System.IObservable<IPeerReputationChange>

Methods

| Improve this Doc View Source

Dispose(Boolean)

Declaration
protected override void Dispose(bool disposing)
Parameters
Type Name Description
System.Boolean disposing
Overrides
| Improve this Doc View Source

EvictionCallback(Object, Object, EvictionReason, Object)

Declaration
protected override void EvictionCallback(object key, object value, EvictionReason reason, object state)
Parameters
Type Name Description
System.Object key
System.Object value
EvictionReason reason
System.Object state
Overrides
| Improve this Doc View Source

TryMatchResponse(ProtocolMessage)

Takes a generic request type of IMessage, and generic response type of IMessage and the message and look them up in the cache. Return what's found or emit an-uncorrectable event

Declaration
public override bool TryMatchResponse(ProtocolMessage response)
Parameters
Type Name Description
ProtocolMessage response
Returns
Type Description
System.Boolean
Overrides

Implements

System.IDisposable