Package org.apache.hadoop.hbase.ipc

Class TestProtobufRpcServiceImpl

java.lang.Object

org.apache.hadoop.hbase.ipc.TestProtobufRpcServiceImpl

All Implemented Interfaces:

org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface

@Private
public class TestProtobufRpcServiceImpl
extends Object
implements org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface

Field Summary

Fields

Modifier and Type	Field	Description
private final ScheduledExecutorService	executor
static final org.apache.hbase.thirdparty.com.google.protobuf.BlockingService	SERVICE

Constructor Summary

Constructors

Constructor	Description
TestProtobufRpcServiceImpl()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.AddrResponseProto	addr(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request)
void	addr(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.AddrResponseProto> done)
org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EchoResponseProto	echo(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EchoRequestProto request)
void	echo(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EchoRequestProto request, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EchoResponseProto> done)
org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto	error(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request)
void	error(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)
static org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface	newBlockingStub(org.apache.hadoop.hbase.ipc.RpcClient client, InetSocketAddress addr)
static org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface	newBlockingStub(org.apache.hadoop.hbase.ipc.RpcClient client, InetSocketAddress addr, org.apache.hadoop.hbase.security.User user)
static org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface	newStub(org.apache.hadoop.hbase.ipc.RpcClient client, InetSocketAddress addr)
org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto	pause(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.PauseRequestProto request)
void	pause(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.PauseRequestProto request, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)
org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto	ping(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request)
void	ping(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

SERVICE

public static final org.apache.hbase.thirdparty.com.google.protobuf.BlockingService SERVICE

executor

private final ScheduledExecutorService executor

Constructor Details

TestProtobufRpcServiceImpl

public TestProtobufRpcServiceImpl()

Method Details

newBlockingStub

public static org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface newBlockingStub(org.apache.hadoop.hbase.ipc.RpcClient client,
 InetSocketAddress addr)
                                                                                                                                         throws IOException

Throws:

IOException

newBlockingStub

public static org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface newBlockingStub(org.apache.hadoop.hbase.ipc.RpcClient client,
 InetSocketAddress addr,
 org.apache.hadoop.hbase.security.User user)
                                                                                                                                         throws IOException

Throws:

IOException

newStub

public static org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface newStub(org.apache.hadoop.hbase.ipc.RpcClient client,
 InetSocketAddress addr)
                                                                                                                         throws IOException

Throws:

IOException

ping

public org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto ping(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request)
                                                                                         throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

ping in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

echo

public org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EchoResponseProto echo(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EchoRequestProto request)
                                                                                        throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

echo in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

error

public org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto error(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request)
                                                                                          throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

error in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

pause

public org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto pause(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.PauseRequestProto request)
                                                                                          throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

pause in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

addr

public org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.AddrResponseProto addr(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request)
                                                                                        throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

addr in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

ping

public void ping(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request,
 org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)

Specified by:

ping in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface

echo

public void echo(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EchoRequestProto request,
 org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EchoResponseProto> done)

Specified by:

echo in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface

error

public void error(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request,
 org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)

Specified by:

error in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface

pause

public void pause(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.PauseRequestProto request,
 org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyResponseProto> done)

Specified by:

pause in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface

addr

public void addr(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.EmptyRequestProto request,
 org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestProtos.AddrResponseProto> done)

Specified by:

addr in interface org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.Interface