{
private Controller2BlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected Controller2BlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new Controller2BlockingStub(channel, callOptions);
}
/**
*
*
*
* Registers the debuggee with the controller service.
* All agents attached to the same application must call this method with
* exactly the same request content to get back the same stable `debuggee_id`.
* Agents should call this method again whenever `google.rpc.Code.NOT_FOUND`
* is returned from any controller method.
* This protocol allows the controller service to disable debuggees, recover
* from data loss, or change the `debuggee_id` format. Agents must handle
* `debuggee_id` value changing upon re-registration.
*
*/
public com.google.devtools.clouddebugger.v2.RegisterDebuggeeResponse registerDebuggee(
com.google.devtools.clouddebugger.v2.RegisterDebuggeeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRegisterDebuggeeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns the list of all active breakpoints for the debuggee.
* The breakpoint specification (`location`, `condition`, and `expressions`
* fields) is semantically immutable, although the field values may
* change. For example, an agent may update the location line number
* to reflect the actual line where the breakpoint was set, but this
* doesn't change the breakpoint semantics.
* This means that an agent does not need to check if a breakpoint has changed
* when it encounters the same breakpoint on a successive call.
* Moreover, an agent should remember the breakpoints that are completed
* until the controller removes them from the active list to avoid
* setting those breakpoints again.
*
*/
public com.google.devtools.clouddebugger.v2.ListActiveBreakpointsResponse listActiveBreakpoints(
com.google.devtools.clouddebugger.v2.ListActiveBreakpointsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListActiveBreakpointsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the breakpoint state or mutable fields.
* The entire Breakpoint message must be sent back to the controller service.
* Updates to active breakpoint fields are only allowed if the new value
* does not change the breakpoint specification. Updates to the `location`,
* `condition` and `expressions` fields should not alter the breakpoint
* semantics. These may only make changes such as canonicalizing a value
* or snapping the location to the correct line of code.
*
*/
public com.google.devtools.clouddebugger.v2.UpdateActiveBreakpointResponse
updateActiveBreakpoint(
com.google.devtools.clouddebugger.v2.UpdateActiveBreakpointRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateActiveBreakpointMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service Controller2.
*
*
* The Controller service provides the API for orchestrating a collection of
* debugger agents to perform debugging tasks. These agents are each attached
* to a process of an application which may include one or more replicas.
* The debugger agents register with the Controller to identify the application
* being debugged, the Debuggee. All agents that register with the same data,
* represent the same Debuggee, and are assigned the same `debuggee_id`.
* The debugger agents call the Controller to retrieve the list of active
* Breakpoints. Agents with the same `debuggee_id` get the same breakpoints
* list. An agent that can fulfill the breakpoint request updates the
* Controller with the breakpoint result. The controller selects the first
* result received and discards the rest of the results.
* Agents that poll again for active breakpoints will no longer have
* the completed breakpoint in the list and should remove that breakpoint from
* their attached process.
* The Controller service does not provide a way to retrieve the results of
* a completed breakpoint. This functionality is available using the Debugger
* service.
*
*/
public static final class Controller2FutureStub
extends io.grpc.stub.AbstractFutureStub {
private Controller2FutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected Controller2FutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new Controller2FutureStub(channel, callOptions);
}
/**
*
*
*
* Registers the debuggee with the controller service.
* All agents attached to the same application must call this method with
* exactly the same request content to get back the same stable `debuggee_id`.
* Agents should call this method again whenever `google.rpc.Code.NOT_FOUND`
* is returned from any controller method.
* This protocol allows the controller service to disable debuggees, recover
* from data loss, or change the `debuggee_id` format. Agents must handle
* `debuggee_id` value changing upon re-registration.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.devtools.clouddebugger.v2.RegisterDebuggeeResponse>
registerDebuggee(com.google.devtools.clouddebugger.v2.RegisterDebuggeeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRegisterDebuggeeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns the list of all active breakpoints for the debuggee.
* The breakpoint specification (`location`, `condition`, and `expressions`
* fields) is semantically immutable, although the field values may
* change. For example, an agent may update the location line number
* to reflect the actual line where the breakpoint was set, but this
* doesn't change the breakpoint semantics.
* This means that an agent does not need to check if a breakpoint has changed
* when it encounters the same breakpoint on a successive call.
* Moreover, an agent should remember the breakpoints that are completed
* until the controller removes them from the active list to avoid
* setting those breakpoints again.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.devtools.clouddebugger.v2.ListActiveBreakpointsResponse>
listActiveBreakpoints(
com.google.devtools.clouddebugger.v2.ListActiveBreakpointsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListActiveBreakpointsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the breakpoint state or mutable fields.
* The entire Breakpoint message must be sent back to the controller service.
* Updates to active breakpoint fields are only allowed if the new value
* does not change the breakpoint specification. Updates to the `location`,
* `condition` and `expressions` fields should not alter the breakpoint
* semantics. These may only make changes such as canonicalizing a value
* or snapping the location to the correct line of code.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.devtools.clouddebugger.v2.UpdateActiveBreakpointResponse>
updateActiveBreakpoint(
com.google.devtools.clouddebugger.v2.UpdateActiveBreakpointRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateActiveBreakpointMethod(), getCallOptions()), request);
}
}
private static final int METHODID_REGISTER_DEBUGGEE = 0;
private static final int METHODID_LIST_ACTIVE_BREAKPOINTS = 1;
private static final int METHODID_UPDATE_ACTIVE_BREAKPOINT = 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_REGISTER_DEBUGGEE:
serviceImpl.registerDebuggee(
(com.google.devtools.clouddebugger.v2.RegisterDebuggeeRequest) request,
(io.grpc.stub.StreamObserver<
com.google.devtools.clouddebugger.v2.RegisterDebuggeeResponse>)
responseObserver);
break;
case METHODID_LIST_ACTIVE_BREAKPOINTS:
serviceImpl.listActiveBreakpoints(
(com.google.devtools.clouddebugger.v2.ListActiveBreakpointsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.devtools.clouddebugger.v2.ListActiveBreakpointsResponse>)
responseObserver);
break;
case METHODID_UPDATE_ACTIVE_BREAKPOINT:
serviceImpl.updateActiveBreakpoint(
(com.google.devtools.clouddebugger.v2.UpdateActiveBreakpointRequest) request,
(io.grpc.stub.StreamObserver<
com.google.devtools.clouddebugger.v2.UpdateActiveBreakpointResponse>)
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(
getRegisterDebuggeeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.devtools.clouddebugger.v2.RegisterDebuggeeRequest,
com.google.devtools.clouddebugger.v2.RegisterDebuggeeResponse>(
service, METHODID_REGISTER_DEBUGGEE)))
.addMethod(
getListActiveBreakpointsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.devtools.clouddebugger.v2.ListActiveBreakpointsRequest,
com.google.devtools.clouddebugger.v2.ListActiveBreakpointsResponse>(
service, METHODID_LIST_ACTIVE_BREAKPOINTS)))
.addMethod(
getUpdateActiveBreakpointMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.devtools.clouddebugger.v2.UpdateActiveBreakpointRequest,
com.google.devtools.clouddebugger.v2.UpdateActiveBreakpointResponse>(
service, METHODID_UPDATE_ACTIVE_BREAKPOINT)))
.build();
}
private abstract static class Controller2BaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
Controller2BaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.devtools.clouddebugger.v2.ControllerProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("Controller2");
}
}
private static final class Controller2FileDescriptorSupplier
extends Controller2BaseDescriptorSupplier {
Controller2FileDescriptorSupplier() {}
}
private static final class Controller2MethodDescriptorSupplier
extends Controller2BaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
Controller2MethodDescriptorSupplier(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 (Controller2Grpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new Controller2FileDescriptorSupplier())
.addMethod(getRegisterDebuggeeMethod())
.addMethod(getListActiveBreakpointsMethod())
.addMethod(getUpdateActiveBreakpointMethod())
.build();
}
}
}
return result;
}
}