class Movie::Cluster::RateLimitedRebalance

Overview

Selects deterministic shards from overloaded owners without allowing a membership change to move an unbounded number at once.

Defined in:

movie/cluster/sharding/strategies.cr

Constructors

Instance Method Summary

Instance methods inherited from class Movie::Cluster::RebalancePolicy

configuration_key : String configuration_key, select_shards(snapshot : AllocationSnapshot) : Array(Int32) select_shards

Constructor Detail

def self.new(threshold : Int32 = 1, max_concurrent : Int32 = 4) #

[View source]

Instance Method Detail

def configuration_key : String #

[View source]
def select_shards(snapshot : AllocationSnapshot) : Array(Int32) #

[View source]