DeploymentBasedQueueBalancer

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. DeploymentBasedQueueBalancer

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

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 : QueueBalancerBase, IStreamQueueBalancer

Constructors

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

Methods

• Create(IServiceProvider, string, IDeploymentConfiguration)
• GetMyQueues Retrieves the latest queue distribution for this balancer.
• Initialize(IStreamQueueMapper) Initializes this instance.