me.ahoo.cosid.machine

Class DefaultMachineIdGuarder

java.lang.Object

me.ahoo.cosid.machine.DefaultMachineIdGuarder

All Implemented Interfaces:

MachineIdGuarder

public class DefaultMachineIdGuarder
extends java.lang.Object
implements MachineIdGuarder

Default MachineId Guarder implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface me.ahoo.cosid.machine.MachineIdGuarder

MachineIdGuarder.None

Field Summary

Fields

Modifier and Type	Field and Description
static java.time.Duration	DEFAULT_DELAY
static java.time.Duration	DEFAULT_INITIAL_DELAY

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

NONE

Constructor Summary

Constructors

Constructor and Description
DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor, java.time.Duration safeGuardDuration)
DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor, java.util.concurrent.ScheduledExecutorService executorService, java.time.Duration initialDelay, java.time.Duration delay, java.time.Duration safeGuardDuration)

Method Summary

Modifier and Type	Method and Description
static java.util.concurrent.ScheduledExecutorService	executorService()
java.util.concurrent.CopyOnWriteArraySet<NamespacedInstanceId>	getRegisteredInstanceIds()
boolean	isRunning()
void	register(java.lang.String namespace, InstanceId instanceId)
void	start()
void	stop()
void	unregister(java.lang.String namespace, InstanceId instanceId)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_INITIAL_DELAY

public static final java.time.Duration DEFAULT_INITIAL_DELAY

DEFAULT_DELAY

public static final java.time.Duration DEFAULT_DELAY

Constructor Detail

DefaultMachineIdGuarder

public DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor,
                               java.time.Duration safeGuardDuration)

DefaultMachineIdGuarder

public DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor,
                               java.util.concurrent.ScheduledExecutorService executorService,
                               java.time.Duration initialDelay,
                               java.time.Duration delay,
                               java.time.Duration safeGuardDuration)

Method Detail

executorService

public static java.util.concurrent.ScheduledExecutorService executorService()

register

public void register(java.lang.String namespace,
                     InstanceId instanceId)

Specified by:

register in interface MachineIdGuarder

unregister

public void unregister(java.lang.String namespace,
                       InstanceId instanceId)

Specified by:

unregister in interface MachineIdGuarder

getRegisteredInstanceIds

public java.util.concurrent.CopyOnWriteArraySet<NamespacedInstanceId> getRegisteredInstanceIds()

start

public void start()

Specified by:

start in interface MachineIdGuarder

stop

public void stop()

Specified by:

stop in interface MachineIdGuarder

isRunning

public boolean isRunning()

Specified by:

isRunning in interface MachineIdGuarder