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.
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).
An interval endpoint based on event time offset.
Builder class for EfsDurationEndpoint.
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.
This class provides meta-information concerning the encapsulated event.
Builder for constructing an EfsEventWrapper instance.
Responsible for storing and forwarding efs events.
Immutable key containing efs event class and subject uniquely defining an efs feed instance.
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.
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.
EfsFeed.subscribe(IEfsAgent, Consumer, EfsInterval) returns an EfsSubscription instance which may be used to EfsSubscription.close() the subscription.
An interval endpoint based on time.
Builder class for EfsTimeEndpoint.
Event reporting a timer expiration.
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.
Exception associated with failure to generate a layout for an IEfsEvent.
This class is used when an agent posting an event to a second agent expecting a reply to its event.
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.