Package me.ahoo.cosid.machine.lease

Class LeaseStoreMachineIdDistributor

java.lang.Object

me.ahoo.cosid.machine.AbstractMachineIdDistributor

me.ahoo.cosid.machine.lease.LeaseStoreMachineIdDistributor

All Implemented Interfaces:

MachineIdDistribute, MachineIdDistributor

public class LeaseStoreMachineIdDistributor
extends AbstractMachineIdDistributor

A MachineIdDistributor on top of a MachineLeaseStore, through MachineLeaseManager.

It reuses everything AbstractMachineIdDistributor provides: local state, the clock-backwards watermark, and the guarder and fail-fast lease on top. It keeps the current Lease of every instance it distributed, so that guard and revert are compare-and-set on the version it last wrote.

Since:

3.4.0

Field Summary

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
LeaseStoreMachineIdDistributor(MachineLeaseManager distributeLeaseManager, MachineLeaseManager leaseManager, MachineStateStorage machineStateStorage, ClockBackwardsSynchronizer clockBackwardsSynchronizer)	Create a distributor whose distribution, usually once at startup, runs on its own lease manager, for example on a store with a longer timeout: the first call also pays for connecting.
LeaseStoreMachineIdDistributor(MachineLeaseManager leaseManager, MachineStateStorage machineStateStorage, ClockBackwardsSynchronizer clockBackwardsSynchronizer)
LeaseStoreMachineIdDistributor(MachineLeaseStore store, MachineStateStorage machineStateStorage, ClockBackwardsSynchronizer clockBackwardsSynchronizer)

Method Summary

Modifier and Type	Method	Description
protected MachineState	distributeRemote(String namespace, int machineBit, InstanceId instanceId, Duration safeGuardDuration)
MachineLeaseManager	getDistributeLeaseManager()
MachineLeaseManager	getLeaseManager()
protected void	guardRemote(String namespace, InstanceId instanceId, MachineState machineState, Duration safeGuardDuration)
protected void	revertRemote(String namespace, InstanceId instanceId, MachineState machineState)

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

distribute, guard, refreshLocalState, revert

Methods inherited from class java.lang.Object

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

Constructor Details

LeaseStoreMachineIdDistributor

public LeaseStoreMachineIdDistributor(MachineLeaseStore store,
 MachineStateStorage machineStateStorage,
 ClockBackwardsSynchronizer clockBackwardsSynchronizer)

LeaseStoreMachineIdDistributor

public LeaseStoreMachineIdDistributor(MachineLeaseManager leaseManager,
 MachineStateStorage machineStateStorage,
 ClockBackwardsSynchronizer clockBackwardsSynchronizer)

LeaseStoreMachineIdDistributor

public LeaseStoreMachineIdDistributor(MachineLeaseManager distributeLeaseManager,
 MachineLeaseManager leaseManager,
 MachineStateStorage machineStateStorage,
 ClockBackwardsSynchronizer clockBackwardsSynchronizer)

Create a distributor whose distribution, usually once at startup, runs on its own lease manager, for example on a store with a longer timeout: the first call also pays for connecting. Guard, revert and every re-claim after a lost lease, which run under a lock, use leaseManager.

Method Details

getDistributeLeaseManager

public MachineLeaseManager getDistributeLeaseManager()

getLeaseManager

public MachineLeaseManager getLeaseManager()

distributeRemote

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

Specified by:

distributeRemote in class AbstractMachineIdDistributor

guardRemote

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

Specified by:

guardRemote in class AbstractMachineIdDistributor

revertRemote

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

Specified by:

revertRemote in class AbstractMachineIdDistributor