portals-core
API
Generated with
portals-core/portals/portals.runtime/portals.runtime.parallel/ParallelRuntimePartition/Events

Events

portals.runtime.parallel.ParallelRuntimePartition$.Events$
object Events

Event types for the parallel runtime partition manager.

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type
Events.type

Members list

Type members

Classlikes

sealed trait Command extends Message

Pekko Actor commands for this behavior.

Pekko Actor commands for this behavior.

Attributes

Supertypes
trait Message
trait Serializable
class Object
trait Matchable
class Any
Known subtypes
class Launch
class Shuffle
class Start
object Step.type
class Stop
case class Launch(application: Application, replyTo: ActorRef[Unit]) extends Command

Launch the application.

Launch the application.

Attributes

Supertypes
trait Product
trait Equals
trait Command
trait Message
trait Serializable
class Object
trait Matchable
class Any
Show all
sealed trait Message extends Serializable

Internal API. Message type for the parallel runtime partition manager.

Internal API. Message type for the parallel runtime partition manager.

Attributes

Supertypes
trait Serializable
class Object
trait Matchable
class Any
Known subtypes
trait Command
class Launch
class Shuffle
class Start
object Step.type
class Stop
Show all
case class Shuffle(partition: Int, batch: EventBatch) extends Command

Shuffled batch of events for partition.

Shuffled batch of events for partition.

Attributes

Supertypes
trait Product
trait Equals
trait Command
trait Message
trait Serializable
class Object
trait Matchable
class Any
Show all
case class Start(replyTo: ActorRef[Unit]) extends Command

Start processing.

Start processing.

Attributes

Supertypes
trait Product
trait Equals
trait Command
trait Message
trait Serializable
class Object
trait Matchable
class Any
Show all
case object Step extends Command

Process the next step.

Process the next step.

Attributes

Supertypes
trait Singleton
trait Product
trait Mirror
trait Product
trait Equals
trait Command
trait Message
trait Serializable
class Object
trait Matchable
class Any
Show all
Self type
Step.type
case class Stop(replyTo: ActorRef[Unit]) extends Command

Stop processing, temporarily.

Stop processing, temporarily.

Attributes

Supertypes
trait Product
trait Equals
trait Command
trait Message
trait Serializable
class Object
trait Matchable
class Any
Show all
Generated with