akka

routing

package routing

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. routing
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. case class Broadcast(message: Any) extends RouterEnvelope with Product with Serializable

    Used to broadcast a message to all connections in a router; only the contained message will be forwarded, i.

  2. trait BroadcastLike extends AnyRef

    The core pieces of the routing logic is located in this trait to be able to extend.

  3. case class BroadcastRouter(nrOfInstances: Int = 0, routees: Iterable[String] = immutable.this.Nil, resizer: Option[Resizer] = scala.None, routerDispatcher: String = ..., supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy) extends RouterConfig with BroadcastLike with OverrideUnsetConfig[BroadcastRouter] with Product with Serializable

    A Router that uses broadcasts a message to all its connections.

  4. class ConsistentHash[T] extends AnyRef

    Consistent Hashing node ring implementation.

  5. trait ConsistentHashingLike extends AnyRef

    The core pieces of the routing logic is located in this trait to be able to extend.

  6. case class ConsistentHashingRouter(nrOfInstances: Int = 0, routees: Iterable[String] = immutable.this.Nil, resizer: Option[Resizer] = scala.None, routerDispatcher: String = ..., supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy, virtualNodesFactor: Int = 0, hashMapping: ConsistentHashMapping = ...) extends RouterConfig with ConsistentHashingLike with OverrideUnsetConfig[ConsistentHashingRouter] with Product with Serializable

    A Router that uses consistent hashing to select a connection based on the sent message.

  7. abstract class CurrentRoutees extends AnyRef

    Sending this message to a router will make it send back its currently used routees.

  8. trait CustomRoute extends AnyRef

    Java API helper for creating a single-destination routing.

  9. abstract class CustomRouterConfig extends RouterConfig

    Java API for a custom router factory.

  10. case class Deafen(listener: ActorRef) extends ListenerMessage with Product with Serializable

  11. case class DefaultResizer(lowerBound: Int = 1, upperBound: Int = 10, pressureThreshold: Int = 1, rampupRate: Double = 0.2, backoffThreshold: Double = 0.3, backoffRate: Double = 0.1, stopDelay: FiniteDuration = ..., messagesPerResize: Int = 10) extends Resizer with Product with Serializable

    Annotations
    @SerialVersionUID( 1L )
  12. case class Destination(sender: ActorRef, recipient: ActorRef) extends Product with Serializable

    For every message sent to a router, its route determines a set of destinations, where for each recipient a different sender may be specified; typically the sender should match the sender of the original request, but e.

  13. class FromConfig extends RouterConfig with Serializable

    Java API: Router configuration which has no default, i.

  14. case class Listen(listener: ActorRef) extends ListenerMessage with Product with Serializable

  15. sealed trait ListenerMessage extends AnyRef

  16. trait Listeners extends AnyRef

    Listeners is a generic trait to implement listening capability on an Actor.

  17. abstract class NoRouter extends RouterConfig

    Routing configuration that indicates no routing; this is also the default value which hence overrides the merge strategy in order to accept values from lower-precedence sources.

  18. trait RandomLike extends AnyRef

    The core pieces of the routing logic is located in this trait to be able to extend.

  19. case class RandomRouter(nrOfInstances: Int = 0, routees: Iterable[String] = immutable.this.Nil, resizer: Option[Resizer] = scala.None, routerDispatcher: String = ..., supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy) extends RouterConfig with RandomLike with OverrideUnsetConfig[RandomRouter] with Product with Serializable

    A Router that randomly selects one of the target connections to send a message to.

  20. trait Resizer extends AnyRef

    Routers with dynamically resizable number of routees is implemented by providing a Resizer implementation in akka.routing.RouterConfig.

  21. trait RoundRobinLike extends AnyRef

    The core pieces of the routing logic is located in this trait to be able to extend.

  22. case class RoundRobinRouter(nrOfInstances: Int = 0, routees: Iterable[String] = immutable.this.Nil, resizer: Option[Resizer] = scala.None, routerDispatcher: String = ..., supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy) extends RouterConfig with RoundRobinLike with OverrideUnsetConfig[RoundRobinRouter] with Product with Serializable

    A Router that uses round-robin to select a connection.

  23. type Route = PartialFunction[(ActorRef, Any), Iterable[Destination]]

    Routing logic, partial function from (sender, message) to a set of destinations.

  24. class RouteeProvider extends AnyRef

    Factory and registry for routees of the router.

  25. trait Router extends Actor

    Base trait for Router actors.

  26. trait RouterConfig extends AnyRef

    This trait represents a router factory: it produces the actual router actor and creates the routing table (a function which determines the recipients for each message which is to be dispatched).

  27. trait RouterEnvelope extends AnyRef

    Only the contained message will be forwarded to the destination, i.

  28. case class RouterRoutees(routees: Iterable[ActorRef]) extends Product with Serializable

    Message used to carry information about what routees the router is currently using.

  29. trait ScatterGatherFirstCompletedLike extends AnyRef

    The core pieces of the routing logic is located in this trait to be able to extend.

  30. case class ScatterGatherFirstCompletedRouter(nrOfInstances: Int = 0, routees: Iterable[String] = immutable.this.Nil, within: FiniteDuration, resizer: Option[Resizer] = scala.None, routerDispatcher: String = ..., supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy) extends RouterConfig with ScatterGatherFirstCompletedLike with OverrideUnsetConfig[ScatterGatherFirstCompletedRouter] with Product with Serializable

    Simple router that broadcasts the message to all routees, and replies with the first response.

  31. trait SmallestMailboxLike extends AnyRef

    The core pieces of the routing logic is located in this trait to be able to extend.

  32. case class SmallestMailboxRouter(nrOfInstances: Int = 0, routees: Iterable[String] = immutable.this.Nil, resizer: Option[Resizer] = scala.None, routerDispatcher: String = ..., supervisorStrategy: SupervisorStrategy = Router.defaultSupervisorStrategy) extends RouterConfig with SmallestMailboxLike with OverrideUnsetConfig[SmallestMailboxRouter] with Product with Serializable

    A Router that tries to send to the non-suspended routee with fewest messages in mailbox.

  33. case class WithListeners(f: (ActorRef) ⇒ Unit) extends ListenerMessage with Product with Serializable

Value Members

  1. object BroadcastRouter extends Serializable

  2. object ConsistentHash

  3. object ConsistentHashingRouter extends Serializable

  4. object CurrentRoutees extends CurrentRoutees with Product with Serializable

    Annotations
    @SerialVersionUID( 1L )
  5. object DefaultResizer extends Product with Serializable

  6. object FromConfig extends FromConfig with Product with Serializable

    Router configuration which has no default, i.

  7. object MurmurHash

    An object designed to generate well-distributed non-cryptographic hashes.

  8. object NoRouter extends NoRouter with Product with Serializable

  9. object RandomRouter extends Serializable

  10. object RoundRobinRouter extends Serializable

  11. object ScatterGatherFirstCompletedRouter extends Serializable

  12. object SmallestMailboxRouter extends Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped