me.ahoo.cosid.machine.k8s

Class StatefulSetMachineIdDistributor

java.lang.Object

me.ahoo.cosid.machine.AbstractMachineIdDistributor

me.ahoo.cosid.machine.k8s.StatefulSetMachineIdDistributor

All Implemented Interfaces:

MachineIdDistributor

public class StatefulSetMachineIdDistributor
extends AbstractMachineIdDistributor

StatefulSet MachineId Distributor.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	HOSTNAME_KEY
static StatefulSetMachineIdDistributor	INSTANCE

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 and Description
StatefulSetMachineIdDistributor(MachineStateStorage machineStateStorage, ClockBackwardsSynchronizer clockBackwardsSynchronizer)

Method Summary

Modifier and Type	Method and Description
protected MachineState	distributeRemote(java.lang.String namespace, int machineBit, InstanceId instanceId, java.time.Duration safeGuardDuration)
protected void	guardRemote(java.lang.String namespace, InstanceId instanceId, MachineState machineState, java.time.Duration safeGuardDuration)
static int	resolveMachineId()
protected void	revertRemote(java.lang.String namespace, InstanceId instanceId, MachineState machineState)

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

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

getSafeGuardAt, maxMachineId, totalMachineIds

Field Detail

INSTANCE

public static final StatefulSetMachineIdDistributor INSTANCE

HOSTNAME_KEY

public static final java.lang.String HOSTNAME_KEY

See Also:

Constant Field Values

Constructor Detail

StatefulSetMachineIdDistributor

public StatefulSetMachineIdDistributor(MachineStateStorage machineStateStorage,
                                       ClockBackwardsSynchronizer clockBackwardsSynchronizer)

Method Detail

resolveMachineId

public static int resolveMachineId()

distributeRemote

protected MachineState distributeRemote(java.lang.String namespace,
                                        int machineBit,
                                        InstanceId instanceId,
                                        java.time.Duration safeGuardDuration)

Specified by:

distributeRemote in class AbstractMachineIdDistributor

revertRemote

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

Specified by:

revertRemote in class AbstractMachineIdDistributor

guardRemote

protected void guardRemote(java.lang.String namespace,
                           InstanceId instanceId,
                           MachineState machineState,
                           java.time.Duration safeGuardDuration)

Specified by:

guardRemote in class AbstractMachineIdDistributor