Kombu.Clocks.LamportClock (Kombu v0.1.0)

Lamport logical clock backed by :atomics for lock-free thread/process safety (kombu.clocks.LamportClock).

Summary

t()

sort_heap(h)

Return the earliest/winning event from a sorted list of {clock, process_id, ...} tuples (kombu.clocks.LamportClock.sort_heap).

@type t() :: %Kombu.Clocks.LamportClock{ref: :atomics.atomics_ref()}

@spec adjust(t(), integer() | nil) :: integer()

@spec forward(t()) :: integer()

@spec new(integer()) :: t()

@spec sort_heap([tuple(), ...]) :: tuple()

Return the earliest/winning event from a sorted list of {clock, process_id, ...} tuples (kombu.clocks.LamportClock.sort_heap).

@spec value(t()) :: integer()