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

Class RemoteTableDataService

java.lang.Object

com.illumon.iris.db.v2.tabledataservice.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

Modifier and Type	Class	Description
class	RemoteTableDataService.TableLocationProviderImpl	TableLocationProvider implementation that delegates to appropriate Requests.

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.tabledataservice.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
void	authenticate()	Authenticate the TableDataService using AuthenticationClientManager.getDefault()
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.
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.tabledataservice.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.tabledataservice.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 TableDataServiceExporter we connect to supports subscriptions

allowIOMessageFlush - allow synchronous flush of message buffers

Method Details

authenticate

public void authenticate()

Description copied from interface: TableDataService

Authenticate the TableDataService using AuthenticationClientManager.getDefault()

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

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