Package io.fluxcapacitor.common

Class ConsistentHashing

java.lang.Object

io.fluxcapacitor.common.ConsistentHashing

public class ConsistentHashing
extends Object

Constructor Summary

Constructors

Constructor	Description
ConsistentHashing()

Method Summary

Modifier and Type	Method	Description
static int	computeSegment(String routingKey)
static int	computeSegment(String routingKey, int maxSegments)
static int	computeSegment(String routingKey, Function<String,Integer> hashFunction, int maxSegments)
static boolean	fallsInRange(int segment, int[] segmentRange)
static boolean	fallsInRange(String routingKey, int[] segmentRange)
static boolean	fallsInRange(String routingKey, int[] segmentRange, int maxSegments)
static boolean	isEmptyRange(int[] segmentRange)

Methods inherited from class java.lang.Object

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

Constructor Details

ConsistentHashing

public ConsistentHashing()

Method Details

computeSegment

public static int computeSegment(String routingKey)

computeSegment

public static int computeSegment(String routingKey,
 int maxSegments)

computeSegment

public static int computeSegment(String routingKey,
 Function<String,Integer> hashFunction,
 int maxSegments)

fallsInRange

public static boolean fallsInRange(String routingKey,
 int[] segmentRange)

fallsInRange

public static boolean fallsInRange(String routingKey,
 int[] segmentRange,
 int maxSegments)

fallsInRange

public static boolean fallsInRange(int segment,
 int[] segmentRange)

isEmptyRange

public static boolean isEmptyRange(int[] segmentRange)