Package com.linkedin.venice.d2

Class D2ServerManager

java.lang.Object

com.linkedin.venice.d2.D2ServerManager

public class D2ServerManager
extends Object

This class provides a server manager with start/shutdown methods to be invoked to manage the lifecycle of the server announcer.

Constructor Summary

Constructors

Constructor	Description
D2ServerManager(com.linkedin.d2.balancer.servers.ZooKeeperConnectionManager manager, long startupTimeoutMillis, boolean continueIfStartupFails, long shutdownTimeoutMillis, boolean continueIfShutdownFails, boolean doNotStart)
D2ServerManager(com.linkedin.d2.balancer.servers.ZooKeeperConnectionManager manager, long startupTimeoutMillis, boolean continueIfStartupFails, long shutdownTimeoutMillis, boolean continueIfShutdownFails, boolean doNotStart, boolean delayStart, boolean initMarkUp, boolean healthCheckEnabled, long healthCheckInterval, int healthCheckRetries, String healthCheckUrl, ScheduledExecutorService scheduledExecutorService, int d2HealthCheckerTimeoutMs)

Method Summary

Modifier and Type	Method	Description
void	doStart()
void	forceStart()
Set<String>	getNodeUris()
com.linkedin.d2.balancer.servers.ZooKeeperAnnouncer[]	getZkAnnouncers()
com.linkedin.d2.balancer.servers.ZooKeeperAnnouncer[]	getZkAnnouncersWithoutStartCheck()
String	getZkConnectString()
boolean	isDelayStart()
boolean	isDoNotStart()
boolean	isStarted()
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Details

D2ServerManager

public D2ServerManager(com.linkedin.d2.balancer.servers.ZooKeeperConnectionManager manager,
 long startupTimeoutMillis,
 boolean continueIfStartupFails,
 long shutdownTimeoutMillis,
 boolean continueIfShutdownFails,
 boolean doNotStart)

D2ServerManager

public D2ServerManager(com.linkedin.d2.balancer.servers.ZooKeeperConnectionManager manager,
 long startupTimeoutMillis,
 boolean continueIfStartupFails,
 long shutdownTimeoutMillis,
 boolean continueIfShutdownFails,
 boolean doNotStart,
 boolean delayStart,
 boolean initMarkUp,
 boolean healthCheckEnabled,
 long healthCheckInterval,
 int healthCheckRetries,
 String healthCheckUrl,
 ScheduledExecutorService scheduledExecutorService,
 int d2HealthCheckerTimeoutMs)

Method Details

start

public void start()
           throws Exception

Throws:

Exception

shutdown

public void shutdown()
              throws Exception

Throws:

Exception

forceStart

public void forceStart()
                throws Exception

Throws:

Exception

doStart

public void doStart()
             throws Exception

Throws:

Exception

getZkAnnouncers

public com.linkedin.d2.balancer.servers.ZooKeeperAnnouncer[] getZkAnnouncers()

getZkAnnouncersWithoutStartCheck

public com.linkedin.d2.balancer.servers.ZooKeeperAnnouncer[] getZkAnnouncersWithoutStartCheck()

getZkConnectString

public String getZkConnectString()

getNodeUris

public Set<String> getNodeUris()

isStarted

public boolean isStarted()

isDelayStart

public boolean isDelayStart()

isDoNotStart

public boolean isDoNotStart()