Index (rt-server-cluster-node 3.6.26 API)

A B C D E G I L M N P R S U W
All Classes and Interfaces|All Packages|Constant Field Values

A

AbstractLocalInvocationDispatcher - Class in dev.getelements.elements.rt.remote
AbstractLocalInvocationDispatcher() - Constructor for class dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
accessWorkerState() - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
accessWorkerState() - Method in interface dev.getelements.elements.rt.remote.Worker: Opens an Worker.Accessor which can be used to read the run-state of this Worker.
addNode(ApplicationId) - Method in interface dev.getelements.elements.rt.remote.Worker.Mutator: Adds a new node with the supplied ApplicationId.
addNode(String) - Method in interface dev.getelements.elements.rt.remote.Worker.Mutator: Adds a new node with the supplied application unique name.

B

beginMutation() - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
beginMutation() - Method in interface dev.getelements.elements.rt.remote.Worker: Opens a Worker.Mutator which can be used to modify the run-state of this Worker.
beginShutdown() - Method in interface dev.getelements.elements.rt.remote.Node: Begins the shutdown process.
beginStartup() - Method in interface dev.getelements.elements.rt.remote.Node: Begins the startup process by returning an instance of Node.Startup.
blockingFutureStrategy() - Static method in interface dev.getelements.elements.rt.remote.LocalInvocationProcessor: Returns an instance of LocalInvocationProcessor.ReturnValueStrategy which simply blocks until the Future either returns or throws an instance of Throwable.
build() - Method in class dev.getelements.elements.rt.remote.LocalInvocationProcessorBuilder: Builds a new instance of the LocalInvocationDispatcher.

C

CachedThreadPoolProvider - Class in dev.getelements.elements.rt.remote.provider
CachedThreadPoolProvider() - Constructor for class dev.getelements.elements.rt.remote.provider.CachedThreadPoolProvider
cancel() - Method in interface dev.getelements.elements.rt.remote.Node.Startup: Cancels the operation.
close() - Method in interface dev.getelements.elements.rt.remote.Worker.Accessor: Releases any resources associated with the Worker.Mutator.
commit() - Method in interface dev.getelements.elements.rt.remote.Worker.Mutator: Commits any changes to the Worker.
ContextLocalInvocationDispatcher - Class in dev.getelements.elements.rt.remote: Deprecated.
This needs to be replaced with a dispatch to an Element via ElementRegistry
ContextLocalInvocationDispatcher() - Constructor for class dev.getelements.elements.rt.remote.ContextLocalInvocationDispatcher: Deprecated.
CPUCountThreadPoolProvider - Class in dev.getelements.elements.rt.remote.provider
CPUCountThreadPoolProvider(Class<?>) - Constructor for class dev.getelements.elements.rt.remote.provider.CPUCountThreadPoolProvider
CPUCountThreadPoolProvider(Class<?>, String) - Constructor for class dev.getelements.elements.rt.remote.provider.CPUCountThreadPoolProvider
create(ApplicationId) - Method in interface dev.getelements.elements.rt.remote.Node.Factory: Creates a Node for the supplied ApplicationId

D

dev.getelements.elements.rt.remote - package dev.getelements.elements.rt.remote
dev.getelements.elements.rt.remote.provider - package dev.getelements.elements.rt.remote.provider
dev.getelements.elements.rt.remote.watchdog - package dev.getelements.elements.rt.remote.watchdog
dispatch(Invocation, ResultHandlerStrategy) - Method in interface dev.getelements.elements.rt.remote.LocalInvocationDispatcher: Dispatches using the Invocation and ResultHandlerStrategy.
dispatch(Invocation, Consumer<InvocationResult>, Consumer<InvocationError>, List<Consumer<InvocationResult>>, Consumer<InvocationError>) - Method in class dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
dispatch(Invocation, Consumer<InvocationResult>, Consumer<InvocationError>, List<Consumer<InvocationResult>>, Consumer<InvocationError>) - Method in interface dev.getelements.elements.rt.remote.LocalInvocationDispatcher: Performs the actual dispatch by unpacking the Invocation and collecting the results into the provided Consumer<dev.getelements.elements.rt.remote.InvocationResult>.

