dsl/it.unibo.collektive.networking

Package-level declarations

Types

data class InMemoryMessage<ID : Any>(val senderId: ID, val sharedData: Map<Path, Any?>) : Message<ID, Any?>

A message specifically designed to be delivered in a in-memory fashion, containing a senderId and sharedData.

TODO.

interface Mailbox<ID : Any>

TODO.

sealed interface Message<ID : Any, out Payload>

A message meant to be delivered in a communication medium, containing a senderId and sharedData.

Factory for creating Message instances.

Data received from neighbors.

An empty inbound message.

Defined the output of the aggregate program. Holds all the messages to be sent to the neighbors.

Representation of a payload with its payload and representation.

@Serializable

data class SerializedMessage<ID : Any>(val senderId: ID, val sharedData: Map<Path, ByteArray>) : Message<ID, ByteArray>

Serialized message meant to be sent over the network containing a senderId and sharedData.

abstract class SerializedMessageFactory<ID : Any, Payload>(serializerFormat: SerialFormat) : MessageFactory<ID, ByteArray>

TODO.