WeakCodeMobilityDeviceActor

Type Members

type Receive = PartialFunction[Any, Unit]

Definition Classes
Actor

Abstract Value Members

abstract val aggregateExecutor: Option[Platform.ProgramContract]

Definition Classes
ComputationDeviceActor
abstract def propagateMsgToNeighbors(msg: Any): Unit

Definition Classes
ComputationDeviceActor
abstract val selfId: Platform.UID

Definition Classes
BaseDeviceActor

Concrete Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def actuatorManagementBehavior: Receive

Definition Classes
ActuatorManagementBehavior
val actuators: Map[Platform.LSensorName, (Any) ⇒ Unit]

Definition Classes
ActuatorManagementBehavior
def afterJob(): Unit

Definition Classes
ComputationDeviceActor
def aroundPostRestart(reason: Throwable): Unit

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
def aroundPostStop(): Unit

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
def aroundPreStart(): Unit

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

Attributes
protected[akka]
Definition Classes
Actor
Annotations
@InternalApi()
final def asInstanceOf[T0]: T0

Definition Classes
Any
def beforeJob(): Unit

Definition Classes
WeakCodeMobilityDeviceActor → ComputationDeviceActor
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@HotSpotIntrinsicCandidate() @throws( ... )
def commandManagementBehavior: Receive

Definition Classes
BasicActorBehavior
def compute(ctx: Platform.ComputationContext): Platform.ComputationExport

Definition Classes
ComputationDeviceActor
implicit val context: ActorContext

Definition Classes
Actor
def doJob(): Unit

Definition Classes
ComputationDeviceActor
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def executeActuators(value: Any): Unit

Definition Classes
ActuatorManagementBehavior
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
Annotations
@HotSpotIntrinsicCandidate()
def handleProgram(nid: Platform.UID, program: () ⇒ Any): Unit
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@HotSpotIntrinsicCandidate()
def inputManagementBehavior: Receive

Definition Classes
WeakCodeMobilityDeviceActor → ActuatorManagementBehavior → SensorManagementBehavior → SensingBehavior → BasicActorBehavior
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
var lastExport: Option[Platform.ComputationExport]

Definition Classes
ComputationDeviceActor
var lastProgram: Option[() ⇒ Any]
val localSensors: Map[Platform.LSensorName, () ⇒ Any]

Definition Classes
SensorManagementBehavior
val logger: LoggingAdapter

Definition Classes
BasicActorBehavior
def mergeNeighborInfo(idn: Platform.UID, info: NbrInfo): Unit

Definition Classes
BaseNbrManagementBehavior
val nbrSensorValues: Map[Platform.NSensorName, Map[Platform.UID, Any]]

Definition Classes
SensingBehavior
var nbrs: Map[Platform.UID, NbrInfo]

Definition Classes
BaseNbrManagementBehavior
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
Annotations
@HotSpotIntrinsicCandidate()
final def notifyAll(): Unit

Definition Classes
AnyRef
Annotations
@HotSpotIntrinsicCandidate()
def postRestart(reason: Throwable): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def postStop(): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def preRestart(reason: Throwable, message: Option[Any]): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def preStart(): Unit

Definition Classes
ComputationDeviceActor → Actor
def propagateExportToNeighbors(export: Platform.ComputationExport): Unit

Definition Classes
ComputationDeviceActor
def propagateProgramToNeighbors(program: () ⇒ Any): Unit
def queryManagementBehavior: Receive

Definition Classes
BasicActorBehavior
def receive: Receive

Definition Classes
BasicActorBehavior
def removeNeighbor(idn: Platform.UID): Unit

Definition Classes
BaseNbrManagementBehavior
def resetComputationState(): Unit
var rounds: Int

Definition Classes
ComputationDeviceActor
implicit final val self: ActorRef

Definition Classes
Actor
final def sender(): ActorRef

Definition Classes
Actor
def sensingBehavior: Receive

Definition Classes
SensingBehavior
def sensorManagementBehavior: Receive

Definition Classes
SensorManagementBehavior
val sensorValues: Map[Platform.LSensorName, Any]

Definition Classes
SensingBehavior
def setActuator(name: Platform.LSensorName, consumer: (Any) ⇒ Unit): Unit

Definition Classes
ActuatorManagementBehavior
def setLocalSensor(name: Platform.LSensorName, provider: () ⇒ Any): Unit

