Package dev.getelements.elements.rt.remote

Class SimpleRemoteInvokerRegistry

java.lang.Object

dev.getelements.elements.rt.remote.SimpleRemoteInvokerRegistry

All Implemented Interfaces:

RemoteInvokerRegistry

public class SimpleRemoteInvokerRegistry
extends Object
implements RemoteInvokerRegistry

Nested Class Summary

Nested classes/interfaces inherited from interface dev.getelements.elements.rt.remote.RemoteInvokerRegistry

RemoteInvokerRegistry.RemoteInvokerStatus

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_REFRESH_RATE
static final long	DEFAULT_REFRESH_TIMEOUT
static final long	DEFAULT_TOTAL_REFRESH_TIMEOUT
static final String	REFRESH_RATE_SECONDS
static final String	REFRESH_TIMEOUT_SECONDS
static final String	TOTAL_REFRESH_TIMEOUT_SECONDS

Constructor Summary

Constructors

Constructor	Description
SimpleRemoteInvokerRegistry()

Method Summary

Modifier and Type	Method	Description
List<RemoteInvoker>	getAllRemoteInvokers(ApplicationId applicationId)	Returns a RemoteInvoker for all known NodeIds.
List<RemoteInvokerRegistry.RemoteInvokerStatus>	getAllRemoteInvokerStatuses()	Gets all RemoteInvoker instances across all applications.
List<RemoteInvokerRegistry.RemoteInvokerStatus>	getAllRemoteInvokerStatuses(ApplicationId applicationId)	Returns a RemoteInvoker for all known NodeIds.
RemoteInvokerRegistry.RemoteInvokerStatus	getBestRemoteInvokerStatus(ApplicationId applicationId)	Returns a RemoteInvoker by arbitrary selection.
InstanceConnectionService	getInstanceConnectionService()
InstanceId	getInstanceId()
long	getRefreshRateSeconds()
long	getRefreshTimeoutSeconds()
RemoteInvoker	getRemoteInvoker(NodeId nodeId)	Returns the RemoteInvoker registered under the given NodeId.
jakarta.inject.Provider<RemoteInvoker>	getRemoteInvokerProvider()
long	getTotalRefreshTimeoutSeconds()
void	refresh()	Forces or initiates a refresh of all NodeIds available.
void	setInstanceConnectionService(InstanceConnectionService instanceConnectionService)
void	setInstanceId(InstanceId instanceId)
void	setRefreshRateSeconds(long refreshRateSeconds)
void	setRefreshTimeoutSeconds(long refreshTimeoutSeconds)
void	setRemoteInvokerProvider(jakarta.inject.Provider<RemoteInvoker> remoteInvokerProvider)
void	setTotalRefreshTimeoutSeconds(long totalRefreshTimeoutSeconds)
void	start()	Starts this RemoteInvokerRegistry.
void	stop()	STops this RemoteInvokerRegistry.

Methods inherited from class java.lang.Object

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

Methods inherited from interface dev.getelements.elements.rt.remote.RemoteInvokerRegistry

getBestRemoteInvoker

Field Details

REFRESH_RATE_SECONDS

public static final String REFRESH_RATE_SECONDS

See Also:

• Constant Field Values

REFRESH_TIMEOUT_SECONDS

public static final String REFRESH_TIMEOUT_SECONDS

See Also:

• Constant Field Values

TOTAL_REFRESH_TIMEOUT_SECONDS

public static final String TOTAL_REFRESH_TIMEOUT_SECONDS

See Also:

• Constant Field Values

DEFAULT_REFRESH_RATE

public static final long DEFAULT_REFRESH_RATE

See Also:

• Constant Field Values

DEFAULT_REFRESH_TIMEOUT

public static final long DEFAULT_REFRESH_TIMEOUT

See Also:

• Constant Field Values

DEFAULT_TOTAL_REFRESH_TIMEOUT

public static final long DEFAULT_TOTAL_REFRESH_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

SimpleRemoteInvokerRegistry

public SimpleRemoteInvokerRegistry()

Method Details

start

public void start()

Description copied from interface: RemoteInvokerRegistry

Starts this RemoteInvokerRegistry.

Specified by:

start in interface RemoteInvokerRegistry

stop

public void stop()

Description copied from interface: RemoteInvokerRegistry

STops this RemoteInvokerRegistry.

