|
24 | 24 | import com.google.api.gax.grpc.GrpcStubCallableFactory; |
25 | 25 | import com.google.api.gax.rpc.ClientContext; |
26 | 26 | import com.google.api.gax.rpc.OperationCallable; |
27 | | -import com.google.api.gax.rpc.RequestParamsExtractor; |
28 | 27 | import com.google.api.gax.rpc.UnaryCallable; |
29 | 28 | import com.google.cloud.redis.v1.CreateInstanceRequest; |
30 | 29 | import com.google.cloud.redis.v1.DeleteInstanceRequest; |
|
45 | 44 | import io.grpc.MethodDescriptor; |
46 | 45 | import io.grpc.protobuf.ProtoUtils; |
47 | 46 | import java.io.IOException; |
48 | | -import java.util.Map; |
49 | 47 | import java.util.concurrent.TimeUnit; |
50 | 48 | import javax.annotation.Generated; |
51 | 49 |
|
@@ -218,117 +216,90 @@ protected GrpcCloudRedisStub( |
218 | 216 | GrpcCallSettings.<ListInstancesRequest, ListInstancesResponse>newBuilder() |
219 | 217 | .setMethodDescriptor(listInstancesMethodDescriptor) |
220 | 218 | .setParamsExtractor( |
221 | | - new RequestParamsExtractor<ListInstancesRequest>() { |
222 | | - @Override |
223 | | - public Map<String, String> extract(ListInstancesRequest request) { |
224 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
225 | | - params.put("parent", String.valueOf(request.getParent())); |
226 | | - return params.build(); |
227 | | - } |
| 219 | + request -> { |
| 220 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 221 | + params.put("parent", String.valueOf(request.getParent())); |
| 222 | + return params.build(); |
228 | 223 | }) |
229 | 224 | .build(); |
230 | 225 | GrpcCallSettings<GetInstanceRequest, Instance> getInstanceTransportSettings = |
231 | 226 | GrpcCallSettings.<GetInstanceRequest, Instance>newBuilder() |
232 | 227 | .setMethodDescriptor(getInstanceMethodDescriptor) |
233 | 228 | .setParamsExtractor( |
234 | | - new RequestParamsExtractor<GetInstanceRequest>() { |
235 | | - @Override |
236 | | - public Map<String, String> extract(GetInstanceRequest request) { |
237 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
238 | | - params.put("name", String.valueOf(request.getName())); |
239 | | - return params.build(); |
240 | | - } |
| 229 | + request -> { |
| 230 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 231 | + params.put("name", String.valueOf(request.getName())); |
| 232 | + return params.build(); |
241 | 233 | }) |
242 | 234 | .build(); |
243 | 235 | GrpcCallSettings<CreateInstanceRequest, Operation> createInstanceTransportSettings = |
244 | 236 | GrpcCallSettings.<CreateInstanceRequest, Operation>newBuilder() |
245 | 237 | .setMethodDescriptor(createInstanceMethodDescriptor) |
246 | 238 | .setParamsExtractor( |
247 | | - new RequestParamsExtractor<CreateInstanceRequest>() { |
248 | | - @Override |
249 | | - public Map<String, String> extract(CreateInstanceRequest request) { |
250 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
251 | | - params.put("parent", String.valueOf(request.getParent())); |
252 | | - return params.build(); |
253 | | - } |
| 239 | + request -> { |
| 240 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 241 | + params.put("parent", String.valueOf(request.getParent())); |
| 242 | + return params.build(); |
254 | 243 | }) |
255 | 244 | .build(); |
256 | 245 | GrpcCallSettings<UpdateInstanceRequest, Operation> updateInstanceTransportSettings = |
257 | 246 | GrpcCallSettings.<UpdateInstanceRequest, Operation>newBuilder() |
258 | 247 | .setMethodDescriptor(updateInstanceMethodDescriptor) |
259 | 248 | .setParamsExtractor( |
260 | | - new RequestParamsExtractor<UpdateInstanceRequest>() { |
261 | | - @Override |
262 | | - public Map<String, String> extract(UpdateInstanceRequest request) { |
263 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
264 | | - params.put("instance.name", String.valueOf(request.getInstance().getName())); |
265 | | - return params.build(); |
266 | | - } |
| 249 | + request -> { |
| 250 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 251 | + params.put("instance.name", String.valueOf(request.getInstance().getName())); |
| 252 | + return params.build(); |
267 | 253 | }) |
268 | 254 | .build(); |
269 | 255 | GrpcCallSettings<UpgradeInstanceRequest, Operation> upgradeInstanceTransportSettings = |
270 | 256 | GrpcCallSettings.<UpgradeInstanceRequest, Operation>newBuilder() |
271 | 257 | .setMethodDescriptor(upgradeInstanceMethodDescriptor) |
272 | 258 | .setParamsExtractor( |
273 | | - new RequestParamsExtractor<UpgradeInstanceRequest>() { |
274 | | - @Override |
275 | | - public Map<String, String> extract(UpgradeInstanceRequest request) { |
276 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
277 | | - params.put("name", String.valueOf(request.getName())); |
278 | | - return params.build(); |
279 | | - } |
| 259 | + request -> { |
| 260 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 261 | + params.put("name", String.valueOf(request.getName())); |
| 262 | + return params.build(); |
280 | 263 | }) |
281 | 264 | .build(); |
282 | 265 | GrpcCallSettings<ImportInstanceRequest, Operation> importInstanceTransportSettings = |
283 | 266 | GrpcCallSettings.<ImportInstanceRequest, Operation>newBuilder() |
284 | 267 | .setMethodDescriptor(importInstanceMethodDescriptor) |
285 | 268 | .setParamsExtractor( |
286 | | - new RequestParamsExtractor<ImportInstanceRequest>() { |
287 | | - @Override |
288 | | - public Map<String, String> extract(ImportInstanceRequest request) { |
289 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
290 | | - params.put("name", String.valueOf(request.getName())); |
291 | | - return params.build(); |
292 | | - } |
| 269 | + request -> { |
| 270 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 271 | + params.put("name", String.valueOf(request.getName())); |
| 272 | + return params.build(); |
293 | 273 | }) |
294 | 274 | .build(); |
295 | 275 | GrpcCallSettings<ExportInstanceRequest, Operation> exportInstanceTransportSettings = |
296 | 276 | GrpcCallSettings.<ExportInstanceRequest, Operation>newBuilder() |
297 | 277 | .setMethodDescriptor(exportInstanceMethodDescriptor) |
298 | 278 | .setParamsExtractor( |
299 | | - new RequestParamsExtractor<ExportInstanceRequest>() { |
300 | | - @Override |
301 | | - public Map<String, String> extract(ExportInstanceRequest request) { |
302 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
303 | | - params.put("name", String.valueOf(request.getName())); |
304 | | - return params.build(); |
305 | | - } |
| 279 | + request -> { |
| 280 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 281 | + params.put("name", String.valueOf(request.getName())); |
| 282 | + return params.build(); |
306 | 283 | }) |
307 | 284 | .build(); |
308 | 285 | GrpcCallSettings<FailoverInstanceRequest, Operation> failoverInstanceTransportSettings = |
309 | 286 | GrpcCallSettings.<FailoverInstanceRequest, Operation>newBuilder() |
310 | 287 | .setMethodDescriptor(failoverInstanceMethodDescriptor) |
311 | 288 | .setParamsExtractor( |
312 | | - new RequestParamsExtractor<FailoverInstanceRequest>() { |
313 | | - @Override |
314 | | - public Map<String, String> extract(FailoverInstanceRequest request) { |
315 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
316 | | - params.put("name", String.valueOf(request.getName())); |
317 | | - return params.build(); |
318 | | - } |
| 289 | + request -> { |
| 290 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 291 | + params.put("name", String.valueOf(request.getName())); |
| 292 | + return params.build(); |
319 | 293 | }) |
320 | 294 | .build(); |
321 | 295 | GrpcCallSettings<DeleteInstanceRequest, Operation> deleteInstanceTransportSettings = |
322 | 296 | GrpcCallSettings.<DeleteInstanceRequest, Operation>newBuilder() |
323 | 297 | .setMethodDescriptor(deleteInstanceMethodDescriptor) |
324 | 298 | .setParamsExtractor( |
325 | | - new RequestParamsExtractor<DeleteInstanceRequest>() { |
326 | | - @Override |
327 | | - public Map<String, String> extract(DeleteInstanceRequest request) { |
328 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
329 | | - params.put("name", String.valueOf(request.getName())); |
330 | | - return params.build(); |
331 | | - } |
| 299 | + request -> { |
| 300 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 301 | + params.put("name", String.valueOf(request.getName())); |
| 302 | + return params.build(); |
332 | 303 | }) |
333 | 304 | .build(); |
334 | 305 |
|
|
0 commit comments