org.spf4j.perf.impl.ms.graphite

Class GraphiteUdpStore

java.lang.Object

org.spf4j.perf.impl.ms.graphite.GraphiteUdpStore

All Implemented Interfaces:

Closeable, AutoCloseable, MeasurementStore

public final class GraphiteUdpStore
extends Object
implements MeasurementStore

Author:

zoly

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_UDP_MSG_SIZE

Constructor Summary

Constructors

Constructor and Description
GraphiteUdpStore(String hostPort)
GraphiteUdpStore(String hostName, int port)
GraphiteUdpStore(URI uri)

Method Summary

Methods

Modifier and Type	Method and Description
void	alocateMeasurements(EntityMeasurementsInfo measurement, int sampleTimeMillis) Make any allocations necessary for the following measurements.
void	close()
void	flush() flush all data that might be buffered by this store.
void	saveMeasurements(EntityMeasurementsInfo measurementInfo, long timeStampMillis, int sampleTimeMillis, long... measurements) Save measurements.
String	toString()
static void	writeMetric(EntityMeasurementsInfo measurementInfo, String measurementName, long measurement, long timeStampMillis, Writer os)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_UDP_MSG_SIZE

public static final int MAX_UDP_MSG_SIZE

See Also:

Constant Field Values

Constructor Detail

GraphiteUdpStore

public GraphiteUdpStore(String hostPort)
                 throws ObjectCreationException,
                        URISyntaxException

Throws:

ObjectCreationException

URISyntaxException

GraphiteUdpStore

public GraphiteUdpStore(URI uri)
                 throws ObjectCreationException

Throws:

ObjectCreationException

GraphiteUdpStore

public GraphiteUdpStore(String hostName,
                int port)
                 throws ObjectCreationException

Throws:

ObjectCreationException

Method Detail

flush

public void flush()

Description copied from interface: MeasurementStore

flush all data that might be buffered by this store.

Specified by:

flush in interface MeasurementStore

alocateMeasurements

public void alocateMeasurements(EntityMeasurementsInfo measurement,
                       int sampleTimeMillis)

Description copied from interface: MeasurementStore

Make any allocations necessary for the following measurements.

Specified by:

alocateMeasurements in interface MeasurementStore

saveMeasurements

public void saveMeasurements(EntityMeasurementsInfo measurementInfo,
                    long timeStampMillis,
                    int sampleTimeMillis,
                    long... measurements)
                      throws IOException

Description copied from interface: MeasurementStore

Save measurements.

Specified by:

saveMeasurements in interface MeasurementStore

Throws:

IOException

writeMetric

public static void writeMetric(EntityMeasurementsInfo measurementInfo,
               String measurementName,
               long measurement,
               long timeStampMillis,
               Writer os)
                        throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException