services.moleculer.strategy

Class ShardStrategy.Ring

java.lang.Object

services.moleculer.strategy.ShardStrategy.Ring

Enclosing class:

ShardStrategy<T extends Endpoint>

protected static class ShardStrategy.Ring
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected io.datatree.dom.Cache<java.lang.String,Endpoint>	cache Accelerator cache
protected java.util.HashMap<Endpoint,long[]>	limitMap The "hash ring" (https://www.toptal.com/big-data/consistent-hashing)
protected int	ringSize Actual/minimum ring size (or -1, if not set)

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Ring(int nodes, int vnodes, java.lang.Integer ringSize, int cacheSize)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

limitMap

protected java.util.HashMap<Endpoint,long[]> limitMap

The "hash ring" (https://www.toptal.com/big-data/consistent-hashing)

ringSize

protected final int ringSize

Actual/minimum ring size (or -1, if not set)

cache

protected final io.datatree.dom.Cache<java.lang.String,Endpoint> cache

Accelerator cache

Constructor Detail

Ring

protected Ring(int nodes,
               int vnodes,
               java.lang.Integer ringSize,
               int cacheSize)