dsl/it.unibo.collektive.aggregate.api

Package-level declarations

Types

Aggregate

interface Aggregate<ID : Any>

Models the minimal set of aggregate operations. Holds the localId of the device executing the aggregate program.

DataSharingMethod

sealed interface DataSharingMethod<in DataType>

A method to share data between nodes in a network.

DelicateCollektiveApi

@Target(allowedTargets = [AnnotationTarget.FUNCTION])

annotation class DelicateCollektiveApi

Represents methods intended to be used internally only. The usage of these methods is discouraged and should be avoided.

InMemory

object InMemory : DataSharingMethod<Any?>

In-memory share. No serialization. Working only across multiple nodes hosted on the same operating system (for instance, in simulation).

Serialize

@JvmInline

value class Serialize<DataType>(val serializer: KSerializer<DataType>) : DataSharingMethod<DataType>

Serialization-based share using kotlinx.serialization. The data is serialized and deserialized using the provided serializer.

YieldingContext

class YieldingContext<Initial, Return>

Context for yielding operations (exchanging, sharing). Yielding operations means operate on an Initial value (usually exchanged with neighbors), but return a possibly different value Return to the caller.

YieldingResult

data class YieldingResult<Initial, Return>(val toSend: Initial, val toReturn: Return)

Specifies the value toSend and the value toReturn of a yielding operator.

YieldingScope

typealias YieldingScope<Initial, Return> = YieldingContext<Initial, Return>.(Initial) -> YieldingResult<Initial, Return>