E

ExecutorServiceFactory<ExecutorServiceFactoryT> - Interface in dev.getelements.elements.rt.remote.provider

G

get() - Method in class dev.getelements.elements.rt.remote.provider.CachedThreadPoolProvider
get() - Method in class dev.getelements.elements.rt.remote.provider.CPUCountThreadPoolProvider
get() - Method in class dev.getelements.elements.rt.remote.provider.ScheduledExecutorServiceProvider
getBindingSet() - Method in interface dev.getelements.elements.rt.remote.Worker.Accessor: Gets all active InstanceConnectionService.InstanceBindings.
getContext() - Method in class dev.getelements.elements.rt.remote.ContextLocalInvocationDispatcher: Deprecated.
getDispatchType() - Method in class dev.getelements.elements.rt.remote.LocalInvocationProcessorBuilder: Gets the Dispatch.Type strategy to use when dispatching the method.
getInstanceId() - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
getInstanceMetadataContext() - Method in class dev.getelements.elements.rt.remote.MasterNodeLifecycle
getInstanceMetadataContext() - Method in class dev.getelements.elements.rt.remote.MasterNodeLocalInvocationDispatcher: Deprecated.
getMasterNode() - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
getMethod() - Method in class dev.getelements.elements.rt.remote.LocalInvocationProcessorBuilder: Gets the Method to dispatch.
getName() - Method in interface dev.getelements.elements.rt.remote.Node: Gets the symbolic name of the node.
getNode() - Method in interface dev.getelements.elements.rt.remote.Node.Startup: Gets the Node starting up.
getNodeFactory() - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
getNodeId() - Method in interface dev.getelements.elements.rt.remote.Node: Gets the NodeId
getNodeId() - Method in interface dev.getelements.elements.rt.remote.Node.Startup: Gets the NodeId being started-up.
getNodeSet() - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
getNodeSet() - Method in interface dev.getelements.elements.rt.remote.Worker.Accessor: Gets all Node instances running in this Worker.
getPersistenceEnvironment() - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
getProtocol() - Method in class dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
getScheduledExecutorServiceFactory() - Method in class dev.getelements.elements.rt.remote.watchdog.SimpleWatchdogService
getSchedulerPoolSizeProvider() - Method in class dev.getelements.elements.rt.remote.provider.ScheduledExecutorServiceProvider
getScope() - Method in class dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
getService(Class<?>) - Method in interface dev.getelements.elements.rt.remote.provider.ExecutorServiceFactory
getService(String) - Method in interface dev.getelements.elements.rt.remote.provider.ExecutorServiceFactory
getServiceLocator() - Method in class dev.getelements.elements.rt.remote.ServiceLocatorLocalInvocationDispatcher: Deprecated.
getState() - Method in interface dev.getelements.elements.rt.remote.Node: Gets the state of the node.
getThreadGroupProvider() - Method in class dev.getelements.elements.rt.remote.provider.CachedThreadPoolProvider
getThreadGroupProvider() - Method in class dev.getelements.elements.rt.remote.provider.ScheduledExecutorServiceProvider
getWorker() - Method in class dev.getelements.elements.rt.remote.watchdog.SimpleWatchdogService
getWorkerWatchdogList() - Method in class dev.getelements.elements.rt.remote.watchdog.SimpleWatchdogService

I

ignoreReturnValueStrategy() - Static method in interface dev.getelements.elements.rt.remote.LocalInvocationProcessor: Constructs a LocalInvocationProcessor.ReturnValueStrategy which ignores the return value and immediately returns an InvocationResult with a null result.
InstanceThreadFactory - Class in dev.getelements.elements.rt.remote.provider
InstanceThreadFactory(ThreadGroup, String) - Constructor for class dev.getelements.elements.rt.remote.provider.InstanceThreadFactory

L

