{
private ModelServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ModelServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ModelServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Creates a new model.
*
*/
public com.google.longrunning.Operation createModel(
com.google.cloud.retail.v2beta.CreateModelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateModelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets a model.
*
*/
public com.google.cloud.retail.v2beta.Model getModel(
com.google.cloud.retail.v2beta.GetModelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetModelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Pauses the training of an existing model.
*
*/
public com.google.cloud.retail.v2beta.Model pauseModel(
com.google.cloud.retail.v2beta.PauseModelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getPauseModelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Resumes the training of an existing model.
*
*/
public com.google.cloud.retail.v2beta.Model resumeModel(
com.google.cloud.retail.v2beta.ResumeModelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getResumeModelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes an existing model.
*
*/
public com.google.protobuf.Empty deleteModel(
com.google.cloud.retail.v2beta.DeleteModelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteModelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all the models linked to this event store.
*
*/
public com.google.cloud.retail.v2beta.ListModelsResponse listModels(
com.google.cloud.retail.v2beta.ListModelsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListModelsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Update of model metadata. Only fields that
* currently can be updated are: `filtering_option` and
* `periodic_tuning_state`.
* If other values are provided, this API method ignores them.
*
*/
public com.google.cloud.retail.v2beta.Model updateModel(
com.google.cloud.retail.v2beta.UpdateModelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateModelMethod(), getCallOptions(), request);
}
/**
*
*
*
* Tunes an existing model.
*
*/
public com.google.longrunning.Operation tuneModel(
com.google.cloud.retail.v2beta.TuneModelRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getTuneModelMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service ModelService.
*
*
* Service for performing CRUD operations on models.
* Recommendation models contain all the metadata necessary to generate a set of
* models for the `Predict()` API. A model is queried
* indirectly via a ServingConfig, which associates a model with a
* given Placement (e.g. Frequently Bought Together on Home Page).
* This service allows you to do the following:
* * Initiate training of a model.
* * Pause training of an existing model.
* * List all the available models along with their metadata.
* * Control their tuning schedule.
*
*/
public static final class ModelServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private ModelServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ModelServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ModelServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Creates a new model.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createModel(com.google.cloud.retail.v2beta.CreateModelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateModelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets a model.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getModel(com.google.cloud.retail.v2beta.GetModelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetModelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Pauses the training of an existing model.
*
*/
public com.google.common.util.concurrent.ListenableFuture
pauseModel(com.google.cloud.retail.v2beta.PauseModelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getPauseModelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Resumes the training of an existing model.
*
*/
public com.google.common.util.concurrent.ListenableFuture
resumeModel(com.google.cloud.retail.v2beta.ResumeModelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getResumeModelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes an existing model.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteModel(com.google.cloud.retail.v2beta.DeleteModelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteModelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all the models linked to this event store.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.retail.v2beta.ListModelsResponse>
listModels(com.google.cloud.retail.v2beta.ListModelsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListModelsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Update of model metadata. Only fields that
* currently can be updated are: `filtering_option` and
* `periodic_tuning_state`.
* If other values are provided, this API method ignores them.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateModel(com.google.cloud.retail.v2beta.UpdateModelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateModelMethod(), getCallOptions()), request);
}
/**
*
*
*
* Tunes an existing model.
*
*/
public com.google.common.util.concurrent.ListenableFuture
tuneModel(com.google.cloud.retail.v2beta.TuneModelRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getTuneModelMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_MODEL = 0;
private static final int METHODID_GET_MODEL = 1;
private static final int METHODID_PAUSE_MODEL = 2;
private static final int METHODID_RESUME_MODEL = 3;
private static final int METHODID_DELETE_MODEL = 4;
private static final int METHODID_LIST_MODELS = 5;
private static final int METHODID_UPDATE_MODEL = 6;
private static final int METHODID_TUNE_MODEL = 7;
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_MODEL:
serviceImpl.createModel(
(com.google.cloud.retail.v2beta.CreateModelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_MODEL:
serviceImpl.getModel(
(com.google.cloud.retail.v2beta.GetModelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_PAUSE_MODEL:
serviceImpl.pauseModel(
(com.google.cloud.retail.v2beta.PauseModelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_RESUME_MODEL:
serviceImpl.resumeModel(
(com.google.cloud.retail.v2beta.ResumeModelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_MODEL:
serviceImpl.deleteModel(
(com.google.cloud.retail.v2beta.DeleteModelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_MODELS:
serviceImpl.listModels(
(com.google.cloud.retail.v2beta.ListModelsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_MODEL:
serviceImpl.updateModel(
(com.google.cloud.retail.v2beta.UpdateModelRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_TUNE_MODEL:
serviceImpl.tuneModel(
(com.google.cloud.retail.v2beta.TuneModelRequest) 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(
getCreateModelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.retail.v2beta.CreateModelRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_MODEL)))
.addMethod(
getGetModelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.retail.v2beta.GetModelRequest,
com.google.cloud.retail.v2beta.Model>(service, METHODID_GET_MODEL)))
.addMethod(
getPauseModelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.retail.v2beta.PauseModelRequest,
com.google.cloud.retail.v2beta.Model>(service, METHODID_PAUSE_MODEL)))
.addMethod(
getResumeModelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.retail.v2beta.ResumeModelRequest,
com.google.cloud.retail.v2beta.Model>(service, METHODID_RESUME_MODEL)))
.addMethod(
getDeleteModelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.retail.v2beta.DeleteModelRequest, com.google.protobuf.Empty>(
service, METHODID_DELETE_MODEL)))
.addMethod(
getListModelsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.retail.v2beta.ListModelsRequest,
com.google.cloud.retail.v2beta.ListModelsResponse>(
service, METHODID_LIST_MODELS)))
.addMethod(
getUpdateModelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.retail.v2beta.UpdateModelRequest,
com.google.cloud.retail.v2beta.Model>(service, METHODID_UPDATE_MODEL)))
.addMethod(
getTuneModelMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.retail.v2beta.TuneModelRequest,
com.google.longrunning.Operation>(service, METHODID_TUNE_MODEL)))
.build();
}
private abstract static class ModelServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
ModelServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.retail.v2beta.ModelServiceProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("ModelService");
}
}
private static final class ModelServiceFileDescriptorSupplier
extends ModelServiceBaseDescriptorSupplier {
ModelServiceFileDescriptorSupplier() {}
}
private static final class ModelServiceMethodDescriptorSupplier
extends ModelServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
ModelServiceMethodDescriptorSupplier(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 (ModelServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new ModelServiceFileDescriptorSupplier())
.addMethod(getCreateModelMethod())
.addMethod(getGetModelMethod())
.addMethod(getPauseModelMethod())
.addMethod(getResumeModelMethod())
.addMethod(getDeleteModelMethod())
.addMethod(getListModelsMethod())
.addMethod(getUpdateModelMethod())
.addMethod(getTuneModelMethod())
.build();
}
}
}
return result;
}
}