Package com.illumon.iris.controller

Class ControllerHashtableServer

java.lang.Object

com.illumon.iris.controller.ControllerHashtable

com.illumon.iris.controller.ControllerHashtableServer

All Implemented Interfaces:

ControllerHashtableEventSource, Map<Long,PersistentQueryInfo>

public class ControllerHashtableServer
extends ControllerHashtable

Nested Class Summary

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

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

Field Summary

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

data, handlers

Constructor Summary

Constructors

Constructor	Description
ControllerHashtableServer(com.fishlib.io.logger.Logger log, IrisGroupProvider groupProvider, ClientStateManager clientManager, WorkerUrlBuilder workerUrlBuilder)	Create a ControllerHashtableServer with the specified id, date, persistence policy, underlying map, and initial capacity for size entries (use default capacity if size==0).

Method Summary

Modifier and Type	Method	Description
void	clear()
PersistentQueryInfo	put(Long key, PersistentQueryInfo value)
PersistentQueryInfo	remove(Object key)
protected void	removeClientAndObserver(ClientStateManager.ClientState clientState)
protected void	subscribe(io.deephaven.proto.controller.SubscribeRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<io.deephaven.proto.controller.SubscribeResponse> responseObserver, io.deephaven.proto.controller.ControllerConfigurationMessage controllerConfigMessage)

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

addEventHandler, addEventHandlerAndGetData, containsKey, containsValue, entrySet, get, getData, isEmpty, keySet, notifyHandlers, putAll, removeEventHandler, size, values

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

Constructor Details

ControllerHashtableServer

public ControllerHashtableServer(@NotNull
 com.fishlib.io.logger.Logger log,
 @NotNull
 IrisGroupProvider groupProvider,
 @NotNull
 ClientStateManager clientManager,
 @NotNull
 WorkerUrlBuilder workerUrlBuilder)

Create a ControllerHashtableServer with the specified id, date, persistence policy, underlying map, and initial capacity for size entries (use default capacity if size==0). Requests from the clients are passed over the specified comm channel.

Parameters:

log -

groupProvider -

clientManager -

Method Details

put

public PersistentQueryInfo put(@NotNull
 Long key,
 @NotNull
 PersistentQueryInfo value)

Specified by:

put in interface Map<Long,PersistentQueryInfo>

Overrides:

put in class ControllerHashtable

remove

public PersistentQueryInfo remove(@NotNull
 Object key)

Specified by:

remove in interface Map<Long,PersistentQueryInfo>

Overrides:

remove in class ControllerHashtable

clear

public void clear()

Specified by:

clear in interface Map<Long,PersistentQueryInfo>

Overrides:

clear in class ControllerHashtable

subscribe

protected void subscribe(io.deephaven.proto.controller.SubscribeRequest request,
 io.deephaven.shadow.core.io.grpc.stub.StreamObserver<io.deephaven.proto.controller.SubscribeResponse> responseObserver,
 io.deephaven.proto.controller.ControllerConfigurationMessage controllerConfigMessage)

removeClientAndObserver

protected void removeClientAndObserver(ClientStateManager.ClientState clientState)