Package com.illumon.iris.controller.service

Class ClientStateManager

java.lang.Object

com.illumon.iris.controller.service.ClientStateManager

public class ClientStateManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ClientStateManager.ClientState

Field Summary

Fields

Modifier and Type	Field	Description
static final long	CLIENT_HEARTBEAT_EXPIRY_MILLIS
static final io.deephaven.hash.KeyedObjectKey.Basic<io.deephaven.shadow.core.com.google.protobuf.ByteString,ClientStateManager.ClientState>	CLIENT_STATE_KEY

Constructor Summary

Constructors

Constructor	Description
ClientStateManager(com.fishlib.io.logger.Logger log, ScheduledExecutorService executorService, BiPredicate<String,AuthToken> tokenVerifier)

Method Summary

Modifier and Type	Method	Description
ClientStateManager.ClientState	authenticate(ClientId clientId, AuthToken authToken)
void	forEachSubscribedClient(Consumer<ClientStateManager.ClientState> action)
ClientStateManager.ClientState	getClientStateByCookie(io.deephaven.shadow.core.com.google.protobuf.ByteString cookie)
void	invalidateClient(io.deephaven.shadow.core.com.google.protobuf.ByteString cookie)	Invalidate a client by their cookie.
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Details

CLIENT_HEARTBEAT_EXPIRY_MILLIS

public static final long CLIENT_HEARTBEAT_EXPIRY_MILLIS

CLIENT_STATE_KEY

public static final io.deephaven.hash.KeyedObjectKey.Basic<io.deephaven.shadow.core.com.google.protobuf.ByteString,ClientStateManager.ClientState> CLIENT_STATE_KEY

Constructor Details

ClientStateManager

public ClientStateManager(@NotNull
 com.fishlib.io.logger.Logger log,
 @NotNull
 ScheduledExecutorService executorService,
 @NotNull
 BiPredicate<String,AuthToken> tokenVerifier)

Method Details

authenticate

public ClientStateManager.ClientState authenticate(@NotNull
 ClientId clientId,
 @NotNull
 AuthToken authToken)

getClientStateByCookie

@NotNull
public ClientStateManager.ClientState getClientStateByCookie(io.deephaven.shadow.core.com.google.protobuf.ByteString cookie)

shutdown

public void shutdown()
              throws IOException

Throws:

IOException

forEachSubscribedClient

public void forEachSubscribedClient(@NotNull
 Consumer<ClientStateManager.ClientState> action)

invalidateClient

public void invalidateClient(io.deephaven.shadow.core.com.google.protobuf.ByteString cookie)

Invalidate a client by their cookie. If the client is not found, no further action occurs. If a client is found, this will safely complete any active subscriptions, ignoring any errors.

Parameters:

cookie - the client cookie