Package org.enanoservices.servermonitor

Class Server

java.lang.Object

org.enanoservices.servermonitor.Server

Direct Known Subclasses:

ThisServer

public class Server
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected long	accHbDelay
protected int	adminState
protected java.lang.String	context
protected int	downTime
protected int	heartBeatAlarmDelay
protected java.lang.String	host
protected long	lastHeartBeat
protected int	maxHbDelay
protected java.lang.String	microservice
protected int	minHbDelay
protected int	numHeartBeats
protected java.lang.String	port
protected org.enanoservices.servermonitor.ServerState.State	state

Constructor Summary

Constructors

Constructor	Description
Server()
Server(java.lang.String host, java.lang.String microservice, java.lang.String port, java.lang.String context, int adminState, java.lang.String srvVersion, java.lang.String nsVersion, int serverDownTime, int heartBeatAlarmDelay)	create new servers when heartbeat received

Method Summary

Modifier and Type	Method	Description
protected int	calcHeartBeatDelay(long now, long timeSent)
void	checkHearBeatTimeout(long nowMs, IServerMonitor monitor)	used for remote servers called from ServerHolder.updateServersState(), from ServerMonitorThread - check if heart beat has been received within the last x ms - change the server state to disconnect if it hasn't - no action if server is connected since the heartbeat message will be updating the server state
boolean	checkIfServer(java.lang.String host, java.lang.String port, java.lang.String microservice)
java.lang.String	getAdminClientState()
int	getAdminState()
java.lang.String	getClientState()
java.lang.String	getContext()
java.lang.String	getCtxUrl()	get server's url including context
float	getHbAvgDelay()
java.lang.String	getHost()
long	getLastHeartBeat()
java.lang.String	getMaxHbDelay()
java.lang.String	getMicroservice()
java.lang.String	getMinHbDelay()
java.lang.String	getNsVersion()
java.lang.String	getOrigin()
java.lang.String	getPort()
org.enanoservices.servermonitor.ServerState.State	getServerState()
java.lang.String	getServVersion()
java.lang.String	getSrvVersion()
int	getState()
java.lang.String	getUrl()	get server's url
void	init(java.lang.String host, java.lang.String microservice, java.lang.String port, java.lang.String context, int adminState, java.lang.String srvVersion, java.lang.String nsVersion, int serverDownTime, int heartBeatAlarmDelay)	initialize server - use by ThisServer
boolean	isAdminUp()
boolean	isDisconnected(long nowMs)
void	processHeartBeat(org.enanoservices.servermonitor.HeartBeatBody body, long timeSent, IServerMonitor monitor)	process heart-beat but only for remote servers not for this one ThisServer overrides this method first heart-beat reports server as disconnected, which is finetoggleAdminState server not connected detected in checkHearBeatTimeout, called by ServerMonitorThread caller needs to obtain the lock
void	resetHeartBeatCounters()	reset heartbeat counters if ---
void	setNsVersion(java.lang.String nsVersion)
void	setSrvVersion(java.lang.String srvVersion)
void	setState(org.enanoservices.servermonitor.ServerState.State state)
void	toggleAdminState()

Methods inherited from class java.lang.Object

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

Field Detail

microservice

protected java.lang.String microservice

host

protected java.lang.String host

port

protected java.lang.String port

context

protected java.lang.String context

state

protected org.enanoservices.servermonitor.ServerState.State state

adminState

protected int adminState

lastHeartBeat

protected long lastHeartBeat

heartBeatAlarmDelay

protected int heartBeatAlarmDelay

minHbDelay

protected int minHbDelay

maxHbDelay

protected int maxHbDelay

numHeartBeats

protected int numHeartBeats

accHbDelay

protected long accHbDelay

downTime

protected int downTime

Constructor Detail

Server

public Server()

Server

public Server(java.lang.String host,
              java.lang.String microservice,
              java.lang.String port,
              java.lang.String context,
              int adminState,
              java.lang.String srvVersion,
              java.lang.String nsVersion,
              int serverDownTime,
              int heartBeatAlarmDelay)

create new servers when heartbeat received

Parameters:

host - - host

microservice - - micro service

port - - port

context - - micro service's context

adminState - - server's admin state

srvVersion - - server's version

nsVersion - - server's eNanoServices.jar version

serverDownTime - - down time

heartBeatAlarmDelay - - heartbeat alarm delay

Method Detail

init

public void init(java.lang.String host,
                 java.lang.String microservice,
                 java.lang.String port,
                 java.lang.String context,
                 int adminState,
                 java.lang.String srvVersion,
                 java.lang.String nsVersion,
                 int serverDownTime,
                 int heartBeatAlarmDelay)

initialize server - use by ThisServer

Parameters:

host - - host

microservice - - micro service

port - - server's port

context - - context

adminState - - server's admin state

srvVersion - - microservice version

nsVersion - - enanoservices version

serverDownTime - - server's downtime

heartBeatAlarmDelay - - heart-beat alarm delay

getHost

public java.lang.String getHost()

getMicroservice

public java.lang.String getMicroservice()

getPort

public java.lang.String getPort()

getContext

public java.lang.String getContext()

isDisconnected

public boolean isDisconnected(long nowMs)

checkHearBeatTimeout

public void checkHearBeatTimeout(long nowMs,
                                 IServerMonitor monitor)

used for remote servers called from ServerHolder.updateServersState(), from ServerMonitorThread - check if heart beat has been received within the last x ms - change the server state to disconnect if it hasn't - no action if server is connected since the heartbeat message will be updating the server state

Parameters:

nowMs - - current time

monitor - - IServerMonitor monitor

checkIfServer

public boolean checkIfServer(java.lang.String host,
                             java.lang.String port,
                             java.lang.String microservice)

toggleAdminState

public void toggleAdminState()

getState

public int getState()

getServerState

public org.enanoservices.servermonitor.ServerState.State getServerState()

setState

public void setState(org.enanoservices.servermonitor.ServerState.State state)

getAdminState

public int getAdminState()

isAdminUp

public boolean isAdminUp()

getLastHeartBeat

public long getLastHeartBeat()

getSrvVersion

public java.lang.String getSrvVersion()

setSrvVersion

public void setSrvVersion(java.lang.String srvVersion)

getNsVersion

public java.lang.String getNsVersion()

setNsVersion

public void setNsVersion(java.lang.String nsVersion)

getOrigin

public java.lang.String getOrigin()

getMinHbDelay

public java.lang.String getMinHbDelay()

getMaxHbDelay

public java.lang.String getMaxHbDelay()

getHbAvgDelay

public float getHbAvgDelay()

processHeartBeat

public void processHeartBeat(org.enanoservices.servermonitor.HeartBeatBody body,
                             long timeSent,
                             IServerMonitor monitor)

process heart-beat but only for remote servers not for this one ThisServer overrides this method first heart-beat reports server as disconnected, which is finetoggleAdminState server not connected detected in checkHearBeatTimeout, called by ServerMonitorThread caller needs to obtain the lock

Parameters:

body - - HeartBeatBody

timeSent - - time mesage sent, it comes from BrokerMessageHeader.tms

monitor - - server monitor object

calcHeartBeatDelay

protected int calcHeartBeatDelay(long now,
                                 long timeSent)

resetHeartBeatCounters

public void resetHeartBeatCounters()

reset heartbeat counters if ---

getCtxUrl

public java.lang.String getCtxUrl()

get server's url including context

Returns:

- https://host:port/context

getUrl

public java.lang.String getUrl()

get server's url

Returns:

- https://host:port

getClientState

public java.lang.String getClientState()

getAdminClientState

public java.lang.String getAdminClientState()

getServVersion

public java.lang.String getServVersion()