com.nt.udc.ndk.node

Class DCNodePerformance

java.lang.Object

com.nt.udc.ndk.node.DCNodePerformance

All Implemented Interfaces:

DCNodePerformanceIfc, java.io.Serializable

public class DCNodePerformance
extends java.lang.Object
implements DCNodePerformanceIfc, java.io.Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	AVG_RATE
static java.lang.String	CURRENT_NARS
static java.lang.String	CURRENT_RATE
static java.lang.String	NODE_RUNNING
static java.lang.String	NODE_STATUS
static java.lang.String	NODE_UP_TIME
static java.lang.String	TOTAL_NARS

Constructor Summary

Constructors

Constructor and Description
DCNodePerformance()
DCNodePerformance(java.lang.String node_id)

Method Summary

Modifier and Type	Method and Description
void	createMetrics()
int	getAvgNarRate() Returns the average rate per second of nars passing through the stream handler since the node started.
int	getCurrentNarRate() Returns the average rate per second of nars passing through the stream handler since the last performance check.
int	getLastCheckDelta() Returns difference between the current time and the time of the last performance check.
long	getNarDelta() Returns number of nars processed in this check interval.
long	getNars() Returns total number of nars passed through the stream handler.
java.lang.String	getNodeId() Returns the string id for the node it came from
java.lang.String	getNodeManagerIpAndPort()
int	getNodeUpTime() Returns time node has been up
void	refreshMetrics()
void	reset()
void	setActive(java.lang.Integer status)
void	setCheckTime(int check)
void	setNars(long n)
void	setNodeId(java.lang.String id)
void	setNodeManagerIpAndPort(java.lang.String nodeManagerIpAndPort)
void	setNodeStartTime(int startTime)
void	setStatus(java.lang.Integer status)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

TOTAL_NARS

public static final java.lang.String TOTAL_NARS

See Also:

Constant Field Values

CURRENT_NARS

public static final java.lang.String CURRENT_NARS

See Also:

Constant Field Values

CURRENT_RATE

public static final java.lang.String CURRENT_RATE

See Also:

Constant Field Values

AVG_RATE

public static final java.lang.String AVG_RATE

See Also:

Constant Field Values

NODE_UP_TIME

public static final java.lang.String NODE_UP_TIME

See Also:

Constant Field Values

NODE_RUNNING

public static final java.lang.String NODE_RUNNING

See Also:

Constant Field Values

NODE_STATUS

public static final java.lang.String NODE_STATUS

See Also:

Constant Field Values

Constructor Detail

DCNodePerformance

public DCNodePerformance()

DCNodePerformance

public DCNodePerformance(java.lang.String node_id)

Method Detail

reset

public void reset()

Specified by:

reset in interface DCNodePerformanceIfc

setNars

public void setNars(long n)

getNars

public long getNars()

Description copied from interface: DCNodePerformanceIfc

Returns total number of nars passed through the stream handler.

Specified by:

getNars in interface DCNodePerformanceIfc

Returns:

total nars

getNarDelta

public long getNarDelta()

Description copied from interface: DCNodePerformanceIfc

Returns number of nars processed in this check interval.

Specified by:

getNarDelta in interface DCNodePerformanceIfc

Returns:

nar delta

getAvgNarRate

public int getAvgNarRate()

Description copied from interface: DCNodePerformanceIfc

Returns the average rate per second of nars passing through the stream handler since the node started.

Specified by:

getAvgNarRate in interface DCNodePerformanceIfc

Returns:

average nars per second

getCurrentNarRate

public int getCurrentNarRate()

Description copied from interface: DCNodePerformanceIfc

Returns the average rate per second of nars passing through the stream handler since the last performance check.

Specified by:

getCurrentNarRate in interface DCNodePerformanceIfc

Returns:

current nars per second

setCheckTime

public void setCheckTime(int check)

getLastCheckDelta

public int getLastCheckDelta()

Description copied from interface: DCNodePerformanceIfc

Returns difference between the current time and the time of the last performance check.

Specified by:

getLastCheckDelta in interface DCNodePerformanceIfc

Returns:

check time delta

getNodeUpTime

public int getNodeUpTime()

Description copied from interface: DCNodePerformanceIfc

Returns time node has been up

Specified by:

getNodeUpTime in interface DCNodePerformanceIfc

Returns:

node up time

setNodeStartTime

public void setNodeStartTime(int startTime)

getNodeId

public java.lang.String getNodeId()

Description copied from interface: DCNodePerformanceIfc

Returns the string id for the node it came from

Specified by:

getNodeId in interface DCNodePerformanceIfc

Returns:

node id

setNodeId

public void setNodeId(java.lang.String id)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getNodeManagerIpAndPort

public java.lang.String getNodeManagerIpAndPort()

setNodeManagerIpAndPort

public void setNodeManagerIpAndPort(java.lang.String nodeManagerIpAndPort)

createMetrics

public void createMetrics()

refreshMetrics

public void refreshMetrics()

Specified by:

refreshMetrics in interface DCNodePerformanceIfc

setActive

public void setActive(java.lang.Integer status)

Specified by:

setActive in interface DCNodePerformanceIfc

setStatus

public void setStatus(java.lang.Integer status)

Specified by:

setStatus in interface DCNodePerformanceIfc