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.
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.
Base implementation for a dispatcher thread that runs efs agents and manages their execution lifecycle.
A dispatcher thread is either not running, idle (waiting for an available efs agent) or busy (running an efs agent).
Base builder for concrete dispatcher-thread implementations.
Dispatcher thread that runs a single pinned efs agent on a dedicated busy-spin loop.
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.
Immutable wrapper for an event published on an event bus.
A publish-subscribe event bus implementation that manages type+topic-based event distribution between publishers (advertisers) and subscribers within a single JVM.
Represents a publishing agent's access point to a concrete topic feed.
Configures and creates a new event bus instance.
Base class for subscriptions concrete topic subscriptions, inbox subscriptions, and event 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.
Fluent builder for creating and, optionally, populating an EfsFile.
Run time metrics for an EfsFile instance.
Specifies whether efs file has a size limit restriction and, if so, how to respond when limit is reached.
Provides read and/or write access to events in an EfsFile.
Represents an active or completed event retrieval subscription from an EfsFileConnection.
Exception thrown when EfsFile.Builder encounters an error when initializing a EfsFile instance or adding new row to event file.
An interval endpoint based on fixed event index values.
Builder class for EfsIndexFixedEndpoint.
An interval endpoint based on relative event index offset.
Builder class for EfsIndexOffsetEndpoint.
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.
Defines control policy for agents attempting to connect to an efs event file using a specified access mode.
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.
Enumerates the supported efs dispatcher thread types.
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, maximum allowed concurrent retrievals exceeded, 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.