|
30 | 30 | import com.google.cloud.NoCredentials;
|
31 | 31 | import com.google.cloud.logging.LoggingException;
|
32 | 32 | import com.google.cloud.logging.LoggingOptions;
|
33 |
| -import com.google.cloud.logging.spi.v2.ConfigServiceV2Client; |
34 |
| -import com.google.cloud.logging.spi.v2.ConfigServiceV2Settings; |
35 |
| -import com.google.cloud.logging.spi.v2.LoggingServiceV2Client; |
36 |
| -import com.google.cloud.logging.spi.v2.LoggingServiceV2Settings; |
37 |
| -import com.google.cloud.logging.spi.v2.MetricsServiceV2Client; |
38 |
| -import com.google.cloud.logging.spi.v2.MetricsServiceV2Settings; |
| 33 | +import com.google.cloud.logging.spi.v2.ConfigClient; |
| 34 | +import com.google.cloud.logging.spi.v2.ConfigSettings; |
| 35 | +import com.google.cloud.logging.spi.v2.LoggingClient; |
| 36 | +import com.google.cloud.logging.spi.v2.LoggingSettings; |
| 37 | +import com.google.cloud.logging.spi.v2.MetricsClient; |
| 38 | +import com.google.cloud.logging.spi.v2.MetricsSettings; |
39 | 39 | import com.google.logging.v2.CreateLogMetricRequest;
|
40 | 40 | import com.google.logging.v2.CreateSinkRequest;
|
41 | 41 | import com.google.logging.v2.DeleteLogMetricRequest;
|
|
71 | 71 |
|
72 | 72 | public class DefaultLoggingRpc implements LoggingRpc {
|
73 | 73 |
|
74 |
| - private final ConfigServiceV2Client configClient; |
75 |
| - private final LoggingServiceV2Client loggingClient; |
76 |
| - private final MetricsServiceV2Client metricsClient; |
| 74 | + private final ConfigClient configClient; |
| 75 | + private final LoggingClient loggingClient; |
| 76 | + private final MetricsClient metricsClient; |
77 | 77 | private final ScheduledExecutorService executor;
|
78 | 78 | private final ProviderManager providerManager;
|
79 | 79 | private final ExecutorFactory<ScheduledExecutorService> executorFactory;
|
@@ -127,21 +127,24 @@ public DefaultLoggingRpc(LoggingOptions options) throws IOException {
|
127 | 127 | .setExecutorProvider(executorProvider)
|
128 | 128 | .build();
|
129 | 129 | UnaryCallSettings.Builder callSettingsBuilder = internalOptions.getApiCallSettings();
|
130 |
| - ConfigServiceV2Settings.Builder confBuilder = ConfigServiceV2Settings.defaultBuilder() |
131 |
| - .setExecutorProvider(providerManager) |
132 |
| - .setChannelProvider(providerManager) |
133 |
| - .applyToAllUnaryMethods(callSettingsBuilder); |
134 |
| - LoggingServiceV2Settings.Builder logBuilder = LoggingServiceV2Settings.defaultBuilder() |
135 |
| - .setExecutorProvider(providerManager) |
136 |
| - .setChannelProvider(providerManager) |
137 |
| - .applyToAllUnaryMethods(callSettingsBuilder); |
138 |
| - MetricsServiceV2Settings.Builder metricsBuilder = MetricsServiceV2Settings.defaultBuilder() |
139 |
| - .setExecutorProvider(providerManager) |
140 |
| - .setChannelProvider(providerManager) |
141 |
| - .applyToAllUnaryMethods(callSettingsBuilder); |
142 |
| - configClient = ConfigServiceV2Client.create(confBuilder.build()); |
143 |
| - loggingClient = LoggingServiceV2Client.create(logBuilder.build()); |
144 |
| - metricsClient = MetricsServiceV2Client.create(metricsBuilder.build()); |
| 130 | + ConfigSettings.Builder confBuilder = |
| 131 | + ConfigSettings.defaultBuilder() |
| 132 | + .setExecutorProvider(providerManager) |
| 133 | + .setChannelProvider(providerManager) |
| 134 | + .applyToAllUnaryMethods(callSettingsBuilder); |
| 135 | + LoggingSettings.Builder logBuilder = |
| 136 | + LoggingSettings.defaultBuilder() |
| 137 | + .setExecutorProvider(providerManager) |
| 138 | + .setChannelProvider(providerManager) |
| 139 | + .applyToAllUnaryMethods(callSettingsBuilder); |
| 140 | + MetricsSettings.Builder metricsBuilder = |
| 141 | + MetricsSettings.defaultBuilder() |
| 142 | + .setExecutorProvider(providerManager) |
| 143 | + .setChannelProvider(providerManager) |
| 144 | + .applyToAllUnaryMethods(callSettingsBuilder); |
| 145 | + configClient = ConfigClient.create(confBuilder.build()); |
| 146 | + loggingClient = LoggingClient.create(logBuilder.build()); |
| 147 | + metricsClient = MetricsClient.create(metricsBuilder.build()); |
145 | 148 | } catch (Exception ex) {
|
146 | 149 | throw new IOException(ex);
|
147 | 150 | }
|
|
0 commit comments