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

Class TableDataProtocolDriverImpl

java.lang.Object

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

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, TableDataProtocolDriver, NamedImplementation

public class TableDataProtocolDriverImpl
extends Object
implements TableDataProtocolDriver, NamedImplementation, com.fishlib.base.log.LogOutputAppendable

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
com.fishlib.base.log.LogOutput	append(com.fishlib.base.log.LogOutput logOutput)
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()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.util.type.NamedImplementation

getImplementationName

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

toString

public String toString()

Overrides:

toString in class Object

append

public com.fishlib.base.log.LogOutput append(com.fishlib.base.log.LogOutput logOutput)

Specified by:

append in interface com.fishlib.base.log.LogOutputAppendable