package distributor
Type Members
- type BalancerEndpoints[Req, Rep] = Var[State[Set[EndpointFactory[Req, Rep]]]] with Updatable[State[Set[EndpointFactory[Req, Rep]]]]
An intermediate representation of the endpoints that a load balancer operates over, capable of being updated.
- case class CachedBalancer[Req, Rep](balancer: ServiceFactory[Req, Rep], endpoints: BalancerEndpoints[Req, Rep], size: Int) extends Product with Serializable
Represents cache entries for load balancer instances.
Represents cache entries for load balancer instances. Stores both the load balancer instance and its backing updatable collection. Size refers to the number of elements in
endpoints
. - case class WeightClass[Req, Rep](balancer: ServiceFactory[Req, Rep], endpoints: BalancerEndpoints[Req, Rep], weight: Double, size: Int) extends Product with Serializable
A load balancer and its associated weight.
A load balancer and its associated weight. Size refers to the size of the balancers backing collection. The Distributor operates over these.