io.druid.server.listener.announcer

Class ListeningAnnouncerConfig

java.lang.Object

io.druid.server.listener.announcer.ListeningAnnouncerConfig

public class ListeningAnnouncerConfig
extends Object

Even though we provide the mechanism to get zk paths here, we do NOT handle announcing and unannouncing in this module. The reason is that it is not appropriate to force a global announce/unannounce since individual listeners may have different lifecycles.

Constructor Summary

Constructors

Constructor and Description
ListeningAnnouncerConfig(ZkPathsConfig zkPathsConfig)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getAnnouncementPath(String listenerName) Build a path for the particular named listener.
String	getListenersPath()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ListeningAnnouncerConfig

@Inject
public ListeningAnnouncerConfig(ZkPathsConfig zkPathsConfig)

Method Detail

getListenersPath

public String getListenersPath()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

getAnnouncementPath

public String getAnnouncementPath(String listenerName)

Build a path for the particular named listener. The first implementation of this is used with zookeeper, but there is nothing restricting its use in a more general pathing (example: http endpoint proxy for raft)

Parameters:

listenerName - The key for the listener.

Returns:

A path appropriate for use in zookeeper to discover the listeners with the particular listener name