Class LeaderUtils

java.lang.Object

org.springframework.cloud.kubernetes.commons.leader.LeaderUtils

public final class LeaderUtils
extends Object

Author:

wind57

Field Summary

Fields

Modifier and Type	Field	Description
static final String	COORDINATION_GROUP	Coordination group for leader election.
static final String	COORDINATION_VERSION	Coordination version for leader election.
static final String	LEADER_ELECTION_ENABLED_PROPERTY	Property that controls whether leader election is enabled.
static final String	LEADER_ELECTION_PROPERTY_PREFIX	Prefix for all properties related to leader election.
static final String	LEASE	Lease constant.

Method Summary

Modifier and Type	Method	Description
static void	guarded(ReentrantLock lock, Runnable runnable)
static String	hostName()
static Optional<String>	podNamespace()	Ideally, should always be present.

Methods inherited from class Object

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

Field Details

COORDINATION_GROUP

public static final String COORDINATION_GROUP

Coordination group for leader election.

See Also:

• Constant Field Values

COORDINATION_VERSION

public static final String COORDINATION_VERSION

Coordination version for leader election.

See Also:

• Constant Field Values

LEASE

public static final String LEASE

Lease constant.

See Also:

• Constant Field Values

LEADER_ELECTION_PROPERTY_PREFIX

public static final String LEADER_ELECTION_PROPERTY_PREFIX

Prefix for all properties related to leader election.

See Also:

• Constant Field Values

LEADER_ELECTION_ENABLED_PROPERTY

public static final String LEADER_ELECTION_ENABLED_PROPERTY

Property that controls whether leader election is enabled.

See Also:

• Constant Field Values

Method Details

podNamespace

public static Optional<String> podNamespace()

Ideally, should always be present. If not, downward API must enable this one.

hostName

public static String hostName()
                       throws UnknownHostException

Throws:

UnknownHostException

guarded

public static void guarded(ReentrantLock lock,
 Runnable runnable)