Class DeltaPropagation

Inheritance
object
DeltaPropagation
Implements
Inherited Members
Namespace: Akka.DistributedData.Internal
Assembly: Akka.DistributedData.dll
Syntax
public sealed class DeltaPropagation : IReplicatorMessage, IEquatable<DeltaPropagation>

Constructors

| Edit this page View Source

DeltaPropagation(UniqueAddress, bool, ImmutableDictionary<string, Delta>)

Declaration
public DeltaPropagation(UniqueAddress fromNode, bool shouldReply, ImmutableDictionary<string, Delta> deltas)
Parameters
Type Name Description
UniqueAddress fromNode
bool shouldReply
ImmutableDictionary<string, Delta> deltas

Fields

| Edit this page View Source

NoDeltaPlaceholder

When a DeltaReplicatedData returns null from Delta it must still be treated as a delta that increase the version counter in Akka.DistributedData.DeltaPropagationSelector`. Otherwise a later delta might be applied before the full state gossip is received and thereby violating IRequireCausualDeliveryOfDeltas.

This is used as a placeholder for such null delta. It's filtered out in CreateDeltaPropagation(ImmutableDictionary<string, (IReplicatedData data, long from, long to)>), i.e. never sent to the other replicas.

Declaration
public static readonly IReplicatedDelta NoDeltaPlaceholder
Field Value
Type Description
IReplicatedDelta

Properties

| Edit this page View Source

Deltas

Declaration
public ImmutableDictionary<string, Delta> Deltas { get; }
Property Value
Type Description
ImmutableDictionary<string, Delta>
| Edit this page View Source

FromNode

Declaration
public UniqueAddress FromNode { get; }
Property Value
Type Description
UniqueAddress
| Edit this page View Source

ShouldReply

Declaration
public bool ShouldReply { get; }
Property Value
Type Description
bool

Methods

| Edit this page View Source

Equals(DeltaPropagation)

Declaration
public bool Equals(DeltaPropagation other)
Parameters
Type Name Description
DeltaPropagation other
Returns
Type Description
bool
| Edit this page View Source

Equals(object)

Declaration
public override bool Equals(object obj)
Parameters
Type Name Description
object obj
Returns
Type Description
bool
Overrides
| Edit this page View Source

GetHashCode()

Declaration
public override int GetHashCode()
Returns
Type Description
int
Overrides

Implements

Extension Methods