package simulation
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- class Agenda extends AnyRef
- class ClientCollector extends Collector[Event]
- final case class ClientTick[T](machine: Peer, msg: T) extends Command with Product with Serializable
- class Collector[E] extends AnyRef
- sealed trait Command extends Product
- final case class EmptyClient[E <: Env[E], ClientMessageT](loggerFactory: NamedLoggerFactory) extends Module[E, ClientMessageT] with Product with Serializable
- final case class InternalEvent[T](machine: Peer, to: ModuleName, msg: T) extends Command with Product with Serializable
- final case class InternalTick[T](machine: Peer, from: ModuleName, msg: T) extends Command with Product with Serializable
- final case class LocalSettings(randomSeed: Long, internalEventTimeDistribution: PowerDistribution = LocalSettings.defaultInternalEventTimeDistribution, futureTimeDistribution: PowerDistribution = LocalSettings.defaultFutureTimeDistribution, clockDriftChance: Probability = Probability(0), clockDrift: PowerDistribution = LocalSettings.defaultClockDriftDistribution) extends Product with Serializable
- class LocalSimulator extends AnyRef
- final case class Machine(allReactors: Map[ModuleName, Reactor[_]], networkReactor: ModuleName, nodeCollector: NodeCollector, clientReactor: Reactor[_], clientCollector: ClientCollector, outputModule: FlagCloseable) extends Product with Serializable
- final case class NetworkSettings(randomSeed: Long, oneWayDelay: PowerDistribution = NetworkSettings.defaultRemoteMessageTimeDistribution, packetLoss: Probability = Probability(0), packetReplay: Probability = Probability(0), partitionMode: PartitionMode = PartitionMode.None, partitionSymmetry: PartitionSymmetry = PartitionSymmetry.Symmetric, partitionProbability: Probability = Probability(0), unPartitionProbability: Probability = Probability(0), partitionStability: Duration = Duration.ofNanos(0), unPartitionStability: Duration = Duration.ofNanos(0)) extends Product with Serializable
- class NetworkSimulator extends AnyRef
- class NodeCollector extends Collector[Event]
- sealed trait PartitionMode extends AnyRef
- sealed trait PartitionSymmetry extends AnyRef
- final case class PowerDistribution(low: Duration, mean: Duration) extends Product with Serializable
- final class Probability extends AnyRef
- final case class Quit(reason: String) extends Command with Product with Serializable
- final case class Reactor[InnerMessage](module: Module[SimulationEnv, InnerMessage]) extends Product with Serializable
- final case class ReceiveNetworkMessage[T](machine: Peer, msg: T) extends Command with Product with Serializable
- final case class RunFuture[T](machine: Peer, to: ModuleName, toRun: () => T) extends Command with Product with Serializable
- final case class ScheduledCommand(command: Command, at: Instant) extends Product with Serializable
- class SimulatedClock extends AnyRef
- Annotations
- @SuppressWarnings()
- class Simulation extends AnyRef
- final case class SimulationFuture[T](resolveValue: () => T) extends Product with Serializable
- final case class SimulationSettings(totalSimulationTime: Duration, localSettings: LocalSettings, networkSettings: NetworkSettings) extends Product with Serializable
- final case class SpawnReactor(peer: Peer, name: ModuleName, reactor: Reactor[_]) extends Command with Product with Serializable
- final case class Topology(topology: Map[Peer, Machine]) extends Product with Serializable
Value Members
- object ClientCollector
- object EmptyClient extends Serializable
- object LocalSettings extends Serializable
- object NetworkSettings extends Serializable
- object NodeCollector
- object PartitionMode
- object PartitionSymmetry
- object Probability
- object ScheduledCommand extends Serializable
- object SimulationClient
- object SimulationModuleSystem