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

Class RemoteTableDataService

java.lang.Object

com.illumon.iris.db.v2.locations.AbstractTableDataService

com.illumon.iris.db.v2.locations.remote.RemoteTableDataService

All Implemented Interfaces:

TableDataService

public class RemoteTableDataService
extends AbstractTableDataService

Remote TableDataService implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.locations.TableDataService

TableDataService.Null

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
RemoteTableDataService	connect(com.fishlib.base.Function.Nullary<SocketAddress> addressFunction)	Connect to a remote server by address function, allowing fallback to different server addresses.
RemoteTableDataService	connect(String host, int port)	Connect to a remote server.
RemoteTableDataService	connect(InetSocketAddress address)	Connect to a remote server.
TableDataProtocol.LocalServer	connectLocalServer(String name)	Connect to an in-process server.
String	describe()	Like toString, but with more detail.
protected TableLocationProvider	makeTableLocationProvider(TableKey tableKey)
void	shutdown()
String	toString()

Methods inherited from class com.illumon.iris.db.v2.locations.AbstractTableDataService

getKnownLocationProviders, getName, getTableLocationProvider, reset, reset

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.db.v2.locations.TableDataService

getTableLocationProvider

Constructor Details

RemoteTableDataService

public RemoteTableDataService(@NotNull com.fishlib.io.sched.Scheduler scheduler, @NotNull com.fishlib.io.logger.Logger log, @NotNull String name, long requestTimeoutMillis, boolean supportsSubscriptions, 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

supportsSubscriptions - Whether the service underlying the the TableDataServiceExporter we connect to supports subscriptions

allowIOMessageFlush - allow synchronous flush of message buffers

Method Details

connect

public RemoteTableDataService connect(@NotNull InetSocketAddress address) throws IOException

Connect to a remote server.

Parameters:

address - The host/port to connect to

Returns:

this

Throws:

IOException

connect

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

Connect to a remote server.

Parameters:

host - The host to connect to

port - The port to connect to

Returns:

this

Throws:

IOException

connect

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

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

Parameters:

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

Returns:

this

Throws:

IOException

connectLocalServer

public TableDataProtocol.LocalServer connectLocalServer(@NotNull String name)

Connect to an in-process server.

Parameters:

name - The name to use for the server

Returns:

this

shutdown

public void shutdown()

makeTableLocationProvider

@NotNull protected TableLocationProvider makeTableLocationProvider(@NotNull TableKey tableKey)

Specified by:

makeTableLocationProvider in class AbstractTableDataService

toString

public String toString()

Overrides:

toString in class Object

describe

public String describe()

Description copied from interface: TableDataService

Like toString, but with more detail.

Returns:

a description string