P2pBaseDeviceActor

Type Members

type Receive = PartialFunction[Any, Unit]

Definition Classes
Actor

Abstract Value Members

abstract val aggregateExecutor: Option[(PlatformBehaviors.this)#ProgramContract]

Definition Classes
ComputationDeviceActor
abstract val execScope: (PlatformBehaviors.this)#ExecScope

Definition Classes
DynamicDeviceLifecycleBehavior
abstract val selfId: (PlatformBehaviors.this)#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[(PlatformBehaviors.this)#LSensorName, (Any) ⇒ Unit]

Definition Classes
ActuatorManagementBehavior
def afterJob(): Unit

Definition Classes
DynamicComputationDeviceActor → 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
def clone(): AnyRef

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

Definition Classes
BasicActorBehavior
def compute(ctx: (PlatformBehaviors.this)#ComputationContext): (PlatformBehaviors.this)#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
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
P2pNbrManagementBehavior → BasicActorBehavior
final def isInstanceOf[T0]: Boolean

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

Definition Classes
ComputationDeviceActor
def lifecyclePostStop(): Unit

Definition Classes
DynamicDeviceLifecycleBehavior → LifecycleBehavior
def lifecyclePreStart(): Unit

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

Definition Classes
SensorManagementBehavior
val logger: LoggingAdapter

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

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

Definition Classes
SensingBehavior
var nbrs: Map[(PlatformBehaviors.this)#UID, (PlatformBehaviors.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 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
DynamicComputationDeviceActor → ComputationDeviceActor → Actor
def propagateExportToNeighbors(export: (PlatformBehaviors.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
BasicActorBehavior
def removeNeighbor(idn: (PlatformBehaviors.this)#UID): Unit

Definition Classes
BaseNbrManagementBehavior
def replaceNeighborhood(neighbors: Map[(PlatformBehaviors.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
final def sender(): ActorRef

Definition Classes
Actor
def sensingBehavior: Receive

Definition Classes
SensingBehavior
def sensorManagementBehavior: Receive

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

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

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

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

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

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

Definition Classes
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 Doc: package PlatformBehaviors

trait P2pBaseDeviceActor extends (PlatformBehaviors.this)#DynamicComputationDeviceActor with (PlatformBehaviors.this)#P2pNbrManagementBehavior

Type Members

type Receive = PartialFunction[Any, Unit]

Abstract Value Members

abstract val aggregateExecutor: Option[(PlatformBehaviors.this)#ProgramContract]

abstract val execScope: (PlatformBehaviors.this)#ExecScope

abstract val selfId: (PlatformBehaviors.this)#UID

Concrete Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

def actuatorManagementBehavior: Receive

val actuators: Map[(PlatformBehaviors.this)#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: (PlatformBehaviors.this)#ComputationContext): (PlatformBehaviors.this)#ComputationExport

implicit val context: ActorContext

def doJob(): Unit

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

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[(PlatformBehaviors.this)#ComputationExport]

def lifecyclePostStop(): Unit

def lifecyclePreStart(): Unit

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

val logger: LoggingAdapter

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

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

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

final def ne(arg0: AnyRef): Boolean

def neighbourhoodManagementBehavior: Receive

final def notify(): Unit

final def notifyAll(): Unit

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: (PlatformBehaviors.this)#ComputationExport): Unit

def propagateMsgToNeighbors(msg: Any): Unit

def queryManagementBehavior: Receive

def receive: Receive

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

def replaceNeighborhood(neighbors: Map[(PlatformBehaviors.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

final def sender(): ActorRef

def sensingBehavior: Receive

def sensorManagementBehavior: Receive

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

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

def setLocalSensor(name: (PlatformBehaviors.this)#LSensorName, provider: () ⇒ Any): Unit

def setLocalSensorValue(name: (PlatformBehaviors.this)#LSensorName, value: Any): Unit

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

def supervisorStrategy: SupervisorStrategy

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

var tick: Option[Cancellable]

def toString(): String

def unhandled(message: Any): Unit

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

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