collektivize/it.unibo.collektive.aggregate

Package-level declarations

Types

sealed interface Collapse<out E>

A collapsing view over a collection of size elements that can be accessed as a list, set, or sequence.

interface CollapseAll<out E> : Collapse<E>

A Collapse that include the local element in addition to peers.

A Collapse that represents only the peers (excluding the local element).

sealed interface Field<ID : Any, out T>

A Field represents the local view of distributed values across a network of nodes.

value class FieldEntry<ID : Any, out T>(val pair: Pair<ID, T>)

The entry of a Field.

Returns a collapse containing only the IDs from this CollapseAll.

Returns a collapse containing only the IDs from this CollapseNeighbors.

Returns a collapse containing only the values from this CollapseAll.

Returns a collapse containing only the values from this CollapseNeighbors.

operator fun <T> Collapse<T>.contains(element: T): Boolean

Checks if the given element is present in this collapse.

Converts a Pair to a FieldEntry.

Converts this collapse of field entries into a map from entry IDs to their values.

Converts a Sequence of FieldEntry to a Map.