All Classes and Interfaces

Class
Description
As EfsActivator steps through its workflow, its publishes two ActivatorEvents for each step: An in-progress transition with a zero transition duration.
Builder class used to create an activator event.
Workflow step states are in-progress, completed (success), and completed (failed).
This class implements Logger interface with the goal of performing the actual logging asynchronously on an efs dispatcher thread.
Utility class for creating AsyncLogger instances for a given class or name.
This mutable event allows changing the encapsulated event instance even when this ConflationEvent is posted to an agent event queue.
Method-level, run-time annotation defining two attributes: attribute: defines CQEngine attribute type associated with get method.
Defines CQEngine attributes supported by efs which are: SimpleAttribute SimpleNullableAttribute MultiValueAttribute MultiValueNullableAttribute
Defines CQEngine attribute index types supported by efs which are: HashIndex NavigableIndex RadixTreeIndex ReversedRadixTreeIndex SuffixTreeIndex SuffixTreeIndex
This class provides static methods which perform a Runnable task after a specified delay.
EfsActivator is responsible for starting, enabling, disabling, and stopping agents according to a given Workflow.
Builder class used to create an activator.
A typesafe bean configuration used to define a named workflow traveling in a given direction across a given set of steps.
Lists the possible efs agent states.
Method-level, run-time annotation defining maximum number of elements allowed in a collection or array.
This class forwards events to agents and has each agent process those events in a way that is effectively single-threaded.
Builder for constructing EfsDispatcher instance.
A dispatcher is either stopped, started, or failed to start.
Enumerates the supported efs dispatcher thread types.
EfsDispatcher configuration definition.
Contains list of EfsDispatcherConfig instances.
A dispatcher thread watches a given run queue for EfsAgent instances ready to run, attempting to acquire the next ready agent.
A dispatcher thread is either not running, idle (waiting for an available efs agent) or busy (running an efs agent).
This immutable class combines and IEfsAgent and Consumer into a event delivery target by EfsDispatcher.dispatch(EfsDispatchTarget, IEfsEvent).
An interval endpoint based on event time offset.
Builder class for EfsDurationEndpoint.
A publish-subscribe event bus implementation that manages type+topic-based event distribution between publishers (advertisers) and subscribers within a single JVM.
An advertisement is an publishing agent's access point to a event class+topic feed.
Abstract base class for concrete, inbox, and router subscriptions.
Contains "getter" field names for a given efs event class.
Final class containing a event field's name, getter method handle, setter method handle, and data type.
In-memory event file for a single event type + topic.
Defines how an agent may connect an EfsFile: read-only, write-only, or read+write.
Provides read and/or write access to events in an EfsFile.
Represents an active or completed event retrieval subscription from an EfsFileConnection.
An interval endpoint based on event index offset.
Builder class for EfsIndexEndpoint.
An interval consists of a beginning and ending endpoint.
EfsInterval instances may be created only by using a Builder instance.
An EfsInterval consists of two endpoints: beginning and ending.
Specifies whether an end point is inclusive or exclusive.
Base class for all endpoint builders.
An endpoint is based either on fixed time, time offset, or index offset.
Denotes if endpoint denotes past, current time, future, or future on-going.
Specifies on which interval side this endpoint is placed.
Reports a given topic's publish status.
Builder class used to create EfsPublishStatus instances.
Contains event publish timestamp and row index for a given event.
Executes given timer, IEfsAgent pairs at a specified time.
Method-level, run-time annotation defining two attributes: charset: defines Charset used to encode/decode associated String type.
This event is sent to publishing agents to inform on number of in-place subscribers for a given topic.
Builder for constructing EfsSubscribeStatus events.
An interval endpoint based on time.
Builder class for EfsTimeEndpoint.
Event reporting a timer expiration.
Immutable key containing efs event class and topic uniquely defining an efs bus feed instance.
Extends IEfsAgent with methods supporting activation.
This interface solves the problem of start up and shutting down from a non-efs thread.
Dispatcher behavior interface.
Marker interface denoting that a class is an efs event.
Interface defines an efs event builder class used to create an IEfsEvent instance.
A dynamic event router determines target agent and callback for event delivery based on event content.
Exception associated with failure to generate a layout for an IEfsEvent.
Measures and tracks latency metrics for performance analysis of timed operations.
Histogram bucket that tracks the count of latency measurements within a specific nanosecond time interval.
Builder for constructing LatencyTracker instances with configurable latency measurement parameters.
EfsFile posts this event to target agent signifying a retrieval reached its termination.
A retrieval request ends either due to it reaching its ending point, user cancellation, EfsFileConnection closing, or EfsFile closing.
Provides interface to OpenHFT Thread Affinity Library based on a given ThreadAffinityConfig.
A typesafe configuration bean class containing necessary information needed to create an affinity between a thread and a core using OpenHFT Thread Affinity Library.
These affinity types map to a specific AffinityLock static method used to acquire an affinity lock.
Exception thrown when a dispatcher thread fails to start.
Lists thread types available to efs users when configuring efs dispatchers.
A workflow contains one or more workflow stages which take agent(s) from a start state to an end state.
Provides ability to programmatically define a Workflow instance.
An activator work flow takes one or more agents from a given start state to a target end state.
Workflow either advances agents from a lower to a higher state or descends agents from a higher to a lower state.
A workflow stage contains one or more steps which take agent(s) from a start state to end state.
Provides ability to programmatically define a WorkflowStage instance.
A typesafe bean configuration used to define steps within a workflow stage.
A workflow step takes a single IEfsActivateAgent from an expected begin state to an adjacent next state.
Provides ability to programmatically define a WorkflowStep instance.
A typesafe bean configuration used to define a workflow step within a workflow stage.