Specified by:

stop in interface RemoteInvokerRegistry

refresh

public void refresh()

Description copied from interface: RemoteInvokerRegistry

Forces or initiates a refresh of all NodeIds available. Opening new connections if necessary. This will block until the refresh operation has been completed and all new connections established (if necessary).

Specified by:

refresh in interface RemoteInvokerRegistry

getAllRemoteInvokerStatuses

public List<RemoteInvokerRegistry.RemoteInvokerStatus> getAllRemoteInvokerStatuses()

Description copied from interface: RemoteInvokerRegistry

Gets all RemoteInvoker instances across all applications.

Specified by:

getAllRemoteInvokerStatuses in interface RemoteInvokerRegistry

Returns:

the List<RemoteInvoker>

getAllRemoteInvokerStatuses

public List<RemoteInvokerRegistry.RemoteInvokerStatus> getAllRemoteInvokerStatuses(ApplicationId applicationId)

Description copied from interface: RemoteInvokerRegistry

Returns a RemoteInvoker for all known NodeIds. This will be a perfect snapshot of the state of the registry.

Specified by:

getAllRemoteInvokerStatuses in interface RemoteInvokerRegistry

Parameters:

applicationId -

Returns:

a List<RemoteInvoker>

getBestRemoteInvokerStatus

public RemoteInvokerRegistry.RemoteInvokerStatus getBestRemoteInvokerStatus(ApplicationId applicationId)

Description copied from interface: RemoteInvokerRegistry

Returns a RemoteInvoker by arbitrary selection. The underlying RemoteInvokerRegistry may employ heuristics to determine the most suitable RemoteInvoker to return. However, this defers entirely to the underlying implementation to make that determination.

Specified by:

getBestRemoteInvokerStatus in interface RemoteInvokerRegistry

Parameters:

applicationId -

getAllRemoteInvokers

public List<RemoteInvoker> getAllRemoteInvokers(ApplicationId applicationId)

Description copied from interface: RemoteInvokerRegistry

Returns a RemoteInvoker for all known NodeIds. This will be a perfect snapshot of the state of the registry.

Specified by:

getAllRemoteInvokers in interface RemoteInvokerRegistry

Parameters:

applicationId -

Returns:

a List<RemoteInvoker>

getRemoteInvoker

public RemoteInvoker getRemoteInvoker(NodeId nodeId)

Description copied from interface: RemoteInvokerRegistry

Returns the RemoteInvoker registered under the given NodeId.

Specified by:

getRemoteInvoker in interface RemoteInvokerRegistry

Parameters:

nodeId - the node identifier (may be a NodeId for either an instance or application).

Returns:

a RemoteInvoker for the given nodeId, or null if not found.

getInstanceId

public InstanceId getInstanceId()

setInstanceId

@Inject
public void setInstanceId(InstanceId instanceId)

getInstanceConnectionService

public InstanceConnectionService getInstanceConnectionService()

setInstanceConnectionService

@Inject
public void setInstanceConnectionService(InstanceConnectionService instanceConnectionService)

getRemoteInvokerProvider

public jakarta.inject.Provider<RemoteInvoker> getRemoteInvokerProvider()

setRemoteInvokerProvider

@Inject
public void setRemoteInvokerProvider(jakarta.inject.Provider<RemoteInvoker> remoteInvokerProvider)

getRefreshRateSeconds

public long getRefreshRateSeconds()

setRefreshRateSeconds

@Inject
public void setRefreshRateSeconds(@Named("dev.getelements.elements.rt.remote.invoker.registry.report.refresh.rate.seconds")
 long refreshRateSeconds)

getRefreshTimeoutSeconds

public long getRefreshTimeoutSeconds()

setRefreshTimeoutSeconds

@Inject
public void setRefreshTimeoutSeconds(@Named("dev.getelements.elements.rt.remote.invoker.registry.report.refresh.timeout.seconds")
 long refreshTimeoutSeconds)

getTotalRefreshTimeoutSeconds

public long getTotalRefreshTimeoutSeconds()

setTotalRefreshTimeoutSeconds

@Inject
public void setTotalRefreshTimeoutSeconds(@Named("dev.getelements.elements.rt.remote.invoker.registry.report.total.refresh.timeout.seconds")
 long totalRefreshTimeoutSeconds)