Package me.ahoo.cosid.spring.redis

Class SpringRedisMachineIdDistributor

java.lang.Object

me.ahoo.cosid.machine.AbstractMachineIdDistributor

me.ahoo.cosid.spring.redis.SpringRedisMachineIdDistributor

All Implemented Interfaces:

MachineIdDistributor

public class SpringRedisMachineIdDistributor
extends AbstractMachineIdDistributor

Spring Redis MachineIdDistributor.

Field Summary

Fields

Modifier and Type	Field	Description
static final org.springframework.data.redis.core.script.RedisScript<List>	MACHINE_ID_DISTRIBUTE
static final org.springframework.core.io.Resource	MACHINE_ID_DISTRIBUTE_SOURCE
static final org.springframework.data.redis.core.script.RedisScript<Long>	MACHINE_ID_GUARD
static final org.springframework.core.io.Resource	MACHINE_ID_GUARD_SOURCE
static final org.springframework.data.redis.core.script.RedisScript<Long>	MACHINE_ID_REVERT
static final org.springframework.core.io.Resource	MACHINE_ID_REVERT_SOURCE
static final org.springframework.data.redis.core.script.RedisScript<Long>	MACHINE_ID_REVERT_STABLE
static final org.springframework.core.io.Resource	MACHINE_ID_REVERT_STABLE_SOURCE

Fields inherited from class me.ahoo.cosid.machine.AbstractMachineIdDistributor

NOT_FOUND_LAST_STAMP

Fields inherited from interface me.ahoo.cosid.machine.MachineIdDistributor

FOREVER_SAFE_GUARD_DURATION

Constructor Summary

Constructors

Constructor	Description
SpringRedisMachineIdDistributor(org.springframework.data.redis.core.StringRedisTemplate redisTemplate, MachineStateStorage machineStateStorage, ClockBackwardsSynchronizer clockBackwardsSynchronizer)

Method Summary

Modifier and Type	Method	Description
protected MachineState	distributeRemote(String namespace, int machineBit, InstanceId instanceId, Duration safeGuardDuration)
protected void	guardRemote(String namespace, InstanceId instanceId, MachineState machineState, Duration safeGuardDuration)
static String	hashTag(String key)	redis hash-tag for redis-cluster.
protected void	revertRemote(String namespace, InstanceId instanceId, MachineState machineState)	when InstanceId.isStable() is true,do not revert machineId.

Methods inherited from class me.ahoo.cosid.machine.AbstractMachineIdDistributor

distribute, guard, revert

Methods inherited from class java.lang.Object

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

Field Details

MACHINE_ID_DISTRIBUTE_SOURCE

public static final org.springframework.core.io.Resource MACHINE_ID_DISTRIBUTE_SOURCE

MACHINE_ID_DISTRIBUTE

public static final org.springframework.data.redis.core.script.RedisScript<List> MACHINE_ID_DISTRIBUTE

MACHINE_ID_REVERT_SOURCE

public static final org.springframework.core.io.Resource MACHINE_ID_REVERT_SOURCE

MACHINE_ID_REVERT

public static final org.springframework.data.redis.core.script.RedisScript<Long> MACHINE_ID_REVERT

MACHINE_ID_REVERT_STABLE_SOURCE

public static final org.springframework.core.io.Resource MACHINE_ID_REVERT_STABLE_SOURCE

MACHINE_ID_REVERT_STABLE

public static final org.springframework.data.redis.core.script.RedisScript<Long> MACHINE_ID_REVERT_STABLE

MACHINE_ID_GUARD_SOURCE

public static final org.springframework.core.io.Resource MACHINE_ID_GUARD_SOURCE

MACHINE_ID_GUARD

public static final org.springframework.data.redis.core.script.RedisScript<Long> MACHINE_ID_GUARD

Constructor Details

SpringRedisMachineIdDistributor

public SpringRedisMachineIdDistributor(org.springframework.data.redis.core.StringRedisTemplate redisTemplate,
 MachineStateStorage machineStateStorage,
 ClockBackwardsSynchronizer clockBackwardsSynchronizer)

Method Details

distributeRemote

protected MachineState distributeRemote(String namespace,
 int machineBit,
 InstanceId instanceId,
 Duration safeGuardDuration)

Specified by:

distributeRemote in class AbstractMachineIdDistributor

revertRemote

protected void revertRemote(String namespace,
 InstanceId instanceId,
 MachineState machineState)

when InstanceId.isStable() is true,do not revert machineId.

Specified by:

revertRemote in class AbstractMachineIdDistributor

guardRemote

protected void guardRemote(String namespace,
 InstanceId instanceId,
 MachineState machineState,
 Duration safeGuardDuration)

Specified by:

guardRemote in class AbstractMachineIdDistributor

hashTag

public static String hashTag(String key)

redis hash-tag for redis-cluster.

Parameters:

key - key

Returns:

hash-tag key