Class DeltaHub
Inheritance
System.Object
DeltaHub
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.Modules.Consensus.Deltas
Assembly: Catalyst.Core.Modules.Consensus.dll
Syntax
public class DeltaHub : IDeltaHub
Constructors
| Improve this Doc View SourceDeltaHub(IBroadcastManager, IPeerSettings, IDfs, IHashProvider, ILogger)
Declaration
public DeltaHub(IBroadcastManager broadcastManager, IPeerSettings peerSettings, IDfs dfs, IHashProvider hashProvider, ILogger logger)
Parameters
| Type | Name | Description |
|---|---|---|
| IBroadcastManager | broadcastManager | |
| IPeerSettings | peerSettings | |
| IDfs | dfs | |
| IHashProvider | hashProvider | |
| ILogger | logger |
Properties
| Improve this Doc View SourceDfsRetryPolicy
Declaration
protected virtual AsyncRetryPolicy<Cid> DfsRetryPolicy { get; }
Property Value
| Type | Description |
|---|---|
| AsyncRetryPolicy<Cid> |
Methods
| Improve this Doc View SourceBroadcastCandidate(CandidateDeltaBroadcast)
Declaration
public void BroadcastCandidate(CandidateDeltaBroadcast candidate)
Parameters
| Type | Name | Description |
|---|---|---|
| CandidateDeltaBroadcast | candidate |
BroadcastFavouriteCandidateDelta(FavouriteDeltaBroadcast)
Declaration
public void BroadcastFavouriteCandidateDelta(FavouriteDeltaBroadcast favourite)
Parameters
| Type | Name | Description |
|---|---|---|
| FavouriteDeltaBroadcast | favourite |
PublishDeltaToDfsAndBroadcastAddressAsync(Delta, CancellationToken)
Declaration
public Task<Cid> PublishDeltaToDfsAndBroadcastAddressAsync(Delta delta, CancellationToken cancellationToken = default(CancellationToken))
Parameters
| Type | Name | Description |
|---|---|---|
| Delta | delta | |
| System.Threading.CancellationToken | cancellationToken |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task<Cid> |