Package com.illumon.iris.controller.handle

Class QueryHandleContext

java.lang.Object

com.illumon.iris.controller.handle.QueryHandleContext

public class QueryHandleContext
extends Object

This class is a context object that contains all of the state that might be needed for the creation of a PersistentQueryHandle. PersistentQueryHandle objects are created reflexively by the WorkerKind.createPersistentQueryHandle(Logger, Object) method when the PersistentQueryController starts a query.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	QueryHandleContext.PresenceManager
static interface	QueryHandleContext.WorkerCompletionCallback

Constructor Summary

Constructors

Constructor

Description

QueryHandleContext(ControllerConfigurationType configurationType, PersistentQueryConfiguration config, String workerProcessInfoId, int priority, UserContext userContext, ScriptPathLoader loader, ControllerDispatcherHandler dispatcherHandler, ThreadPoolExecutor executor, PublicPrivateKeyEncryption encryption, Consumer<PersistentQueryState> stateChangedCallback, QueryHandleContext.WorkerCompletionCallback completionCallback, AuthenticationClient authClient, QueryHandleContext.PresenceManager presenceManager, int slot, IrisGroupProvider groupProvider)

Method Summary

Modifier and Type	Method	Description
AuthenticationClient	getAuthClient()
QueryHandleContext.WorkerCompletionCallback	getCompletionCallback()
PersistentQueryConfiguration	getConfig()
ControllerConfigurationType	getConfigurationType()
ControllerDispatcherHandler	getDispatcherHandler()
PublicPrivateKeyEncryption	getEncryption()
ThreadPoolExecutor	getExecutor()
IrisGroupProvider	getGroupProvider()
ScriptPathLoader	getLoader()
QueryHandleContext.PresenceManager	getPresenceManager()
int	getPriority()
int	getSlot()
Consumer<PersistentQueryState>	getStateChangedCallback()
UserContext	getUserContext()
String	getWorkerProcessInfoId()

Methods inherited from class java.lang.Object

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

Constructor Details

QueryHandleContext

public QueryHandleContext(ControllerConfigurationType configurationType,
 PersistentQueryConfiguration config,
 String workerProcessInfoId,
 int priority,
 @Nullable
 UserContext userContext,
 ScriptPathLoader loader,
 ControllerDispatcherHandler dispatcherHandler,
 ThreadPoolExecutor executor,
 PublicPrivateKeyEncryption encryption,
 Consumer<PersistentQueryState> stateChangedCallback,
 QueryHandleContext.WorkerCompletionCallback completionCallback,
 @NotNull
 AuthenticationClient authClient,
 QueryHandleContext.PresenceManager presenceManager,
 int slot,
 IrisGroupProvider groupProvider)

Method Details

getConfigurationType

public ControllerConfigurationType getConfigurationType()

getConfig

public PersistentQueryConfiguration getConfig()

getUserContext

@Nullable
public UserContext getUserContext()

getLoader

public ScriptPathLoader getLoader()

getDispatcherHandler

public ControllerDispatcherHandler getDispatcherHandler()

getStateChangedCallback

public Consumer<PersistentQueryState> getStateChangedCallback()

getWorkerProcessInfoId

public String getWorkerProcessInfoId()

getCompletionCallback

public QueryHandleContext.WorkerCompletionCallback getCompletionCallback()

getPriority

public int getPriority()

getExecutor

public ThreadPoolExecutor getExecutor()

getEncryption

public PublicPrivateKeyEncryption getEncryption()

getAuthClient

public AuthenticationClient getAuthClient()

getPresenceManager

public QueryHandleContext.PresenceManager getPresenceManager()

getSlot

public int getSlot()

getGroupProvider

public IrisGroupProvider getGroupProvider()