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.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.
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.