eu.reservoir.monitoring.distribution
Class MeasurementDecoderWithNames

java.lang.Object
  eu.reservoir.monitoring.distribution.MeasurementDecoder
      eu.reservoir.monitoring.distribution.MeasurementDecoderWithNames

public class MeasurementDecoderWithNames
extends MeasurementDecoder

This decoder is capable to decode messages that contains the name of the values

Constructor Summary

MeasurementDecoderWithNames()

Method Summary

Measurement

decode(java.io.DataInput in) Decode the Measurement from a DataOutput object.

Methods inherited from class eu.reservoir.monitoring.distribution.MeasurementDecoder

decodeType, decodeValue, readInt, readList, readTable, readUTF

Methods inherited from class java.lang.Object

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

Constructor Detail

MeasurementDecoderWithNames

public MeasurementDecoderWithNames()

Method Detail

decode

public Measurement decode(java.io.DataInput in)
                   throws java.io.IOException,
                          TypeException

Decode the Measurement from a DataOutput object. The message is encoded and it's structure is:

 +------------------------------------------------------------------------+
 | seq no (long) | options (byte) [bit 0 : 0 = no names / 1 = with names] |
 +------------------------------------------------------------------------+
 |  probe id (long) | type (utf string)  | timestamp (long)               |
 +------------------------------------------------------------------------+
 | time delta (long) | service id (long) | group id (long)                |
 +------------------------------------------------------------------------+
 | probe name (utf string) | attr count                                   |
 +------------------------------------------------------------------------+
 | attr0 field no (int) | attr0 name (utf string) | attr0 type (byte)     |
 | attr0 value (depends)                                                  |
 +------------------------------------------------------------------------+
 | ....                                                                   |
 +------------------------------------------------------------------------+
 | attrN field no (int) | attrN name (utf string) | attrN type (byte)     | 
 | attrN value (depends)                                                  |
 +------------------------------------------------------------------------+
 

Overrides:

decode in class MeasurementDecoder

Throws:

java.io.IOException

TypeException