com.google.monitoring.metrics.stackdriver

Class StackdriverWriter

java.lang.Object

com.google.monitoring.metrics.stackdriver.StackdriverWriter

All Implemented Interfaces:

MetricWriter, Flushable

@NotThreadSafe
public class StackdriverWriter
extends Object
implements MetricWriter

Metrics writer for Google Cloud Monitoring V3

This class communicates with the API via HTTP. In order to increase throughput and minimize CPU, it buffers points to be written until it has maxPointsPerRequest points buffered or until flush() is called.

See Also:

Introduction to the Stackdriver Monitoring API

Constructor Summary

Constructors

Constructor and Description
StackdriverWriter(com.google.api.services.monitoring.v3.Monitoring monitoringClient, String project, com.google.api.services.monitoring.v3.model.MonitoredResource monitoredResource, int maxQps, int maxPointsPerRequest) Constructs a StackdriverWriter.

Method Summary

Modifier and Type	Method and Description
void	flush() Flushes all buffered metric points to Stackdriver.
<V> void	write(MetricPoint<V> point) Encodes and writes a metric point to Stackdriver.

Methods inherited from class java.lang.Object

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

Constructor Detail

StackdriverWriter

public StackdriverWriter(com.google.api.services.monitoring.v3.Monitoring monitoringClient,
                         String project,
                         com.google.api.services.monitoring.v3.model.MonitoredResource monitoredResource,
                         int maxQps,
                         int maxPointsPerRequest)

Constructs a StackdriverWriter.

The monitoringClient must have read and write permissions to the Cloud Monitoring API v3 on the provided project.

Method Detail

write

public <V> void write(MetricPoint<V> point)
               throws IOException

Encodes and writes a metric point to Stackdriver. The point may be buffered.

Specified by:

write in interface MetricWriter

Throws:

IOException

flush

public void flush()
           throws IOException

Flushes all buffered metric points to Stackdriver. This call is blocking.

Specified by:

flush in interface MetricWriter

Specified by:

flush in interface Flushable

Throws:

IOException