Search Results for

    Show / Hide Table of Contents

    Class AdaptiveLoadBalancingRoutingLogic

    Load balancing of messages to cluster nodes based on cluster metric data.

    It uses random selection of routees based on probabilities derived from the remaining capacity of corresponding node.

    Inheritance
    object
    RoutingLogic
    AdaptiveLoadBalancingRoutingLogic
    Implements
    INoSerializationVerificationNeeded
    IClusterMetricsRoutingLogic
    Inherited Members
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Cluster.Metrics
    Assembly: Akka.Cluster.Metrics.dll
    Syntax
    public sealed class AdaptiveLoadBalancingRoutingLogic : RoutingLogic, INoSerializationVerificationNeeded, IClusterMetricsRoutingLogic

    Constructors

    | Edit this page View Source

    AdaptiveLoadBalancingRoutingLogic(ActorSystem, IMetricsSelector)

    Creates instance if AdaptiveLoadBalancingRoutingLogic

    Declaration
    public AdaptiveLoadBalancingRoutingLogic(ActorSystem system, IMetricsSelector metricsSelector = null)
    Parameters
    Type Name Description
    ActorSystem system

    The actor system hosting this router

    IMetricsSelector metricsSelector

    Decides what probability to use for selecting a routee, based on remaining capacity as indicated by the node metrics

    Methods

    | Edit this page View Source

    MetricsChanged(ClusterMetricsChanged)

    Declaration
    public void MetricsChanged(ClusterMetricsChanged @event)
    Parameters
    Type Name Description
    ClusterMetricsChanged event
    | Edit this page View Source

    Select(object, Routee[])

    Picks a Routee to receive the message.

    note

    Normally it picks one of the passed routees, but it is up to the implementation to return whatever Routee to use for sending a specific message.

    Declaration
    public override Routee Select(object message, Routee[] routees)
    Parameters
    Type Name Description
    object message

    The message that is being routed

    Routee[] routees

    A collection of routees to choose from when receiving the message.

    Returns
    Type Description
    Routee

    A Routee that receives the message.

    Overrides
    RoutingLogic.Select(object, Routee[])

    Implements

    INoSerializationVerificationNeeded
    IClusterMetricsRoutingLogic

    Extension Methods

    ObjectExtensions.IsDefaultForType<T>(T)
    ObjectExtensions.AsOption<T>(T)
    Extensions.AsInstanceOf<T>(object)
    In this article
    • githubEdit this page
    • View Source
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET