Package com.illumon.iris.controller

Class ControllerHashtableClient

java.lang.Object

com.illumon.iris.controller.ControllerHashtable

com.illumon.iris.controller.ControllerHashtableClient

All Implemented Interfaces:

com.fishlib.net.api.CommandHandler, com.fishlib.net.api.ConnectionStatusHandlerEx, com.fishlib.net.CommBase.ConnectionStatusHandler, ControllerHashtableEventSource, Map<Long,PersistentQueryInfo>

Direct Known Subclasses:

PersistentQueryControllerClient

public class ControllerHashtableClient
extends ControllerHashtable
implements com.fishlib.net.api.CommandHandler, com.fishlib.net.api.ConnectionStatusHandlerEx

Nested Class Summary

Nested classes/interfaces inherited from interface com.fishlib.net.api.ConnectionStatusHandlerEx

com.fishlib.net.api.ConnectionStatusHandlerEx.Adapter

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K extends Object,V extends Object>

Field Summary

Fields

Modifier and Type	Field	Description
protected com.fishlib.io.logger.Logger	log

Fields inherited from class com.illumon.iris.controller.ControllerHashtable

id

Method Summary

Modifier and Type	Method	Description
void	addEventHandlerAndGetData(ControllerHashtableEventHandler handler)	Subscribe to events with an initial snapshot of the data.
void	addReloadCommandListener(Consumer<PersistentQueryControllerConfiguration> reloadListener)
void	clear()
boolean	containsKey(Object key)
boolean	containsValue(Object value)
void	disconnect()
Set<Map.Entry<Long,PersistentQueryInfo>>	entrySet()
PersistentQueryInfo	get(Object key)
com.fishlib.net.api.CommClient	getComm()
com.fishlib.base.hash.IndexableMap<Long,PersistentQueryInfo>	getData()
Map<Long,PersistentQueryInfo>	getUnderlyingMap()
void	handleClientDeath(com.fishlib.net.api.ClientEntry client)
void	handleCommand(com.fishlib.net.api.ClientEntry client, com.fishlib.base.Command cmd)
void	handleConnectionLost(com.fishlib.net.api.ClientEntry client)
void	handleConnectionReestablished()
void	handleInitialConnection(com.fishlib.net.api.CommClient commClient)
boolean	isEmpty()
Set<Long>	keySet()
PersistentQueryInfo	put(Long key, PersistentQueryInfo value)
void	putAll(Map<? extends Long,? extends PersistentQueryInfo> t)
PersistentQueryInfo	remove(Object key)
int	size()
void	subscribeToAll()
Collection<PersistentQueryInfo>	values()	Note that this breaks the contract of Map because the values are copied.
protected long	waitUntilConnectedOrTimeout(String who, long timeoutDurationMillis)

Methods inherited from class com.illumon.iris.controller.ControllerHashtable

addCommandHandler, addEventHandler, removeCommandHandler, removeEventHandler

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, equals, forEach, getOrDefault, hashCode, merge, putIfAbsent, remove, replace, replace, replaceAll

Field Details

log

protected final com.fishlib.io.logger.Logger log

Method Details

addReloadCommandListener

public void addReloadCommandListener(Consumer<PersistentQueryControllerConfiguration> reloadListener)

waitUntilConnectedOrTimeout

protected long waitUntilConnectedOrTimeout(String who, long timeoutDurationMillis)

getComm

public com.fishlib.net.api.CommClient getComm()

getData

public com.fishlib.base.hash.IndexableMap<Long,PersistentQueryInfo> getData()

get

public PersistentQueryInfo get(Object key)

Specified by:

get in interface Map<Long,PersistentQueryInfo>

put

public PersistentQueryInfo put(Long key, PersistentQueryInfo value)

Specified by:

put in interface Map<Long,PersistentQueryInfo>

clear

public void clear()

Specified by:

clear in interface Map<Long,PersistentQueryInfo>

remove

public PersistentQueryInfo remove(Object key)

Specified by:

remove in interface Map<Long,PersistentQueryInfo>

handleCommand

public void handleCommand(com.fishlib.net.api.ClientEntry client, com.fishlib.base.Command cmd)

Specified by:

handleCommand in interface com.fishlib.net.api.CommandHandler

size

public int size()

Specified by:

size in interface Map<Long,PersistentQueryInfo>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Map<Long,PersistentQueryInfo>

containsKey

public boolean containsKey(Object key)

Specified by:

containsKey in interface Map<Long,PersistentQueryInfo>

containsValue

public boolean containsValue(Object value)

Specified by:

containsValue in interface Map<Long,PersistentQueryInfo>

values

@NotNull public Collection<PersistentQueryInfo> values()

Note that this breaks the contract of Map because the values are copied.

Specified by:

values in interface Map<Long,PersistentQueryInfo>

putAll

public void putAll(@NotNull Map<? extends Long,? extends PersistentQueryInfo> t)

Specified by:

putAll in interface Map<Long,PersistentQueryInfo>

entrySet

@NotNull public Set<Map.Entry<Long,PersistentQueryInfo>> entrySet()

Specified by:

entrySet in interface Map<Long,PersistentQueryInfo>

keySet

@NotNull public Set<Long> keySet()

Specified by:

keySet in interface Map<Long,PersistentQueryInfo>

handleClientDeath

public void handleClientDeath(com.fishlib.net.api.ClientEntry client)

Specified by:

handleClientDeath in interface com.fishlib.net.api.CommandHandler

disconnect

public void disconnect() throws IOException

Specified by:

disconnect in class ControllerHashtable

Throws:

IOException

addEventHandlerAndGetData

public void addEventHandlerAndGetData(ControllerHashtableEventHandler handler)

Subscribe to events with an initial snapshot of the data.

Specified by:

addEventHandlerAndGetData in interface ControllerHashtableEventSource

Parameters:

handler - the handler for ControllerHashTableEvents

subscribeToAll

public void subscribeToAll() throws IOException

Specified by:

subscribeToAll in class ControllerHashtable

Throws:

IOException

getUnderlyingMap

public Map<Long,PersistentQueryInfo> getUnderlyingMap()

Specified by:

getUnderlyingMap in class ControllerHashtable

handleConnectionLost

public void handleConnectionLost(com.fishlib.net.api.ClientEntry client)

Specified by:

handleConnectionLost in interface com.fishlib.net.CommBase.ConnectionStatusHandler

handleConnectionReestablished

public void handleConnectionReestablished()

Specified by:

handleConnectionReestablished in interface com.fishlib.net.CommBase.ConnectionStatusHandler

handleInitialConnection

public void handleInitialConnection(com.fishlib.net.api.CommClient commClient)

Specified by:

handleInitialConnection in interface com.fishlib.net.api.ConnectionStatusHandlerEx