public static class TestServerCustomProtocol.PingHandler extends PingProtos.PingService implements Coprocessor, CoprocessorService
PingProtos.PingService.BlockingInterface, PingProtos.PingService.Interface, PingProtos.PingService.Stub
Coprocessor.State
PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION
Constructor and Description |
---|
PingHandler() |
Modifier and Type | Method and Description |
---|---|
void |
count(RpcController controller,
PingProtos.CountRequest request,
<any> done)
rpc count(.CountRequest) returns (.CountResponse); |
Service |
getService() |
void |
hello(RpcController controller,
PingProtos.HelloRequest request,
<any> done)
rpc hello(.HelloRequest) returns (.HelloResponse); |
void |
increment(RpcController controller,
PingProtos.IncrementCountRequest request,
<any> done)
rpc increment(.IncrementCountRequest) returns (.IncrementCountResponse); |
void |
noop(RpcController controller,
PingProtos.NoopRequest request,
<any> done)
rpc noop(.NoopRequest) returns (.NoopResponse); |
void |
ping(RpcController controller,
PingProtos.PingRequest request,
<any> done)
rpc ping(.PingRequest) returns (.PingResponse); |
void |
start(CoprocessorEnvironment env) |
void |
stop(CoprocessorEnvironment env) |
callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub
public void start(CoprocessorEnvironment env) throws IOException
start
in interface Coprocessor
IOException
public void stop(CoprocessorEnvironment env) throws IOException
stop
in interface Coprocessor
IOException
public void ping(RpcController controller, PingProtos.PingRequest request, <any> done)
PingProtos.PingService
rpc ping(.PingRequest) returns (.PingResponse);
ping
in class PingProtos.PingService
public void count(RpcController controller, PingProtos.CountRequest request, <any> done)
PingProtos.PingService
rpc count(.CountRequest) returns (.CountResponse);
count
in class PingProtos.PingService
public void increment(RpcController controller, PingProtos.IncrementCountRequest request, <any> done)
PingProtos.PingService
rpc increment(.IncrementCountRequest) returns (.IncrementCountResponse);
increment
in class PingProtos.PingService
public void hello(RpcController controller, PingProtos.HelloRequest request, <any> done)
PingProtos.PingService
rpc hello(.HelloRequest) returns (.HelloResponse);
hello
in class PingProtos.PingService
public void noop(RpcController controller, PingProtos.NoopRequest request, <any> done)
PingProtos.PingService
rpc noop(.NoopRequest) returns (.NoopResponse);
noop
in class PingProtos.PingService
public Service getService()
getService
in interface CoprocessorService