info.ganglia.gmetric4j.gmetric

Class Protocolv31x

java.lang.Object

info.ganglia.gmetric4j.gmetric.AbstractProtocol

info.ganglia.gmetric4j.gmetric.Protocolv31x

All Implemented Interfaces:

Protocol, java.io.Closeable, java.lang.AutoCloseable

public class Protocolv31x
extends AbstractProtocol

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	isSpoofName
private java.lang.String	localHostName
private static int	MAX_BUFFER_SIZE
private int	metadataMessageInterval
private java.util.Map<java.lang.String,java.lang.Integer>	metricCounterMap
private java.util.UUID	uuid
private org.acplt.oncrpc.XdrBufferEncodingStream	xdr

Fields inherited from class info.ganglia.gmetric4j.gmetric.AbstractProtocol

group, port, udpAddr

Constructor Summary

Constructors

Constructor and Description
Protocolv31x(java.lang.String group, int port, GMetric.UDPAddressingMode mode, int ttl, int metadataMessageInterval, java.util.UUID uuid, java.lang.String spoofName)

Method Summary

Modifier and Type	Method and Description
void	announce(java.lang.String name, java.lang.String value, GMetricType type, java.lang.String units, GMetricSlope slope, int tmax, int dmax, java.lang.String groupName) Announces a metric
private void	encodeGMetric(Ganglia_metric_id metric_id, java.lang.String name, java.lang.String value, GMetricType type, java.lang.String units, GMetricSlope slope, int tmax, int dmax, java.lang.String groupName) Encodes the metric using the classes generated by remotetea
private void	encodeGValue(Ganglia_metric_id metric_id, java.lang.String value)
private boolean	isTimeToSendMetadata(java.lang.String metricName)

Methods inherited from class info.ganglia.gmetric4j.gmetric.AbstractProtocol

close, finalize, send

Methods inherited from class java.lang.Object

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

Field Detail

MAX_BUFFER_SIZE

private static final int MAX_BUFFER_SIZE

See Also:

Constant Field Values

xdr

private org.acplt.oncrpc.XdrBufferEncodingStream xdr

metricCounterMap

private java.util.Map<java.lang.String,java.lang.Integer> metricCounterMap

metadataMessageInterval

private int metadataMessageInterval

uuid

private java.util.UUID uuid

isSpoofName

private boolean isSpoofName

localHostName

private java.lang.String localHostName

Constructor Detail

Protocolv31x

public Protocolv31x(java.lang.String group,
                    int port,
                    GMetric.UDPAddressingMode mode,
                    int ttl,
                    int metadataMessageInterval,
                    java.util.UUID uuid,
                    java.lang.String spoofName)
             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

isTimeToSendMetadata

private boolean isTimeToSendMetadata(java.lang.String metricName)

announce

public void announce(java.lang.String name,
                     java.lang.String value,
                     GMetricType type,
                     java.lang.String units,
                     GMetricSlope slope,
                     int tmax,
                     int dmax,
                     java.lang.String groupName)
              throws java.lang.Exception

Description copied from interface: Protocol

Announces a metric

Specified by:

announce in interface Protocol

Specified by:

announce in class AbstractProtocol

Parameters:

name - the metric name

value - the metric value

type - the metric type

units - the units

slope - the slope

tmax - the tmax

dmax - the dmax

groupName - the metric group

Throws:

java.lang.Exception

encodeGMetric

private void encodeGMetric(Ganglia_metric_id metric_id,
                           java.lang.String name,
                           java.lang.String value,
                           GMetricType type,
                           java.lang.String units,
                           GMetricSlope slope,
                           int tmax,
                           int dmax,
                           java.lang.String groupName)
                    throws java.lang.Exception

Encodes the metric using the classes generated by remotetea

Throws:

java.lang.Exception

encodeGValue

private void encodeGValue(Ganglia_metric_id metric_id,
                          java.lang.String value)
                   throws java.lang.Exception

Throws:

java.lang.Exception