Package me.ahoo.cosid.machine

Class DefaultMachineIdGuarder

java.lang.Object

me.ahoo.cosid.machine.DefaultMachineIdGuarder

All Implemented Interfaces:

MachineIdGuarder

public class DefaultMachineIdGuarder
extends 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	Description
static final Duration	DEFAULT_DELAY
static final Duration	DEFAULT_INITIAL_DELAY

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

NONE

Constructor Summary

Constructors

Constructor	Description
DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor, Duration safeGuardDuration)
DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor, ScheduledExecutorService executorService, Duration initialDelay, Duration delay, Duration safeGuardDuration)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_INITIAL_DELAY

public static final Duration DEFAULT_INITIAL_DELAY

DEFAULT_DELAY

public static final Duration DEFAULT_DELAY

Constructor Details

DefaultMachineIdGuarder

public DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor,
 Duration safeGuardDuration)

DefaultMachineIdGuarder

public DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor,
 ScheduledExecutorService executorService,
 Duration initialDelay,
 Duration delay,
 Duration safeGuardDuration)

Method Details

executorService

public static ScheduledExecutorService executorService()

register

public void register(String namespace,
 InstanceId instanceId)

Specified by:

register in interface MachineIdGuarder

unregister

public void unregister(String namespace,
 InstanceId instanceId)

Specified by:

unregister in interface MachineIdGuarder

getRegisteredInstanceIds

public 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