|
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;
|
|
70 | 70 |
|
71 | 71 | public class DefaultLoggingRpc implements LoggingRpc {
|
72 | 72 |
|
73 |
| - private final ConfigServiceV2Client configClient; |
74 |
| - private final LoggingServiceV2Client loggingClient; |
75 |
| - private final MetricsServiceV2Client metricsClient; |
| 73 | + private final ConfigClient configClient; |
| 74 | + private final LoggingClient loggingClient; |
| 75 | + private final MetricsClient metricsClient; |
76 | 76 | private final ScheduledExecutorService executor;
|
77 | 77 | private final ProviderManager providerManager;
|
78 | 78 | private final ExecutorFactory<ScheduledExecutorService> executorFactory;
|
@@ -126,21 +126,24 @@ public DefaultLoggingRpc(LoggingOptions options) throws IOException {
|
126 | 126 | .setExecutorProvider(executorProvider)
|
127 | 127 | .build();
|
128 | 128 | UnaryCallSettings.Builder callSettingsBuilder = internalOptions.getApiCallSettings();
|
129 |
| - ConfigServiceV2Settings.Builder confBuilder = ConfigServiceV2Settings.defaultBuilder() |
130 |
| - .setExecutorProvider(providerManager) |
131 |
| - .setChannelProvider(providerManager) |
132 |
| - .applyToAllUnaryMethods(callSettingsBuilder); |
133 |
| - LoggingServiceV2Settings.Builder logBuilder = LoggingServiceV2Settings.defaultBuilder() |
134 |
| - .setExecutorProvider(providerManager) |
135 |
| - .setChannelProvider(providerManager) |
136 |
| - .applyToAllUnaryMethods(callSettingsBuilder); |
137 |
| - MetricsServiceV2Settings.Builder metricsBuilder = MetricsServiceV2Settings.defaultBuilder() |
138 |
| - .setExecutorProvider(providerManager) |
139 |
| - .setChannelProvider(providerManager) |
140 |
| - .applyToAllUnaryMethods(callSettingsBuilder); |
141 |
| - configClient = ConfigServiceV2Client.create(confBuilder.build()); |
142 |
| - loggingClient = LoggingServiceV2Client.create(logBuilder.build()); |
143 |
| - metricsClient = MetricsServiceV2Client.create(metricsBuilder.build()); |
| 129 | + ConfigSettings.Builder confBuilder = |
| 130 | + ConfigSettings.defaultBuilder() |
| 131 | + .setExecutorProvider(providerManager) |
| 132 | + .setChannelProvider(providerManager) |
| 133 | + .applyToAllUnaryMethods(callSettingsBuilder); |
| 134 | + LoggingSettings.Builder logBuilder = |
| 135 | + LoggingSettings.defaultBuilder() |
| 136 | + .setExecutorProvider(providerManager) |
| 137 | + .setChannelProvider(providerManager) |
| 138 | + .applyToAllUnaryMethods(callSettingsBuilder); |
| 139 | + MetricsSettings.Builder metricsBuilder = |
| 140 | + MetricsSettings.defaultBuilder() |
| 141 | + .setExecutorProvider(providerManager) |
| 142 | + .setChannelProvider(providerManager) |
| 143 | + .applyToAllUnaryMethods(callSettingsBuilder); |
| 144 | + configClient = ConfigClient.create(confBuilder.build()); |
| 145 | + loggingClient = LoggingClient.create(logBuilder.build()); |
| 146 | + metricsClient = MetricsClient.create(metricsBuilder.build()); |
144 | 147 | } catch (Exception ex) {
|
145 | 148 | throw new IOException(ex);
|
146 | 149 | }
|
|
0 commit comments