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