org.apache.drill.exec.rpc

Interface RemoteConnection

All Superinterfaces:

AutoCloseable, ConnectionThrottle

All Known Subinterfaces:

ClientConnection, ServerConnection<S>

All Known Implementing Classes:

AbstractClientConnection, AbstractRemoteConnection, AbstractServerConnection, ControlConnection, DataClientConnection, DataServerConnection, UserClient.UserToBitConnection, UserServer.BitToUserConnection

public interface RemoteConnection
extends ConnectionThrottle, AutoCloseable

Method Summary

Modifier and Type	Method and Description
void	addSecurityHandlers()
boolean	blockOnNotWritable(RpcOutcomeListener<?> listener)
void	channelClosed(RpcException ex)
void	close()
<V> ChannelListenerWithCoordinationId	createNewRpcListener(RpcOutcomeListener<V> handler, Class<V> clazz)
BufferAllocator	getAllocator()
<V> RpcOutcome<V>	getAndRemoveRpcOutcome(int rpcType, int coordinationId, Class<V> clazz)
io.netty.channel.Channel	getChannel()
String	getName()
SocketAddress	getRemoteAddress()
boolean	inEventLoop()
boolean	isActive()
void	recordRemoteFailure(int coordinationId, UserBitShared.DrillPBError failure)

Methods inherited from interface org.apache.drill.exec.rpc.ConnectionThrottle

setAutoRead

Method Detail

inEventLoop

boolean inEventLoop()

getName

String getName()

getAllocator

BufferAllocator getAllocator()

getChannel

io.netty.channel.Channel getChannel()

blockOnNotWritable

boolean blockOnNotWritable(RpcOutcomeListener<?> listener)

isActive

boolean isActive()

getAndRemoveRpcOutcome

<V> RpcOutcome<V> getAndRemoveRpcOutcome(int rpcType,
                                         int coordinationId,
                                         Class<V> clazz)

createNewRpcListener

<V> ChannelListenerWithCoordinationId createNewRpcListener(RpcOutcomeListener<V> handler,
                                                           Class<V> clazz)

recordRemoteFailure

void recordRemoteFailure(int coordinationId,
                         UserBitShared.DrillPBError failure)

channelClosed

void channelClosed(RpcException ex)

getRemoteAddress

SocketAddress getRemoteAddress()

addSecurityHandlers

void addSecurityHandlers()

close

void close()

Specified by:

close in interface AutoCloseable