Package com.devebot.opflow

Class OpflowRpcObserver

java.lang.Object

com.devebot.opflow.OpflowRpcObserver

public class OpflowRpcObserver
extends Object

Author:

acegik

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OpflowRpcObserver.Manifest

Constructor Summary

Constructors

Constructor	Description
OpflowRpcObserver(Map<String,Object> kwargs)

Method Summary

Modifier and Type	Method	Description
void	check(OpflowConstant.Protocol protocol, Map<String,Object> headers)
void	cleanup()
void	close()
boolean	containsInfo(String componentId, String name)
long	getKeepAliveTimeout()
OpflowRpcRoutingInfo	getRoutingInfo(OpflowConstant.Protocol protocol)
OpflowRpcRoutingInfo	getRoutingInfo(OpflowConstant.Protocol protocol, boolean available)
OpflowDiscoveryMaster.ServiceHealthHook	getServiceUpdater()
ExecutorService	getThreadExecutor()
int	getThreadPoolSize()
String	getThreadPoolType()
long	getTrimmingTimeDelay()
boolean	isCongestive()
boolean	isCongestive(OpflowConstant.Protocol protocol)
boolean	isThreadPoolEnabled()
boolean	isThreadPoolUsed()
boolean	isTrimmingEnabled()
void	setCongestive(OpflowConstant.Protocol protocol, boolean congestive)
void	setCongestive(OpflowConstant.Protocol protocol, boolean congestive, String componentId)
void	setKeepAliveTimeout(long timeout)
Collection<OpflowRpcObserver.Manifest>	summary()
void	touch(OpflowConstant.Protocol protocol, Map<String,Object> headers)
void	updateInfo(String componentId, String name, Object data)

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowRpcObserver

public OpflowRpcObserver(Map<String,Object> kwargs)

Method Details

isTrimmingEnabled

public boolean isTrimmingEnabled()

getTrimmingTimeDelay

public long getTrimmingTimeDelay()

isThreadPoolEnabled

public boolean isThreadPoolEnabled()

getThreadPoolType

public String getThreadPoolType()

getThreadPoolSize

public int getThreadPoolSize()

isThreadPoolUsed

public boolean isThreadPoolUsed()

getKeepAliveTimeout

public long getKeepAliveTimeout()

getServiceUpdater

public OpflowDiscoveryMaster.ServiceHealthHook getServiceUpdater()

getThreadExecutor

public ExecutorService getThreadExecutor()

close

public void close()

check

public void check(OpflowConstant.Protocol protocol, Map<String,Object> headers)

touch

public void touch(OpflowConstant.Protocol protocol, Map<String,Object> headers)

isCongestive

public boolean isCongestive()

isCongestive

public boolean isCongestive(OpflowConstant.Protocol protocol)

setCongestive

public void setCongestive(OpflowConstant.Protocol protocol, boolean congestive)

setCongestive

public void setCongestive(OpflowConstant.Protocol protocol, boolean congestive, String componentId)

getRoutingInfo

public OpflowRpcRoutingInfo getRoutingInfo(OpflowConstant.Protocol protocol)

getRoutingInfo

public OpflowRpcRoutingInfo getRoutingInfo(OpflowConstant.Protocol protocol, boolean available)

containsInfo

public boolean containsInfo(String componentId, String name)

updateInfo

public void updateInfo(String componentId, String name, Object data)

cleanup

public void cleanup()

summary

public Collection<OpflowRpcObserver.Manifest> summary()

setKeepAliveTimeout

public void setKeepAliveTimeout(long timeout)