LocalInvocationDispatcher - Interface in dev.getelements.elements.rt.remote: Dispatches Invocation instances to the objects in the container, collects the result, and relays any errors.
LocalInvocationProcessor - Interface in dev.getelements.elements.rt.remote: Implements the strategy by which the Invocation is dispatched to the local Object in memory.
LocalInvocationProcessor.ReturnValueStrategy - Interface in dev.getelements.elements.rt.remote: If the Method called from the Invocation returns a Future instance, this may defined a strategy for handling the result.
LocalInvocationProcessorBuilder - Class in dev.getelements.elements.rt.remote: Inspects the attributes, parameters, and annotations of a specific Method to build an instance of LocalInvocationDispatcher to dispatch Invocation instances to a local object in memory.
LocalInvocationProcessorBuilder(RemoteScope, Class<?>, String, List<String>) - Constructor for class dev.getelements.elements.rt.remote.LocalInvocationProcessorBuilder

M

MASTER_NODE_NAME - Static variable in interface dev.getelements.elements.rt.remote.Node: Designates a master/control Node.
MasterNodeLifecycle - Class in dev.getelements.elements.rt.remote
MasterNodeLifecycle() - Constructor for class dev.getelements.elements.rt.remote.MasterNodeLifecycle
MasterNodeLocalInvocationDispatcher - Class in dev.getelements.elements.rt.remote: Deprecated.
This needs to be replaced with a dispatch to an Element via ElementRegistry
MasterNodeLocalInvocationDispatcher() - Constructor for class dev.getelements.elements.rt.remote.MasterNodeLocalInvocationDispatcher: Deprecated.

N

NAME - Static variable in interface dev.getelements.elements.rt.remote.Node: An indicator of the Node's name to be used with the Named annotation.
newThread(Runnable) - Method in class dev.getelements.elements.rt.remote.provider.InstanceThreadFactory
Node - Interface in dev.getelements.elements.rt.remote: Represents the worker node for a single Application.
Node.Factory - Interface in dev.getelements.elements.rt.remote: Allows for the creation of Node instances on-the-fly.
Node.Shutdown - Interface in dev.getelements.elements.rt.remote: Represents a pending node shut-down process.
Node.Startup - Interface in dev.getelements.elements.rt.remote: Represents a pending node start-up process.
NodeBindingWatchdog - Class in dev.getelements.elements.rt.remote.watchdog
NodeBindingWatchdog() - Constructor for class dev.getelements.elements.rt.remote.watchdog.NodeBindingWatchdog
NodeHealthWorkerWatchdog - Class in dev.getelements.elements.rt.remote.watchdog
NodeHealthWorkerWatchdog() - Constructor for class dev.getelements.elements.rt.remote.watchdog.NodeHealthWorkerWatchdog
NodeLifecycle - Interface in dev.getelements.elements.rt.remote: Informs the underlying application, contained in the Node, of the various livecycle events.
nodePostStart(Node) - Method in interface dev.getelements.elements.rt.remote.NodeLifecycle: Called after the Node is up and accepting connections.
nodePostStop(Node) - Method in class dev.getelements.elements.rt.remote.MasterNodeLifecycle
nodePostStop(Node) - Method in interface dev.getelements.elements.rt.remote.NodeLifecycle: Called just after the Node has stopped accepting connections.
nodePreStart(Node) - Method in class dev.getelements.elements.rt.remote.MasterNodeLifecycle
nodePreStart(Node) - Method in interface dev.getelements.elements.rt.remote.NodeLifecycle: Called before the Node is up and accepting connections
nodePreStop(Node) - Method in interface dev.getelements.elements.rt.remote.NodeLifecycle: Called just before the Node will stop accepting connections and shut down

P

