46
46
import com .google .common .collect .Maps ;
47
47
import com .google .common .util .concurrent .MoreExecutors ;
48
48
import com .google .common .util .concurrent .Uninterruptibles ;
49
- import com .google .logging .v2 .CreateLogMetricRequest ;
50
- import com .google .logging .v2 .CreateSinkRequest ;
51
- import com .google .logging .v2 .DeleteLogMetricRequest ;
52
- import com .google .logging .v2 .DeleteLogRequest ;
53
- import com .google .logging .v2 .DeleteSinkRequest ;
54
- import com .google .logging .v2 .GetLogMetricRequest ;
55
- import com .google .logging .v2 .GetSinkRequest ;
56
- import com .google .logging .v2 .ListLogEntriesRequest ;
57
- import com .google .logging .v2 .ListLogEntriesResponse ;
58
- import com .google .logging .v2 .ListLogMetricsRequest ;
59
- import com .google .logging .v2 .ListLogMetricsResponse ;
60
- import com .google .logging .v2 .ListMonitoredResourceDescriptorsRequest ;
61
- import com .google .logging .v2 .ListMonitoredResourceDescriptorsResponse ;
62
- import com .google .logging .v2 .ListSinksRequest ;
63
- import com .google .logging .v2 .ListSinksResponse ;
64
- import com .google .logging .v2 .ProjectLogName ;
65
- import com .google .logging .v2 .ProjectMetricName ;
66
- import com .google .logging .v2 .ProjectName ;
67
- import com .google .logging .v2 .ProjectSinkName ;
68
- import com .google .logging .v2 .UpdateLogMetricRequest ;
69
- import com .google .logging .v2 .UpdateSinkRequest ;
70
- import com .google .logging .v2 .WriteLogEntriesRequest ;
71
- import com .google .logging .v2 .WriteLogEntriesResponse ;
49
+ import com .google .logging .v2 .*;
72
50
import com .google .protobuf .Empty ;
73
51
import java .util .ArrayList ;
74
52
import java .util .List ;
@@ -254,7 +232,9 @@ public Sink update(SinkInfo sink) {
254
232
public ApiFuture <Sink > updateAsync (SinkInfo sink ) {
255
233
UpdateSinkRequest request =
256
234
UpdateSinkRequest .newBuilder ()
257
- .setSinkName (ProjectSinkName .of (getOptions ().getProjectId (), sink .getName ()).toString ())
235
+ .setSinkName (
236
+ LogSinkName .ofProjectSinkName (getOptions ().getProjectId (), sink .getName ())
237
+ .toString ())
258
238
.setSink (sink .toPb (getOptions ().getProjectId ()))
259
239
.build ();
260
240
return transform (rpc .update (request ), Sink .fromPbFunction (this ));
@@ -269,7 +249,8 @@ public Sink getSink(String sink) {
269
249
public ApiFuture <Sink > getSinkAsync (String sink ) {
270
250
GetSinkRequest request =
271
251
GetSinkRequest .newBuilder ()
272
- .setSinkName (ProjectSinkName .of (getOptions ().getProjectId (), sink ).toString ())
252
+ .setSinkName (
253
+ LogSinkName .ofProjectSinkName (getOptions ().getProjectId (), sink ).toString ())
273
254
.build ();
274
255
return transform (rpc .get (request ), Sink .fromPbFunction (this ));
275
256
}
@@ -333,7 +314,8 @@ public boolean deleteSink(String sink) {
333
314
public ApiFuture <Boolean > deleteSinkAsync (String sink ) {
334
315
DeleteSinkRequest request =
335
316
DeleteSinkRequest .newBuilder ()
336
- .setSinkName (ProjectSinkName .of (getOptions ().getProjectId (), sink ).toString ())
317
+ .setSinkName (
318
+ LogSinkName .ofProjectSinkName (getOptions ().getProjectId (), sink ).toString ())
337
319
.build ();
338
320
return transform (rpc .delete (request ), EMPTY_TO_BOOLEAN_FUNCTION );
339
321
}
@@ -345,7 +327,7 @@ public boolean deleteLog(String log) {
345
327
public ApiFuture <Boolean > deleteLogAsync (String log ) {
346
328
DeleteLogRequest request =
347
329
DeleteLogRequest .newBuilder ()
348
- .setLogName (ProjectLogName . of (getOptions ().getProjectId (), log ).toString ())
330
+ .setLogName (LogName . ofProjectLogName (getOptions ().getProjectId (), log ).toString ())
349
331
.build ();
350
332
return transform (rpc .delete (request ), EMPTY_TO_BOOLEAN_FUNCTION );
351
333
}
@@ -441,7 +423,7 @@ public ApiFuture<Metric> updateAsync(MetricInfo metric) {
441
423
UpdateLogMetricRequest request =
442
424
UpdateLogMetricRequest .newBuilder ()
443
425
.setMetricName (
444
- ProjectMetricName .of (getOptions ().getProjectId (), metric .getName ()).toString ())
426
+ LogMetricName .of (getOptions ().getProjectId (), metric .getName ()).toString ())
445
427
.setMetric (metric .toPb ())
446
428
.build ();
447
429
return transform (rpc .update (request ), Metric .fromPbFunction (this ));
@@ -456,7 +438,7 @@ public Metric getMetric(String metric) {
456
438
public ApiFuture <Metric > getMetricAsync (String metric ) {
457
439
GetLogMetricRequest request =
458
440
GetLogMetricRequest .newBuilder ()
459
- .setMetricName (ProjectMetricName .of (getOptions ().getProjectId (), metric ).toString ())
441
+ .setMetricName (LogMetricName .of (getOptions ().getProjectId (), metric ).toString ())
460
442
.build ();
461
443
return transform (rpc .get (request ), Metric .fromPbFunction (this ));
462
444
}
@@ -520,7 +502,7 @@ public boolean deleteMetric(String metric) {
520
502
public ApiFuture <Boolean > deleteMetricAsync (String metric ) {
521
503
DeleteLogMetricRequest request =
522
504
DeleteLogMetricRequest .newBuilder ()
523
- .setMetricName (ProjectMetricName .of (getOptions ().getProjectId (), metric ).toString ())
505
+ .setMetricName (LogMetricName .of (getOptions ().getProjectId (), metric ).toString ())
524
506
.build ();
525
507
return transform (rpc .delete (request ), EMPTY_TO_BOOLEAN_FUNCTION );
526
508
}
@@ -533,7 +515,7 @@ private static WriteLogEntriesRequest writeLogEntriesRequest(
533
515
WriteLogEntriesRequest .Builder builder = WriteLogEntriesRequest .newBuilder ();
534
516
String logName = LOG_NAME .get (options );
535
517
if (logName != null ) {
536
- builder .setLogName (ProjectLogName . of (projectId , logName ).toString ());
518
+ builder .setLogName (LogName . ofProjectLogName (projectId , logName ).toString ());
537
519
}
538
520
MonitoredResource resource = RESOURCE .get (options );
539
521
if (resource != null ) {
0 commit comments