Package io.deephaven.enterprise.etcdclient.presence

Class PresenceKvConstants

java.lang.Object

io.deephaven.enterprise.etcdclient.presence.PresenceKvConstants

public class PresenceKvConstants
extends Object

Constants using in setting up presence KVs on etcd.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	PRESENCE_KV_DELETE_TIMEOUT_MILLIS
static final long	PRESENCE_KV_PUT_TIMEOUT_MILLIS

Constructor Summary

Constructors

Constructor	Description
PresenceKvConstants()

Method Summary

Modifier and Type	Method	Description
static io.deephaven.shadow.jetcd.io.etcd.jetcd.ByteSequence	controllerWorkerPresenceKey(String workerProcessInfoId)	Determine the key for the presence KV for a particular controller and worker
static io.deephaven.shadow.jetcd.io.etcd.jetcd.ByteSequence	controllerWorkerPresencePrefixKey()	Return the key prefix for the presence KV for all dispatchers.
static io.deephaven.shadow.jetcd.io.etcd.jetcd.ByteSequence	dispatcherWorkerPresenceKey(String dispatcherName, String processInfoId)	Determine the key for the presence KV for a particular dispatcher and worker.
static io.deephaven.shadow.jetcd.io.etcd.jetcd.ByteSequence	dispatcherWorkerPresencePrefixKey()	Return the key prefix for the presence KV for all dispatchers.

Methods inherited from class java.lang.Object

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

Field Details

PRESENCE_KV_PUT_TIMEOUT_MILLIS

public static final long PRESENCE_KV_PUT_TIMEOUT_MILLIS

See Also:

• Constant Field Values

PRESENCE_KV_DELETE_TIMEOUT_MILLIS

public static final long PRESENCE_KV_DELETE_TIMEOUT_MILLIS

See Also:

• Constant Field Values

Constructor Details

PresenceKvConstants

public PresenceKvConstants()

Method Details

controllerWorkerPresenceKey

public static io.deephaven.shadow.jetcd.io.etcd.jetcd.ByteSequence controllerWorkerPresenceKey(String workerProcessInfoId)

Determine the key for the presence KV for a particular controller and worker

Parameters:

workerProcessInfoId - the unique process info ID of the worker

Returns:

the key to set or observe for ensuring the controller has presence (is handling) the given worker

controllerWorkerPresencePrefixKey

public static io.deephaven.shadow.jetcd.io.etcd.jetcd.ByteSequence controllerWorkerPresencePrefixKey()

Return the key prefix for the presence KV for all dispatchers.

Returns:

the key to set or observe for ensuring the dispatcher has presence (is handling) the given worker

dispatcherWorkerPresenceKey

public static io.deephaven.shadow.jetcd.io.etcd.jetcd.ByteSequence dispatcherWorkerPresenceKey(String dispatcherName,
 String processInfoId)

Determine the key for the presence KV for a particular dispatcher and worker.

Parameters:

dispatcherName - the unique name of the dispatcher

processInfoId - the unique process info ID of the worker

Returns:

the key to set or observe for ensuring the dispatcher has presence (is handling) the given worker

dispatcherWorkerPresencePrefixKey

public static io.deephaven.shadow.jetcd.io.etcd.jetcd.ByteSequence dispatcherWorkerPresencePrefixKey()

Return the key prefix for the presence KV for all dispatchers.

Returns:

the key to set or observe for ensuring the dispatcher has presence (is handling) the given worker