DeviceActor

Instance Constructors

new DeviceActor(selfId: ServerPlatform.UID, aggregateExecutor: Option[ServerPlatform.ProgramContract], execScope: ServerPlatform.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[ServerPlatform.LSensorName, (Any) ⇒ Unit]

Definition Classes
ActuatorManagementBehavior
def afterJob(): Unit

Definition Classes
DeviceActor → ObservableDeviceActor → DynamicComputationDeviceActor → ComputationDeviceActor
var aggregateExecutor: Option[ServerPlatform.ProgramContract]

Definition Classes
DeviceActor → 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: ServerPlatform.ComputationContext): ServerPlatform.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: ServerPlatform.ExecScope

Definition Classes
DeviceActor → 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[ServerPlatform.ComputationExport]

Definition Classes
ComputationDeviceActor
def lifecyclePostStop(): Unit

Definition Classes
DynamicDeviceLifecycleBehavior → LifecycleBehavior
def lifecyclePreStart(): Unit

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

Definition Classes
SensorManagementBehavior
val logger: LoggingAdapter

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

Definition Classes
BaseNbrManagementBehavior
val mobilityExt: CodeMobilityExtensionImpl

Definition Classes
MissingCodeManagementBehavior
val nbrSensorValues: Map[ServerPlatform.NSensorName, Map[ServerPlatform.UID, Any]]

Definition Classes
SensingBehavior
var nbrs: Map[ServerPlatform.UID, ServerPlatform.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 notifyObservers(msg: Any): Unit

Definition Classes
ObservableActorBehavior
def notifyObservers(): Unit

Definition Classes
ObservableActorBehavior
def notifySensorValueToServer(name: ServerPlatform.LSensorName, value: Any): Unit
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
DeviceActor → ServerBaseDeviceActor → DynamicComputationDeviceActor → ComputationDeviceActor → Actor
def propagateExportToNeighbors(export: ServerPlatform.ComputationExport): Unit

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

Definition Classes
ServerBaseDeviceActor → ComputationDeviceActor
def queryManagementBehavior: Receive

Definition Classes
QueryableDeviceActorBehavior → BasicActorBehavior
def receive: Receive

Definition Classes
ObservableDeviceActor → BasicActorBehavior → Actor
def removeNeighbor(idn: ServerPlatform.UID): Unit

Definition Classes
ObservableDeviceActor → BaseNbrManagementBehavior
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: ServerPlatform.UID

Definition Classes
DeviceActor → BaseDeviceActor
final def sender(): ActorRef

Definition Classes
Actor
def sensingBehavior: Receive

Definition Classes
SensingBehavior
def sensorManagementBehavior: Receive

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

Definition Classes
SensingBehavior
val server: ActorRef

Definition Classes
DeviceActor → ServerBaseDeviceActor
def setActuator(name: ServerPlatform.LSensorName, consumer: (Any) ⇒ Unit): Unit

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

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

Definition Classes
DeviceActor → ObservableDeviceActor → SensingBehavior
def setNbrSensorValue(name: ServerPlatform.NSensorName, map: Map[ServerPlatform.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[ServerPlatform.UID], clear: Boolean = false): Unit

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

Definition Classes
ObservableDeviceActor → BaseNbrManagementBehavior
def updateSensorValues(): Unit

Definition Classes
DeviceActor → 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 DeviceActor | package PlatformDevices

class DeviceActor extends ServerPlatform.ServerBaseDeviceActor with ServerPlatform.MissingCodeManagementBehavior with ServerPlatform.ObservableDeviceActor

Instance Constructors

new DeviceActor(selfId: ServerPlatform.UID, aggregateExecutor: Option[ServerPlatform.ProgramContract], execScope: ServerPlatform.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[ServerPlatform.LSensorName, (Any) ⇒ Unit]

def afterJob(): Unit

var aggregateExecutor: Option[ServerPlatform.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: ServerPlatform.ComputationContext): ServerPlatform.ComputationExport

implicit val context: ActorContext

def currentStateMessage: Any

def doJob(): Unit

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

var execScope: ServerPlatform.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[ServerPlatform.ComputationExport]

def lifecyclePostStop(): Unit

def lifecyclePreStart(): Unit

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

val logger: LoggingAdapter

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

val mobilityExt: CodeMobilityExtensionImpl

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

var nbrs: Map[ServerPlatform.UID, ServerPlatform.NbrInfo]

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def notifyObservers(msg: Any): Unit

def notifyObservers(): Unit

def notifySensorValueToServer(name: ServerPlatform.LSensorName, value: Any): 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: ServerPlatform.ComputationExport): Unit

def propagateMsgToNeighbors(msg: Any): Unit

def queryManagementBehavior: Receive

def receive: Receive

def removeNeighbor(idn: ServerPlatform.UID): Unit

var rounds: Int

def scheduleNextWorkingCycle(): Unit

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

implicit final val self: ActorRef

val selfId: ServerPlatform.UID

final def sender(): ActorRef

def sensingBehavior: Receive

def sensorManagementBehavior: Receive

val sensorValues: Map[ServerPlatform.LSensorName, Any]

val server: ActorRef

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

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