postClose(Consumer<Exception>) - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
postStart() - Method in interface dev.getelements.elements.rt.remote.Node.Startup: Performs any post-start operations.
postStart(Consumer<Exception>) - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
postStop() - Method in interface dev.getelements.elements.rt.remote.Node.Shutdown: Performs any post-start operations.
preClose(Consumer<Exception>) - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
preStart() - Method in interface dev.getelements.elements.rt.remote.Node.Startup: Performs any pre-start operations.
preStart(Consumer<Exception>) - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
preStop() - Method in interface dev.getelements.elements.rt.remote.Node.Shutdown: Performs any pre-start operations.
process(Object, Consumer<InvocationError>, Consumer<InvocationResult>) - Method in interface dev.getelements.elements.rt.remote.LocalInvocationProcessor.ReturnValueStrategy
processInvocation(Object, Invocation, Consumer<InvocationResult>, Consumer<InvocationError>, List<Consumer<InvocationResult>>, Consumer<InvocationError>) - Method in interface dev.getelements.elements.rt.remote.LocalInvocationProcessor: Performs the dispatch to the supplied object.

R

removeNode(ApplicationId) - Method in interface dev.getelements.elements.rt.remote.Worker.Mutator: Removes the supplied Node with the supplied ApplicationId.
removeNode(String) - Method in interface dev.getelements.elements.rt.remote.Worker.Mutator: Removes the supplied Node with the supplied name.
removeNode(Collection<ApplicationId>) - Method in interface dev.getelements.elements.rt.remote.Worker.Mutator: Removes the supplied Nodes with the supplied ApplicationIds.
resolve(Class<?>) - Method in class dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
resolve(Class<?>) - Method in class dev.getelements.elements.rt.remote.MasterNodeLocalInvocationDispatcher: Deprecated.
resolve(Class<?>) - Method in class dev.getelements.elements.rt.remote.ServiceLocatorLocalInvocationDispatcher: Deprecated.
resolve(Class<?>, Invocation) - Method in class dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
resolve(Class<?>, String) - Method in class dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
resolve(Class<?>, String) - Method in class dev.getelements.elements.rt.remote.ContextLocalInvocationDispatcher: Deprecated.
resolve(Class<?>, String) - Method in class dev.getelements.elements.rt.remote.ServiceLocatorLocalInvocationDispatcher: Deprecated.
restartNode(ApplicationId) - Method in interface dev.getelements.elements.rt.remote.Worker.Mutator: Restarts the supplied Node with the supplied ApplicationId.
restartNode(String) - Method in interface dev.getelements.elements.rt.remote.Worker.Mutator: Restarts the supplied Node with the supplied name.
restartNode(Collection<ApplicationId>) - Method in interface dev.getelements.elements.rt.remote.Worker.Mutator: Restarts the supplied Nodes with the supplied ApplicationIds.

S

