Edit

Share via


DeploymentBasedQueueBalancer Class

Definition

DeploymentBasedQueueBalancer is a stream queue balancer that uses deployment information to help balance queue distribution. DeploymentBasedQueueBalancer uses the deployment configuration to determine how many silos to expect and uses a silo status oracle to determine which of the silos are available. With this information it tries to balance the queues using a best fit resource balancing algorithm.

public class DeploymentBasedQueueBalancer : Orleans.Streams.QueueBalancerBase, Orleans.Runtime.ISiloStatusListener, Orleans.Streams.IStreamQueueBalancer
public class DeploymentBasedQueueBalancer : Orleans.Streams.QueueBalancerBase, Orleans.Streams.IStreamQueueBalancer
public class DeploymentBasedQueueBalancer : Orleans.Streams.QueueBalancerBase
type DeploymentBasedQueueBalancer = class
    inherit QueueBalancerBase
    interface ISiloStatusListener
    interface IStreamQueueBalancer
type DeploymentBasedQueueBalancer = class
    inherit QueueBalancerBase
    interface IStreamQueueBalancer
Public Class DeploymentBasedQueueBalancer
Inherits QueueBalancerBase
Implements ISiloStatusListener, IStreamQueueBalancer
Public Class DeploymentBasedQueueBalancer
Inherits QueueBalancerBase
Implements IStreamQueueBalancer
Public Class DeploymentBasedQueueBalancer
Inherits QueueBalancerBase
Inheritance
DeploymentBasedQueueBalancer
Implements

Constructors

DeploymentBasedQueueBalancer(ISiloStatusOracle, IDeploymentConfiguration, DeploymentBasedQueueBalancerOptions, IServiceProvider, ILogger<DeploymentBasedQueueBalancer>)
DeploymentBasedQueueBalancer(ISiloStatusOracle, IDeploymentConfiguration, DeploymentBasedQueueBalancerOptions)

Fields

queueBalanceListeners

A collection for its IStreamQueueBalancerListener

(Inherited from QueueBalancerBase)

Properties

Cancellation (Inherited from QueueBalancerBase)
Logger (Inherited from QueueBalancerBase)
SiloAddress (Inherited from QueueBalancerBase)

Methods

Create(IServiceProvider, String, IDeploymentConfiguration)
GetMyQueues()
Initialize(IStreamQueueMapper)
NotifyListeners() (Inherited from QueueBalancerBase)
OnClusterMembershipChange(HashSet<SiloAddress>)
OnClusterMembershipChange(HashSet<SiloAddress>) (Inherited from QueueBalancerBase)
Shutdown() (Inherited from QueueBalancerBase)
SiloStatusChangeNotification(SiloAddress, SiloStatus)

Called when the status of a silo in the cluster changes.

  • Notify listeners
SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Subscribes to receive queue distribution change notifications

(Inherited from QueueBalancerBase)
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener)

Unsubscribes from receiving queue distribution notifications.

(Inherited from QueueBalancerBase)

Applies to