class Movie::Cluster::MembershipState

Overview

Thread-safe convergent member-record store. Reachability remains local to each observer and is supplied only when a public snapshot is materialized.

Defined in:

movie/cluster/model.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(capacity : Int32 = 10000) #

[View source]

Instance Method Detail

def active_members : Array(Member) #

[View source]
def all_members : Array(Member) #

[View source]
def digest : String #

[View source]
def member(unique_address : UniqueAddress) : Member | Nil #

[View source]
def merge(incoming : Enumerable(Member)) : Int32 #

[View source]
def snapshot(self_unique_address : UniqueAddress, unreachable : Set(UniqueAddress)) : ClusterSnapshot #

[View source]