{
private ProfilerServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ProfilerServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ProfilerServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* CreateProfile creates a new profile resource in the online mode.
* The server ensures that the new profiles are created at a constant rate per
* deployment, so the creation request may hang for some time until the next
* profile session is available.
* The request may fail with ABORTED error if the creation is not available
* within ~1m, the response will indicate the duration of the backoff the
* client should take before attempting creating a profile again. The backoff
* duration is returned in google.rpc.RetryInfo extension on the response
* status. To a gRPC client, the extension will be return as a
* binary-serialized proto in the trailing metadata item named
* "google.rpc.retryinfo-bin".
*
*/
public com.google.devtools.cloudprofiler.v2.Profile createProfile(
com.google.devtools.cloudprofiler.v2.CreateProfileRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateProfileMethod(), getCallOptions(), request);
}
/**
*
*
*
* CreateOfflineProfile creates a new profile resource in the offline mode.
* The client provides the profile to create along with the profile bytes, the
* server records it.
*
*/
public com.google.devtools.cloudprofiler.v2.Profile createOfflineProfile(
com.google.devtools.cloudprofiler.v2.CreateOfflineProfileRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateOfflineProfileMethod(), getCallOptions(), request);
}
/**
*
*
*
* UpdateProfile updates the profile bytes and labels on the profile resource
* created in the online mode. Updating the bytes for profiles created in the
* offline mode is currently not supported: the profile content must be
* provided at the time of the profile creation.
*
*/
public com.google.devtools.cloudprofiler.v2.Profile updateProfile(
com.google.devtools.cloudprofiler.v2.UpdateProfileRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateProfileMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service ProfilerService.
*
*
* Manage the collection of continuous profiling data provided by profiling
* agents running in the cloud or by an offline provider of profiling data.
* General guidelines:
* * Profiles for a single deployment must be created in ascending time order.
* * Profiles can be created in either online or offline mode, see below.
*
*/
public static final class ProfilerServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private ProfilerServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ProfilerServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ProfilerServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* CreateProfile creates a new profile resource in the online mode.
* The server ensures that the new profiles are created at a constant rate per
* deployment, so the creation request may hang for some time until the next
* profile session is available.
* The request may fail with ABORTED error if the creation is not available
* within ~1m, the response will indicate the duration of the backoff the
* client should take before attempting creating a profile again. The backoff
* duration is returned in google.rpc.RetryInfo extension on the response
* status. To a gRPC client, the extension will be return as a
* binary-serialized proto in the trailing metadata item named
* "google.rpc.retryinfo-bin".
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.devtools.cloudprofiler.v2.Profile>
createProfile(com.google.devtools.cloudprofiler.v2.CreateProfileRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateProfileMethod(), getCallOptions()), request);
}
/**
*
*
*
* CreateOfflineProfile creates a new profile resource in the offline mode.
* The client provides the profile to create along with the profile bytes, the
* server records it.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.devtools.cloudprofiler.v2.Profile>
createOfflineProfile(
com.google.devtools.cloudprofiler.v2.CreateOfflineProfileRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateOfflineProfileMethod(), getCallOptions()), request);
}
/**
*
*
*
* UpdateProfile updates the profile bytes and labels on the profile resource
* created in the online mode. Updating the bytes for profiles created in the
* offline mode is currently not supported: the profile content must be
* provided at the time of the profile creation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.devtools.cloudprofiler.v2.Profile>
updateProfile(com.google.devtools.cloudprofiler.v2.UpdateProfileRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateProfileMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_PROFILE = 0;
private static final int METHODID_CREATE_OFFLINE_PROFILE = 1;
private static final int METHODID_UPDATE_PROFILE = 2;
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_PROFILE:
serviceImpl.createProfile(
(com.google.devtools.cloudprofiler.v2.CreateProfileRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_OFFLINE_PROFILE:
serviceImpl.createOfflineProfile(
(com.google.devtools.cloudprofiler.v2.CreateOfflineProfileRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_PROFILE:
serviceImpl.updateProfile(
(com.google.devtools.cloudprofiler.v2.UpdateProfileRequest) 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(
getCreateProfileMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.devtools.cloudprofiler.v2.CreateProfileRequest,
com.google.devtools.cloudprofiler.v2.Profile>(
service, METHODID_CREATE_PROFILE)))
.addMethod(
getCreateOfflineProfileMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.devtools.cloudprofiler.v2.CreateOfflineProfileRequest,
com.google.devtools.cloudprofiler.v2.Profile>(
service, METHODID_CREATE_OFFLINE_PROFILE)))
.addMethod(
getUpdateProfileMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.devtools.cloudprofiler.v2.UpdateProfileRequest,
com.google.devtools.cloudprofiler.v2.Profile>(
service, METHODID_UPDATE_PROFILE)))
.build();
}
private abstract static class ProfilerServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
ProfilerServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.devtools.cloudprofiler.v2.ProfilerProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("ProfilerService");
}
}
private static final class ProfilerServiceFileDescriptorSupplier
extends ProfilerServiceBaseDescriptorSupplier {
ProfilerServiceFileDescriptorSupplier() {}
}
private static final class ProfilerServiceMethodDescriptorSupplier
extends ProfilerServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
ProfilerServiceMethodDescriptorSupplier(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 (ProfilerServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new ProfilerServiceFileDescriptorSupplier())
.addMethod(getCreateProfileMethod())
.addMethod(getCreateOfflineProfileMethod())
.addMethod(getUpdateProfileMethod())
.build();
}
}
}
return result;
}
}