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,io.deephaven.enterprise.auth.AuthToken> tokenVerifier)

Method Summary

Modifier and Type	Method	Description
ClientStateManager.ClientState	authenticate(io.deephaven.proto.auth.ClientId clientId, io.deephaven.enterprise.auth.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)
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,io.deephaven.enterprise.auth.AuthToken> tokenVerifier)

Method Details

authenticate

public ClientStateManager.ClientState authenticate(@NotNull
 io.deephaven.proto.auth.ClientId clientId,
 @NotNull
 io.deephaven.enterprise.auth.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)