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(io.deephaven.enterprise.niowrapper.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()	Authenticates with the remote server.
void	connect(String host, int port)	Connect to a remote server.
void	connect(InetSocketAddress address)	Connect to a remote server.
void	connect(Supplier<SocketAddress> addressSupplier)	Connect to a remote server by address supplier, allowing fallback to different server addresses.
TableDataProtocol.LocalServer	connectLocalServer(String name)
String	getLogPrefix()	Returns the log prefix used for logging messages from this driver.
TableDataRequest	removePendingRequest(long requestKey)	Removes and returns a pending request by its key.
void	shutdown()	Shuts down the protocol driver and releases any resources.
TableDataRequest	takeOrAllocateFreeRequest()	Takes an available free request from the pool or allocates a new one if none are available.
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
 io.deephaven.enterprise.niowrapper.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()

Description copied from interface: TableDataProtocolDriver

Authenticates with the remote server.

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 - if an I/O error occurs during connection

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 - if an I/O error occurs during connection

connect

public void connect(@NotNull
 Supplier<SocketAddress> addressSupplier)
             throws IOException

Description copied from interface: TableDataProtocolDriver

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

Specified by:

connect in interface TableDataProtocolDriver

Parameters:

addressSupplier - The address supplier to determine each connection attempt's host and port

Throws:

IOException - if an I/O error occurs during connection

connectLocalServer

public TableDataProtocol.LocalServer connectLocalServer(@NotNull
 String name)

shutdown

public void shutdown()

Description copied from interface: TableDataProtocolDriver

Shuts down the protocol driver and releases any resources.

Specified by:

shutdown in interface TableDataProtocolDriver

removePendingRequest

@Nullable
public TableDataRequest removePendingRequest(long requestKey)

Description copied from interface: TableDataProtocolDriver

Removes and returns a pending request by its key.

Specified by:

removePendingRequest in interface TableDataProtocolDriver

Parameters:

requestKey - the unique key identifying the request

Returns:

the removed request, or null if no request exists for the given key

takeOrAllocateFreeRequest

@NotNull
public TableDataRequest takeOrAllocateFreeRequest()

Description copied from interface: TableDataProtocolDriver

Takes an available free request from the pool or allocates a new one if none are available.

Specified by:

takeOrAllocateFreeRequest in interface TableDataProtocolDriver

Returns:

a table data request ready for use

getLogPrefix

public String getLogPrefix()

Description copied from interface: TableDataProtocolDriver

Returns the log prefix used for logging messages from this driver.

Specified by:

getLogPrefix in interface TableDataProtocolDriver

Returns:

the log prefix string

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