class Movie::Cluster::ShardingSettings

Defined in:

movie/cluster/sharding/model.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(shard_count : Int32 = 256, partitioner : EntityPartitioner = StableHashPartitioner.new, allocation : ShardAllocationStrategy = LeastLoadedAllocation.new, rebalance : RebalancePolicy = RateLimitedRebalance.new, lease_duration : Time::Span = 10.seconds, lease_renew_interval : Time::Span = 3.seconds, idle_timeout : Time::Span | Nil = nil) #

[View source]

Instance Method Detail

def allocation : ShardAllocationStrategy #

[View source]
def compatible?(other : self) : Bool #

[View source]
def configuration_key : String #

[View source]
def idle_timeout : Time::Span | Nil #

[View source]
def lease_duration : Time::Span #

[View source]
def lease_renew_interval : Time::Span #

[View source]
def partitioner : EntityPartitioner #

[View source]
def rebalance : RebalancePolicy #

[View source]
def shard_count : Int32 #

[View source]