{
private FlowsBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected FlowsBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new FlowsBlockingStub(channel, callOptions);
}
/**
*
*
*
* Creates a flow in the specified agent.
* Note: You should always train a flow prior to sending it queries. See the
* [training
* documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
*
*/
public com.google.cloud.dialogflow.cx.v3beta1.Flow createFlow(
com.google.cloud.dialogflow.cx.v3beta1.CreateFlowRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateFlowMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a specified flow.
*
*/
public com.google.protobuf.Empty deleteFlow(
com.google.cloud.dialogflow.cx.v3beta1.DeleteFlowRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteFlowMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns the list of all flows in the specified agent.
*
*/
public com.google.cloud.dialogflow.cx.v3beta1.ListFlowsResponse listFlows(
com.google.cloud.dialogflow.cx.v3beta1.ListFlowsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListFlowsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retrieves the specified flow.
*
*/
public com.google.cloud.dialogflow.cx.v3beta1.Flow getFlow(
com.google.cloud.dialogflow.cx.v3beta1.GetFlowRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetFlowMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the specified flow.
* Note: You should always train a flow prior to sending it queries. See the
* [training
* documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
*
*/
public com.google.cloud.dialogflow.cx.v3beta1.Flow updateFlow(
com.google.cloud.dialogflow.cx.v3beta1.UpdateFlowRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateFlowMethod(), getCallOptions(), request);
}
/**
*
*
*
* Trains the specified flow. Note that only the flow in 'draft' environment
* is trained.
* This method is a [long-running
* operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
* The returned `Operation` type has the following method-specific fields:
* - `metadata`: An empty [Struct
* message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
* - `response`: An [Empty
* message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#empty)
* Note: You should always train a flow prior to sending it queries. See the
* [training
* documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
*
*/
public com.google.longrunning.Operation trainFlow(
com.google.cloud.dialogflow.cx.v3beta1.TrainFlowRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getTrainFlowMethod(), getCallOptions(), request);
}
/**
*
*
*
* Validates the specified flow and creates or updates validation results.
* Please call this API after the training is completed to get the complete
* validation results.
*
*/
public com.google.cloud.dialogflow.cx.v3beta1.FlowValidationResult validateFlow(
com.google.cloud.dialogflow.cx.v3beta1.ValidateFlowRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getValidateFlowMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the latest flow validation result. Flow validation is performed
* when ValidateFlow is called.
*
*/
public com.google.cloud.dialogflow.cx.v3beta1.FlowValidationResult getFlowValidationResult(
com.google.cloud.dialogflow.cx.v3beta1.GetFlowValidationResultRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetFlowValidationResultMethod(), getCallOptions(), request);
}
/**
*
*
*
* Imports the specified flow to the specified agent from a binary file.
* This method is a [long-running
* operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
* The returned `Operation` type has the following method-specific fields:
* - `metadata`: An empty [Struct
* message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
* - `response`:
* [ImportFlowResponse][google.cloud.dialogflow.cx.v3beta1.ImportFlowResponse]
* Note: You should always train a flow prior to sending it queries. See the
* [training
* documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
*
*/
public com.google.longrunning.Operation importFlow(
com.google.cloud.dialogflow.cx.v3beta1.ImportFlowRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getImportFlowMethod(), getCallOptions(), request);
}
/**
*
*
*
* Exports the specified flow to a binary file.
* This method is a [long-running
* operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
* The returned `Operation` type has the following method-specific fields:
* - `metadata`: An empty [Struct
* message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
* - `response`:
* [ExportFlowResponse][google.cloud.dialogflow.cx.v3beta1.ExportFlowResponse]
* Note that resources (e.g. intents, entities, webhooks) that the flow
* references will also be exported.
*
*/
public com.google.longrunning.Operation exportFlow(
com.google.cloud.dialogflow.cx.v3beta1.ExportFlowRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getExportFlowMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service Flows.
*
*
* Service for managing [Flows][google.cloud.dialogflow.cx.v3beta1.Flow].
*
*/
public static final class FlowsFutureStub
extends io.grpc.stub.AbstractFutureStub {
private FlowsFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected FlowsFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new FlowsFutureStub(channel, callOptions);
}
/**
*
*
*
* Creates a flow in the specified agent.
* Note: You should always train a flow prior to sending it queries. See the
* [training
* documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.cx.v3beta1.Flow>
createFlow(com.google.cloud.dialogflow.cx.v3beta1.CreateFlowRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateFlowMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a specified flow.
*
*/
public com.google.common.util.concurrent.ListenableFuture deleteFlow(
com.google.cloud.dialogflow.cx.v3beta1.DeleteFlowRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteFlowMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns the list of all flows in the specified agent.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.cx.v3beta1.ListFlowsResponse>
listFlows(com.google.cloud.dialogflow.cx.v3beta1.ListFlowsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListFlowsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retrieves the specified flow.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.cx.v3beta1.Flow>
getFlow(com.google.cloud.dialogflow.cx.v3beta1.GetFlowRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetFlowMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the specified flow.
* Note: You should always train a flow prior to sending it queries. See the
* [training
* documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.cx.v3beta1.Flow>
updateFlow(com.google.cloud.dialogflow.cx.v3beta1.UpdateFlowRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateFlowMethod(), getCallOptions()), request);
}
/**
*
*
*
* Trains the specified flow. Note that only the flow in 'draft' environment
* is trained.
* This method is a [long-running
* operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
* The returned `Operation` type has the following method-specific fields:
* - `metadata`: An empty [Struct
* message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
* - `response`: An [Empty
* message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#empty)
* Note: You should always train a flow prior to sending it queries. See the
* [training
* documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
*
*/
public com.google.common.util.concurrent.ListenableFuture
trainFlow(com.google.cloud.dialogflow.cx.v3beta1.TrainFlowRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getTrainFlowMethod(), getCallOptions()), request);
}
/**
*
*
*
* Validates the specified flow and creates or updates validation results.
* Please call this API after the training is completed to get the complete
* validation results.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.cx.v3beta1.FlowValidationResult>
validateFlow(com.google.cloud.dialogflow.cx.v3beta1.ValidateFlowRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getValidateFlowMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the latest flow validation result. Flow validation is performed
* when ValidateFlow is called.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.cx.v3beta1.FlowValidationResult>
getFlowValidationResult(
com.google.cloud.dialogflow.cx.v3beta1.GetFlowValidationResultRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetFlowValidationResultMethod(), getCallOptions()), request);
}
/**
*
*
*
* Imports the specified flow to the specified agent from a binary file.
* This method is a [long-running
* operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
* The returned `Operation` type has the following method-specific fields:
* - `metadata`: An empty [Struct
* message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
* - `response`:
* [ImportFlowResponse][google.cloud.dialogflow.cx.v3beta1.ImportFlowResponse]
* Note: You should always train a flow prior to sending it queries. See the
* [training
* documentation](https://cloud.google.com/dialogflow/cx/docs/concept/training).
*
*/
public com.google.common.util.concurrent.ListenableFuture
importFlow(com.google.cloud.dialogflow.cx.v3beta1.ImportFlowRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getImportFlowMethod(), getCallOptions()), request);
}
/**
*
*
*
* Exports the specified flow to a binary file.
* This method is a [long-running
* operation](https://cloud.google.com/dialogflow/cx/docs/how/long-running-operation).
* The returned `Operation` type has the following method-specific fields:
* - `metadata`: An empty [Struct
* message](https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#struct)
* - `response`:
* [ExportFlowResponse][google.cloud.dialogflow.cx.v3beta1.ExportFlowResponse]
* Note that resources (e.g. intents, entities, webhooks) that the flow
* references will also be exported.
*
*/
public com.google.common.util.concurrent.ListenableFuture
exportFlow(com.google.cloud.dialogflow.cx.v3beta1.ExportFlowRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getExportFlowMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_FLOW = 0;
private static final int METHODID_DELETE_FLOW = 1;
private static final int METHODID_LIST_FLOWS = 2;
private static final int METHODID_GET_FLOW = 3;
private static final int METHODID_UPDATE_FLOW = 4;
private static final int METHODID_TRAIN_FLOW = 5;
private static final int METHODID_VALIDATE_FLOW = 6;
private static final int METHODID_GET_FLOW_VALIDATION_RESULT = 7;
private static final int METHODID_IMPORT_FLOW = 8;
private static final int METHODID_EXPORT_FLOW = 9;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
io.grpc.stub.ServerCalls.ServerStreamingMethod,
io.grpc.stub.ServerCalls.ClientStreamingMethod,
io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_CREATE_FLOW:
serviceImpl.createFlow(
(com.google.cloud.dialogflow.cx.v3beta1.CreateFlowRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_FLOW:
serviceImpl.deleteFlow(
(com.google.cloud.dialogflow.cx.v3beta1.DeleteFlowRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_FLOWS:
serviceImpl.listFlows(
(com.google.cloud.dialogflow.cx.v3beta1.ListFlowsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.dialogflow.cx.v3beta1.ListFlowsResponse>)
responseObserver);
break;
case METHODID_GET_FLOW:
serviceImpl.getFlow(
(com.google.cloud.dialogflow.cx.v3beta1.GetFlowRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_FLOW:
serviceImpl.updateFlow(
(com.google.cloud.dialogflow.cx.v3beta1.UpdateFlowRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_TRAIN_FLOW:
serviceImpl.trainFlow(
(com.google.cloud.dialogflow.cx.v3beta1.TrainFlowRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_VALIDATE_FLOW:
serviceImpl.validateFlow(
(com.google.cloud.dialogflow.cx.v3beta1.ValidateFlowRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.dialogflow.cx.v3beta1.FlowValidationResult>)
responseObserver);
break;
case METHODID_GET_FLOW_VALIDATION_RESULT:
serviceImpl.getFlowValidationResult(
(com.google.cloud.dialogflow.cx.v3beta1.GetFlowValidationResultRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.dialogflow.cx.v3beta1.FlowValidationResult>)
responseObserver);
break;
case METHODID_IMPORT_FLOW:
serviceImpl.importFlow(
(com.google.cloud.dialogflow.cx.v3beta1.ImportFlowRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_EXPORT_FLOW:
serviceImpl.exportFlow(
(com.google.cloud.dialogflow.cx.v3beta1.ExportFlowRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
default:
throw new AssertionError();
}
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
default:
throw new AssertionError();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateFlowMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.CreateFlowRequest,
com.google.cloud.dialogflow.cx.v3beta1.Flow>(service, METHODID_CREATE_FLOW)))
.addMethod(
getDeleteFlowMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.DeleteFlowRequest,
com.google.protobuf.Empty>(service, METHODID_DELETE_FLOW)))
.addMethod(
getListFlowsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.ListFlowsRequest,
com.google.cloud.dialogflow.cx.v3beta1.ListFlowsResponse>(
service, METHODID_LIST_FLOWS)))
.addMethod(
getGetFlowMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.GetFlowRequest,
com.google.cloud.dialogflow.cx.v3beta1.Flow>(service, METHODID_GET_FLOW)))
.addMethod(
getUpdateFlowMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.UpdateFlowRequest,
com.google.cloud.dialogflow.cx.v3beta1.Flow>(service, METHODID_UPDATE_FLOW)))
.addMethod(
getTrainFlowMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.TrainFlowRequest,
com.google.longrunning.Operation>(service, METHODID_TRAIN_FLOW)))
.addMethod(
getValidateFlowMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.ValidateFlowRequest,
com.google.cloud.dialogflow.cx.v3beta1.FlowValidationResult>(
service, METHODID_VALIDATE_FLOW)))
.addMethod(
getGetFlowValidationResultMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.GetFlowValidationResultRequest,
com.google.cloud.dialogflow.cx.v3beta1.FlowValidationResult>(
service, METHODID_GET_FLOW_VALIDATION_RESULT)))
.addMethod(
getImportFlowMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.ImportFlowRequest,
com.google.longrunning.Operation>(service, METHODID_IMPORT_FLOW)))
.addMethod(
getExportFlowMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.cx.v3beta1.ExportFlowRequest,
com.google.longrunning.Operation>(service, METHODID_EXPORT_FLOW)))
.build();
}
private abstract static class FlowsBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
FlowsBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.dialogflow.cx.v3beta1.FlowProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("Flows");
}
}
private static final class FlowsFileDescriptorSupplier extends FlowsBaseDescriptorSupplier {
FlowsFileDescriptorSupplier() {}
}
private static final class FlowsMethodDescriptorSupplier extends FlowsBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
FlowsMethodDescriptorSupplier(String methodName) {
this.methodName = methodName;
}
@java.lang.Override
public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
return getServiceDescriptor().findMethodByName(methodName);
}
}
private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
public static io.grpc.ServiceDescriptor getServiceDescriptor() {
io.grpc.ServiceDescriptor result = serviceDescriptor;
if (result == null) {
synchronized (FlowsGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new FlowsFileDescriptorSupplier())
.addMethod(getCreateFlowMethod())
.addMethod(getDeleteFlowMethod())
.addMethod(getListFlowsMethod())
.addMethod(getGetFlowMethod())
.addMethod(getUpdateFlowMethod())
.addMethod(getTrainFlowMethod())
.addMethod(getValidateFlowMethod())
.addMethod(getGetFlowValidationResultMethod())
.addMethod(getImportFlowMethod())
.addMethod(getExportFlowMethod())
.build();
}
}
}
return result;
}
}