|
24 | 24 | import com.google.api.gax.grpc.GaxGrpcProperties;
|
25 | 25 | import com.google.api.gax.grpc.GrpcTransportChannel;
|
26 | 26 | import com.google.api.gax.grpc.InstantiatingGrpcChannelProvider;
|
| 27 | +import com.google.api.gax.httpjson.GaxHttpJsonProperties; |
| 28 | +import com.google.api.gax.httpjson.HttpJsonTransportChannel; |
| 29 | +import com.google.api.gax.httpjson.InstantiatingHttpJsonChannelProvider; |
27 | 30 | import com.google.api.gax.retrying.RetrySettings;
|
28 | 31 | import com.google.api.gax.rpc.ApiClientHeaderProvider;
|
29 | 32 | import com.google.api.gax.rpc.ClientContext;
|
@@ -114,13 +117,17 @@ public class Controller2StubSettings extends StubSettings<Controller2StubSetting
|
114 | 117 | return updateActiveBreakpointSettings;
|
115 | 118 | }
|
116 | 119 |
|
117 |
| - @BetaApi("A restructuring of stub classes is planned, so this may break in the future") |
118 | 120 | public Controller2Stub createStub() throws IOException {
|
119 | 121 | if (getTransportChannelProvider()
|
120 | 122 | .getTransportName()
|
121 | 123 | .equals(GrpcTransportChannel.getGrpcTransportName())) {
|
122 | 124 | return GrpcController2Stub.create(this);
|
123 | 125 | }
|
| 126 | + if (getTransportChannelProvider() |
| 127 | + .getTransportName() |
| 128 | + .equals(HttpJsonTransportChannel.getHttpJsonTransportName())) { |
| 129 | + return HttpJsonController2Stub.create(this); |
| 130 | + } |
124 | 131 | throw new UnsupportedOperationException(
|
125 | 132 | String.format(
|
126 | 133 | "Transport not supported: %s", getTransportChannelProvider().getTransportName()));
|
@@ -153,30 +160,56 @@ public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilde
|
153 | 160 | .setUseJwtAccessWithScope(true);
|
154 | 161 | }
|
155 | 162 |
|
156 |
| - /** Returns a builder for the default ChannelProvider for this service. */ |
| 163 | + /** Returns a builder for the default gRPC ChannelProvider for this service. */ |
157 | 164 | public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() {
|
158 | 165 | return InstantiatingGrpcChannelProvider.newBuilder()
|
159 | 166 | .setMaxInboundMessageSize(Integer.MAX_VALUE);
|
160 | 167 | }
|
161 | 168 |
|
| 169 | + /** Returns a builder for the default REST ChannelProvider for this service. */ |
| 170 | + @BetaApi |
| 171 | + public static InstantiatingHttpJsonChannelProvider.Builder |
| 172 | + defaultHttpJsonTransportProviderBuilder() { |
| 173 | + return InstantiatingHttpJsonChannelProvider.newBuilder(); |
| 174 | + } |
| 175 | + |
162 | 176 | public static TransportChannelProvider defaultTransportChannelProvider() {
|
163 | 177 | return defaultGrpcTransportProviderBuilder().build();
|
164 | 178 | }
|
165 | 179 |
|
166 | 180 | @BetaApi("The surface for customizing headers is not stable yet and may change in the future.")
|
167 |
| - public static ApiClientHeaderProvider.Builder defaultApiClientHeaderProviderBuilder() { |
| 181 | + public static ApiClientHeaderProvider.Builder defaultGrpcApiClientHeaderProviderBuilder() { |
168 | 182 | return ApiClientHeaderProvider.newBuilder()
|
169 | 183 | .setGeneratedLibToken(
|
170 | 184 | "gapic", GaxProperties.getLibraryVersion(Controller2StubSettings.class))
|
171 | 185 | .setTransportToken(
|
172 | 186 | GaxGrpcProperties.getGrpcTokenName(), GaxGrpcProperties.getGrpcVersion());
|
173 | 187 | }
|
174 | 188 |
|
175 |
| - /** Returns a new builder for this class. */ |
| 189 | + @BetaApi("The surface for customizing headers is not stable yet and may change in the future.") |
| 190 | + public static ApiClientHeaderProvider.Builder defaultHttpJsonApiClientHeaderProviderBuilder() { |
| 191 | + return ApiClientHeaderProvider.newBuilder() |
| 192 | + .setGeneratedLibToken( |
| 193 | + "gapic", GaxProperties.getLibraryVersion(Controller2StubSettings.class)) |
| 194 | + .setTransportToken( |
| 195 | + GaxHttpJsonProperties.getHttpJsonTokenName(), |
| 196 | + GaxHttpJsonProperties.getHttpJsonVersion()); |
| 197 | + } |
| 198 | + |
| 199 | + public static ApiClientHeaderProvider.Builder defaultApiClientHeaderProviderBuilder() { |
| 200 | + return Controller2StubSettings.defaultGrpcApiClientHeaderProviderBuilder(); |
| 201 | + } |
| 202 | + |
| 203 | + /** Returns a new gRPC builder for this class. */ |
176 | 204 | public static Builder newBuilder() {
|
177 | 205 | return Builder.createDefault();
|
178 | 206 | }
|
179 | 207 |
|
| 208 | + /** Returns a new REST builder for this class. */ |
| 209 | + public static Builder newHttpJsonBuilder() { |
| 210 | + return Builder.createHttpJsonDefault(); |
| 211 | + } |
| 212 | + |
180 | 213 | /** Returns a new builder for this class. */
|
181 | 214 | public static Builder newBuilder(ClientContext clientContext) {
|
182 | 215 | return new Builder(clientContext);
|
@@ -295,6 +328,19 @@ private static Builder createDefault() {
|
295 | 328 | return initDefaults(builder);
|
296 | 329 | }
|
297 | 330 |
|
| 331 | + private static Builder createHttpJsonDefault() { |
| 332 | + Builder builder = new Builder(((ClientContext) null)); |
| 333 | + |
| 334 | + builder.setTransportChannelProvider(defaultHttpJsonTransportProviderBuilder().build()); |
| 335 | + builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build()); |
| 336 | + builder.setInternalHeaderProvider(defaultHttpJsonApiClientHeaderProviderBuilder().build()); |
| 337 | + builder.setEndpoint(getDefaultEndpoint()); |
| 338 | + builder.setMtlsEndpoint(getDefaultMtlsEndpoint()); |
| 339 | + builder.setSwitchToMtlsEndpointAllowed(true); |
| 340 | + |
| 341 | + return initDefaults(builder); |
| 342 | + } |
| 343 | + |
298 | 344 | private static Builder initDefaults(Builder builder) {
|
299 | 345 | builder
|
300 | 346 | .registerDebuggeeSettings()
|
|
0 commit comments