Package io.deephaven.enterprise.remote

Class CorePlusClusterSessionFactory

java.lang.Object

io.deephaven.enterprise.remote.CorePlusClusterSessionFactory

All Implemented Interfaces:

RemoteTableSessionFactory

public final class CorePlusClusterSessionFactory
extends Object
implements RemoteTableSessionFactory

A session factory that knows how to associate a barrage session and its managed channel; the session is created authenticated to a DHE authentication service client. It also allows obtaining a controller client.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	CorePlusClusterSessionFactory.SessionAndChannel

Constructor Summary

Constructors

Constructor	Description
CorePlusClusterSessionFactory(@NotNull Supplier<PersistentQueryControllerClient> controllerClient, @NotNull ScheduledExecutorService executor, @NotNull org.apache.arrow.memory.BufferAllocator allocator, @NotNull ManagedChannelFactory clientChannelFactory, @NotNull AuthenticationClient authClient, boolean isInternal)	Create a new CorePlusClusterSessionFactory

Method Summary

Modifier and Type	Method	Description
void	close()	Close any state associated with this factory.
static CorePlusClusterSessionFactory	forCluster(@NotNull DeephavenClusterConnection clusterConnection, boolean isInternal)	Create a new CorePlusClusterSessionFactory for connections to the specified cluster.
@NotNull PersistentQueryControllerClient	getControllerClient()	Get a subscribed PersistentQueryControllerClient for this cluster.
@NotNull CorePlusClusterSessionFactory.SessionAndChannel	newSession(RemoteTableStateWatcher.StateToken token)	Create a new BarrageSession for susbcriptions using the RemoteTableStateWatcher.StateToken.

Methods inherited from class java.lang.Object

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

Constructor Details

CorePlusClusterSessionFactory

public CorePlusClusterSessionFactory(@NotNull
 @NotNull Supplier<PersistentQueryControllerClient> controllerClient,
 @NotNull
 @NotNull ScheduledExecutorService executor,
 @NotNull
 @NotNull org.apache.arrow.memory.BufferAllocator allocator,
 @NotNull
 @NotNull ManagedChannelFactory clientChannelFactory,
 @NotNull
 @NotNull AuthenticationClient authClient,
 boolean isInternal)

Create a new CorePlusClusterSessionFactory

Parameters:

controllerClient - the controller client

executor - the executor for the sessions

allocator - the allocator

clientChannelFactory - the factory for ManagedChannels

authClient - the authentication client

isInternal - if this object exists within the cluster being connected to

Method Details

forCluster

public static CorePlusClusterSessionFactory forCluster(@NotNull
 @NotNull DeephavenClusterConnection clusterConnection,
 boolean isInternal)

Create a new CorePlusClusterSessionFactory for connections to the specified cluster.

Parameters:

clusterConnection - the cluster connection

isInternal - if this object exists within the same cluster as clusterConnection

Returns:

a new CorePlusClusterSessionFactory

newSession

@NotNull
public @NotNull CorePlusClusterSessionFactory.SessionAndChannel newSession(@NotNull
 RemoteTableStateWatcher.StateToken token)

Description copied from interface: RemoteTableSessionFactory

Create a new BarrageSession for susbcriptions using the RemoteTableStateWatcher.StateToken.

Specified by:

newSession in interface RemoteTableSessionFactory

Parameters:

token - the state

Returns:

a new BarrageSession

getControllerClient

@NotNull
public @NotNull PersistentQueryControllerClient getControllerClient()

Get a subscribed PersistentQueryControllerClient for this cluster.

Returns:

a subscribed PersistentQueryControllerClient

close

public void close()

Description copied from interface: RemoteTableSessionFactory

Close any state associated with this factory.

Specified by:

close in interface RemoteTableSessionFactory