Package com.illumon.iris.db.v2.locations.protocol

Class TableDataProtocolDriverImpl

java.lang.Object

com.illumon.iris.db.v2.locations.protocol.TableDataProtocolDriverImpl

All Implemented Interfaces:

TableDataProtocolDriver

public class TableDataProtocolDriverImpl
extends Object
implements TableDataProtocolDriver

Remote TableDataService implementation.

Constructor Summary

Constructors

Constructor	Description
TableDataProtocolDriverImpl(com.fishlib.io.sched.Scheduler scheduler, com.fishlib.io.logger.Logger log, String name, long requestTimeoutMillis, boolean allowIOMessageFlush)	Construct a new remote table data service, ready to be connected.

Method Summary

Modifier and Type	Method	Description
void	authenticate()
void	connect(com.fishlib.base.Function.Nullary<SocketAddress> addressFunction)	Connect to a remote server by address function, allowing fallback to different server addresses.
void	connect(String host, int port)	Connect to a remote server.
void	connect(InetSocketAddress address)	Connect to a remote server.
TableDataProtocol.LocalServer	connectLocalServer(String name)
String	getLogPrefix()
TableDataRequest	removePendingRequest(long requestKey)
void	shutdown()
TableDataRequest	takeOrAllocateFreeRequest()

Methods inherited from class java.lang.Object

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

Constructor Details

TableDataProtocolDriverImpl

public TableDataProtocolDriverImpl(@NotNull com.fishlib.io.sched.Scheduler scheduler, @NotNull com.fishlib.io.logger.Logger log, @NotNull String name, long requestTimeoutMillis, boolean allowIOMessageFlush)

Construct a new remote table data service, ready to be connected.

Parameters:

scheduler - Job scheduler

log - Logger for output

name - Remote service name

requestTimeoutMillis - The timeout value to use for all requests

allowIOMessageFlush - allow synchronous flush of message buffers

Method Details

authenticate

public void authenticate()

Specified by:

authenticate in interface TableDataProtocolDriver

connect

public void connect(@NotNull InetSocketAddress address) throws IOException

Description copied from interface: TableDataProtocolDriver

Connect to a remote server.

Specified by:

connect in interface TableDataProtocolDriver

Parameters:

address - The host/port to connect to

Throws:

IOException

connect

public void connect(@NotNull String host, int port) throws IOException

Description copied from interface: TableDataProtocolDriver

Connect to a remote server.

Specified by:

connect in interface TableDataProtocolDriver

Parameters:

host - The host to connect to

port - The port to connect to

Throws:

IOException

connect

public void connect(@NotNull com.fishlib.base.Function.Nullary<SocketAddress> addressFunction) throws IOException

Description copied from interface: TableDataProtocolDriver

Connect to a remote server by address function, allowing fallback to different server addresses.

Specified by:

connect in interface TableDataProtocolDriver

Parameters:

addressFunction - The address function to determine each connection attempt's host and port

Throws:

IOException

connectLocalServer

public TableDataProtocol.LocalServer connectLocalServer(@NotNull String name)

shutdown

public void shutdown()

Specified by:

shutdown in interface TableDataProtocolDriver

removePendingRequest

@Nullable public TableDataRequest removePendingRequest(long requestKey)

Specified by:

removePendingRequest in interface TableDataProtocolDriver

takeOrAllocateFreeRequest

@NotNull public TableDataRequest takeOrAllocateFreeRequest()

Specified by:

takeOrAllocateFreeRequest in interface TableDataProtocolDriver

getLogPrefix

public String getLogPrefix()

Specified by:

getLogPrefix in interface TableDataProtocolDriver