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. abstract class CurrentRoutees extends AnyRef

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

  7. trait CustomRoute extends AnyRef

  8. abstract class CustomRouterConfig extends RouterConfig

    Java API for a custom router factory.

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

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

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

  12. class FromConfig extends RouterConfig with Product with Serializable with Equals

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

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

  14. sealed trait ListenerMessage extends AnyRef

  15. trait Listeners extends AnyRef

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

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

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

  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

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

  20. class RemoteRouteeProvider extends RouteeProvider

    Factory and registry for routees of the router.

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

    RouterConfig implementation for remote deployment on defined target nodes.

  22. trait Resizer extends AnyRef

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

  23. trait RoundRobinLike extends AnyRef

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

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

    Definition Classes
    package
  26. class RouteeProvider extends AnyRef

    Factory and registry for routees of the router.

  27. trait Router extends Actor

    Base trait for Router actors.

  28. 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).

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

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

  30. trait ScatterGatherFirstCompletedLike extends AnyRef

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

  32. trait SmallestMailboxLike extends AnyRef

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

  34. trait VersionedIterable[A] extends AnyRef

    An Iterable that also contains a version.

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

Value Members

  1. object BroadcastRouter extends Serializable

  2. object CurrentRoutees extends CurrentRoutees with Product with Serializable

  3. object DefaultResizer extends Product with Serializable

  4. object FromConfig extends FromConfig 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 NoRouter with Product with Serializable

  7. object RandomRouter extends Serializable

  8. object RoundRobinRouter extends Serializable

  9. object ScatterGatherFirstCompletedRouter extends Serializable

  10. object SmallestMailboxRouter extends Serializable