public class DefaultMachineIdGuarder extends java.lang.Object implements MachineIdGuarder
MachineIdGuarder.None| Modifier and Type | Field and Description |
|---|---|
static java.time.Duration |
DEFAULT_DELAY |
static java.time.Duration |
DEFAULT_INITIAL_DELAY |
NONE| 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) |
| 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) |
public static final java.time.Duration DEFAULT_INITIAL_DELAY
public static final java.time.Duration DEFAULT_DELAY
public DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor, java.time.Duration safeGuardDuration)
public DefaultMachineIdGuarder(MachineIdDistributor machineIdDistributor, java.util.concurrent.ScheduledExecutorService executorService, java.time.Duration initialDelay, java.time.Duration delay, java.time.Duration safeGuardDuration)
public static java.util.concurrent.ScheduledExecutorService executorService()
public void register(java.lang.String namespace,
InstanceId instanceId)
register in interface MachineIdGuarderpublic void unregister(java.lang.String namespace,
InstanceId instanceId)
unregister in interface MachineIdGuarderpublic java.util.concurrent.CopyOnWriteArraySet<NamespacedInstanceId> getRegisteredInstanceIds()
public void start()
start in interface MachineIdGuarderpublic void stop()
stop in interface MachineIdGuarderpublic boolean isRunning()
isRunning in interface MachineIdGuarder