public class ProtobufCoprocessorService extends TestRpcServiceProtos.TestProtobufRpcProto implements CoprocessorService, Coprocessor
TestRpcServiceProtos.TestProtobufRpcProto
service methods. For internal use by
unit tests only.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface, TestRpcServiceProtos.TestProtobufRpcProto.Interface, TestRpcServiceProtos.TestProtobufRpcProto.Stub
Coprocessor.State
PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION
Constructor and Description |
---|
ProtobufCoprocessorService() |
Modifier and Type | Method and Description |
---|---|
void |
echo(RpcController controller,
TestProtos.EchoRequestProto request,
<any> done)
rpc echo(.EchoRequestProto) returns (.EchoResponseProto); |
void |
error(RpcController controller,
TestProtos.EmptyRequestProto request,
<any> done)
rpc error(.EmptyRequestProto) returns (.EmptyResponseProto); |
Service |
getService() |
void |
ping(RpcController controller,
TestProtos.EmptyRequestProto request,
<any> done)
rpc ping(.EmptyRequestProto) returns (.EmptyResponseProto); |
void |
start(CoprocessorEnvironment env) |
void |
stop(CoprocessorEnvironment env) |
callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub
public Service getService()
getService
in interface CoprocessorService
public void ping(RpcController controller, TestProtos.EmptyRequestProto request, <any> done)
TestRpcServiceProtos.TestProtobufRpcProto
rpc ping(.EmptyRequestProto) returns (.EmptyResponseProto);
ping
in class TestRpcServiceProtos.TestProtobufRpcProto
public void echo(RpcController controller, TestProtos.EchoRequestProto request, <any> done)
TestRpcServiceProtos.TestProtobufRpcProto
rpc echo(.EchoRequestProto) returns (.EchoResponseProto);
echo
in class TestRpcServiceProtos.TestProtobufRpcProto
public void error(RpcController controller, TestProtos.EmptyRequestProto request, <any> done)
TestRpcServiceProtos.TestProtobufRpcProto
rpc error(.EmptyRequestProto) returns (.EmptyResponseProto);
error
in class TestRpcServiceProtos.TestProtobufRpcProto
public void start(CoprocessorEnvironment env) throws java.io.IOException
start
in interface Coprocessor
java.io.IOException
public void stop(CoprocessorEnvironment env) throws java.io.IOException
stop
in interface Coprocessor
java.io.IOException