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(@NotNull IrisGroupProvider groupProvider, @NotNull ClientStateManager clientManager, @NotNull Function<PersistentQueryInfo,AssignmentPolicy> policyFinder)	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(@NotNull Long key, @NotNull PersistentQueryInfo value)
PersistentQueryInfo	remove(@NotNull Object key)
protected void	removeClientAndObserver(ClientStateManager.ClientState clientState)	Remove a client, possibly completing its subscription if it was active.
protected void	subscribe(SubscribeRequest request, io.grpc.stub.ServerCallStreamObserver<SubscribeResponse> responseObserver, PersistentQueryControllerConfiguration controllerConfig)

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
 @NotNull IrisGroupProvider groupProvider,
 @NotNull
 @NotNull ClientStateManager clientManager,
 @NotNull
 @NotNull Function<PersistentQueryInfo,AssignmentPolicy> policyFinder)

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:

groupProvider - the provider of group information

clientManager - the ClientStateManager for looking up client details

policyFinder - a function to locate the AssignmentPolicy instance for queries.

Method Details

put

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

Specified by:

put in interface Map<Long,PersistentQueryInfo>

Overrides:

put in class ControllerHashtable

remove

public PersistentQueryInfo remove(@NotNull
 @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(SubscribeRequest request,
 io.grpc.stub.ServerCallStreamObserver<SubscribeResponse> responseObserver,
 PersistentQueryControllerConfiguration controllerConfig)

removeClientAndObserver

protected void removeClientAndObserver(ClientStateManager.ClientState clientState)

Remove a client, possibly completing its subscription if it was active. If the state was already removed or already completed this returns without error.

Parameters:

clientState - The state to try to remove