ScheduledExecutorServiceProvider - Class in dev.getelements.elements.rt.remote.provider
ScheduledExecutorServiceProvider() - Constructor for class dev.getelements.elements.rt.remote.provider.ScheduledExecutorServiceProvider
ServiceLocatorLocalInvocationDispatcher - Class in dev.getelements.elements.rt.remote: Deprecated.
This needs to be replaced with a dispatch to an Element via ElementRegistry
ServiceLocatorLocalInvocationDispatcher() - Constructor for class dev.getelements.elements.rt.remote.ServiceLocatorLocalInvocationDispatcher: Deprecated.
setContext(Context) - Method in class dev.getelements.elements.rt.remote.ContextLocalInvocationDispatcher: Deprecated.
setInstanceId(InstanceId) - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
setInstanceMetadataContext(InstanceMetadataContext) - Method in class dev.getelements.elements.rt.remote.MasterNodeLifecycle
setInstanceMetadataContext(InstanceMetadataContext) - Method in class dev.getelements.elements.rt.remote.MasterNodeLocalInvocationDispatcher: Deprecated.
setMasterNode(Node) - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
setNodeFactory(Node.Factory) - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
setNodeSet(Set<Node>) - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
setPersistenceEnvironment(PersistenceEnvironment) - Method in class dev.getelements.elements.rt.remote.SimpleWorkerInstance
setProtocol(String) - Method in class dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
setScheduledExecutorServiceFactory(ExecutorServiceFactory<ScheduledExecutorService>) - Method in class dev.getelements.elements.rt.remote.watchdog.SimpleWatchdogService
setSchedulerPoolSizeProvider(Provider<Integer>) - Method in class dev.getelements.elements.rt.remote.provider.ScheduledExecutorServiceProvider
setScope(String) - Method in class dev.getelements.elements.rt.remote.AbstractLocalInvocationDispatcher
setServiceLocator(ServiceLocator) - Method in class dev.getelements.elements.rt.remote.ServiceLocatorLocalInvocationDispatcher: Deprecated.
setThreadGroupProvider(Provider<ThreadGroup>) - Method in class dev.getelements.elements.rt.remote.provider.CachedThreadPoolProvider
setThreadGroupProvider(Provider<ThreadGroup>) - Method in class dev.getelements.elements.rt.remote.provider.ScheduledExecutorServiceProvider
setWorker(Worker) - Method in class dev.getelements.elements.rt.remote.watchdog.SimpleWatchdogService
setWorkerWatchdogList(Set<WorkerWatchdog>) - Method in class dev.getelements.elements.rt.remote.watchdog.SimpleWatchdogService
simpleReturnValueStrategy() - Static method in interface dev.getelements.elements.rt.remote.LocalInvocationProcessor: Constructs a LocalInvocationProcessor.ReturnValueStrategy which simply hands the result of the Invocation directly to a new instance of InvocationResult and passes it into to the supplied Consumer
SimpleWatchdogService - Class in dev.getelements.elements.rt.remote.watchdog
SimpleWatchdogService() - Constructor for class dev.getelements.elements.rt.remote.watchdog.SimpleWatchdogService
SimpleWorkerInstance - Class in dev.getelements.elements.rt.remote: Contains all Node instances for several Node instances and manages their life cycles therein.
SimpleWorkerInstance() - Constructor for class dev.getelements.elements.rt.remote.SimpleWorkerInstance
start() - Method in class dev.getelements.elements.rt.remote.watchdog.SimpleWatchdogService
start() - Method in interface dev.getelements.elements.rt.remote.watchdog.WatchdogService: Starts monitoring.
start() - Method in interface dev.getelements.elements.rt.remote.watchdog.WorkerWatchdog: Starts this WorkerWatchdog.
start(InstanceConnectionService.InstanceBinding) - Method in interface dev.getelements.elements.rt.remote.Node.Startup: Starts the service.
stop() - Method in interface dev.getelements.elements.rt.remote.Node.Shutdown: Stops the service.
stop() - Method in class dev.getelements.elements.rt.remote.watchdog.SimpleWatchdogService
stop() - Method in interface dev.getelements.elements.rt.remote.watchdog.WatchdogService: Stops monitoring.
stop() - Method in interface dev.getelements.elements.rt.remote.watchdog.WorkerWatchdog: Stops this WorkerWatchdog.

U

unsupported() - Static method in interface dev.getelements.elements.rt.remote.Node.Factory: Indicates that factory support is currently disabled or otherwise unsupported.

W

watch(Logger, Worker) - Method in class dev.getelements.elements.rt.remote.watchdog.NodeBindingWatchdog
watch(Logger, Worker) - Method in class dev.getelements.elements.rt.remote.watchdog.NodeHealthWorkerWatchdog
watch(Logger, Worker) - Method in interface dev.getelements.elements.rt.remote.watchdog.WorkerWatchdog: Executes the rules for this WorkerWatchdog
WatchdogService - Interface in dev.getelements.elements.rt.remote.watchdog: Times and executes watchdogs.
Worker - Interface in dev.getelements.elements.rt.remote: Represents the worker, hosing one or more nodes performing work.
Worker.Accessor - Interface in dev.getelements.elements.rt.remote: Allows client code to read the sstate of the Worker
Worker.Mutator - Interface in dev.getelements.elements.rt.remote: Allows for the mutation of the Worker.
WorkerWatchdog - Interface in dev.getelements.elements.rt.remote.watchdog: Represents a watchdog service which is designed to perform operations against the Worker on a regular basis, ensuring things like health checks and other critical operations.

A B C D E G I L M N P R S U W
All Classes and Interfaces|All Packages|Constant Field Values