DeploymentBasedQueueBalancer Class
Definition
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
- Implements
Constructors
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.
|
SubscribeToQueueDistributionChangeEvents(IStreamQueueBalanceListener) |
Subscribes to receive queue distribution change notifications (Inherited from QueueBalancerBase) |
UnSubscribeFromQueueDistributionChangeEvents(IStreamQueueBalanceListener) |
Unsubscribes from receiving queue distribution notifications. (Inherited from QueueBalancerBase) |