zydronium/google-nomulus
1
0
Fork 0
mirror of https://github.com/google/nomulus.git synced 2025-05-13 07:57:13 +02:00
Code Issues Projects Releases Packages Wiki Activity

Change project to projectResource to better match Stackdriver sample code

Browse source 
-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=130432024
This commit is contained in:
shikhman 2016-08-16 12:24:19 -07:00 • committed by Ben McIlwain
parent cfe4eb0fbb
commit 9b4ef23d92
1 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
java/google/registry/monitoring/metrics/StackdriverWriter.java
View file

@ -109,7 +109,7 @@ public class StackdriverWriter implements MetricWriter {
*/
private final HashMap<google.registry.monitoring.metrics.Metric<?>, MetricDescriptor>
registeredDescriptors = new HashMap<>();
private final String project;
private final String projectResource;
private final Monitoring monitoringClient;
private final int maxPointsPerRequest;
private final RateLimiter rateLimiter;
@ -128,7 +128,7 @@ public class StackdriverWriter implements MetricWriter {
@Named("stackdriverMaxQps") int maxQps,
@Named("stackdriverMaxPointsPerRequest") int maxPointsPerRequest) {
this.monitoringClient = checkNotNull(monitoringClient);
this.project = "projects/" + checkNotNull(project);
this.projectResource = "projects/" + checkNotNull(project);
this.monitoredResource = monitoredResource;
this.maxPointsPerRequest = maxPointsPerRequest;
this.timeSeriesBuffer = new ArrayDeque<>(maxPointsPerRequest);
@ -244,7 +244,7 @@ public class StackdriverWriter implements MetricWriter {
CreateTimeSeriesRequest request = new CreateTimeSeriesRequest().setTimeSeries(timeSeriesList);
rateLimiter.acquire();
monitoringClient.projects().timeSeries().create(project, request).execute();
monitoringClient.projects().timeSeries().create(projectResource, request).execute();
for (TimeSeries timeSeries : timeSeriesList) {
pushedPoints.incrementBy(1, timeSeries.getMetricKind(), timeSeries.getValueType());
@ -270,7 +270,11 @@ public class StackdriverWriter implements MetricWriter {
try {
rateLimiter.acquire();
descriptor =
monitoringClient.projects().metricDescriptors().create(project, descriptor).execute();
monitoringClient
.projects()
.metricDescriptors()
.create(projectResource, descriptor)
.execute();
} catch (IOException e) {
throw new RuntimeException("Error creating a MetricDescriptor");
}