Package titan.balancer

Class NginxAdapter

java.lang.Object

titan.balancer.NginxAdapter

All Implemented Interfaces:

IngressAdapter

public class NginxAdapter
extends Object
implements IngressAdapter

Field Summary

Fields

Modifier and Type	Field	Description
private final String	NGINX_CONF_PATH
private ConcurrentHashMap<String,List<String>>	routeTable

Constructor Summary

Constructors

Constructor	Description
NginxAdapter()

Method Summary

Modifier and Type	Method	Description
void	applyRoutingConfig()	Flushes the current state to the Load Balancer and triggers a hot-reload.
void	deRegisterService(String serviceName, String workerIp, int port)	Called by the Master when a worker crashes or a service is scaled down.
Map<String,List<String>>	getActiveRoutes()
void	registerService(String serviceName, String workerIp, int port)	Called by the Master when a worker successfully starts a long-running service.

Methods inherited from class java.lang.Object

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

Field Details

routeTable

private ConcurrentHashMap<String,List<String>> routeTable

NGINX_CONF_PATH

private final String NGINX_CONF_PATH

See Also:

• Constant Field Values

Constructor Details

NginxAdapter

public NginxAdapter()

Method Details

registerService

public void registerService(String serviceName,
 String workerIp,
 int port)

Description copied from interface: IngressAdapter

Called by the Master when a worker successfully starts a long-running service.

Specified by:

registerService in interface IngressAdapter

deRegisterService

public void deRegisterService(String serviceName,
 String workerIp,
 int port)

Description copied from interface: IngressAdapter

Called by the Master when a worker crashes or a service is scaled down.

Specified by:

deRegisterService in interface IngressAdapter

applyRoutingConfig

public void applyRoutingConfig()

Description copied from interface: IngressAdapter

Flushes the current state to the Load Balancer and triggers a hot-reload.

Specified by:

applyRoutingConfig in interface IngressAdapter

getActiveRoutes

public Map<String,List<String>> getActiveRoutes()

Specified by:

getActiveRoutes in interface IngressAdapter