DeploymentBasedQueueBalancer Class

Definition

Namespace:: Orleans.Streams

Assembly:: Orleans.Streaming.dll

Assembly:: Orleans.Runtime.dll

Package:: Microsoft.Orleans.Streaming v10.0.0

Package:: Microsoft.Orleans.OrleansRuntime v2.4.5

Package:: Microsoft.Orleans.OrleansRuntime v3.6.5

Package:: Microsoft.Orleans.Streaming v7.2.5

Package:: Microsoft.Orleans.Streaming v8.0.0

Package:: Microsoft.Orleans.Streaming v8.1.0

Package:: Microsoft.Orleans.Streaming v8.2.0

Package:: Microsoft.Orleans.Streaming v9.0.0

Package:: Microsoft.Orleans.Streaming v9.1.2

Source:: DeploymentBasedQueueBalancer.cs

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

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

public class DeploymentBasedQueueBalancer : Orleans.Streams.QueueBalancerBase, Orleans.Runtime.ISiloStatusListener, Orleans.Streams.IStreamQueueBalancer

public class DeploymentBasedQueueBalancer : Orleans.Streams.QueueBalancerBase, Orleans.Streams.IStreamQueueBalancer

type DeploymentBasedQueueBalancer = class
    inherit QueueBalancerBase
    interface IStreamQueueBalancer

type DeploymentBasedQueueBalancer = class
    inherit QueueBalancerBase
    interface ISiloStatusListener
    interface IStreamQueueBalancer

Public Class DeploymentBasedQueueBalancer
Inherits QueueBalancerBase

Public Class DeploymentBasedQueueBalancer
Inherits QueueBalancerBase
Implements ISiloStatusListener, IStreamQueueBalancer

Public Class DeploymentBasedQueueBalancer
Inherits QueueBalancerBase
Implements IStreamQueueBalancer

Inheritance: Object

QueueBalancerBase
DeploymentBasedQueueBalancer

Implements: IStreamQueueBalancer ISiloStatusListener

Constructors

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

Fields

Name	Description
queueBalanceListeners	A collection for its IStreamQueueBalancerListener (Inherited from QueueBalancerBase)

Properties

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

Methods

Name	Description
Create(IServiceProvider, String, IDeploymentConfiguration)
GetMyQueues()
Initialize(IStreamQueueMapper)
NotifyListeners()	(Inherited from QueueBalancerBase)
OnClusterMembershipChange(HashSet<SiloAddress>)
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