me.ahoo.cosid.machine

Interface MachineIdDistributor

All Known Implementing Classes:

AbstractMachineIdDistributor, ManualMachineIdDistributor, StatefulSetMachineIdDistributor

@ThreadSafe
public interface MachineIdDistributor

MachineId Distributor.

Field Summary

Fields

Modifier and Type	Field and Description
static java.time.Duration	FOREVER_SAFE_GUARD_DURATION

Method Summary

Modifier and Type	Method and Description
MachineState	distribute(java.lang.String namespace, int machineBit, InstanceId instanceId, java.time.Duration safeGuardDuration) distribute machine id.
static long	getSafeGuardAt(java.time.Duration safeGuardDuration, boolean stable)
void	guard(java.lang.String namespace, InstanceId instanceId, java.time.Duration safeGuardDuration) Guard the machine id by heartbeat.
static int	maxMachineId(int machineBit)
void	revert(java.lang.String namespace, InstanceId instanceId) revert machine id.
static int	totalMachineIds(int machineBit)

Field Detail

FOREVER_SAFE_GUARD_DURATION

static final java.time.Duration FOREVER_SAFE_GUARD_DURATION

Method Detail

maxMachineId

static int maxMachineId(int machineBit)

totalMachineIds

static int totalMachineIds(int machineBit)

getSafeGuardAt

static long getSafeGuardAt(java.time.Duration safeGuardDuration,
                           boolean stable)

distribute

MachineState distribute(java.lang.String namespace,
                        int machineBit,
                        InstanceId instanceId,
                        java.time.Duration safeGuardDuration)
                 throws MachineIdOverflowException

distribute machine id.

Parameters:

namespace - namespace

machineBit - machineBit

instanceId - instanceId

safeGuardDuration - safe Guard Duration

Returns:

machine state

Throws:

MachineIdOverflowException - This exception is thrown when the machine number allocation exceeds the threshold

revert

void revert(java.lang.String namespace,
            InstanceId instanceId)
     throws NotFoundMachineStateException

revert machine id.

Parameters:

namespace - namespace

instanceId - instanceId

Throws:

NotFoundMachineStateException

guard

void guard(java.lang.String namespace,
           InstanceId instanceId,
           java.time.Duration safeGuardDuration)
    throws NotFoundMachineStateException,
           MachineIdLostException

Guard the machine id by heartbeat.

Parameters:

namespace - namespace

instanceId - instanceId

safeGuardDuration - safe Guard Duration

Throws:

NotFoundMachineStateException

MachineIdLostException