DeploymentBasedQueueBalancer Class

Reference

Definition

Namespace:: Orleans.Streams

Assembly:: Orleans.Runtime.dll

Assembly:: Orleans.Streaming.dll

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

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, 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: Object

QueueBalancerBase
DeploymentBasedQueueBalancer

Implements: ISiloStatusListener IStreamQueueBalancer

Constructors

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

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