akka

routing

package routing

Visibility
  1. Public
  2. All

Type Members

  1. case class Broadcast (message: Any) extends 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

  3. case class BroadcastRouter (nrOfInstances: Int, routees: Iterable[String], resizer: Option[Resizer], routerDispatcher: String, supervisorStrategy: SupervisorStrategy) extends RouterConfig with BroadcastLike with Product with Serializable

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

  4. trait ConnectionManager extends AnyRef

    Manages connections (ActorRefs) for a router.

  5. class ConsistentHash [T] extends AnyRef

    Consistent Hashing node ring abstraction.

  6. trait CustomRoute extends AnyRef

  7. class CustomRouterConfig extends RouterConfig

    Java API for a custom router factory.

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

  9. case class DefaultResizer (lowerBound: Int, upperBound: Int, pressureThreshold: Int, rampupRate: Double, backoffThreshold: Double, backoffRate: Double, stopDelay: Duration, messagesPerResize: Int) extends Resizer with Product with Serializable

  10. 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.

  11. case class FromConfig (routerDispatcher: String) extends RouterConfig with Product with Serializable

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

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

  13. trait ListenerMessage extends AnyRef

    Attributes
    sealed
  14. trait Listeners extends AnyRef

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

  15. class MurmurHash [T] extends (T) ⇒ Unit

    A class designed to generate well-distributed non-cryptographic hashes.

  16. trait RandomLike extends AnyRef

  17. case class RandomRouter (nrOfInstances: Int, routees: Iterable[String], resizer: Option[Resizer], routerDispatcher: String, supervisorStrategy: SupervisorStrategy) extends RouterConfig with RandomLike with Product with Serializable

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

  18. class RemoteRouteeProvider extends RouteeProvider

    Factory and registry for routees of the router.

  19. case class RemoteRouterConfig (local: RouterConfig, nodes: Iterable[Address]) extends RouterConfig with Product with Serializable

    RouterConfig implementation for remote deployment on defined target nodes.

  20. trait Resizer extends AnyRef

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

  21. trait RoundRobinLike extends AnyRef

  22. case class RoundRobinRouter (nrOfInstances: Int, routees: Iterable[String], resizer: Option[Resizer], routerDispatcher: String, supervisorStrategy: SupervisorStrategy) extends RouterConfig with RoundRobinLike with Product with Serializable

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

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

    Definition Classes
    package
  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. case class RouterRoutees (routees: Iterable[ActorRef]) extends Product with Serializable

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

  28. trait ScatterGatherFirstCompletedLike extends AnyRef

  29. case class ScatterGatherFirstCompletedRouter (nrOfInstances: Int, routees: Iterable[String], within: Duration, resizer: Option[Resizer], routerDispatcher: String, supervisorStrategy: SupervisorStrategy) extends RouterConfig with ScatterGatherFirstCompletedLike with Product with Serializable

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

  30. trait SmallestMailboxLike extends AnyRef

  31. case class SmallestMailboxRouter (nrOfInstances: Int, routees: Iterable[String], resizer: Option[Resizer], routerDispatcher: String, supervisorStrategy: SupervisorStrategy) extends RouterConfig with SmallestMailboxLike with Product with Serializable

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

  32. trait VersionedIterable [A] extends AnyRef

    An Iterable that also contains a version.

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

Value Members

  1. object BroadcastRouter extends Serializable

  2. object CurrentRoutees extends Product with Serializable

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

  3. object DefaultResizer extends Product with Serializable

  4. object FromConfig extends RouterConfig with Product with Serializable

    Router configuration which has no default, i.

  5. object MurmurHash extends AnyRef

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

  6. object NoRouter extends RouterConfig with Product with Serializable

    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.

  7. object RandomRouter extends Serializable

  8. object RoundRobinRouter extends Serializable

  9. object ScatterGatherFirstCompletedRouter extends Serializable

  10. object SmallestMailboxRouter extends Serializable