Search Results for

    Show / Hide Table of Contents

    Class MultiVersionVector

    Inheritance
    object
    VersionVector
    MultiVersionVector
    Implements
    IReplicatedDataSerialization
    IRemovedNodePruning<VersionVector>
    IRemovedNodePruning
    IReplicatedData<VersionVector>
    IReplicatedData
    IEquatable<VersionVector>
    Inherited Members
    VersionVector.Create(UniqueAddress, long)
    VersionVector.Create(ImmutableDictionary<UniqueAddress, long>)
    VersionVector.Empty
    VersionVector.Merge(IReplicatedData)
    VersionVector.Equals(VersionVector)
    VersionVector.Equals(object)
    VersionVector.IsSame(VersionVector)
    VersionVector.IsConcurrent(VersionVector)
    VersionVector.IsBefore(VersionVector)
    VersionVector.IsAfter(VersionVector)
    VersionVector.Compare(VersionVector)
    object.Equals(object, object)
    object.GetType()
    object.ReferenceEquals(object, object)
    Namespace: Akka.DistributedData
    Assembly: Akka.DistributedData.dll
    Syntax
    [Serializable]
    public sealed class MultiVersionVector : VersionVector, IReplicatedDataSerialization, IRemovedNodePruning<VersionVector>, IRemovedNodePruning, IReplicatedData<VersionVector>, IReplicatedData, IEquatable<VersionVector>

    Constructors

    | Edit this page View Source

    MultiVersionVector(IEnumerable<KeyValuePair<UniqueAddress, long>>)

    Declaration
    public MultiVersionVector(IEnumerable<KeyValuePair<UniqueAddress, long>> versions)
    Parameters
    Type Name Description
    IEnumerable<KeyValuePair<UniqueAddress, long>> versions
    | Edit this page View Source

    MultiVersionVector(params KeyValuePair<UniqueAddress, long>[])

    Declaration
    public MultiVersionVector(params KeyValuePair<UniqueAddress, long>[] nodeVersions)
    Parameters
    Type Name Description
    KeyValuePair<UniqueAddress, long>[] nodeVersions
    | Edit this page View Source

    MultiVersionVector(ImmutableDictionary<UniqueAddress, long>)

    Declaration
    public MultiVersionVector(ImmutableDictionary<UniqueAddress, long> nodeVersions)
    Parameters
    Type Name Description
    ImmutableDictionary<UniqueAddress, long> nodeVersions

    Properties

    | Edit this page View Source

    Count

    Declaration
    public override int Count { get; }
    Property Value
    Type Description
    int
    Overrides
    VersionVector.Count
    | Edit this page View Source

    IsEmpty

    Declaration
    public override bool IsEmpty { get; }
    Property Value
    Type Description
    bool
    Overrides
    VersionVector.IsEmpty
    | Edit this page View Source

    ModifiedByNodes

    The nodes that have changed the state for this data and would need pruning when such node is no longer part of the cluster.

    Declaration
    public override ImmutableHashSet<UniqueAddress> ModifiedByNodes { get; }
    Property Value
    Type Description
    ImmutableHashSet<UniqueAddress>
    Overrides
    VersionVector.ModifiedByNodes
    | Edit this page View Source

    VersionEnumerator

    Declaration
    public override IEnumerator<KeyValuePair<UniqueAddress, long>> VersionEnumerator { get; }
    Property Value
    Type Description
    IEnumerator<KeyValuePair<UniqueAddress, long>>
    Overrides
    VersionVector.VersionEnumerator

    Methods

    | Edit this page View Source

    Contains(UniqueAddress)

    Declaration
    public override bool Contains(UniqueAddress node)
    Parameters
    Type Name Description
    UniqueAddress node
    Returns
    Type Description
    bool
    Overrides
    VersionVector.Contains(UniqueAddress)
    | Edit this page View Source

    GetHashCode()

    Declaration
    public override int GetHashCode()
    Returns
    Type Description
    int
    Overrides
    object.GetHashCode()
    | Edit this page View Source

    Increment(UniqueAddress)

    Increment the version for the node passed as argument. Returns a new VersionVector.

    Declaration
    public override VersionVector Increment(UniqueAddress node)
    Parameters
    Type Name Description
    UniqueAddress node
    Returns
    Type Description
    VersionVector
    Overrides
    VersionVector.Increment(UniqueAddress)
    | Edit this page View Source

    Merge(VersionVector)

    Merges this VersionVector with another VersionVector. E.g. merges its versioned history.

    Declaration
    public override VersionVector Merge(VersionVector other)
    Parameters
    Type Name Description
    VersionVector other
    Returns
    Type Description
    VersionVector
    Overrides
    VersionVector.Merge(VersionVector)
    | Edit this page View Source

    NeedPruningFrom(UniqueAddress)

    Does it have any state changes from a specific node, which has been removed from the cluster.

    Declaration
    public override bool NeedPruningFrom(UniqueAddress removedNode)
    Parameters
    Type Name Description
    UniqueAddress removedNode
    Returns
    Type Description
    bool
    Overrides
    VersionVector.NeedPruningFrom(UniqueAddress)
    | Edit this page View Source

    Prune(UniqueAddress, UniqueAddress)

    When the removedNode node has been removed from the cluster the state changes from that node will be pruned by collapsing the data entries to another node.

    Declaration
    public override VersionVector Prune(UniqueAddress removedNode, UniqueAddress collapseInto)
    Parameters
    Type Name Description
    UniqueAddress removedNode
    UniqueAddress collapseInto
    Returns
    Type Description
    VersionVector
    Overrides
    VersionVector.Prune(UniqueAddress, UniqueAddress)
    | Edit this page View Source

    PruningCleanup(UniqueAddress)

    Remove data entries from a node that has been removed from the cluster and already been pruned.

    Declaration
    public override VersionVector PruningCleanup(UniqueAddress removedNode)
    Parameters
    Type Name Description
    UniqueAddress removedNode
    Returns
    Type Description
    VersionVector
    Overrides
    VersionVector.PruningCleanup(UniqueAddress)
    | Edit this page View Source

    ToString()

    Declaration
    public override string ToString()
    Returns
    Type Description
    string
    Overrides
    object.ToString()
    | Edit this page View Source

    VersionAt(UniqueAddress)

    Declaration
    public override long VersionAt(UniqueAddress node)
    Parameters
    Type Name Description
    UniqueAddress node
    Returns
    Type Description
    long
    Overrides
    VersionVector.VersionAt(UniqueAddress)

    Implements

    IReplicatedDataSerialization
    IRemovedNodePruning<T>
    IRemovedNodePruning
    IReplicatedData<T>
    IReplicatedData
    IEquatable<T>

    Extension Methods

    ObjectExtensions.IsDefaultForType<T>(T)
    ObjectExtensions.AsOption<T>(T)
    Extensions.AsInstanceOf<T>(object)
    In this article
    • githubEdit this page
    • View Source
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET