Summary

groups()

key_fun()

A faster version of Enum.group_by with less bells and whistles.

hash(key)

Gets the next delay at which we should attempt to hibernate a worker or partitioner process.

Computes the partition for a given pid using :erlang.phash2/2

Partitions a bunch of pids into a tuple, of lists of pids grouped by by the result of :erlang.pash2/2

Types

@type groups() :: %{required(any()) => [pid()]}

@type key_fun() :: (any() -> any())

@spec group_by([pid()], key_fun()) :: groups()

A faster version of Enum.group_by with less bells and whistles.

@spec hash(atom() | binary() | integer()) :: integer()

@spec next_hibernate_delay() :: integer()

Gets the next delay at which we should attempt to hibernate a worker or partitioner process.

@spec pack_message(mode :: Manifold.pack_mode(), message :: term()) :: term()

@spec partition_for(pid(), integer()) :: integer()

Computes the partition for a given pid using :erlang.phash2/2

@spec partition_pids([pid()], integer()) :: tuple()

Partitions a bunch of pids into a tuple, of lists of pids grouped by by the result of :erlang.pash2/2

@spec unpack_message(message :: term()) :: term()