SpatialDeviceActor

Instance Constructors

new SpatialDeviceActor(selfId: (SpatialPlatform.this)#UID, _aggregateExecutor: Option[(SpatialPlatform.this)#ProgramContract], _execScope: (SpatialPlatform.this)#ExecScope, server: ActorRef)

Type Members

type Receive = PartialFunction[Any, Unit]

Definition Classes
Actor

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[(SpatialPlatform.this)#LSensorName, (Any) ⇒ Unit]

Definition Classes
ActuatorManagementBehavior
def afterJob(): Unit

Definition Classes
ObservableDeviceActor → ComputationDeviceActor
var aggregateExecutor: Option[(SpatialPlatform.this)#ProgramContract]

Definition Classes
HybridDeviceActor → 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
ComputationDeviceActor
val classloader: CustomClassLoader

Definition Classes
MissingCodeManagementBehavior
def clone(): AnyRef

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

Definition Classes
MissingCodeManagementBehavior → BasicActorBehavior
def compute(ctx: (SpatialPlatform.this)#ComputationContext): (SpatialPlatform.this)#ComputationExport

Definition Classes
ComputationDeviceActor
implicit val context: ActorContext

Definition Classes
Actor
def currentStateMessage: Any

Definition Classes
ObservableActorBehavior
def doJob(): Unit

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

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

Definition Classes
AnyRef → Any
var execScope: (SpatialPlatform.this)#ExecScope

Definition Classes
HybridDeviceActor → DynamicDeviceLifecycleBehavior
def executeActuators(value: Any): Unit

Definition Classes
ActuatorManagementBehavior
var first: Boolean

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

Definition Classes
AnyRef → Any
Annotations
@HotSpotIntrinsicCandidate()
def handleLifecycle(): Unit

Definition Classes
DynamicDeviceLifecycleBehavior → PeriodicBehavior → LifecycleBehavior
def hashCode(): Int

Definition Classes
AnyRef → Any
Annotations
@HotSpotIntrinsicCandidate()
val initialDelay: Option[FiniteDuration]

Definition Classes
DynamicDeviceLifecycleBehavior → PeriodicBehavior
def inputManagementBehavior: Receive

Definition Classes
MissingCodeManagementBehavior → BasicActorBehavior
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
var lastExport: Option[(SpatialPlatform.this)#ComputationExport]

Definition Classes
ComputationDeviceActor
def lifecyclePostStop(): Unit

Definition Classes
DynamicDeviceLifecycleBehavior → LifecycleBehavior
def lifecyclePreStart(): Unit

Definition Classes
DynamicDeviceLifecycleBehavior → PeriodicBehavior → LifecycleBehavior
val localSensors: Map[(SpatialPlatform.this)#LSensorName, () ⇒ Any]

Definition Classes
SensorManagementBehavior
val logger: LoggingAdapter

Definition Classes
BasicActorBehavior
def mergeNeighborInfo(idn: (SpatialPlatform.this)#UID, info: (SpatialPlatform.this)#NbrInfo): Unit

Definition Classes
BaseNbrManagementBehavior
val mobilityExt: CodeMobilityExtensionImpl

Definition Classes
MissingCodeManagementBehavior
val nbrSensorValues: Map[(SpatialPlatform.this)#NSensorName, Map[(SpatialPlatform.this)#UID, Any]]

Definition Classes
SensingBehavior
var nbrs: Map[(SpatialPlatform.this)#UID, (SpatialPlatform.this)#NbrInfo]

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

Definition Classes
AnyRef
def neighbourhoodManagementBehavior: Receive

Definition Classes
P2pNbrManagementBehavior
final def notify(): Unit

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

Definition Classes
AnyRef
Annotations
@HotSpotIntrinsicCandidate()
def notifyObservers(msg: Any): Unit

Definition Classes
ObservableActorBehavior
def notifyObservers(): Unit

Definition Classes
ObservableActorBehavior
def observerAdded(ref: ActorRef): Unit

Definition Classes
ObservableDeviceActor → ObservableActorBehavior
val observers: Set[ActorRef]

Definition Classes
ObservableActorBehavior
def observersManagementBehavior: Receive

Definition Classes
ObservableActorBehavior
def periodicBehaviorPreStart(): Unit

Definition Classes
PeriodicBehavior
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
HybridDeviceActor → DynamicComputationDeviceActor → ComputationDeviceActor → Actor
def propagateExportToNeighbors(export: (SpatialPlatform.this)#ComputationExport): Unit

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

Definition Classes
P2pBaseDeviceActor → ComputationDeviceActor
def queryManagementBehavior: Receive

Definition Classes
BasicActorBehavior
def receive: Receive

Definition Classes
ObservableDeviceActor → BasicActorBehavior → Actor
def removeNeighbor(idn: (SpatialPlatform.this)#UID): Unit

Definition Classes
ObservableDeviceActor → BaseNbrManagementBehavior
def replaceNeighborhood(neighbors: Map[(SpatialPlatform.this)#UID, (Option[ActorRef], Option[String])]): Unit

Definition Classes
P2pNbrManagementBehavior
var rounds: Int

Definition Classes
ComputationDeviceActor
def scheduleNextWorkingCycle(): Unit

Definition Classes
PeriodicBehavior
def scheduleNextWorkingCycle(delay: FiniteDuration, msg: Any = GoOn): Unit

Definition Classes
LifecycleBehavior
implicit final val self: ActorRef

Definition Classes
Actor
val selfId: (SpatialPlatform.this)#UID

Definition Classes
SpatialDeviceActor → HybridDeviceActor → BaseDeviceActor
final def sender(): ActorRef

Definition Classes
Actor
def sensingBehavior: Receive

Definition Classes
SensingBehavior
def sensorManagementBehavior: Receive

Definition Classes
SensorManagementBehavior
val sensorValues: Map[(SpatialPlatform.this)#LSensorName, Any]

Definition Classes
SensingBehavior
val server: ActorRef

Definition Classes
SpatialDeviceActor → HybridDeviceActor
def setActuator(name: (SpatialPlatform.this)#LSensorName, consumer: (Any) ⇒ Unit): Unit

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

Definition Classes
SensorManagementBehavior
def setLocalSensorValue(name: (SpatialPlatform.this)#LSensorName, value: Any): Unit

Definition Classes
SpatialDeviceActor → ObservableDeviceActor → SensingBehavior
def setNbrSensorValue(name: (SpatialPlatform.this)#NSensorName, map: Map[(SpatialPlatform.this)#UID, Any]): Unit

Definition Classes
SensingBehavior
def supervisorStrategy: SupervisorStrategy

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

Definition Classes
AnyRef
var tick: Option[Cancellable]

Definition Classes
DynamicDeviceLifecycleBehavior
def toString(): String

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

Definition Classes
Actor
def updateNeighborhood(neighbors: Set[(SpatialPlatform.this)#UID], clear: Boolean = false): Unit

Definition Classes
ObservableDeviceActor → BaseNbrManagementBehavior
def updateNeighborsState(nexps: Map[(SpatialPlatform.this)#UID, Option[(SpatialPlatform.this)#ComputationExport]], clear: Boolean = false): Unit

Definition Classes
ObservableDeviceActor → BaseNbrManagementBehavior
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( ... )
var workInterval: FiniteDuration

Definition Classes
DynamicDeviceLifecycleBehavior → PeriodicBehavior
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 Docs: object SpatialDeviceActor | package SpatialPlatform

class SpatialDeviceActor extends (SpatialPlatform.this)#HybridDeviceActor

Instance Constructors

new SpatialDeviceActor(selfId: (SpatialPlatform.this)#UID, _aggregateExecutor: Option[(SpatialPlatform.this)#ProgramContract], _execScope: (SpatialPlatform.this)#ExecScope, server: ActorRef)

Type Members

type Receive = PartialFunction[Any, Unit]

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

def actuatorManagementBehavior: Receive

val actuators: Map[(SpatialPlatform.this)#LSensorName, (Any) ⇒ Unit]

def afterJob(): Unit

var aggregateExecutor: Option[(SpatialPlatform.this)#ProgramContract]

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

val classloader: CustomClassLoader

def clone(): AnyRef

def commandManagementBehavior: Receive

def compute(ctx: (SpatialPlatform.this)#ComputationContext): (SpatialPlatform.this)#ComputationExport

implicit val context: ActorContext

def currentStateMessage: Any

def doJob(): Unit

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

var execScope: (SpatialPlatform.this)#ExecScope

def executeActuators(value: Any): Unit

var first: Boolean

final def getClass(): Class[_]

def handleLifecycle(): Unit

def hashCode(): Int

val initialDelay: Option[FiniteDuration]

def inputManagementBehavior: Receive

final def isInstanceOf[T0]: Boolean

var lastExport: Option[(SpatialPlatform.this)#ComputationExport]

def lifecyclePostStop(): Unit

def lifecyclePreStart(): Unit

val localSensors: Map[(SpatialPlatform.this)#LSensorName, () ⇒ Any]

val logger: LoggingAdapter

def mergeNeighborInfo(idn: (SpatialPlatform.this)#UID, info: (SpatialPlatform.this)#NbrInfo): Unit

val mobilityExt: CodeMobilityExtensionImpl

val nbrSensorValues: Map[(SpatialPlatform.this)#NSensorName, Map[(SpatialPlatform.this)#UID, Any]]

var nbrs: Map[(SpatialPlatform.this)#UID, (SpatialPlatform.this)#NbrInfo]

final def ne(arg0: AnyRef): Boolean

def neighbourhoodManagementBehavior: Receive

final def notify(): Unit

final def notifyAll(): Unit

def notifyObservers(msg: Any): Unit

def notifyObservers(): Unit

def observerAdded(ref: ActorRef): Unit

val observers: Set[ActorRef]

def observersManagementBehavior: Receive

def periodicBehaviorPreStart(): Unit

def postRestart(reason: Throwable): Unit

def postStop(): Unit

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

def preStart(): Unit

def propagateExportToNeighbors(export: (SpatialPlatform.this)#ComputationExport): Unit

def propagateMsgToNeighbors(msg: Any): Unit

def queryManagementBehavior: Receive

def receive: Receive

def removeNeighbor(idn: (SpatialPlatform.this)#UID): Unit

def replaceNeighborhood(neighbors: Map[(SpatialPlatform.this)#UID, (Option[ActorRef], Option[String])]): Unit

var rounds: Int

def scheduleNextWorkingCycle(): Unit

def scheduleNextWorkingCycle(delay: FiniteDuration, msg: Any = GoOn): Unit

implicit final val self: ActorRef

val selfId: (SpatialPlatform.this)#UID

final def sender(): ActorRef

def sensingBehavior: Receive

def sensorManagementBehavior: Receive

val sensorValues: Map[(SpatialPlatform.this)#LSensorName, Any]

val server: ActorRef

def setActuator(name: (SpatialPlatform.this)#LSensorName, consumer: (Any) ⇒ Unit): Unit