Definition Classes
SensorManagementBehavior
def setLocalSensorValue(name: Platform.LSensorName, value: Any): Unit

Definition Classes
SensingBehavior
def setNbrSensorValue(name: Platform.NSensorName, map: Map[Platform.UID, Any]): Unit

Definition Classes
SensingBehavior
def supervisorStrategy: SupervisorStrategy

Definition Classes
Actor
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
def unhandled(message: Any): Unit

Definition Classes
Actor
var unreliableNbrs: Set[Platform.UID]
def updateNeighborhood(neighbors: Set[Platform.UID], clear: Boolean = false): Unit

Definition Classes
BaseNbrManagementBehavior
def updateNeighborsState(exps: Map[Platform.UID, Option[Platform.ComputationExport]], clear: Boolean = false): Unit

Definition Classes
BaseNbrManagementBehavior
def updateProgram(program: () ⇒ Any): Unit
def updateSensorValues(): Unit

Definition Classes
ComputationDeviceActor
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
def workingBehavior: Receive

Definition Classes
ComputationDeviceActor → BasicActorBehavior

Deprecated Value Members

def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
Deprecated
(Since version ) see corresponding Javadoc for more information.

Related Doc: package PlatformDevices

trait WeakCodeMobilityDeviceActor extends Platform.ComputationDeviceActor

Type Members

type Receive = PartialFunction[Any, Unit]

Abstract Value Members

abstract val aggregateExecutor: Option[Platform.ProgramContract]

abstract def propagateMsgToNeighbors(msg: Any): Unit

abstract val selfId: Platform.UID

Concrete Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

def actuatorManagementBehavior: Receive

val actuators: Map[Platform.LSensorName, (Any) ⇒ Unit]

def afterJob(): Unit

def aroundPostRestart(reason: Throwable): Unit

def aroundPostStop(): Unit

def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

def aroundPreStart(): Unit

def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

final def asInstanceOf[T0]: T0

def beforeJob(): Unit

def clone(): AnyRef

def commandManagementBehavior: Receive

def compute(ctx: Platform.ComputationContext): Platform.ComputationExport

implicit val context: ActorContext

def doJob(): Unit

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def executeActuators(value: Any): Unit

final def getClass(): Class[_]

def handleProgram(nid: Platform.UID, program: () ⇒ Any): Unit

def hashCode(): Int

def inputManagementBehavior: Receive

final def isInstanceOf[T0]: Boolean

var lastExport: Option[Platform.ComputationExport]

var lastProgram: Option[() ⇒ Any]

val localSensors: Map[Platform.LSensorName, () ⇒ Any]

val logger: LoggingAdapter

def mergeNeighborInfo(idn: Platform.UID, info: NbrInfo): Unit

val nbrSensorValues: Map[Platform.NSensorName, Map[Platform.UID, Any]]

var nbrs: Map[Platform.UID, NbrInfo]

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def postRestart(reason: Throwable): Unit

def postStop(): Unit

def preRestart(reason: Throwable, message: Option[Any]): Unit

def preStart(): Unit

def propagateExportToNeighbors(export: Platform.ComputationExport): Unit

def propagateProgramToNeighbors(program: () ⇒ Any): Unit

def queryManagementBehavior: Receive

def receive: Receive

def removeNeighbor(idn: Platform.UID): Unit

def resetComputationState(): Unit

var rounds: Int

implicit final val self: ActorRef

final def sender(): ActorRef

def sensingBehavior: Receive

def sensorManagementBehavior: Receive

val sensorValues: Map[Platform.LSensorName, Any]

def setActuator(name: Platform.LSensorName, consumer: (Any) ⇒ Unit): Unit

def setLocalSensor(name: Platform.LSensorName, provider: () ⇒ Any): Unit

def setLocalSensorValue(name: Platform.LSensorName, value: Any): Unit

def setNbrSensorValue(name: Platform.NSensorName, map: Map[Platform.UID, Any]): Unit

def supervisorStrategy: SupervisorStrategy

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

def unhandled(message: Any): Unit

var unreliableNbrs: Set[Platform.UID]

def updateNeighborhood(neighbors: Set[Platform.UID], clear: Boolean = false): Unit

def updateNeighborsState(exps: Map[Platform.UID, Option[Platform.ComputationExport]], clear: Boolean = false): Unit

def updateProgram(program: () ⇒ Any): Unit

def updateSensorValues(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

final def wait(): Unit

def workingBehavior: Receive

Deprecated Value Members