• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright 2020 Google LLC
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *     https://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 package com.google.cloud.dialogflow.cx.v3;
17 
18 import static io.grpc.MethodDescriptor.generateFullMethodName;
19 
20 /**
21  *
22  *
23  * <pre>
24  * Service for managing [Flows][google.cloud.dialogflow.cx.v3.Flow].
25  * </pre>
26  */
27 @javax.annotation.Generated(
28     value = "by gRPC proto compiler",
29     comments = "Source: google/cloud/dialogflow/cx/v3/flow.proto")
30 @io.grpc.stub.annotations.GrpcGenerated
31 public final class FlowsGrpc {
32 
FlowsGrpc()33   private FlowsGrpc() {}
34 
35   public static final String SERVICE_NAME = "google.cloud.dialogflow.cx.v3.Flows";
36 
37   // Static method descriptors that strictly reflect the proto.
38   private static volatile io.grpc.MethodDescriptor<
39           com.google.cloud.dialogflow.cx.v3.CreateFlowRequest,
40           com.google.cloud.dialogflow.cx.v3.Flow>
41       getCreateFlowMethod;
42 
43   @io.grpc.stub.annotations.RpcMethod(
44       fullMethodName = SERVICE_NAME + '/' + "CreateFlow",
45       requestType = com.google.cloud.dialogflow.cx.v3.CreateFlowRequest.class,
46       responseType = com.google.cloud.dialogflow.cx.v3.Flow.class,
47       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
48   public static io.grpc.MethodDescriptor<
49           com.google.cloud.dialogflow.cx.v3.CreateFlowRequest,
50           com.google.cloud.dialogflow.cx.v3.Flow>
getCreateFlowMethod()51       getCreateFlowMethod() {
52     io.grpc.MethodDescriptor<
53             com.google.cloud.dialogflow.cx.v3.CreateFlowRequest,
54             com.google.cloud.dialogflow.cx.v3.Flow>
55         getCreateFlowMethod;
56     if ((getCreateFlowMethod = FlowsGrpc.getCreateFlowMethod) == null) {
57       synchronized (FlowsGrpc.class) {
58         if ((getCreateFlowMethod = FlowsGrpc.getCreateFlowMethod) == null) {
59           FlowsGrpc.getCreateFlowMethod =
60               getCreateFlowMethod =
61                   io.grpc.MethodDescriptor
62                       .<com.google.cloud.dialogflow.cx.v3.CreateFlowRequest,
63                           com.google.cloud.dialogflow.cx.v3.Flow>
64                           newBuilder()
65                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
66                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateFlow"))
67                       .setSampledToLocalTracing(true)
68                       .setRequestMarshaller(
69                           io.grpc.protobuf.ProtoUtils.marshaller(
70                               com.google.cloud.dialogflow.cx.v3.CreateFlowRequest
71                                   .getDefaultInstance()))
72                       .setResponseMarshaller(
73                           io.grpc.protobuf.ProtoUtils.marshaller(
74                               com.google.cloud.dialogflow.cx.v3.Flow.getDefaultInstance()))
75                       .setSchemaDescriptor(new FlowsMethodDescriptorSupplier("CreateFlow"))
76                       .build();
77         }
78       }
79     }
80     return getCreateFlowMethod;
81   }
82 
83   private static volatile io.grpc.MethodDescriptor<
84           com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest, com.google.protobuf.Empty>
85       getDeleteFlowMethod;
86 
87   @io.grpc.stub.annotations.RpcMethod(
88       fullMethodName = SERVICE_NAME + '/' + "DeleteFlow",
89       requestType = com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest.class,
90       responseType = com.google.protobuf.Empty.class,
91       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
92   public static io.grpc.MethodDescriptor<
93           com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest, com.google.protobuf.Empty>
getDeleteFlowMethod()94       getDeleteFlowMethod() {
95     io.grpc.MethodDescriptor<
96             com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest, com.google.protobuf.Empty>
97         getDeleteFlowMethod;
98     if ((getDeleteFlowMethod = FlowsGrpc.getDeleteFlowMethod) == null) {
99       synchronized (FlowsGrpc.class) {
100         if ((getDeleteFlowMethod = FlowsGrpc.getDeleteFlowMethod) == null) {
101           FlowsGrpc.getDeleteFlowMethod =
102               getDeleteFlowMethod =
103                   io.grpc.MethodDescriptor
104                       .<com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest,
105                           com.google.protobuf.Empty>
106                           newBuilder()
107                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
108                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteFlow"))
109                       .setSampledToLocalTracing(true)
110                       .setRequestMarshaller(
111                           io.grpc.protobuf.ProtoUtils.marshaller(
112                               com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest
113                                   .getDefaultInstance()))
114                       .setResponseMarshaller(
115                           io.grpc.protobuf.ProtoUtils.marshaller(
116                               com.google.protobuf.Empty.getDefaultInstance()))
117                       .setSchemaDescriptor(new FlowsMethodDescriptorSupplier("DeleteFlow"))
118                       .build();
119         }
120       }
121     }
122     return getDeleteFlowMethod;
123   }
124 
125   private static volatile io.grpc.MethodDescriptor<
126           com.google.cloud.dialogflow.cx.v3.ListFlowsRequest,
127           com.google.cloud.dialogflow.cx.v3.ListFlowsResponse>
128       getListFlowsMethod;
129 
130   @io.grpc.stub.annotations.RpcMethod(
131       fullMethodName = SERVICE_NAME + '/' + "ListFlows",
132       requestType = com.google.cloud.dialogflow.cx.v3.ListFlowsRequest.class,
133       responseType = com.google.cloud.dialogflow.cx.v3.ListFlowsResponse.class,
134       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
135   public static io.grpc.MethodDescriptor<
136           com.google.cloud.dialogflow.cx.v3.ListFlowsRequest,
137           com.google.cloud.dialogflow.cx.v3.ListFlowsResponse>
getListFlowsMethod()138       getListFlowsMethod() {
139     io.grpc.MethodDescriptor<
140             com.google.cloud.dialogflow.cx.v3.ListFlowsRequest,
141             com.google.cloud.dialogflow.cx.v3.ListFlowsResponse>
142         getListFlowsMethod;
143     if ((getListFlowsMethod = FlowsGrpc.getListFlowsMethod) == null) {
144       synchronized (FlowsGrpc.class) {
145         if ((getListFlowsMethod = FlowsGrpc.getListFlowsMethod) == null) {
146           FlowsGrpc.getListFlowsMethod =
147               getListFlowsMethod =
148                   io.grpc.MethodDescriptor
149                       .<com.google.cloud.dialogflow.cx.v3.ListFlowsRequest,
150                           com.google.cloud.dialogflow.cx.v3.ListFlowsResponse>
151                           newBuilder()
152                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
153                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListFlows"))
154                       .setSampledToLocalTracing(true)
155                       .setRequestMarshaller(
156                           io.grpc.protobuf.ProtoUtils.marshaller(
157                               com.google.cloud.dialogflow.cx.v3.ListFlowsRequest
158                                   .getDefaultInstance()))
159                       .setResponseMarshaller(
160                           io.grpc.protobuf.ProtoUtils.marshaller(
161                               com.google.cloud.dialogflow.cx.v3.ListFlowsResponse
162                                   .getDefaultInstance()))
163                       .setSchemaDescriptor(new FlowsMethodDescriptorSupplier("ListFlows"))
164                       .build();
165         }
166       }
167     }
168     return getListFlowsMethod;
169   }
170 
171   private static volatile io.grpc.MethodDescriptor<
172           com.google.cloud.dialogflow.cx.v3.GetFlowRequest, com.google.cloud.dialogflow.cx.v3.Flow>
173       getGetFlowMethod;
174 
175   @io.grpc.stub.annotations.RpcMethod(
176       fullMethodName = SERVICE_NAME + '/' + "GetFlow",
177       requestType = com.google.cloud.dialogflow.cx.v3.GetFlowRequest.class,
178       responseType = com.google.cloud.dialogflow.cx.v3.Flow.class,
179       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
180   public static io.grpc.MethodDescriptor<
181           com.google.cloud.dialogflow.cx.v3.GetFlowRequest, com.google.cloud.dialogflow.cx.v3.Flow>
getGetFlowMethod()182       getGetFlowMethod() {
183     io.grpc.MethodDescriptor<
184             com.google.cloud.dialogflow.cx.v3.GetFlowRequest,
185             com.google.cloud.dialogflow.cx.v3.Flow>
186         getGetFlowMethod;
187     if ((getGetFlowMethod = FlowsGrpc.getGetFlowMethod) == null) {
188       synchronized (FlowsGrpc.class) {
189         if ((getGetFlowMethod = FlowsGrpc.getGetFlowMethod) == null) {
190           FlowsGrpc.getGetFlowMethod =
191               getGetFlowMethod =
192                   io.grpc.MethodDescriptor
193                       .<com.google.cloud.dialogflow.cx.v3.GetFlowRequest,
194                           com.google.cloud.dialogflow.cx.v3.Flow>
195                           newBuilder()
196                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
197                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetFlow"))
198                       .setSampledToLocalTracing(true)
199                       .setRequestMarshaller(
200                           io.grpc.protobuf.ProtoUtils.marshaller(
201                               com.google.cloud.dialogflow.cx.v3.GetFlowRequest
202                                   .getDefaultInstance()))
203                       .setResponseMarshaller(
204                           io.grpc.protobuf.ProtoUtils.marshaller(
205                               com.google.cloud.dialogflow.cx.v3.Flow.getDefaultInstance()))
206                       .setSchemaDescriptor(new FlowsMethodDescriptorSupplier("GetFlow"))
207                       .build();
208         }
209       }
210     }
211     return getGetFlowMethod;
212   }
213 
214   private static volatile io.grpc.MethodDescriptor<
215           com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest,
216           com.google.cloud.dialogflow.cx.v3.Flow>
217       getUpdateFlowMethod;
218 
219   @io.grpc.stub.annotations.RpcMethod(
220       fullMethodName = SERVICE_NAME + '/' + "UpdateFlow",
221       requestType = com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest.class,
222       responseType = com.google.cloud.dialogflow.cx.v3.Flow.class,
223       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
224   public static io.grpc.MethodDescriptor<
225           com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest,
226           com.google.cloud.dialogflow.cx.v3.Flow>
getUpdateFlowMethod()227       getUpdateFlowMethod() {
228     io.grpc.MethodDescriptor<
229             com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest,
230             com.google.cloud.dialogflow.cx.v3.Flow>
231         getUpdateFlowMethod;
232     if ((getUpdateFlowMethod = FlowsGrpc.getUpdateFlowMethod) == null) {
233       synchronized (FlowsGrpc.class) {
234         if ((getUpdateFlowMethod = FlowsGrpc.getUpdateFlowMethod) == null) {
235           FlowsGrpc.getUpdateFlowMethod =
236               getUpdateFlowMethod =
237                   io.grpc.MethodDescriptor
238                       .<com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest,
239                           com.google.cloud.dialogflow.cx.v3.Flow>
240                           newBuilder()
241                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
242                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateFlow"))
243                       .setSampledToLocalTracing(true)
244                       .setRequestMarshaller(
245                           io.grpc.protobuf.ProtoUtils.marshaller(
246                               com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest
247                                   .getDefaultInstance()))
248                       .setResponseMarshaller(
249                           io.grpc.protobuf.ProtoUtils.marshaller(
250                               com.google.cloud.dialogflow.cx.v3.Flow.getDefaultInstance()))
251                       .setSchemaDescriptor(new FlowsMethodDescriptorSupplier("UpdateFlow"))
252                       .build();
253         }
254       }
255     }
256     return getUpdateFlowMethod;
257   }
258 
259   private static volatile io.grpc.MethodDescriptor<
260           com.google.cloud.dialogflow.cx.v3.TrainFlowRequest, com.google.longrunning.Operation>
261       getTrainFlowMethod;
262 
263   @io.grpc.stub.annotations.RpcMethod(
264       fullMethodName = SERVICE_NAME + '/' + "TrainFlow",
265       requestType = com.google.cloud.dialogflow.cx.v3.TrainFlowRequest.class,
266       responseType = com.google.longrunning.Operation.class,
267       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
268   public static io.grpc.MethodDescriptor<
269           com.google.cloud.dialogflow.cx.v3.TrainFlowRequest, com.google.longrunning.Operation>
getTrainFlowMethod()270       getTrainFlowMethod() {
271     io.grpc.MethodDescriptor<
272             com.google.cloud.dialogflow.cx.v3.TrainFlowRequest, com.google.longrunning.Operation>
273         getTrainFlowMethod;
274     if ((getTrainFlowMethod = FlowsGrpc.getTrainFlowMethod) == null) {
275       synchronized (FlowsGrpc.class) {
276         if ((getTrainFlowMethod = FlowsGrpc.getTrainFlowMethod) == null) {
277           FlowsGrpc.getTrainFlowMethod =
278               getTrainFlowMethod =
279                   io.grpc.MethodDescriptor
280                       .<com.google.cloud.dialogflow.cx.v3.TrainFlowRequest,
281                           com.google.longrunning.Operation>
282                           newBuilder()
283                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
284                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "TrainFlow"))
285                       .setSampledToLocalTracing(true)
286                       .setRequestMarshaller(
287                           io.grpc.protobuf.ProtoUtils.marshaller(
288                               com.google.cloud.dialogflow.cx.v3.TrainFlowRequest
289                                   .getDefaultInstance()))
290                       .setResponseMarshaller(
291                           io.grpc.protobuf.ProtoUtils.marshaller(
292                               com.google.longrunning.Operation.getDefaultInstance()))
293                       .setSchemaDescriptor(new FlowsMethodDescriptorSupplier("TrainFlow"))
294                       .build();
295         }
296       }
297     }
298     return getTrainFlowMethod;
299   }
300 
301   private static volatile io.grpc.MethodDescriptor<
302           com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest,
303           com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
304       getValidateFlowMethod;
305 
306   @io.grpc.stub.annotations.RpcMethod(
307       fullMethodName = SERVICE_NAME + '/' + "ValidateFlow",
308       requestType = com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest.class,
309       responseType = com.google.cloud.dialogflow.cx.v3.FlowValidationResult.class,
310       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
311   public static io.grpc.MethodDescriptor<
312           com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest,
313           com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
getValidateFlowMethod()314       getValidateFlowMethod() {
315     io.grpc.MethodDescriptor<
316             com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest,
317             com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
318         getValidateFlowMethod;
319     if ((getValidateFlowMethod = FlowsGrpc.getValidateFlowMethod) == null) {
320       synchronized (FlowsGrpc.class) {
321         if ((getValidateFlowMethod = FlowsGrpc.getValidateFlowMethod) == null) {
322           FlowsGrpc.getValidateFlowMethod =
323               getValidateFlowMethod =
324                   io.grpc.MethodDescriptor
325                       .<com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest,
326                           com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
327                           newBuilder()
328                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
329                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ValidateFlow"))
330                       .setSampledToLocalTracing(true)
331                       .setRequestMarshaller(
332                           io.grpc.protobuf.ProtoUtils.marshaller(
333                               com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest
334                                   .getDefaultInstance()))
335                       .setResponseMarshaller(
336                           io.grpc.protobuf.ProtoUtils.marshaller(
337                               com.google.cloud.dialogflow.cx.v3.FlowValidationResult
338                                   .getDefaultInstance()))
339                       .setSchemaDescriptor(new FlowsMethodDescriptorSupplier("ValidateFlow"))
340                       .build();
341         }
342       }
343     }
344     return getValidateFlowMethod;
345   }
346 
347   private static volatile io.grpc.MethodDescriptor<
348           com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest,
349           com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
350       getGetFlowValidationResultMethod;
351 
352   @io.grpc.stub.annotations.RpcMethod(
353       fullMethodName = SERVICE_NAME + '/' + "GetFlowValidationResult",
354       requestType = com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest.class,
355       responseType = com.google.cloud.dialogflow.cx.v3.FlowValidationResult.class,
356       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
357   public static io.grpc.MethodDescriptor<
358           com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest,
359           com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
getGetFlowValidationResultMethod()360       getGetFlowValidationResultMethod() {
361     io.grpc.MethodDescriptor<
362             com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest,
363             com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
364         getGetFlowValidationResultMethod;
365     if ((getGetFlowValidationResultMethod = FlowsGrpc.getGetFlowValidationResultMethod) == null) {
366       synchronized (FlowsGrpc.class) {
367         if ((getGetFlowValidationResultMethod = FlowsGrpc.getGetFlowValidationResultMethod)
368             == null) {
369           FlowsGrpc.getGetFlowValidationResultMethod =
370               getGetFlowValidationResultMethod =
371                   io.grpc.MethodDescriptor
372                       .<com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest,
373                           com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
374                           newBuilder()
375                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
376                       .setFullMethodName(
377                           generateFullMethodName(SERVICE_NAME, "GetFlowValidationResult"))
378                       .setSampledToLocalTracing(true)
379                       .setRequestMarshaller(
380                           io.grpc.protobuf.ProtoUtils.marshaller(
381                               com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest
382                                   .getDefaultInstance()))
383                       .setResponseMarshaller(
384                           io.grpc.protobuf.ProtoUtils.marshaller(
385                               com.google.cloud.dialogflow.cx.v3.FlowValidationResult
386                                   .getDefaultInstance()))
387                       .setSchemaDescriptor(
388                           new FlowsMethodDescriptorSupplier("GetFlowValidationResult"))
389                       .build();
390         }
391       }
392     }
393     return getGetFlowValidationResultMethod;
394   }
395 
396   private static volatile io.grpc.MethodDescriptor<
397           com.google.cloud.dialogflow.cx.v3.ImportFlowRequest, com.google.longrunning.Operation>
398       getImportFlowMethod;
399 
400   @io.grpc.stub.annotations.RpcMethod(
401       fullMethodName = SERVICE_NAME + '/' + "ImportFlow",
402       requestType = com.google.cloud.dialogflow.cx.v3.ImportFlowRequest.class,
403       responseType = com.google.longrunning.Operation.class,
404       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
405   public static io.grpc.MethodDescriptor<
406           com.google.cloud.dialogflow.cx.v3.ImportFlowRequest, com.google.longrunning.Operation>
getImportFlowMethod()407       getImportFlowMethod() {
408     io.grpc.MethodDescriptor<
409             com.google.cloud.dialogflow.cx.v3.ImportFlowRequest, com.google.longrunning.Operation>
410         getImportFlowMethod;
411     if ((getImportFlowMethod = FlowsGrpc.getImportFlowMethod) == null) {
412       synchronized (FlowsGrpc.class) {
413         if ((getImportFlowMethod = FlowsGrpc.getImportFlowMethod) == null) {
414           FlowsGrpc.getImportFlowMethod =
415               getImportFlowMethod =
416                   io.grpc.MethodDescriptor
417                       .<com.google.cloud.dialogflow.cx.v3.ImportFlowRequest,
418                           com.google.longrunning.Operation>
419                           newBuilder()
420                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
421                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ImportFlow"))
422                       .setSampledToLocalTracing(true)
423                       .setRequestMarshaller(
424                           io.grpc.protobuf.ProtoUtils.marshaller(
425                               com.google.cloud.dialogflow.cx.v3.ImportFlowRequest
426                                   .getDefaultInstance()))
427                       .setResponseMarshaller(
428                           io.grpc.protobuf.ProtoUtils.marshaller(
429                               com.google.longrunning.Operation.getDefaultInstance()))
430                       .setSchemaDescriptor(new FlowsMethodDescriptorSupplier("ImportFlow"))
431                       .build();
432         }
433       }
434     }
435     return getImportFlowMethod;
436   }
437 
438   private static volatile io.grpc.MethodDescriptor<
439           com.google.cloud.dialogflow.cx.v3.ExportFlowRequest, com.google.longrunning.Operation>
440       getExportFlowMethod;
441 
442   @io.grpc.stub.annotations.RpcMethod(
443       fullMethodName = SERVICE_NAME + '/' + "ExportFlow",
444       requestType = com.google.cloud.dialogflow.cx.v3.ExportFlowRequest.class,
445       responseType = com.google.longrunning.Operation.class,
446       methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
447   public static io.grpc.MethodDescriptor<
448           com.google.cloud.dialogflow.cx.v3.ExportFlowRequest, com.google.longrunning.Operation>
getExportFlowMethod()449       getExportFlowMethod() {
450     io.grpc.MethodDescriptor<
451             com.google.cloud.dialogflow.cx.v3.ExportFlowRequest, com.google.longrunning.Operation>
452         getExportFlowMethod;
453     if ((getExportFlowMethod = FlowsGrpc.getExportFlowMethod) == null) {
454       synchronized (FlowsGrpc.class) {
455         if ((getExportFlowMethod = FlowsGrpc.getExportFlowMethod) == null) {
456           FlowsGrpc.getExportFlowMethod =
457               getExportFlowMethod =
458                   io.grpc.MethodDescriptor
459                       .<com.google.cloud.dialogflow.cx.v3.ExportFlowRequest,
460                           com.google.longrunning.Operation>
461                           newBuilder()
462                       .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
463                       .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ExportFlow"))
464                       .setSampledToLocalTracing(true)
465                       .setRequestMarshaller(
466                           io.grpc.protobuf.ProtoUtils.marshaller(
467                               com.google.cloud.dialogflow.cx.v3.ExportFlowRequest
468                                   .getDefaultInstance()))
469                       .setResponseMarshaller(
470                           io.grpc.protobuf.ProtoUtils.marshaller(
471                               com.google.longrunning.Operation.getDefaultInstance()))
472                       .setSchemaDescriptor(new FlowsMethodDescriptorSupplier("ExportFlow"))
473                       .build();
474         }
475       }
476     }
477     return getExportFlowMethod;
478   }
479 
480   /** Creates a new async stub that supports all call types for the service */
newStub(io.grpc.Channel channel)481   public static FlowsStub newStub(io.grpc.Channel channel) {
482     io.grpc.stub.AbstractStub.StubFactory<FlowsStub> factory =
483         new io.grpc.stub.AbstractStub.StubFactory<FlowsStub>() {
484           @java.lang.Override
485           public FlowsStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
486             return new FlowsStub(channel, callOptions);
487           }
488         };
489     return FlowsStub.newStub(factory, channel);
490   }
491 
492   /**
493    * Creates a new blocking-style stub that supports unary and streaming output calls on the service
494    */
newBlockingStub(io.grpc.Channel channel)495   public static FlowsBlockingStub newBlockingStub(io.grpc.Channel channel) {
496     io.grpc.stub.AbstractStub.StubFactory<FlowsBlockingStub> factory =
497         new io.grpc.stub.AbstractStub.StubFactory<FlowsBlockingStub>() {
498           @java.lang.Override
499           public FlowsBlockingStub newStub(
500               io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
501             return new FlowsBlockingStub(channel, callOptions);
502           }
503         };
504     return FlowsBlockingStub.newStub(factory, channel);
505   }
506 
507   /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
newFutureStub(io.grpc.Channel channel)508   public static FlowsFutureStub newFutureStub(io.grpc.Channel channel) {
509     io.grpc.stub.AbstractStub.StubFactory<FlowsFutureStub> factory =
510         new io.grpc.stub.AbstractStub.StubFactory<FlowsFutureStub>() {
511           @java.lang.Override
512           public FlowsFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
513             return new FlowsFutureStub(channel, callOptions);
514           }
515         };
516     return FlowsFutureStub.newStub(factory, channel);
517   }
518 
519   /**
520    *
521    *
522    * <pre>
523    * Service for managing [Flows][google.cloud.dialogflow.cx.v3.Flow].
524    * </pre>
525    */
526   public interface AsyncService {
527 
528     /**
529      *
530      *
531      * <pre>
532      * Creates a flow in the specified agent.
533      * Note: You should always train a flow prior to sending it queries. See the
534      * [training
535      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
536      * </pre>
537      */
createFlow( com.google.cloud.dialogflow.cx.v3.CreateFlowRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver)538     default void createFlow(
539         com.google.cloud.dialogflow.cx.v3.CreateFlowRequest request,
540         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver) {
541       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateFlowMethod(), responseObserver);
542     }
543 
544     /**
545      *
546      *
547      * <pre>
548      * Deletes a specified flow.
549      * </pre>
550      */
deleteFlow( com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)551     default void deleteFlow(
552         com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest request,
553         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
554       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDeleteFlowMethod(), responseObserver);
555     }
556 
557     /**
558      *
559      *
560      * <pre>
561      * Returns the list of all flows in the specified agent.
562      * </pre>
563      */
listFlows( com.google.cloud.dialogflow.cx.v3.ListFlowsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.ListFlowsResponse> responseObserver)564     default void listFlows(
565         com.google.cloud.dialogflow.cx.v3.ListFlowsRequest request,
566         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.ListFlowsResponse>
567             responseObserver) {
568       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListFlowsMethod(), responseObserver);
569     }
570 
571     /**
572      *
573      *
574      * <pre>
575      * Retrieves the specified flow.
576      * </pre>
577      */
getFlow( com.google.cloud.dialogflow.cx.v3.GetFlowRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver)578     default void getFlow(
579         com.google.cloud.dialogflow.cx.v3.GetFlowRequest request,
580         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver) {
581       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetFlowMethod(), responseObserver);
582     }
583 
584     /**
585      *
586      *
587      * <pre>
588      * Updates the specified flow.
589      * Note: You should always train a flow prior to sending it queries. See the
590      * [training
591      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
592      * </pre>
593      */
updateFlow( com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver)594     default void updateFlow(
595         com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest request,
596         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver) {
597       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getUpdateFlowMethod(), responseObserver);
598     }
599 
600     /**
601      *
602      *
603      * <pre>
604      * Trains the specified flow. Note that only the flow in 'draft' environment
605      * is trained.
606      * This method is a [long-running
607      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
608      * The returned `Operation` type has the following method-specific fields:
609      * - `metadata`: An empty [Struct
610      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
611      * - `response`: An [Empty
612      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#empty)
613      * Note: You should always train a flow prior to sending it queries. See the
614      * [training
615      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
616      * </pre>
617      */
trainFlow( com.google.cloud.dialogflow.cx.v3.TrainFlowRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)618     default void trainFlow(
619         com.google.cloud.dialogflow.cx.v3.TrainFlowRequest request,
620         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
621       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getTrainFlowMethod(), responseObserver);
622     }
623 
624     /**
625      *
626      *
627      * <pre>
628      * Validates the specified flow and creates or updates validation results.
629      * Please call this API after the training is completed to get the complete
630      * validation results.
631      * </pre>
632      */
validateFlow( com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult> responseObserver)633     default void validateFlow(
634         com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest request,
635         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
636             responseObserver) {
637       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
638           getValidateFlowMethod(), responseObserver);
639     }
640 
641     /**
642      *
643      *
644      * <pre>
645      * Gets the latest flow validation result. Flow validation is performed
646      * when ValidateFlow is called.
647      * </pre>
648      */
getFlowValidationResult( com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult> responseObserver)649     default void getFlowValidationResult(
650         com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest request,
651         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
652             responseObserver) {
653       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
654           getGetFlowValidationResultMethod(), responseObserver);
655     }
656 
657     /**
658      *
659      *
660      * <pre>
661      * Imports the specified flow to the specified agent from a binary file.
662      * This method is a [long-running
663      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
664      * The returned `Operation` type has the following method-specific fields:
665      * - `metadata`: An empty [Struct
666      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
667      * - `response`:
668      * [ImportFlowResponse][google.cloud.dialogflow.cx.v3.ImportFlowResponse]
669      * Note: You should always train a flow prior to sending it queries. See the
670      * [training
671      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
672      * </pre>
673      */
importFlow( com.google.cloud.dialogflow.cx.v3.ImportFlowRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)674     default void importFlow(
675         com.google.cloud.dialogflow.cx.v3.ImportFlowRequest request,
676         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
677       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getImportFlowMethod(), responseObserver);
678     }
679 
680     /**
681      *
682      *
683      * <pre>
684      * Exports the specified flow to a binary file.
685      * This method is a [long-running
686      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
687      * The returned `Operation` type has the following method-specific fields:
688      * - `metadata`: An empty [Struct
689      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
690      * - `response`:
691      * [ExportFlowResponse][google.cloud.dialogflow.cx.v3.ExportFlowResponse]
692      * Note that resources (e.g. intents, entities, webhooks) that the flow
693      * references will also be exported.
694      * </pre>
695      */
exportFlow( com.google.cloud.dialogflow.cx.v3.ExportFlowRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)696     default void exportFlow(
697         com.google.cloud.dialogflow.cx.v3.ExportFlowRequest request,
698         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
699       io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getExportFlowMethod(), responseObserver);
700     }
701   }
702 
703   /**
704    * Base class for the server implementation of the service Flows.
705    *
706    * <pre>
707    * Service for managing [Flows][google.cloud.dialogflow.cx.v3.Flow].
708    * </pre>
709    */
710   public abstract static class FlowsImplBase implements io.grpc.BindableService, AsyncService {
711 
712     @java.lang.Override
bindService()713     public final io.grpc.ServerServiceDefinition bindService() {
714       return FlowsGrpc.bindService(this);
715     }
716   }
717 
718   /**
719    * A stub to allow clients to do asynchronous rpc calls to service Flows.
720    *
721    * <pre>
722    * Service for managing [Flows][google.cloud.dialogflow.cx.v3.Flow].
723    * </pre>
724    */
725   public static final class FlowsStub extends io.grpc.stub.AbstractAsyncStub<FlowsStub> {
FlowsStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)726     private FlowsStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
727       super(channel, callOptions);
728     }
729 
730     @java.lang.Override
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)731     protected FlowsStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
732       return new FlowsStub(channel, callOptions);
733     }
734 
735     /**
736      *
737      *
738      * <pre>
739      * Creates a flow in the specified agent.
740      * Note: You should always train a flow prior to sending it queries. See the
741      * [training
742      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
743      * </pre>
744      */
createFlow( com.google.cloud.dialogflow.cx.v3.CreateFlowRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver)745     public void createFlow(
746         com.google.cloud.dialogflow.cx.v3.CreateFlowRequest request,
747         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver) {
748       io.grpc.stub.ClientCalls.asyncUnaryCall(
749           getChannel().newCall(getCreateFlowMethod(), getCallOptions()), request, responseObserver);
750     }
751 
752     /**
753      *
754      *
755      * <pre>
756      * Deletes a specified flow.
757      * </pre>
758      */
deleteFlow( com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)759     public void deleteFlow(
760         com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest request,
761         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
762       io.grpc.stub.ClientCalls.asyncUnaryCall(
763           getChannel().newCall(getDeleteFlowMethod(), getCallOptions()), request, responseObserver);
764     }
765 
766     /**
767      *
768      *
769      * <pre>
770      * Returns the list of all flows in the specified agent.
771      * </pre>
772      */
listFlows( com.google.cloud.dialogflow.cx.v3.ListFlowsRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.ListFlowsResponse> responseObserver)773     public void listFlows(
774         com.google.cloud.dialogflow.cx.v3.ListFlowsRequest request,
775         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.ListFlowsResponse>
776             responseObserver) {
777       io.grpc.stub.ClientCalls.asyncUnaryCall(
778           getChannel().newCall(getListFlowsMethod(), getCallOptions()), request, responseObserver);
779     }
780 
781     /**
782      *
783      *
784      * <pre>
785      * Retrieves the specified flow.
786      * </pre>
787      */
getFlow( com.google.cloud.dialogflow.cx.v3.GetFlowRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver)788     public void getFlow(
789         com.google.cloud.dialogflow.cx.v3.GetFlowRequest request,
790         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver) {
791       io.grpc.stub.ClientCalls.asyncUnaryCall(
792           getChannel().newCall(getGetFlowMethod(), getCallOptions()), request, responseObserver);
793     }
794 
795     /**
796      *
797      *
798      * <pre>
799      * Updates the specified flow.
800      * Note: You should always train a flow prior to sending it queries. See the
801      * [training
802      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
803      * </pre>
804      */
updateFlow( com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver)805     public void updateFlow(
806         com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest request,
807         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow> responseObserver) {
808       io.grpc.stub.ClientCalls.asyncUnaryCall(
809           getChannel().newCall(getUpdateFlowMethod(), getCallOptions()), request, responseObserver);
810     }
811 
812     /**
813      *
814      *
815      * <pre>
816      * Trains the specified flow. Note that only the flow in 'draft' environment
817      * is trained.
818      * This method is a [long-running
819      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
820      * The returned `Operation` type has the following method-specific fields:
821      * - `metadata`: An empty [Struct
822      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
823      * - `response`: An [Empty
824      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#empty)
825      * Note: You should always train a flow prior to sending it queries. See the
826      * [training
827      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
828      * </pre>
829      */
trainFlow( com.google.cloud.dialogflow.cx.v3.TrainFlowRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)830     public void trainFlow(
831         com.google.cloud.dialogflow.cx.v3.TrainFlowRequest request,
832         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
833       io.grpc.stub.ClientCalls.asyncUnaryCall(
834           getChannel().newCall(getTrainFlowMethod(), getCallOptions()), request, responseObserver);
835     }
836 
837     /**
838      *
839      *
840      * <pre>
841      * Validates the specified flow and creates or updates validation results.
842      * Please call this API after the training is completed to get the complete
843      * validation results.
844      * </pre>
845      */
validateFlow( com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult> responseObserver)846     public void validateFlow(
847         com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest request,
848         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
849             responseObserver) {
850       io.grpc.stub.ClientCalls.asyncUnaryCall(
851           getChannel().newCall(getValidateFlowMethod(), getCallOptions()),
852           request,
853           responseObserver);
854     }
855 
856     /**
857      *
858      *
859      * <pre>
860      * Gets the latest flow validation result. Flow validation is performed
861      * when ValidateFlow is called.
862      * </pre>
863      */
getFlowValidationResult( com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest request, io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult> responseObserver)864     public void getFlowValidationResult(
865         com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest request,
866         io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
867             responseObserver) {
868       io.grpc.stub.ClientCalls.asyncUnaryCall(
869           getChannel().newCall(getGetFlowValidationResultMethod(), getCallOptions()),
870           request,
871           responseObserver);
872     }
873 
874     /**
875      *
876      *
877      * <pre>
878      * Imports the specified flow to the specified agent from a binary file.
879      * This method is a [long-running
880      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
881      * The returned `Operation` type has the following method-specific fields:
882      * - `metadata`: An empty [Struct
883      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
884      * - `response`:
885      * [ImportFlowResponse][google.cloud.dialogflow.cx.v3.ImportFlowResponse]
886      * Note: You should always train a flow prior to sending it queries. See the
887      * [training
888      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
889      * </pre>
890      */
importFlow( com.google.cloud.dialogflow.cx.v3.ImportFlowRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)891     public void importFlow(
892         com.google.cloud.dialogflow.cx.v3.ImportFlowRequest request,
893         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
894       io.grpc.stub.ClientCalls.asyncUnaryCall(
895           getChannel().newCall(getImportFlowMethod(), getCallOptions()), request, responseObserver);
896     }
897 
898     /**
899      *
900      *
901      * <pre>
902      * Exports the specified flow to a binary file.
903      * This method is a [long-running
904      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
905      * The returned `Operation` type has the following method-specific fields:
906      * - `metadata`: An empty [Struct
907      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
908      * - `response`:
909      * [ExportFlowResponse][google.cloud.dialogflow.cx.v3.ExportFlowResponse]
910      * Note that resources (e.g. intents, entities, webhooks) that the flow
911      * references will also be exported.
912      * </pre>
913      */
exportFlow( com.google.cloud.dialogflow.cx.v3.ExportFlowRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)914     public void exportFlow(
915         com.google.cloud.dialogflow.cx.v3.ExportFlowRequest request,
916         io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) {
917       io.grpc.stub.ClientCalls.asyncUnaryCall(
918           getChannel().newCall(getExportFlowMethod(), getCallOptions()), request, responseObserver);
919     }
920   }
921 
922   /**
923    * A stub to allow clients to do synchronous rpc calls to service Flows.
924    *
925    * <pre>
926    * Service for managing [Flows][google.cloud.dialogflow.cx.v3.Flow].
927    * </pre>
928    */
929   public static final class FlowsBlockingStub
930       extends io.grpc.stub.AbstractBlockingStub<FlowsBlockingStub> {
FlowsBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)931     private FlowsBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
932       super(channel, callOptions);
933     }
934 
935     @java.lang.Override
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)936     protected FlowsBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
937       return new FlowsBlockingStub(channel, callOptions);
938     }
939 
940     /**
941      *
942      *
943      * <pre>
944      * Creates a flow in the specified agent.
945      * Note: You should always train a flow prior to sending it queries. See the
946      * [training
947      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
948      * </pre>
949      */
createFlow( com.google.cloud.dialogflow.cx.v3.CreateFlowRequest request)950     public com.google.cloud.dialogflow.cx.v3.Flow createFlow(
951         com.google.cloud.dialogflow.cx.v3.CreateFlowRequest request) {
952       return io.grpc.stub.ClientCalls.blockingUnaryCall(
953           getChannel(), getCreateFlowMethod(), getCallOptions(), request);
954     }
955 
956     /**
957      *
958      *
959      * <pre>
960      * Deletes a specified flow.
961      * </pre>
962      */
deleteFlow( com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest request)963     public com.google.protobuf.Empty deleteFlow(
964         com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest request) {
965       return io.grpc.stub.ClientCalls.blockingUnaryCall(
966           getChannel(), getDeleteFlowMethod(), getCallOptions(), request);
967     }
968 
969     /**
970      *
971      *
972      * <pre>
973      * Returns the list of all flows in the specified agent.
974      * </pre>
975      */
listFlows( com.google.cloud.dialogflow.cx.v3.ListFlowsRequest request)976     public com.google.cloud.dialogflow.cx.v3.ListFlowsResponse listFlows(
977         com.google.cloud.dialogflow.cx.v3.ListFlowsRequest request) {
978       return io.grpc.stub.ClientCalls.blockingUnaryCall(
979           getChannel(), getListFlowsMethod(), getCallOptions(), request);
980     }
981 
982     /**
983      *
984      *
985      * <pre>
986      * Retrieves the specified flow.
987      * </pre>
988      */
getFlow( com.google.cloud.dialogflow.cx.v3.GetFlowRequest request)989     public com.google.cloud.dialogflow.cx.v3.Flow getFlow(
990         com.google.cloud.dialogflow.cx.v3.GetFlowRequest request) {
991       return io.grpc.stub.ClientCalls.blockingUnaryCall(
992           getChannel(), getGetFlowMethod(), getCallOptions(), request);
993     }
994 
995     /**
996      *
997      *
998      * <pre>
999      * Updates the specified flow.
1000      * Note: You should always train a flow prior to sending it queries. See the
1001      * [training
1002      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
1003      * </pre>
1004      */
updateFlow( com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest request)1005     public com.google.cloud.dialogflow.cx.v3.Flow updateFlow(
1006         com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest request) {
1007       return io.grpc.stub.ClientCalls.blockingUnaryCall(
1008           getChannel(), getUpdateFlowMethod(), getCallOptions(), request);
1009     }
1010 
1011     /**
1012      *
1013      *
1014      * <pre>
1015      * Trains the specified flow. Note that only the flow in 'draft' environment
1016      * is trained.
1017      * This method is a [long-running
1018      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
1019      * The returned `Operation` type has the following method-specific fields:
1020      * - `metadata`: An empty [Struct
1021      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
1022      * - `response`: An [Empty
1023      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#empty)
1024      * Note: You should always train a flow prior to sending it queries. See the
1025      * [training
1026      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
1027      * </pre>
1028      */
trainFlow( com.google.cloud.dialogflow.cx.v3.TrainFlowRequest request)1029     public com.google.longrunning.Operation trainFlow(
1030         com.google.cloud.dialogflow.cx.v3.TrainFlowRequest request) {
1031       return io.grpc.stub.ClientCalls.blockingUnaryCall(
1032           getChannel(), getTrainFlowMethod(), getCallOptions(), request);
1033     }
1034 
1035     /**
1036      *
1037      *
1038      * <pre>
1039      * Validates the specified flow and creates or updates validation results.
1040      * Please call this API after the training is completed to get the complete
1041      * validation results.
1042      * </pre>
1043      */
validateFlow( com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest request)1044     public com.google.cloud.dialogflow.cx.v3.FlowValidationResult validateFlow(
1045         com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest request) {
1046       return io.grpc.stub.ClientCalls.blockingUnaryCall(
1047           getChannel(), getValidateFlowMethod(), getCallOptions(), request);
1048     }
1049 
1050     /**
1051      *
1052      *
1053      * <pre>
1054      * Gets the latest flow validation result. Flow validation is performed
1055      * when ValidateFlow is called.
1056      * </pre>
1057      */
getFlowValidationResult( com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest request)1058     public com.google.cloud.dialogflow.cx.v3.FlowValidationResult getFlowValidationResult(
1059         com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest request) {
1060       return io.grpc.stub.ClientCalls.blockingUnaryCall(
1061           getChannel(), getGetFlowValidationResultMethod(), getCallOptions(), request);
1062     }
1063 
1064     /**
1065      *
1066      *
1067      * <pre>
1068      * Imports the specified flow to the specified agent from a binary file.
1069      * This method is a [long-running
1070      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
1071      * The returned `Operation` type has the following method-specific fields:
1072      * - `metadata`: An empty [Struct
1073      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
1074      * - `response`:
1075      * [ImportFlowResponse][google.cloud.dialogflow.cx.v3.ImportFlowResponse]
1076      * Note: You should always train a flow prior to sending it queries. See the
1077      * [training
1078      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
1079      * </pre>
1080      */
importFlow( com.google.cloud.dialogflow.cx.v3.ImportFlowRequest request)1081     public com.google.longrunning.Operation importFlow(
1082         com.google.cloud.dialogflow.cx.v3.ImportFlowRequest request) {
1083       return io.grpc.stub.ClientCalls.blockingUnaryCall(
1084           getChannel(), getImportFlowMethod(), getCallOptions(), request);
1085     }
1086 
1087     /**
1088      *
1089      *
1090      * <pre>
1091      * Exports the specified flow to a binary file.
1092      * This method is a [long-running
1093      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
1094      * The returned `Operation` type has the following method-specific fields:
1095      * - `metadata`: An empty [Struct
1096      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
1097      * - `response`:
1098      * [ExportFlowResponse][google.cloud.dialogflow.cx.v3.ExportFlowResponse]
1099      * Note that resources (e.g. intents, entities, webhooks) that the flow
1100      * references will also be exported.
1101      * </pre>
1102      */
exportFlow( com.google.cloud.dialogflow.cx.v3.ExportFlowRequest request)1103     public com.google.longrunning.Operation exportFlow(
1104         com.google.cloud.dialogflow.cx.v3.ExportFlowRequest request) {
1105       return io.grpc.stub.ClientCalls.blockingUnaryCall(
1106           getChannel(), getExportFlowMethod(), getCallOptions(), request);
1107     }
1108   }
1109 
1110   /**
1111    * A stub to allow clients to do ListenableFuture-style rpc calls to service Flows.
1112    *
1113    * <pre>
1114    * Service for managing [Flows][google.cloud.dialogflow.cx.v3.Flow].
1115    * </pre>
1116    */
1117   public static final class FlowsFutureStub
1118       extends io.grpc.stub.AbstractFutureStub<FlowsFutureStub> {
FlowsFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)1119     private FlowsFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
1120       super(channel, callOptions);
1121     }
1122 
1123     @java.lang.Override
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)1124     protected FlowsFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
1125       return new FlowsFutureStub(channel, callOptions);
1126     }
1127 
1128     /**
1129      *
1130      *
1131      * <pre>
1132      * Creates a flow in the specified agent.
1133      * Note: You should always train a flow prior to sending it queries. See the
1134      * [training
1135      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
1136      * </pre>
1137      */
1138     public com.google.common.util.concurrent.ListenableFuture<
1139             com.google.cloud.dialogflow.cx.v3.Flow>
createFlow(com.google.cloud.dialogflow.cx.v3.CreateFlowRequest request)1140         createFlow(com.google.cloud.dialogflow.cx.v3.CreateFlowRequest request) {
1141       return io.grpc.stub.ClientCalls.futureUnaryCall(
1142           getChannel().newCall(getCreateFlowMethod(), getCallOptions()), request);
1143     }
1144 
1145     /**
1146      *
1147      *
1148      * <pre>
1149      * Deletes a specified flow.
1150      * </pre>
1151      */
deleteFlow( com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest request)1152     public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteFlow(
1153         com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest request) {
1154       return io.grpc.stub.ClientCalls.futureUnaryCall(
1155           getChannel().newCall(getDeleteFlowMethod(), getCallOptions()), request);
1156     }
1157 
1158     /**
1159      *
1160      *
1161      * <pre>
1162      * Returns the list of all flows in the specified agent.
1163      * </pre>
1164      */
1165     public com.google.common.util.concurrent.ListenableFuture<
1166             com.google.cloud.dialogflow.cx.v3.ListFlowsResponse>
listFlows(com.google.cloud.dialogflow.cx.v3.ListFlowsRequest request)1167         listFlows(com.google.cloud.dialogflow.cx.v3.ListFlowsRequest request) {
1168       return io.grpc.stub.ClientCalls.futureUnaryCall(
1169           getChannel().newCall(getListFlowsMethod(), getCallOptions()), request);
1170     }
1171 
1172     /**
1173      *
1174      *
1175      * <pre>
1176      * Retrieves the specified flow.
1177      * </pre>
1178      */
1179     public com.google.common.util.concurrent.ListenableFuture<
1180             com.google.cloud.dialogflow.cx.v3.Flow>
getFlow(com.google.cloud.dialogflow.cx.v3.GetFlowRequest request)1181         getFlow(com.google.cloud.dialogflow.cx.v3.GetFlowRequest request) {
1182       return io.grpc.stub.ClientCalls.futureUnaryCall(
1183           getChannel().newCall(getGetFlowMethod(), getCallOptions()), request);
1184     }
1185 
1186     /**
1187      *
1188      *
1189      * <pre>
1190      * Updates the specified flow.
1191      * Note: You should always train a flow prior to sending it queries. See the
1192      * [training
1193      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
1194      * </pre>
1195      */
1196     public com.google.common.util.concurrent.ListenableFuture<
1197             com.google.cloud.dialogflow.cx.v3.Flow>
updateFlow(com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest request)1198         updateFlow(com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest request) {
1199       return io.grpc.stub.ClientCalls.futureUnaryCall(
1200           getChannel().newCall(getUpdateFlowMethod(), getCallOptions()), request);
1201     }
1202 
1203     /**
1204      *
1205      *
1206      * <pre>
1207      * Trains the specified flow. Note that only the flow in 'draft' environment
1208      * is trained.
1209      * This method is a [long-running
1210      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
1211      * The returned `Operation` type has the following method-specific fields:
1212      * - `metadata`: An empty [Struct
1213      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
1214      * - `response`: An [Empty
1215      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#empty)
1216      * Note: You should always train a flow prior to sending it queries. See the
1217      * [training
1218      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
1219      * </pre>
1220      */
1221     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
trainFlow(com.google.cloud.dialogflow.cx.v3.TrainFlowRequest request)1222         trainFlow(com.google.cloud.dialogflow.cx.v3.TrainFlowRequest request) {
1223       return io.grpc.stub.ClientCalls.futureUnaryCall(
1224           getChannel().newCall(getTrainFlowMethod(), getCallOptions()), request);
1225     }
1226 
1227     /**
1228      *
1229      *
1230      * <pre>
1231      * Validates the specified flow and creates or updates validation results.
1232      * Please call this API after the training is completed to get the complete
1233      * validation results.
1234      * </pre>
1235      */
1236     public com.google.common.util.concurrent.ListenableFuture<
1237             com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
validateFlow(com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest request)1238         validateFlow(com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest request) {
1239       return io.grpc.stub.ClientCalls.futureUnaryCall(
1240           getChannel().newCall(getValidateFlowMethod(), getCallOptions()), request);
1241     }
1242 
1243     /**
1244      *
1245      *
1246      * <pre>
1247      * Gets the latest flow validation result. Flow validation is performed
1248      * when ValidateFlow is called.
1249      * </pre>
1250      */
1251     public com.google.common.util.concurrent.ListenableFuture<
1252             com.google.cloud.dialogflow.cx.v3.FlowValidationResult>
getFlowValidationResult( com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest request)1253         getFlowValidationResult(
1254             com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest request) {
1255       return io.grpc.stub.ClientCalls.futureUnaryCall(
1256           getChannel().newCall(getGetFlowValidationResultMethod(), getCallOptions()), request);
1257     }
1258 
1259     /**
1260      *
1261      *
1262      * <pre>
1263      * Imports the specified flow to the specified agent from a binary file.
1264      * This method is a [long-running
1265      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
1266      * The returned `Operation` type has the following method-specific fields:
1267      * - `metadata`: An empty [Struct
1268      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
1269      * - `response`:
1270      * [ImportFlowResponse][google.cloud.dialogflow.cx.v3.ImportFlowResponse]
1271      * Note: You should always train a flow prior to sending it queries. See the
1272      * [training
1273      * documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
1274      * </pre>
1275      */
1276     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
importFlow(com.google.cloud.dialogflow.cx.v3.ImportFlowRequest request)1277         importFlow(com.google.cloud.dialogflow.cx.v3.ImportFlowRequest request) {
1278       return io.grpc.stub.ClientCalls.futureUnaryCall(
1279           getChannel().newCall(getImportFlowMethod(), getCallOptions()), request);
1280     }
1281 
1282     /**
1283      *
1284      *
1285      * <pre>
1286      * Exports the specified flow to a binary file.
1287      * This method is a [long-running
1288      * operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
1289      * The returned `Operation` type has the following method-specific fields:
1290      * - `metadata`: An empty [Struct
1291      *   message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
1292      * - `response`:
1293      * [ExportFlowResponse][google.cloud.dialogflow.cx.v3.ExportFlowResponse]
1294      * Note that resources (e.g. intents, entities, webhooks) that the flow
1295      * references will also be exported.
1296      * </pre>
1297      */
1298     public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation>
exportFlow(com.google.cloud.dialogflow.cx.v3.ExportFlowRequest request)1299         exportFlow(com.google.cloud.dialogflow.cx.v3.ExportFlowRequest request) {
1300       return io.grpc.stub.ClientCalls.futureUnaryCall(
1301           getChannel().newCall(getExportFlowMethod(), getCallOptions()), request);
1302     }
1303   }
1304 
1305   private static final int METHODID_CREATE_FLOW = 0;
1306   private static final int METHODID_DELETE_FLOW = 1;
1307   private static final int METHODID_LIST_FLOWS = 2;
1308   private static final int METHODID_GET_FLOW = 3;
1309   private static final int METHODID_UPDATE_FLOW = 4;
1310   private static final int METHODID_TRAIN_FLOW = 5;
1311   private static final int METHODID_VALIDATE_FLOW = 6;
1312   private static final int METHODID_GET_FLOW_VALIDATION_RESULT = 7;
1313   private static final int METHODID_IMPORT_FLOW = 8;
1314   private static final int METHODID_EXPORT_FLOW = 9;
1315 
1316   private static final class MethodHandlers<Req, Resp>
1317       implements io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
1318           io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
1319           io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
1320           io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
1321     private final AsyncService serviceImpl;
1322     private final int methodId;
1323 
MethodHandlers(AsyncService serviceImpl, int methodId)1324     MethodHandlers(AsyncService serviceImpl, int methodId) {
1325       this.serviceImpl = serviceImpl;
1326       this.methodId = methodId;
1327     }
1328 
1329     @java.lang.Override
1330     @java.lang.SuppressWarnings("unchecked")
invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver)1331     public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
1332       switch (methodId) {
1333         case METHODID_CREATE_FLOW:
1334           serviceImpl.createFlow(
1335               (com.google.cloud.dialogflow.cx.v3.CreateFlowRequest) request,
1336               (io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow>)
1337                   responseObserver);
1338           break;
1339         case METHODID_DELETE_FLOW:
1340           serviceImpl.deleteFlow(
1341               (com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest) request,
1342               (io.grpc.stub.StreamObserver<com.google.protobuf.Empty>) responseObserver);
1343           break;
1344         case METHODID_LIST_FLOWS:
1345           serviceImpl.listFlows(
1346               (com.google.cloud.dialogflow.cx.v3.ListFlowsRequest) request,
1347               (io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.ListFlowsResponse>)
1348                   responseObserver);
1349           break;
1350         case METHODID_GET_FLOW:
1351           serviceImpl.getFlow(
1352               (com.google.cloud.dialogflow.cx.v3.GetFlowRequest) request,
1353               (io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow>)
1354                   responseObserver);
1355           break;
1356         case METHODID_UPDATE_FLOW:
1357           serviceImpl.updateFlow(
1358               (com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest) request,
1359               (io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.Flow>)
1360                   responseObserver);
1361           break;
1362         case METHODID_TRAIN_FLOW:
1363           serviceImpl.trainFlow(
1364               (com.google.cloud.dialogflow.cx.v3.TrainFlowRequest) request,
1365               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
1366           break;
1367         case METHODID_VALIDATE_FLOW:
1368           serviceImpl.validateFlow(
1369               (com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest) request,
1370               (io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult>)
1371                   responseObserver);
1372           break;
1373         case METHODID_GET_FLOW_VALIDATION_RESULT:
1374           serviceImpl.getFlowValidationResult(
1375               (com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest) request,
1376               (io.grpc.stub.StreamObserver<com.google.cloud.dialogflow.cx.v3.FlowValidationResult>)
1377                   responseObserver);
1378           break;
1379         case METHODID_IMPORT_FLOW:
1380           serviceImpl.importFlow(
1381               (com.google.cloud.dialogflow.cx.v3.ImportFlowRequest) request,
1382               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
1383           break;
1384         case METHODID_EXPORT_FLOW:
1385           serviceImpl.exportFlow(
1386               (com.google.cloud.dialogflow.cx.v3.ExportFlowRequest) request,
1387               (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver);
1388           break;
1389         default:
1390           throw new AssertionError();
1391       }
1392     }
1393 
1394     @java.lang.Override
1395     @java.lang.SuppressWarnings("unchecked")
invoke( io.grpc.stub.StreamObserver<Resp> responseObserver)1396     public io.grpc.stub.StreamObserver<Req> invoke(
1397         io.grpc.stub.StreamObserver<Resp> responseObserver) {
1398       switch (methodId) {
1399         default:
1400           throw new AssertionError();
1401       }
1402     }
1403   }
1404 
bindService(AsyncService service)1405   public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
1406     return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
1407         .addMethod(
1408             getCreateFlowMethod(),
1409             io.grpc.stub.ServerCalls.asyncUnaryCall(
1410                 new MethodHandlers<
1411                     com.google.cloud.dialogflow.cx.v3.CreateFlowRequest,
1412                     com.google.cloud.dialogflow.cx.v3.Flow>(service, METHODID_CREATE_FLOW)))
1413         .addMethod(
1414             getDeleteFlowMethod(),
1415             io.grpc.stub.ServerCalls.asyncUnaryCall(
1416                 new MethodHandlers<
1417                     com.google.cloud.dialogflow.cx.v3.DeleteFlowRequest, com.google.protobuf.Empty>(
1418                     service, METHODID_DELETE_FLOW)))
1419         .addMethod(
1420             getListFlowsMethod(),
1421             io.grpc.stub.ServerCalls.asyncUnaryCall(
1422                 new MethodHandlers<
1423                     com.google.cloud.dialogflow.cx.v3.ListFlowsRequest,
1424                     com.google.cloud.dialogflow.cx.v3.ListFlowsResponse>(
1425                     service, METHODID_LIST_FLOWS)))
1426         .addMethod(
1427             getGetFlowMethod(),
1428             io.grpc.stub.ServerCalls.asyncUnaryCall(
1429                 new MethodHandlers<
1430                     com.google.cloud.dialogflow.cx.v3.GetFlowRequest,
1431                     com.google.cloud.dialogflow.cx.v3.Flow>(service, METHODID_GET_FLOW)))
1432         .addMethod(
1433             getUpdateFlowMethod(),
1434             io.grpc.stub.ServerCalls.asyncUnaryCall(
1435                 new MethodHandlers<
1436                     com.google.cloud.dialogflow.cx.v3.UpdateFlowRequest,
1437                     com.google.cloud.dialogflow.cx.v3.Flow>(service, METHODID_UPDATE_FLOW)))
1438         .addMethod(
1439             getTrainFlowMethod(),
1440             io.grpc.stub.ServerCalls.asyncUnaryCall(
1441                 new MethodHandlers<
1442                     com.google.cloud.dialogflow.cx.v3.TrainFlowRequest,
1443                     com.google.longrunning.Operation>(service, METHODID_TRAIN_FLOW)))
1444         .addMethod(
1445             getValidateFlowMethod(),
1446             io.grpc.stub.ServerCalls.asyncUnaryCall(
1447                 new MethodHandlers<
1448                     com.google.cloud.dialogflow.cx.v3.ValidateFlowRequest,
1449                     com.google.cloud.dialogflow.cx.v3.FlowValidationResult>(
1450                     service, METHODID_VALIDATE_FLOW)))
1451         .addMethod(
1452             getGetFlowValidationResultMethod(),
1453             io.grpc.stub.ServerCalls.asyncUnaryCall(
1454                 new MethodHandlers<
1455                     com.google.cloud.dialogflow.cx.v3.GetFlowValidationResultRequest,
1456                     com.google.cloud.dialogflow.cx.v3.FlowValidationResult>(
1457                     service, METHODID_GET_FLOW_VALIDATION_RESULT)))
1458         .addMethod(
1459             getImportFlowMethod(),
1460             io.grpc.stub.ServerCalls.asyncUnaryCall(
1461                 new MethodHandlers<
1462                     com.google.cloud.dialogflow.cx.v3.ImportFlowRequest,
1463                     com.google.longrunning.Operation>(service, METHODID_IMPORT_FLOW)))
1464         .addMethod(
1465             getExportFlowMethod(),
1466             io.grpc.stub.ServerCalls.asyncUnaryCall(
1467                 new MethodHandlers<
1468                     com.google.cloud.dialogflow.cx.v3.ExportFlowRequest,
1469                     com.google.longrunning.Operation>(service, METHODID_EXPORT_FLOW)))
1470         .build();
1471   }
1472 
1473   private abstract static class FlowsBaseDescriptorSupplier
1474       implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
1475           io.grpc.protobuf.ProtoServiceDescriptorSupplier {
FlowsBaseDescriptorSupplier()1476     FlowsBaseDescriptorSupplier() {}
1477 
1478     @java.lang.Override
getFileDescriptor()1479     public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
1480       return com.google.cloud.dialogflow.cx.v3.FlowProto.getDescriptor();
1481     }
1482 
1483     @java.lang.Override
getServiceDescriptor()1484     public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
1485       return getFileDescriptor().findServiceByName("Flows");
1486     }
1487   }
1488 
1489   private static final class FlowsFileDescriptorSupplier extends FlowsBaseDescriptorSupplier {
FlowsFileDescriptorSupplier()1490     FlowsFileDescriptorSupplier() {}
1491   }
1492 
1493   private static final class FlowsMethodDescriptorSupplier extends FlowsBaseDescriptorSupplier
1494       implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
1495     private final String methodName;
1496 
FlowsMethodDescriptorSupplier(String methodName)1497     FlowsMethodDescriptorSupplier(String methodName) {
1498       this.methodName = methodName;
1499     }
1500 
1501     @java.lang.Override
getMethodDescriptor()1502     public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
1503       return getServiceDescriptor().findMethodByName(methodName);
1504     }
1505   }
1506 
1507   private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
1508 
getServiceDescriptor()1509   public static io.grpc.ServiceDescriptor getServiceDescriptor() {
1510     io.grpc.ServiceDescriptor result = serviceDescriptor;
1511     if (result == null) {
1512       synchronized (FlowsGrpc.class) {
1513         result = serviceDescriptor;
1514         if (result == null) {
1515           serviceDescriptor =
1516               result =
1517                   io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
1518                       .setSchemaDescriptor(new FlowsFileDescriptorSupplier())
1519                       .addMethod(getCreateFlowMethod())
1520                       .addMethod(getDeleteFlowMethod())
1521                       .addMethod(getListFlowsMethod())
1522                       .addMethod(getGetFlowMethod())
1523                       .addMethod(getUpdateFlowMethod())
1524                       .addMethod(getTrainFlowMethod())
1525                       .addMethod(getValidateFlowMethod())
1526                       .addMethod(getGetFlowValidationResultMethod())
1527                       .addMethod(getImportFlowMethod())
1528                       .addMethod(getExportFlowMethod())
1529                       .build();
1530         }
1531       }
1532     }
1533     return result;
1534   }
1535 }
1536