Package dev.getelements.elements.rt
package dev.getelements.elements.rt
-
ClassDescriptionAsyncConnection<ContextT,
SocketT> Represents an asynchornous type ofConnection.Enumeration of events for which to listen.AsyncConnectionGroup<ContextT,SocketT> Represents a group ofAsyncConnections which all are serviced by the same thread.AsyncConnectionGroup.Builder<ContextT,BuilderSocketT> AsyncConnectionPool<ContextT,SocketT> An interface to an underlying pool of sockets.AsyncConnectionService<ContextT,SocketT> A system-wide service to houseAsyncConnectioninstances.Connection<ContextT,SocketT> Represents a connection to the remote node.Created by patricktwohig on 8/5/15.Represents the connection the backend cluster of services.Builds aContextwhich can communicate with a specific application.Houses aReentrantThreadLocalto represent the currently availableReentrantThreadLocal<Attributes>Manages events.Used to manage handler-typeResourceinstances.Represents an association between aPathand theResourceIdto which it points.The result of theIndexContext.unlinkAsync(Path, Consumer, Consumer)andIndexContext.unlink(Path)call.Provides data for an Instance, which is representative of the physical machine running one or more nodes.Monitors the load of the local instance and reports information such as CPU load and Memory load.Locks a set of objects based on their identity in a consistent and order ensuring no deadlocks when having to acquire multiple locks.Loads the various manifest types over the network to be used by dependent services.Created by patricktwohig on 8/14/17.Dispatches invocations of methods againstResourceinstances.Loads theModelManifest.Handles the actual details of writing to theOutputStream.Handles the actual details of writing anObjectto a byte stream.Drives the instance-wide persistence system, if available.Provides a means to a persist the state ofResourceinstances as managed by an associatedResourceService.Houses some utility logic for interacting with the Reflection API.AResourceis a logical unit of work, which is represented by an instance of this type.The interface for manipulatingResources in the cluster.This is the service responsible for maintaining a set ofResourceinstances.Contains the association between thePathandResourceId.Acquires aResource, guaranteeing it will stay in memory until this object is closed.Represents a transaction against a single instance of aResource.The return-value for methods such asResourceService.unlinkPath(Path)andResourceService.unlinkPath(Path, Consumer)Enumeration of the various server reserved response codes.Provides a means to accept results returned by instances ofMethodDispatcherThis defines the strategy of how JSON-RPC handles the response.Provides a reason as to why a task was resumed, typically by theSchedulerContext, but not always.Allows for the manipulating of handlerResources as shared instances.RoundRobin<T>Implements a round-robin data structure which will repeatedly select from a set of values ensuring an even distribution across all values.The Scheduler is the main entry point dispatching requests and operations to the variousResourceinstances contained in the underlying services.This is theProxyablefor scheduling tasks within the cluster.This is the main class used to manage the lifecycle of the underlyingSchedulerinstances.SharedAsyncConnectionService<ContextT,SocketT> A type ofAsyncConnectionServicewhich uses an internal reference count to ensure that the backedAsyncConnectionServiceis opened and closed properly.Provides data for an Instance.The simple handler server is responsible for dispatching requests and events to allResourceinstances contained therein.Used to implement handler types.Manages the global state of currently operating tasks.