{
private ParticipantsBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ParticipantsBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ParticipantsBlockingStub(channel, callOptions);
}
/**
*
*
*
* Creates a new participant in a conversation.
*
*/
public com.google.cloud.dialogflow.v2.Participant createParticipant(
com.google.cloud.dialogflow.v2.CreateParticipantRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateParticipantMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retrieves a conversation participant.
*
*/
public com.google.cloud.dialogflow.v2.Participant getParticipant(
com.google.cloud.dialogflow.v2.GetParticipantRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetParticipantMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns the list of all participants in the specified conversation.
*
*/
public com.google.cloud.dialogflow.v2.ListParticipantsResponse listParticipants(
com.google.cloud.dialogflow.v2.ListParticipantsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListParticipantsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the specified participant.
*
*/
public com.google.cloud.dialogflow.v2.Participant updateParticipant(
com.google.cloud.dialogflow.v2.UpdateParticipantRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateParticipantMethod(), getCallOptions(), request);
}
/**
*
*
*
* Adds a text (chat, for example), or audio (phone recording, for example)
* message from a participant into the conversation.
* Note: Always use agent versions for production traffic
* sent to virtual agents. See [Versions and
* environments](https://cloud.google.com/dialogflow/es/docs/agents-versions).
*
*/
public com.google.cloud.dialogflow.v2.AnalyzeContentResponse analyzeContent(
com.google.cloud.dialogflow.v2.AnalyzeContentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAnalyzeContentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets suggested articles for a participant based on specific historical
* messages.
*
*/
public com.google.cloud.dialogflow.v2.SuggestArticlesResponse suggestArticles(
com.google.cloud.dialogflow.v2.SuggestArticlesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSuggestArticlesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets suggested faq answers for a participant based on specific historical
* messages.
*
*/
public com.google.cloud.dialogflow.v2.SuggestFaqAnswersResponse suggestFaqAnswers(
com.google.cloud.dialogflow.v2.SuggestFaqAnswersRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSuggestFaqAnswersMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets smart replies for a participant based on specific historical
* messages.
*
*/
public com.google.cloud.dialogflow.v2.SuggestSmartRepliesResponse suggestSmartReplies(
com.google.cloud.dialogflow.v2.SuggestSmartRepliesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSuggestSmartRepliesMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service Participants.
*
*
* Service for managing [Participants][google.cloud.dialogflow.v2.Participant].
*
*/
public static final class ParticipantsFutureStub
extends io.grpc.stub.AbstractFutureStub {
private ParticipantsFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ParticipantsFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ParticipantsFutureStub(channel, callOptions);
}
/**
*
*
*
* Creates a new participant in a conversation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.v2.Participant>
createParticipant(com.google.cloud.dialogflow.v2.CreateParticipantRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateParticipantMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retrieves a conversation participant.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.v2.Participant>
getParticipant(com.google.cloud.dialogflow.v2.GetParticipantRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetParticipantMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns the list of all participants in the specified conversation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.v2.ListParticipantsResponse>
listParticipants(com.google.cloud.dialogflow.v2.ListParticipantsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListParticipantsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the specified participant.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.v2.Participant>
updateParticipant(com.google.cloud.dialogflow.v2.UpdateParticipantRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateParticipantMethod(), getCallOptions()), request);
}
/**
*
*
*
* Adds a text (chat, for example), or audio (phone recording, for example)
* message from a participant into the conversation.
* Note: Always use agent versions for production traffic
* sent to virtual agents. See [Versions and
* environments](https://cloud.google.com/dialogflow/es/docs/agents-versions).
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.v2.AnalyzeContentResponse>
analyzeContent(com.google.cloud.dialogflow.v2.AnalyzeContentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAnalyzeContentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets suggested articles for a participant based on specific historical
* messages.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.v2.SuggestArticlesResponse>
suggestArticles(com.google.cloud.dialogflow.v2.SuggestArticlesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSuggestArticlesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets suggested faq answers for a participant based on specific historical
* messages.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.v2.SuggestFaqAnswersResponse>
suggestFaqAnswers(com.google.cloud.dialogflow.v2.SuggestFaqAnswersRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSuggestFaqAnswersMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets smart replies for a participant based on specific historical
* messages.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.dialogflow.v2.SuggestSmartRepliesResponse>
suggestSmartReplies(com.google.cloud.dialogflow.v2.SuggestSmartRepliesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSuggestSmartRepliesMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_PARTICIPANT = 0;
private static final int METHODID_GET_PARTICIPANT = 1;
private static final int METHODID_LIST_PARTICIPANTS = 2;
private static final int METHODID_UPDATE_PARTICIPANT = 3;
private static final int METHODID_ANALYZE_CONTENT = 4;
private static final int METHODID_SUGGEST_ARTICLES = 5;
private static final int METHODID_SUGGEST_FAQ_ANSWERS = 6;
private static final int METHODID_SUGGEST_SMART_REPLIES = 7;
private static final int METHODID_STREAMING_ANALYZE_CONTENT = 8;
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_PARTICIPANT:
serviceImpl.createParticipant(
(com.google.cloud.dialogflow.v2.CreateParticipantRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_PARTICIPANT:
serviceImpl.getParticipant(
(com.google.cloud.dialogflow.v2.GetParticipantRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_PARTICIPANTS:
serviceImpl.listParticipants(
(com.google.cloud.dialogflow.v2.ListParticipantsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_PARTICIPANT:
serviceImpl.updateParticipant(
(com.google.cloud.dialogflow.v2.UpdateParticipantRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_ANALYZE_CONTENT:
serviceImpl.analyzeContent(
(com.google.cloud.dialogflow.v2.AnalyzeContentRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SUGGEST_ARTICLES:
serviceImpl.suggestArticles(
(com.google.cloud.dialogflow.v2.SuggestArticlesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SUGGEST_FAQ_ANSWERS:
serviceImpl.suggestFaqAnswers(
(com.google.cloud.dialogflow.v2.SuggestFaqAnswersRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.dialogflow.v2.SuggestFaqAnswersResponse>)
responseObserver);
break;
case METHODID_SUGGEST_SMART_REPLIES:
serviceImpl.suggestSmartReplies(
(com.google.cloud.dialogflow.v2.SuggestSmartRepliesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.dialogflow.v2.SuggestSmartRepliesResponse>)
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) {
case METHODID_STREAMING_ANALYZE_CONTENT:
return (io.grpc.stub.StreamObserver)
serviceImpl.streamingAnalyzeContent(
(io.grpc.stub.StreamObserver<
com.google.cloud.dialogflow.v2.StreamingAnalyzeContentResponse>)
responseObserver);
default:
throw new AssertionError();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateParticipantMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.v2.CreateParticipantRequest,
com.google.cloud.dialogflow.v2.Participant>(
service, METHODID_CREATE_PARTICIPANT)))
.addMethod(
getGetParticipantMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.v2.GetParticipantRequest,
com.google.cloud.dialogflow.v2.Participant>(service, METHODID_GET_PARTICIPANT)))
.addMethod(
getListParticipantsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.v2.ListParticipantsRequest,
com.google.cloud.dialogflow.v2.ListParticipantsResponse>(
service, METHODID_LIST_PARTICIPANTS)))
.addMethod(
getUpdateParticipantMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.v2.UpdateParticipantRequest,
com.google.cloud.dialogflow.v2.Participant>(
service, METHODID_UPDATE_PARTICIPANT)))
.addMethod(
getAnalyzeContentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.v2.AnalyzeContentRequest,
com.google.cloud.dialogflow.v2.AnalyzeContentResponse>(
service, METHODID_ANALYZE_CONTENT)))
.addMethod(
getStreamingAnalyzeContentMethod(),
io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
new MethodHandlers<
com.google.cloud.dialogflow.v2.StreamingAnalyzeContentRequest,
com.google.cloud.dialogflow.v2.StreamingAnalyzeContentResponse>(
service, METHODID_STREAMING_ANALYZE_CONTENT)))
.addMethod(
getSuggestArticlesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.v2.SuggestArticlesRequest,
com.google.cloud.dialogflow.v2.SuggestArticlesResponse>(
service, METHODID_SUGGEST_ARTICLES)))
.addMethod(
getSuggestFaqAnswersMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.v2.SuggestFaqAnswersRequest,
com.google.cloud.dialogflow.v2.SuggestFaqAnswersResponse>(
service, METHODID_SUGGEST_FAQ_ANSWERS)))
.addMethod(
getSuggestSmartRepliesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.dialogflow.v2.SuggestSmartRepliesRequest,
com.google.cloud.dialogflow.v2.SuggestSmartRepliesResponse>(
service, METHODID_SUGGEST_SMART_REPLIES)))
.build();
}
private abstract static class ParticipantsBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
ParticipantsBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.dialogflow.v2.ParticipantProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("Participants");
}
}
private static final class ParticipantsFileDescriptorSupplier
extends ParticipantsBaseDescriptorSupplier {
ParticipantsFileDescriptorSupplier() {}
}
private static final class ParticipantsMethodDescriptorSupplier
extends ParticipantsBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
ParticipantsMethodDescriptorSupplier(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 (ParticipantsGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new ParticipantsFileDescriptorSupplier())
.addMethod(getCreateParticipantMethod())
.addMethod(getGetParticipantMethod())
.addMethod(getListParticipantsMethod())
.addMethod(getUpdateParticipantMethod())
.addMethod(getAnalyzeContentMethod())
.addMethod(getStreamingAnalyzeContentMethod())
.addMethod(getSuggestArticlesMethod())
.addMethod(getSuggestFaqAnswersMethod())
.addMethod(getSuggestSmartRepliesMethod())
.build();
}
}
}
return result;
}
}