Index (efs 0.5.0 API)

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

acquireLock(AffinityLock, ThreadAffinityConfig) - Static method in class org.efs.dispatcher.config.ThreadAffinity: Returns an OpenHFT thread affinity lock based on an existing lock and CPU strategy configuration.
acquireLock(ThreadAffinityConfig) - Static method in class org.efs.dispatcher.config.ThreadAffinity: Returns an OpenHFT thread affinity lock.
activate() - Method in interface org.efs.activator.IEfsActivateAgent: This method transitions an agent from stand-by to active.
ACTIVATING - Enum constant in enum class org.efs.activator.EfsAgentState: Agent is in this temporary state while transitioning from EfsAgentState.STAND_BY to EfsAgentState.ACTIVE.
ActivatorEvent - Class in org.efs.activator.event: As EfsActivator steps through its workflow, its publishes two ActivatorEvents for each step: An in-progress transition with a zero transition duration.
ActivatorEvent.Builder - Class in org.efs.activator.event: Builder class used to create an activator event.
ActivatorEvent.StepState - Enum Class in org.efs.activator.event: Workflow step states are in-progress, completed (success), and completed (failed).
Activator Execution - Search tag in package org.efs.activator: Section
ACTIVE - Enum constant in enum class org.efs.activator.EfsAgentState: Agent is both successfully started and active.
addDispatcher(String, IEfsDispatcher) - Static method in class org.efs.dispatcher.EfsDispatcher: Adds a mocked dispatcher with the given name to dispatchers map.
affinity() - Method in class org.efs.dispatcher.EfsDispatcherThread: Returns thread affinity configuration.
AFFINITY_NAME_KEY - Static variable in class org.efs.dispatcher.config.ThreadAffinityConfig: Key "affinityName" contain unique affinity name.
AFFINITY_TYPE_KEY - Static variable in class org.efs.dispatcher.config.ThreadAffinityConfig: Key "affinityType" contains an ThreadAffinityConfig.AffinityType value.
agent(String) - Static method in class org.efs.dispatcher.EfsDispatcher: Returns efs agent instance with the given name.
AGENT_NAME_KEY - Static variable in class org.efs.activator.config.WorkflowStepConfig: Key "agent" contains unique activate agent name.
agentEventStats() - Method in class org.efs.dispatcher.EfsDispatcher.DispatcherStats: Returns aggregated dispatcher thread statistics for agent event count (number of events processed per run).
agentEventStats() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns agent statistics with respect to how many events agents processed per run.
agentName() - Method in class org.efs.activator.WorkflowStep: Returns step's agent name.
agentName() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns currently executing agent's name.
agentName(String) - Method in class org.efs.activator.event.ActivatorEvent.Builder: Sets IEfsActivateAgent unique name.
agentName(String) - Method in class org.efs.activator.WorkflowStep.Builder: Sets agent name.
Agent Processing Events - Search tag in package org.efs.dispatcher: Section
agentReadyTimeStats() - Method in class org.efs.dispatcher.EfsDispatcher.DispatcherStats: Returns aggregated dispatcher thread statistics for agent ready time (time spent on dispatcher ready queue).
agentReadyTimeStats() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns agent statistics with respect to how long agents spent on dispatcher ready queue before running.
Agent Registration - Search tag in package org.efs.dispatcher: Section
agentRunCount() - Method in class org.efs.dispatcher.EfsDispatcher.AgentStats: Returns number of agents run on this thread.
agentRunCount() - Method in class org.efs.dispatcher.EfsDispatcherThread.AgentStats: Returns number of agents run on this thread.
agentRunCount() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns total number of agents run.
agentRunTimeStats() - Method in class org.efs.dispatcher.EfsDispatcher.DispatcherStats: Returns aggregated dispatcher thread statistics for agent run time (time spent processing events).
agentRunTimeStats() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns agent statistics with respect to how long agents spent processing events.
agentState(String) - Method in class org.efs.activator.EfsActivator: Returns named agent's current state.
agentState(String, EfsAgentState) - Method in class org.efs.activator.EfsActivator: Forcibly sets named agent's state.
ALLOWED_TRANSITION_TIME_KEY - Static variable in class org.efs.activator.config.WorkflowStepConfig: Key "allowedTransitionTime" contains allowed agent transition time.
allowedTransitionTime() - Method in class org.efs.activator.WorkflowStep: Returns agent's allowed time to execute this transition.
allowedTransitionTime(Duration) - Method in class org.efs.activator.WorkflowStep.Builder: Sets time agent is allowed to complete the transition from begin to end state.
ANY_CORE - Enum constant in enum class org.efs.dispatcher.config.ThreadAffinityConfig.AffinityType: Use AffinityLock.acquireCore() to assign any free core to thread.
ANY_CPU - Enum constant in enum class org.efs.dispatcher.config.ThreadAffinityConfig.AffinityType: Use AffinityLock.acquireLock() to assign any free CPU to thread.
ASCEND - Enum constant in enum class org.efs.activator.WorkflowDirection: Move agents up from a lower to a higher (or possible same) agent state.
AsyncLogger - Class in org.efs.logging: This class implements Logger interface with the goal of performing the actual logging asynchronously on an efs dispatcher thread.
AsyncLoggerFactory - Class in org.efs.logging: Utility class for creating AsyncLogger instances for a given class or name.
average() - Method in class org.efs.dispatcher.EfsDispatcher.AgentStats: Returns average value for all stats.
awaitTermination(long, TimeUnit) - Method in class org.efs.timer.EfsScheduledExecutor: Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

B

BEGIN_STATE_KEY - Static variable in class org.efs.activator.config.WorkflowStepConfig: Key "beginState" contains transition begin state.
beginning() - Method in class org.efs.feed.EfsInterval: Returns interval begin endpoint.
beginning(EfsIntervalEndpoint) - Method in class org.efs.feed.EfsInterval.Builder: Sets interval beginning endpoint.
BEGINNING - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.IntervalSide: Endpoint is the interval beginning endpoint.
BEGINNING_ENDPOINT_NULL - Static variable in class org.efs.feed.EfsInterval.Builder: When attempting to set interval's beginning endpoint to null, then NullPointerException contains message "beginning endpoint is null".
BEGINNING_GREATER_THAN_ENDING - Static variable in class org.efs.feed.EfsInterval.Builder: When attempting to set interval with a beginning endpoint > ending endpoint, then ValidationException contains message "beginning > ending".
beginsPast(int, Instant) - Method in class org.efs.feed.EfsSubscription: Returns true if this subscription begins in the past and false otherwise.
beginState() - Method in class org.efs.activator.WorkflowStep: Returns agent expected begin state.
beginState(EfsAgentState) - Method in class org.efs.activator.WorkflowStep.Builder: Sets expected agent begin state.
beginSymbol() - Method in enum class org.efs.feed.EfsIntervalEndpoint.Clusivity: Returns clusivity begin symbol.
BIND_KEY - Static variable in class org.efs.dispatcher.config.ThreadAffinityConfig: Key "bind" contains the bind-thread-to-affinity lock flag.
BLOCKING - Enum constant in enum class org.efs.dispatcher.config.ThreadType: The thread blocks while waiting for the desired event to occur.
build() - Method in class org.efs.activator.EfsActivator.Builder: Returns a new activator based on this builder's settings.
build() - Method in class org.efs.activator.event.ActivatorEvent.Builder: Returns a newly created activator event based on this builder's properties.
build() - Method in class org.efs.activator.Workflow.Builder: Returns new workflow based on this builder's settings.
build() - Method in class org.efs.activator.WorkflowStage.Builder: Returns new workflow stage based on this builder's settings.
build() - Method in class org.efs.activator.WorkflowStep.Builder: Returns new workflow step based on this builder's settings.
build() - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Returns a new IEfsDispatcher instance based on this builder's settings.
build() - Method in class org.efs.event.EfsEventWrapper.Builder: Creates a new EfsEventWrapper instance based on this builder's settings.
build() - Method in interface org.efs.event.IEfsEventBuilder: Returns a new event instance based on the builder settings.
build() - Method in class org.efs.feed.EfsInterval.Builder: Returns a new interval instance based on this builder's settings.
build() - Method in class org.efs.feed.EfsIntervalEndpoint.EndpointBuilder: Returns a new endpoint constructed from this builder's settings.
builder() - Static method in class org.efs.activator.EfsActivator: Returns a new Builder instance.
builder() - Static method in class org.efs.activator.event.ActivatorEvent: Returns a new activator event builder instance.
builder() - Static method in class org.efs.activator.Workflow: Returns a new Builder instance.
builder() - Static method in class org.efs.activator.WorkflowStage: Returns a new Builder instance.
builder() - Static method in class org.efs.activator.WorkflowStep: Returns a new Builder instance.
builder() - Static method in class org.efs.event.EfsEventWrapper: Returns a new efs event wrapper builder.
builder() - Static method in class org.efs.feed.EfsDurationEndpoint: Returns a new EfsDurationEndpoint builder instance used to create an EfsDurationEndpoint object.
builder() - Static method in class org.efs.feed.EfsIndexEndpoint: Returns a new EfsIndexEndpoint builder instance used to create an EfsIndexEndpoint object.
builder() - Static method in class org.efs.feed.EfsInterval: Returns a new EfsInterval builder instance which is used to create an EfsInterval object.
builder() - Static method in class org.efs.feed.EfsTimeEndpoint: Returns a new EfsTimeEndpoint builder instance used to create an EfsTimeEndpoint object.
builder(String) - Static method in class org.efs.dispatcher.EfsDispatcher: Returns a new dispatcher configuration builder.
builderMethod() - Method in class org.efs.event.type.EfsEventLayout: Returns event public static builder() method handle.
buildImpl() - Method in class org.efs.feed.EfsDurationEndpoint.Builder: Returns a new EfsDurationEndpoint instance based on this builder's settings.
buildImpl() - Method in class org.efs.feed.EfsIndexEndpoint.Builder: Returns a new EfsIndexEndpoint instance based on this builder's settings.
buildImpl() - Method in class org.efs.feed.EfsIntervalEndpoint.EndpointBuilder: Returns a newly constructed endpoint.
buildImpl() - Method in class org.efs.feed.EfsTimeEndpoint.Builder: Returns a new EfsTimeEndpoint instance based on this builder's settings.
buildMethod() - Method in class org.efs.event.type.EfsEventLayout: Returns efs event builder class required build() method handle.
BUSY - Enum constant in enum class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadState: Dispatcher thread is busy running efs agent events.

C

charset() - Element in annotation interface org.efs.event.EfsStringInfo: Returns character set name used to encode/decode String field.
CLASSES_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "classes" contains efs agent class names supported by this dispatcher.
close() - Method in class org.efs.feed.EfsSubscription: Marks this subscription as inactive.
clusivity() - Method in class org.efs.feed.EfsIntervalEndpoint: Returns endpoint clusivity.
CLUSIVITY_NULL - Static variable in class org.efs.feed.EfsIntervalEndpoint.EndpointBuilder: When attempting to set endpoint clusivity to null, then NullPointerException contains message "clusivity is null".
compare(int, Instant) - Method in class org.efs.feed.EfsSubscription: Returns integer value <, equal to, or > zero if given event index or time (based on endpoint type) is before, during, or after this subscription's interval.
compare(EfsIntervalEndpoint.IntervalLocation, EfsIntervalEndpoint.IntervalLocation) - Static method in enum class org.efs.feed.EfsIntervalEndpoint.IntervalLocation: Returns an integer value <, equal to, or > zero if l0 is <, equal to, or > l1.
compareEndpoints(EfsIntervalEndpoint, EfsIntervalEndpoint) - Method in class org.efs.feed.EfsInterval.Builder: Returns integer value <, equal to, or > zero if begin is <, equal to, > end.
compareEndpoints(EfsIntervalEndpoint, EfsIntervalEndpoint) - Static method in class org.efs.feed.EfsIntervalEndpoint: Returns integer value <, equal to, or > zero if ep0 is <, equal to, > ep1.
compareTo(EfsDurationEndpoint) - Method in class org.efs.feed.EfsDurationEndpoint
compareTo(EfsIndexEndpoint) - Method in class org.efs.feed.EfsIndexEndpoint: Returns integer value <, equal to, or > zero if this EfsIndexEndpoint is <, equal to, or > given time endpoint argument.
compareTo(EfsTimeEndpoint) - Method in class org.efs.feed.EfsTimeEndpoint: Returns integer value <, equal to, or > zero if this EfsTimeEndpoint is <, equal to, or > given time endpoint argument.
Comparison with Existing Concurrency Frameworks - Search tag in package org.efs.dispatcher: Section
COMPLETED_FAILED - Enum constant in enum class org.efs.activator.event.ActivatorEvent.StepState: Workflow step execution failed.
COMPLETED_SUCCESS - Enum constant in enum class org.efs.activator.event.ActivatorEvent.StepState: Workflow step successfully completed.
ConflationEvent<E> - Class in org.efs.event: This mutable event allows changing the encapsulated event instance even when this ConflationEvent is posted to an agent event queue.
ConflationEvent() - Constructor for class org.efs.event.ConflationEvent: Creates a new conflation event with no encapsulated event.
contains(Class<?>) - Method in class org.efs.event.ConflationEvent: Return true if this conflation event is not empty and the contained event is a class which is assignable from the given class.
containsField(String) - Method in class org.efs.event.type.EfsEventLayout: Returns true if given name is an event field and false otherwise.
CPU_ID - Enum constant in enum class org.efs.dispatcher.config.ThreadAffinityConfig.AffinityType: Use AffinityLock.acquireLock(int cpuId to assign a CPU with specified identifier to thread.
CPU_ID_KEY - Static variable in class org.efs.dispatcher.config.ThreadAffinityConfig: Key "cpuId" contains CPU identifier used when ThreadAffinityConfig.AFFINITY_TYPE_KEY is set to ThreadAffinityConfig.AffinityType.CPU_ID.
CPU_LAST_MINUS - Enum constant in enum class org.efs.dispatcher.config.ThreadAffinityConfig.AffinityType: Use AffinityLock.acquireLockLastMinus(int n to allocate a CPU from the end of the core set based on the given positive number.
CPU_OFFSET_KEY - Static variable in class org.efs.dispatcher.config.ThreadAffinityConfig: Key "cpuOffset" contains CPU offset used when ThreadAffinityConfig.AFFINITY_TYPE_KEY is set to ThreadAffinityConfig.AffinityType.CPU_LAST_MINUS.
CPU_STRATEGIES - Enum constant in enum class org.efs.dispatcher.config.ThreadAffinityConfig.AffinityType: Use AffinityLock.acquireLock(AffinityStrategies...) to assign a CPU for thread affinity.
Creating an EfsScheduledTimer - Search tag in class org.efs.timer.EfsScheduledExecutor: Section
Creating Dispatchers - Search tag in class org.efs.dispatcher.EfsDispatcher: Section
Creating efs Scheduled Executors - Search tag in package org.efs.timer: Section
currentMissedEventCount() - Method in class org.efs.event.ConflationEvent: Returns number of missed events between initial ConflationEvent.offer(IEfsEvent) and before ConflationEvent.poll().

D

dataType() - Method in class org.efs.event.type.EfsEventLayout.EfsEventField: Returns field Java type.
datum() - Method in class org.efs.timer.EfsTimerEvent: Returns optional user-provided datum forwarded in this timer.
deactivate() - Method in interface org.efs.activator.IEfsActivateAgent: This method transitions an agent from active to stand-by.
DEACTIVATING - Enum constant in enum class org.efs.activator.EfsAgentState: Agent is in this temporary state while transitioning from EfsAgentState.ACTIVE to EfsAgentState.STAND_BY.
debug(String) - Method in class org.efs.logging.AsyncLogger
debug(String, Object) - Method in class org.efs.logging.AsyncLogger
debug(String, Object...) - Method in class org.efs.logging.AsyncLogger
debug(String, Object, Object) - Method in class org.efs.logging.AsyncLogger
debug(String, Throwable) - Method in class org.efs.logging.AsyncLogger
debug(Marker, String) - Method in class org.efs.logging.AsyncLogger
debug(Marker, String, Object) - Method in class org.efs.logging.AsyncLogger
debug(Marker, String, Object...) - Method in class org.efs.logging.AsyncLogger
debug(Marker, String, Object, Object) - Method in class org.efs.logging.AsyncLogger
debug(Marker, String, Throwable) - Method in class org.efs.logging.AsyncLogger
DEFAULT_DISPATCHER_EVENT_QUEUE_CAPACITY - Static variable in class org.efs.feed.EfsFeed: Default efs feed dispatcher event queue capacity is 512.
DEFAULT_DISPATCHER_MAX_EVENTS - Static variable in class org.efs.feed.EfsFeed: Default efs feed dispatcher may process up to 32 events at a time.
DEFAULT_DISPATCHER_NAME - Static variable in class org.efs.feed.EfsFeed: Default efs feed dispatcher is named "__DefaultFeedDispatcher__".
DEFAULT_DISPATCHER_PRIORITY - Static variable in class org.efs.feed.EfsFeed: Default efs feed dispatcher priority is 5.
DEFAULT_DISPATCHER_RUN_QUEUE_LIMIT - Static variable in class org.efs.feed.EfsFeed: Default efs feed dispatcher run queue capacity is 65536.
DEFAULT_DISPATCHER_THREAD_COUNT - Static variable in class org.efs.feed.EfsFeed: Default efs feed dispatcher thread count is 4.
DEFAULT_DISPATCHER_THREAD_TYPE - Static variable in class org.efs.feed.EfsFeed: Default efs feed dispatcher thread type is ThreadType.BLOCKING.
DEFAULT_EVENT_QUEUE_CAPACITY - Static variable in class org.efs.dispatcher.EfsDispatcher: Default dispatcher event queue capacity is 1024.
DEFAULT_EXECUTOR_PRIORITY - Static variable in class org.efs.timer.EfsScheduledExecutor: Default scheduled service thread has Thread.NORM_PRIORITY priority.
DEFAULT_FEED_STORE_SIZE - Static variable in class org.efs.feed.EfsFeed: Initial persistent store size is 65536 events.
DEFAULT_MAX_EVENTS - Static variable in class org.efs.dispatcher.EfsDispatcher: The default maximum events per call out is 4.
DEFAULT_MAX_EVENTS - Static variable in class org.efs.dispatcher.EfsDispatcherThread: The default run maximum events is 4.
DEFAULT_PARK_TIME - Static variable in class org.efs.dispatcher.EfsDispatcher: The default park time after spinning is 1 microsecond.
DEFAULT_PRIORITY - Static variable in class org.efs.dispatcher.EfsDispatcher: Default dispatcher has Thread.NORM_PRIORITY priority.
DEFAULT_RUN_QUEUE_CAPACITY - Static variable in class org.efs.dispatcher.EfsDispatcher: Default dispatcher run queue capacity is 64.
DEFAULT_SPIN_LIMIT - Static variable in class org.efs.dispatcher.EfsDispatcher: The default spin limit is 2500000 calls to Queue.poll() before parking or yielding.
DEFAULT_THREAD_TYPE - Static variable in class org.efs.dispatcher.EfsDispatcher: Default dispatcher thread type is ThreadType.BLOCKING.
DEFAULT_THREAD_TYPE - Static variable in class org.efs.timer.EfsScheduledExecutor: Default scheduled service thread type is ThreadType.BLOCKING.
Definitions - Search tag in package org.efs.dispatcher: Section
deregister(IEfsAgent) - Static method in class org.efs.dispatcher.EfsDispatcher: De-registers agent from its dispatcher.
deregisterListener(Consumer<ActivatorEvent>, IEfsAgent) - Method in class org.efs.activator.EfsActivator: Retracts registered agent from activator state listening.
DESCEND - Enum constant in enum class org.efs.activator.WorkflowDirection: Move agents down from a higher to a lower (or possible same) agent state.
Design Goals - Search tag in package org.efs.dispatcher: Section
dispatch(E) - Method in class org.efs.dispatcher.ReplyTo: Dispatches given event to the configured callback and agent.
dispatch(Runnable, IEfsAgent) - Static method in class org.efs.dispatcher.EfsDispatcher: Executes given task in agent dispatcher inline with dispatched tasks.
dispatch(Consumer<E>, E, IEfsAgent) - Static method in class org.efs.dispatcher.EfsDispatcher: Forwards event to agent using given callback.
dispatch(EfsAgent) - Method in class org.efs.dispatcher.EfsDispatcher: Enqueues given agent to this dispatcher's run queue.
dispatch(EfsAgent) - Method in interface org.efs.dispatcher.IEfsDispatcher: Enqueues given agent to dispatcher run queue.
dispatcher(Consumer<Runnable>) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets dispatcher method used to post efs agent to dispatcher run queue for a special dispatcher only.
dispatcher(IEfsAgent) - Static method in class org.efs.dispatcher.EfsDispatcher: Returns agent's assigned dispatcher's name.
DISPATCHER_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "dispatcher" sets dispatcher method.
DISPATCHER_NAME_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "dispatcherName" contains a unique dispatcher name.
DISPATCHER_NAME_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "dispatcherName" sets dispatcher thread name prefix.
DISPATCHER_TYPE_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "dispatcherType" sets dispatcher thread type.
Dispatcher Coding example - Search tag in package org.efs.dispatcher: Section
dispatcherName() - Method in class org.efs.dispatcher.EfsDispatcher.DispatcherStats: Returns dispatcher name.
dispatcherName() - Method in exception class org.efs.dispatcher.ThreadStartException: Returns failed dispatcher's name.
dispatcherNames() - Static method in class org.efs.dispatcher.EfsDispatcher: Returns an immutable copy of dispatcher names.
dispatcherState() - Method in class org.efs.dispatcher.EfsDispatcher: Returns current dispatcher agentState.
dispatcherThreadStats() - Method in class org.efs.dispatcher.EfsDispatcher.DispatcherStats: Returns a copy of the dispatcher thread stats array.
dispatcherType(EfsDispatcher.DispatcherType) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets dispatcher type.
Dispatching an Event to an Agent - Search tag in package org.efs.dispatcher: Section
Dispatching Events - Search tag in package org.efs.dispatcher: Section
dispatchTimestamp() - Method in class org.efs.timer.EfsTimerEvent: Returns when timer event dispatched to agent in Java nanoseconds (see System.nanoTime()).
duration(Duration) - Method in class org.efs.activator.event.ActivatorEvent.Builder: Sets transition duration. if step state is ActivatorEvent.StepState.IN_PROGRESS, then duration is automatically set to Duration.ZERO.

E

EFS - Enum constant in enum class org.efs.dispatcher.EfsDispatcher.DispatcherType: Default efs dispatcher type.
EfsActivator - Class in org.efs.activator: EfsActivator is responsible for starting, enabling, disabling, and stopping agents according to a given Workflow.
EfsActivator.Builder - Class in org.efs.activator: Builder class used to create an activator.
EfsActivatorConfig - Class in org.efs.activator.config: A typesafe bean configuration used to define a named workflow traveling in a given direction across a given set of steps.
EfsActivatorConfig() - Constructor for class org.efs.activator.config.EfsActivatorConfig: Default constructor required for a typesafe bean class.
EfsAgentState - Enum Class in org.efs.activator: Lists the possible efs agent states.
efs Background - Search tag in Overview: Section
EfsCollectionInfo - Annotation Interface in org.efs.event: Method-level, run-time annotation defining maximum number of elements allowed in a collection or array.
EfsDispatcher - Class in org.efs.dispatcher: This class forwards events to agents and has each agent process those events in a way that is effectively single-threaded.
EfsDispatcher.AgentStats - Class in org.efs.dispatcher: Immutable class containing aggregated EfsDispatcherThread.AgentStats providing a snapshot of efs dispatcher's performance.
EfsDispatcher.Builder - Class in org.efs.dispatcher: Builder for constructing EfsDispatcher instance.
EfsDispatcher.DispatcherState - Enum Class in org.efs.dispatcher: A dispatcher is either stopped, started, or failed to start.
EfsDispatcher.DispatcherStats - Class in org.efs.dispatcher: Contains EfsDispatcherThread.DispatcherThreadStats for each dispatcher thread.
EfsDispatcher.DispatcherType - Enum Class in org.efs.dispatcher: Enumerates the supported efs dispatcher thread types.
EfsDispatcherConfig - Class in org.efs.dispatcher.config: EfsDispatcher configuration definition.
EfsDispatcherConfig() - Constructor for class org.efs.dispatcher.config.EfsDispatcherConfig: Default constructor required for typesafe config bean.
EfsDispatchersConfig - Class in org.efs.dispatcher.config: Contains list of EfsDispatcherConfig instances.
EfsDispatchersConfig() - Constructor for class org.efs.dispatcher.config.EfsDispatchersConfig: Default constructor required for typesafe config bean.
EfsDispatcherThread - Class in org.efs.dispatcher: A dispatcher thread watches a given run queue for EfsAgent instances ready to run, attempting to acquire the next ready agent.
EfsDispatcherThread.AgentStats - Class in org.efs.dispatcher: This class is used to track agent performance for a variety of statistics: time spent on dispatcher ready queue, time spent processing events, and number of event processed per run.
EfsDispatcherThread.DispatcherThreadState - Enum Class in org.efs.dispatcher: A dispatcher thread is either not running, idle (waiting for an available efs agent) or busy (running an efs agent).
EfsDispatcherThread.DispatcherThreadStats - Class in org.efs.dispatcher: Contains the following dispatcher thread measurements (all times are in nanoseconds): dispatcher thread start time, name of agent currently executing events (set to EfsDispatcherThread.NO_EFS_AGENT if no there is no executing agent), number of agents run by this thread, amount of time those agents spent on dispatcher ready queue, amount of time agents spend processing events, and number of events agents processed per run.
EfsDurationEndpoint - Class in org.efs.feed: An interval endpoint based on event time offset.
EfsDurationEndpoint.Builder - Class in org.efs.feed: Builder class for EfsDurationEndpoint.
EfsEventLayout<E> - Class in org.efs.event.type: Contains "getter" field names for a given efs event class.
EfsEventLayout.EfsEventField - Class in org.efs.event.type: Final class containing a event field's name, getter method handle, setter method handle, and data type.
EfsEventWrapper<E> - Class in org.efs.event: This class provides meta-information concerning the encapsulated event.
EfsEventWrapper.Builder<E> - Class in org.efs.event: Builder for constructing an EfsEventWrapper instance.
EfsFeed<E> - Class in org.efs.feed: Responsible for storing and forwarding efs events.
EfsFeedKey<E> - Class in org.efs.feed: Immutable key containing efs event class and subject uniquely defining an efs feed instance.
EfsIndexEndpoint - Class in org.efs.feed: An interval endpoint based on event index offset.
EfsIndexEndpoint.Builder - Class in org.efs.feed: Builder class for EfsIndexEndpoint.
EfsInterval - Class in org.efs.feed: An interval consists of a beginning and ending endpoint.
EfsInterval.Builder - Class in org.efs.feed: EfsInterval instances may be created only by using a Builder instance.
EfsIntervalEndpoint - Class in org.efs.feed: An EfsInterval consists of two endpoints: beginning and ending.
EfsIntervalEndpoint(EfsIntervalEndpoint.EndpointBuilder<?>) - Constructor for class org.efs.feed.EfsIntervalEndpoint: Creates a new interval endpoint with the given clusivity and interval location.
EfsIntervalEndpoint.Clusivity - Enum Class in org.efs.feed: Specifies whether an end point is inclusive or exclusive.
EfsIntervalEndpoint.EndpointBuilder<T> - Class in org.efs.feed: Base class for all endpoint builders.
EfsIntervalEndpoint.EndpointType - Enum Class in org.efs.feed: An endpoint is based either on fixed time, time offset, or index offset.
EfsIntervalEndpoint.IntervalLocation - Enum Class in org.efs.feed: Denotes if endpoint denotes past, current time, future, or future on-going.
EfsIntervalEndpoint.IntervalSide - Enum Class in org.efs.feed: Specifies on which interval side this endpoint is placed.
EfsScheduledExecutor - Class in org.efs.timer: Executes given timer, IEfsAgent pairs at a specified time.
EfsScheduledExecutor(ScheduledExecutorService) - Constructor for class org.efs.timer.EfsScheduledExecutor: Creates a new efs scheduled service instance for the given Java scheduled service.
EfsStringInfo - Annotation Interface in org.efs.event: Method-level, run-time annotation defining two attributes: charset: defines Charset used to encode/decode associated String type.
EfsSubscription<E> - Class in org.efs.feed: EfsFeed.subscribe(IEfsAgent, Consumer, EfsInterval) returns an EfsSubscription instance which may be used to EfsSubscription.close() the subscription.
EfsTimeEndpoint - Class in org.efs.feed: An interval endpoint based on time.
EfsTimeEndpoint.Builder - Class in org.efs.feed: Builder class for EfsTimeEndpoint.
EfsTimerEvent - Class in org.efs.timer: Event reporting a timer expiration.
END_STATE_KEY - Static variable in class org.efs.activator.config.WorkflowStepConfig: Key "endState" contains transition end state.
ending() - Method in class org.efs.feed.EfsInterval: Returns interval ending endpoint.
ending(EfsIntervalEndpoint) - Method in class org.efs.feed.EfsInterval.Builder: Sets interval ending endpoint.
ENDING - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.IntervalSide: Endpoint is the interval ending endpoint.
ENDING_ENDPOINT_NULL - Static variable in class org.efs.feed.EfsInterval.Builder: When attempting to set interval's ending endpoint to null, then NullPointerException contains message "ending endpoint is null".
endNever() - Method in class org.efs.feed.EfsDurationEndpoint.Builder: Sets time offset to ChronoUnit.FOREVER, interval location to EfsIntervalEndpoint.IntervalLocation.FUTURE, and clusivity to EfsIntervalEndpoint.Clusivity.EXCLUSIVE.
endNever() - Method in class org.efs.feed.EfsIndexEndpoint.Builder: Sets index offset to Integer.MAX_VALUE, interval location to EfsIntervalEndpoint.IntervalLocation.FUTURE, and clusivity to EfsIntervalEndpoint.Clusivity.EXCLUSIVE.
endNever() - Method in class org.efs.feed.EfsTimeEndpoint.Builder: Sets endpoint to Instant.MAX, interval location to EfsIntervalEndpoint.IntervalLocation.FUTURE, and clusivity to EfsIntervalEndpoint.Clusivity.EXCLUSIVE.
EndpointBuilder(EfsIntervalEndpoint.EndpointType) - Constructor for class org.efs.feed.EfsIntervalEndpoint.EndpointBuilder: Creates an endpoint builder for given endpoint type.
endpointType() - Method in class org.efs.feed.EfsIntervalEndpoint: Returns endpoint type.
endsFuture(int, Instant) - Method in class org.efs.feed.EfsSubscription: Returns true if this subscription ends in the future and false otherwise.
endState() - Method in class org.efs.activator.WorkflowStep: Returns agent target end state.
endState(EfsAgentState) - Method in class org.efs.activator.WorkflowStep.Builder: Sets target agent end state.
endSymbol() - Method in enum class org.efs.feed.EfsIntervalEndpoint.Clusivity: Returns clusivity end symbol.
equals(Object) - Method in class org.efs.activator.event.ActivatorEvent: Returns true if o is a non-null ActivorEvent instance whose agent name, step name, step state, initial and final states are equal.
equals(Object) - Method in class org.efs.feed.EfsDurationEndpoint: Returns true if o is an EfsDurationEndpoint instance with the same duration, clusivity, and interval location as this EfsDurationEndpoint instance.
equals(Object) - Method in class org.efs.feed.EfsFeedKey: Returns true if o is same EfsFeedKey instance as this EfsFeedKey instance.
equals(Object) - Method in class org.efs.feed.EfsIndexEndpoint: Returns true if o is an EfsIndexEndpoint instance with the same index offset, clusivity, and interval location as this EfsIndexEndpoint instance.
equals(Object) - Method in class org.efs.feed.EfsInterval: : Returns true if: o is the same EfsInterval instance as this interval or o is a non-null EfsInterval instance with the same end points and clusivities as this EfsInterval instance.
equals(Object) - Method in class org.efs.feed.EfsIntervalEndpoint: Returns true if o is an EfsIntervalEndpoint instance with equal EfsIntervalEndpoint.Clusivity and EfsIntervalEndpoint.IntervalLocation as this EfsIntervalEndpoint instance.
equals(Object) - Method in class org.efs.feed.EfsTimeEndpoint: Returns true if o is an EfsTimeEndpoint instance with the same time, clusivity, and interval location as this EfsTimeEndpoint instance.
equals(Object) - Method in class org.efs.timer.EfsTimerEvent: Returns true if o is a non-null timer event with the same name and dispatcher timestamp as this timer event.
error(String) - Method in class org.efs.logging.AsyncLogger
error(String, Object) - Method in class org.efs.logging.AsyncLogger
error(String, Object...) - Method in class org.efs.logging.AsyncLogger
error(String, Object, Object) - Method in class org.efs.logging.AsyncLogger
error(String, Throwable) - Method in class org.efs.logging.AsyncLogger
error(Marker, String) - Method in class org.efs.logging.AsyncLogger
error(Marker, String, Object) - Method in class org.efs.logging.AsyncLogger
error(Marker, String, Object...) - Method in class org.efs.logging.AsyncLogger
error(Marker, String, Object, Object) - Method in class org.efs.logging.AsyncLogger
error(Marker, String, Throwable) - Method in class org.efs.logging.AsyncLogger
event() - Method in class org.efs.event.EfsEventWrapper: Returns encapsulated event.
event(E) - Method in class org.efs.event.EfsEventWrapper.Builder: Sets encapsulated event.
EVENT_QUEUE_CAPACITY_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "eventQueueCapacity" contains efs agent event queue capacity.
EVENT_QUEUE_CAPACITY_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "eventQueueCapacity" sets efs agent maximum event queue capacity.
eventCallback() - Method in class org.efs.feed.EfsSubscription: Returns subscriber's event lambda callback.
eventClass() - Method in class org.efs.event.type.EfsEventLayout: Returns efs event class.
eventClass() - Method in class org.efs.feed.EfsFeedKey: Returns feed key's efs event class.
eventClassName() - Method in class org.efs.feed.EfsFeedKey: Returns feed key's efs event class name.
eventId() - Method in class org.efs.event.EfsEventWrapper: Returns event identifier.
eventId(int) - Method in class org.efs.event.EfsEventWrapper.Builder: Sets event identifier which uniquely identifies event within a wall clock second.
eventQueueCapacity() - Method in class org.efs.dispatcher.EfsDispatcher: Returns configured agent event queue maximum capacity.
eventQueueCapacity() - Method in interface org.efs.dispatcher.IEfsDispatcher: Returns configured agent event queue maximum capacity.
eventQueueCapacity(int) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets efs agent event queue capacity.
Example Building EfsDispatcher - Search tag in class org.efs.dispatcher.EfsDispatcher.Builder: Section
Example EfsDispatcherConfig File Enty - Search tag in class org.efs.dispatcher.config.EfsDispatcherConfig: Section
Example EfsDispatchersConfig File Entry - Search tag in class org.efs.dispatcher.config.EfsDispatchersConfig: Section
Example IEfsAgent Implementation - Search tag in interface org.efs.dispatcher.IEfsAgent: Section
Example Typesafe Configuration Entry - Search tag in class org.efs.activator.config.EfsActivatorConfig: Section
Example Typesafe Configuration Entry - Search tag in class org.efs.activator.config.WorkflowStageConfig: Section
Example Typesafe Configuration Entry - Search tag in class org.efs.activator.config.WorkflowStepConfig: Section
Example Workflows - Search tag in package org.efs.activator: Section
exception(Throwable) - Method in class org.efs.activator.event.ActivatorEvent.Builder: Sets getException associated with a failed step execution.
EXCESSIVE_DELAY - Static variable in class org.efs.timer.EfsScheduledExecutor: Invalid delay exceeding long size message is "delay > Long.MAX_VALUE".
EXCESSIVE_INIT_DELAY - Static variable in class org.efs.timer.EfsScheduledExecutor: Invalid initial delay exceeding long size message is "initial delay > Long.MAX_VALUE".
EXCESSIVE_PERIOD - Static variable in class org.efs.timer.EfsScheduledExecutor: Invalid period exceeding long size message is "period > Long.MAX_VALUE".
EXCLUSIVE - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.Clusivity: The end point time is excluded from the interval.
EXEC_SHUT_DOWN - Static variable in class org.efs.timer.EfsScheduledExecutor: Shut down scheduler message is "scheduled executor is shut down".
execute(String, EfsAgentState, EfsAgentState, Duration) - Method in class org.efs.activator.EfsActivator: Executes a single explicit step on a given agent.
executeNextStage() - Method in class org.efs.activator.EfsActivator: Executes next stage in workflow.
executeNextStep() - Method in class org.efs.activator.EfsActivator: Executes next step in workflow.
executeWorkflow() - Method in class org.efs.activator.EfsActivator: Executes all remaining stages and steps in this workflow.

F

field(String) - Method in class org.efs.event.type.EfsEventLayout: Returns event field's type.
fields() - Method in class org.efs.event.type.EfsEventLayout: Returns an immutable list of event class field names.
finalState(EfsAgentState) - Method in class org.efs.activator.event.ActivatorEvent.Builder: Sets transition final state.
find(String) - Static method in enum class org.efs.dispatcher.config.ThreadType: Returns the thread type with a text name equaling s, ignoring case.
FIXED_TIME - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.EndpointType: A fixed time endpoint specifies a specific wall clock date/time.
FUTURE - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.IntervalLocation: Interval endpoint is in the future.

G

getAdjacent(WorkflowDirection) - Method in enum class org.efs.activator.EfsAgentState: Returns next state from this agent state in the given direction.
getAffinity() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns core affinity for underlying threads.
getAffinityType() - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Returns affinity type used for creating thread affinity to selected CPU_ID.
getAgent() - Method in class org.efs.activator.config.WorkflowStepConfig: Returns unique agent name returned by IEfsAgent.name().
getAgentName() - Method in class org.efs.activator.event.ActivatorEvent: Returns efs agent name.
getAllowedTransitionTime() - Method in class org.efs.activator.config.WorkflowStepConfig: Returns time agent is allowed to complete transition from begin to end state.
getBeginState() - Method in class org.efs.activator.config.WorkflowStepConfig: Returns agent's expected begin state.
getBindFlag() - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Returns the bind-thread-to-affinity lock setting.
getCpuId() - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Returns CPU_ID identifier used for ThreadAffinityConfig.AffinityType.CPU_ID affinity type.
getDispatcher(String) - Static method in class org.efs.dispatcher.EfsDispatcher: Returns dispatcher associated with the given name.
getDispatcherName() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns unique dispatcher name.
getDispatchers() - Method in class org.efs.dispatcher.config.EfsDispatchersConfig: Returns immutable EfsDispatcherConfig list.
getDuration() - Method in class org.efs.activator.event.ActivatorEvent: Returns allowed transition time.
getEndState() - Method in class org.efs.activator.config.WorkflowStepConfig: Returns agent's target end state.
getEventQueueCapacity() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns agent event queue capacity.
getException() - Method in class org.efs.activator.event.ActivatorEvent: Returns optional getException associated with a failed step.
getFinalState() - Method in class org.efs.activator.event.ActivatorEvent: Returns target agent final state.
getInitialState() - Method in class org.efs.activator.event.ActivatorEvent: Returns agent initial state.
getKey(Class<E>, String) - Static method in class org.efs.feed.EfsFeedKey: Returns a unique efs feed key instance for given efs event class and feed subject.
getLastMinusOffset() - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Returns CPU offset used for ThreadAffinityConfig.AffinityType.CPU_LAST_MINUS affinity type.
getLayout(Class<E>) - Static method in class org.efs.event.type.EfsEventLayout: Returns layout for the given efs event class.
getLogger() - Static method in class org.efs.logging.AsyncLoggerFactory: Returns a new asynchronous logger for the calling object's class.
getLogger(Class<?>) - Static method in class org.efs.logging.AsyncLoggerFactory: Returns a new asynchronous logger for the given class.
getLogger(String) - Static method in class org.efs.logging.AsyncLoggerFactory: Returns a new asynchronous logger for the given name.
getMaxEvents() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns maximum number of events an IEfsAgent may process at a time.
getName() - Method in class org.efs.activator.config.WorkflowConfig: Returns unique workflow name.
getName() - Method in class org.efs.logging.AsyncLogger: Returns logger instance's name.
getNumThreads() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns number of underlying threads.
getParkTime() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns part time used by spin+park underlying thread(s).
getPriority() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns priority of underlying threads.
getRunQueueCapacity() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns dispatcher agent run queue capacity (> zero).
getSpinLimit() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns priority of underlying threads.
getStages() - Method in class org.efs.activator.config.WorkflowConfig: Returns workflow stages as an immutable list.
getStepName() - Method in class org.efs.activator.event.ActivatorEvent: Returns workflow step name.
getSteps() - Method in class org.efs.activator.config.WorkflowStageConfig: Returns steps contained within this workflow stage.
getStepState() - Method in class org.efs.activator.event.ActivatorEvent: Returns workflow step's state.
getStrategies() - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Returns immutable list of CPU_ID selection strategies used for ThreadAffinityConfig.AffinityType.CPU_STRATEGIES affinity type.
getter() - Method in class org.efs.event.type.EfsEventLayout.EfsEventField: Returns field getter method handle.
getThreadType() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Returns thread type for underlying thread(s).
getWholeCoreFlag() - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Returns whole core reservation bind settings.
getWorkflows() - Method in class org.efs.activator.config.EfsActivatorConfig: Returns activator workflows.

H

hashCode() - Method in class org.efs.activator.event.ActivatorEvent: Activator event hash code based on unique agent name, workflow step name, workflow step state, agent current state, and agent target final state.
hashCode() - Method in class org.efs.feed.EfsDurationEndpoint: Returns a hash value based on endpoint duration, clusivity, and interval location.
hashCode() - Method in class org.efs.feed.EfsFeedKey: Returns efs feed key hash code based on efs event class and subject
hashCode() - Method in class org.efs.feed.EfsIndexEndpoint: Returns a hash value based on endpoint offset, clusivity, and interval location.
hashCode() - Method in class org.efs.feed.EfsInterval: Returns hash code based on end point times and clusivities.
hashCode() - Method in class org.efs.feed.EfsIntervalEndpoint: Returns a hash value based on endpoint clusivity and interval location.
hashCode() - Method in class org.efs.feed.EfsTimeEndpoint: Returns a hash value based on endpoint time, clusivity, and interval location.
hashCode() - Method in class org.efs.timer.EfsTimerEvent: Returns hash code based on timer name and dispatch timestamp.

I

IDLE - Enum constant in enum class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadState: Dispatcher thread is waiting for the next available efs agent to run.
IEfsActivateAgent - Interface in org.efs.activator: Extends IEfsAgent with methods supporting activation.
IEfsAgent - Interface in org.efs.dispatcher: This interface solves the problem of start up and shutting down from a non-efs thread.
IEfsDispatcher - Interface in org.efs.dispatcher: Dispatcher behavior interface.
IEfsEvent - Interface in org.efs.event: Marker interface denoting that a class is an efs event.
IEfsEventBuilder<E> - Interface in org.efs.event: Interface defines an efs event builder class used to create an IEfsEvent instance.
IN_PROGRESS - Enum constant in enum class org.efs.activator.event.ActivatorEvent.StepState: Workflow step is in-progress.
INCLUSIVE - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.Clusivity: The end point time is included in the interval.
INDEX_OFFSET - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.EndpointType: An index offset endpoint is relative to feed's current index.
indexOffset() - Method in class org.efs.feed.EfsIndexEndpoint: Returns event store index offset.
indexOffset(int, EfsIntervalEndpoint.Clusivity) - Method in class org.efs.feed.EfsIndexEndpoint.Builder: Sets index offset to given value and clusivity.
info(String) - Method in class org.efs.logging.AsyncLogger
info(String, Object) - Method in class org.efs.logging.AsyncLogger
info(String, Object...) - Method in class org.efs.logging.AsyncLogger
info(String, Object, Object) - Method in class org.efs.logging.AsyncLogger
info(String, Throwable) - Method in class org.efs.logging.AsyncLogger
info(Marker, String) - Method in class org.efs.logging.AsyncLogger
info(Marker, String, Object) - Method in class org.efs.logging.AsyncLogger
info(Marker, String, Object...) - Method in class org.efs.logging.AsyncLogger
info(Marker, String, Object, Object) - Method in class org.efs.logging.AsyncLogger
info(Marker, String, Throwable) - Method in class org.efs.logging.AsyncLogger
initializeWorkflow(String) - Method in class org.efs.activator.EfsActivator: Sets workflow to be executed.
initialState(EfsAgentState) - Method in class org.efs.activator.event.ActivatorEvent.Builder: Sets transition initial state.
interval() - Method in class org.efs.feed.EfsSubscription: Returns subscription interval.
Introduction - Search tag in Overview: Section
INVALID_CALLBACK - Static variable in class org.efs.feed.EfsFeed: Invalid event callback message is "eventCallback is null".
INVALID_DISPATCHER_NAME - Static variable in class org.efs.feed.EfsFeed: Invalid dispatcher name message is "dispatcherName is either null or an empty string".
INVALID_DISPATCHERS - Static variable in class org.efs.feed.EfsFeed: Invalid event class-to-dispatcher name map is "dispatchers is null".
INVALID_EVENT - Static variable in class org.efs.feed.EfsFeed: Invalid event message is "event is null".
INVALID_EVENT_CLASS - Static variable in class org.efs.feed.EfsFeed: Invalid event class message is "eventClass is null".
INVALID_EXECUTOR - Static variable in class org.efs.timer.EfsScheduledExecutor: Invalid executor service message is "executor is shutdown".
INVALID_FEED_KEY - Static variable in class org.efs.feed.EfsFeed: Invalid event feed key message is "key is null".
INVALID_INTERVAL - Static variable in class org.efs.feed.EfsFeed: Invalid interval message is "interval is null".
INVALID_NAME - Static variable in class org.efs.dispatcher.EfsDispatcher: Invalid name IllegalArgumentException message is "name is either null or an empty string".
INVALID_SUBSCRIBER - Static variable in class org.efs.feed.EfsFeed: Invalid subscriber message is "subscriber is null".
InvalidEventException - Exception Class in org.efs.event.type: Exception associated with failure to generate a layout for an IEfsEvent.
InvalidEventException(Class<? extends IEfsEvent>, String) - Constructor for exception class org.efs.event.type.InvalidEventException: Creates a new instance of InvalidEventException containing invalid efs event class and detail message.
InvalidEventException(Class<? extends IEfsEvent>, String, Throwable) - Constructor for exception class org.efs.event.type.InvalidEventException: Constructs an instance of InvalidEventException with the specified efs event class, detail message, and cause.
isActive() - Method in class org.efs.feed.EfsSubscription: Returns true if this subscription is active and false if inactive.
isAdjacent(EfsAgentState) - Method in enum class org.efs.activator.EfsAgentState: Returns true if given state is adjacent to this state either ascending or descending direction; otherwise returns false.
isDebugEnabled() - Method in class org.efs.logging.AsyncLogger
isDebugEnabled(Marker) - Method in class org.efs.logging.AsyncLogger
isDispatcher(String) - Static method in class org.efs.dispatcher.EfsDispatcher: Returns true if given name is a known dispatcher and false otherwise.
isEmpty() - Method in class org.efs.event.ConflationEvent: Returns true if this conflation event does not contain an encapsulated event and false if it does.
isErrorEnabled() - Method in class org.efs.logging.AsyncLogger
isErrorEnabled(Marker) - Method in class org.efs.logging.AsyncLogger
isFuture() - Method in enum class org.efs.feed.EfsIntervalEndpoint.IntervalLocation: Returns true if time is located in future.
isInfoEnabled() - Method in class org.efs.logging.AsyncLogger
isInfoEnabled(Marker) - Method in class org.efs.logging.AsyncLogger
isInProgress() - Method in class org.efs.activator.Workflow: Returns true if this workflow is in-progress and not yet reached completion.
isPast() - Method in enum class org.efs.feed.EfsIntervalEndpoint.IntervalLocation: Returns true if time is located in past.
isRegistered(IEfsAgent) - Static method in class org.efs.dispatcher.EfsDispatcher: Returns true if given agent is currently registered with an efs dispatcher and false if not registered.
isRegisteredListener(IEfsAgent) - Method in class org.efs.activator.EfsActivator: Returns true if agent is a registered activator listener and false otherwise.
isRunning() - Method in class org.efs.timer.EfsScheduledExecutor: Returns true if this service has not been shut down.
isShutdown() - Method in class org.efs.timer.EfsScheduledExecutor: Returns true if this service has been shut down.
isSpecial() - Method in enum class org.efs.dispatcher.EfsDispatcher.DispatcherType: Returns true if this dispatcher type is a special, non-configurable dispatcher.
isTerminated() - Method in class org.efs.timer.EfsScheduledExecutor: Returns true if all tasks have completed following shut down.
isTraceEnabled() - Method in class org.efs.logging.AsyncLogger
isTraceEnabled(Marker) - Method in class org.efs.logging.AsyncLogger
isTransition() - Method in enum class org.efs.activator.EfsAgentState: Returns true if this is a transition state and false if this is a persistent state.
isWarnEnabled() - Method in class org.efs.logging.AsyncLogger
isWarnEnabled(Marker) - Method in class org.efs.logging.AsyncLogger

K

key() - Method in class org.efs.feed.EfsFeed: Returns key containing event class and subject.
KEY_FORMAT - Static variable in class org.efs.feed.EfsFeedKey: Event key string format is "%s%c%s".
KEY_IFS - Static variable in class org.efs.feed.EfsFeedKey: Use '|' as event class and subject separator.

L

Learning efs - Search tag in Overview: Section
LMAX Disruptor - Search tag in package org.efs.dispatcher: Section
loadActivator(String) - Static method in class org.efs.activator.EfsActivator: Returns activator based on configuration loaded from given file name.
loadDispatchers(EfsDispatchersConfig) - Static method in class org.efs.dispatcher.EfsDispatcher: Loads dispatcher definitions from named file and then creates and starts dispatchers based on those definitions.
loadDispatchersConfigFile(File) - Static method in class org.efs.dispatcher.EfsDispatcher: Loads dispatcher definitions from named file and then creates and starts dispatchers based on those definitions.
location() - Method in class org.efs.feed.EfsIntervalEndpoint: Returns endpoint interval location.
LOCATION_NULL - Static variable in class org.efs.feed.EfsIntervalEndpoint.EndpointBuilder: When attempting to set endpoint location to null, then NullPointerException contains message "location is null".
LOGGER_DISPATCHER_NAME - Static variable in class org.efs.logging.AsyncLogger: Asynchronous logging is performed on dispatcher "AsyncLoggerDispatcher".

M

MAX_AGENT_STATS - Static variable in class org.efs.dispatcher.EfsDispatcherThread: Collect at most 1024 agent statistics.
MAX_EVENTS_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "maxEvents" contains maximum number of events an efs agent may process at any one time.
MAX_EVENTS_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "maxEvents" set agent maximum events per call out.
maxEvents() - Method in class org.efs.dispatcher.EfsDispatcher.DispatcherStats: Returns maximum events per agent call out.
maxEvents() - Method in class org.efs.dispatcher.EfsDispatcher: Returns maximum number of events an agent is allowed to process per callback.
maxEvents() - Method in class org.efs.dispatcher.EfsDispatcherThread: Returns thread maximum events per agent call out.
maxEvents() - Method in interface org.efs.dispatcher.IEfsDispatcher: Returns maximum number of events an agent is allowed to process per callback.
maxEvents(int) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets maximum number of events agent is allowed to process per call out.
maximumSize() - Element in annotation interface org.efs.event.EfsCollectionInfo: Returns maximum number of elements allowed in collection.
maximumSize() - Element in annotation interface org.efs.event.EfsStringInfo: Returns String maximum size in bytes.
mClusivity - Variable in class org.efs.feed.EfsIntervalEndpoint.EndpointBuilder: Endpoint is either inclusive or exclusive.
mClusivity - Variable in class org.efs.feed.EfsIntervalEndpoint: Endpoint is either inclusive or exclusive.
MIN_EVENT_QUEUE_SIZE - Static variable in class org.efs.dispatcher.EfsDispatcher: Event queue minimum allowed size is 2.
missedEventCount() - Method in class org.efs.event.ConflationEvent: Returns missed count set after the most recent poll.
MISSING_AGENT_NAME - Static variable in class org.efs.dispatcher.EfsDispatcher: Missing agent name message is "agent name is either null or an empty string".
mLocation - Variable in class org.efs.feed.EfsIntervalEndpoint.EndpointBuilder: Endpoint is either in the past, now, or in the future.
mLocation - Variable in class org.efs.feed.EfsIntervalEndpoint: Endpoint location within interval.
Monitor EfsActivator - Search tag in package org.efs.activator: Section
movingAverage() - Method in class org.efs.dispatcher.EfsDispatcherThread.AgentStats: Returns current moving average.
mType - Variable in class org.efs.feed.EfsIntervalEndpoint.EndpointBuilder: Specified endpoint type: fixed time, time offset, or index offset.
mType - Variable in class org.efs.feed.EfsIntervalEndpoint: Endpoint type.

N

name() - Method in class org.efs.activator.Workflow: Returns workflow name.
name() - Method in class org.efs.dispatcher.EfsDispatcher: Returns dispatcher name.
name() - Method in interface org.efs.dispatcher.IEfsAgent: Returns unique efs agent name.
name() - Method in interface org.efs.dispatcher.IEfsDispatcher: Returns dispatcher's unique name.
name() - Method in class org.efs.event.type.EfsEventLayout.EfsEventField: Returns field name.
name() - Method in class org.efs.feed.EfsFeed: Returns EfsFeedKey.toString() as dispatcher name.
name(String) - Method in class org.efs.activator.Workflow.Builder: Sets workflow name which must be unique within activator.
NAME_KEY - Static variable in class org.efs.activator.config.WorkflowConfig: Key "name" contains unique workflow name.
NEGATIVE_DELAY - Static variable in class org.efs.timer.EfsScheduledExecutor: Invalid negative delay message is "delay < zero".
NEGATIVE_INIT_DELAY - Static variable in class org.efs.timer.EfsScheduledExecutor: Invalid negative initial delay message is "initial delay < zero".
NEGATIVE_PERIOD - Static variable in class org.efs.timer.EfsScheduledExecutor: Invalid negative period message is "period <= zero".
NEGATIVE_REPEAT_DELAY - Static variable in class org.efs.timer.EfsScheduledExecutor: Negative repeat delay message is "delay <= zero".
nestedLogger() - Method in class org.efs.logging.AsyncLogger: Returns nested logger.
NO_EFS_AGENT - Static variable in class org.efs.dispatcher.EfsDispatcherThread: Set efs agent name to "(idle)" when dispatcher thread is idle.
NO_MESSAGE - Static variable in class org.efs.activator.event.ActivatorEvent: Exception did not contain a message.
NO_WORKFLOW_IN_PROGRESS - Static variable in class org.efs.activator.EfsActivator: IllegalStateException message when execution is called but there is not workflow in progress (""no workflow in-progress"").
NOT_STARTED - Enum constant in enum class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadState: Dispatcher thread is not running due to it not yet being started.
now(EfsIntervalEndpoint.Clusivity) - Method in class org.efs.feed.EfsDurationEndpoint.Builder: Sets time offset to zero with the given clusivity.
now(EfsIntervalEndpoint.Clusivity) - Method in class org.efs.feed.EfsIndexEndpoint.Builder: Sets index offset to zero with the given clusivity.
now(EfsIntervalEndpoint.Clusivity) - Method in class org.efs.feed.EfsTimeEndpoint.Builder: Sets endpoint time to current time, interval location to EfsIntervalEndpoint.IntervalLocation.NOW, and clusivity to given value.
NOW - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.IntervalLocation: Interval endpoint is the current time.
NULL_AGENT - Static variable in class org.efs.activator.EfsActivator: NullPointerException message for a null agent is "agent is null".
NULL_AGENT - Static variable in class org.efs.dispatcher.EfsDispatcher: Invalid efs agent NullPointerException message is "agent is null".
NULL_AGENT - Static variable in class org.efs.timer.EfsScheduledExecutor: null efs agent message is "agent is null".
NULL_CALLBACK - Static variable in class org.efs.activator.EfsActivator: NullPointerException message for a null callback is "callback is null".
NULL_CALLBACK - Static variable in class org.efs.dispatcher.EfsDispatcher: Invalid callback NullPointerException message is "callback is null".
NULL_CALLBACK - Static variable in class org.efs.timer.EfsScheduledExecutor: null callback lambda message is "callback is null".
NULL_CONFIG_FILE - Static variable in class org.efs.dispatcher.EfsDispatcher: Invalid dispatcher configuration file NullPointException message is "configFile is null".
NULL_DELAY - Static variable in class org.efs.timer.EfsScheduledExecutor: null delay message is "delay is null".
NULL_EVENT - Static variable in class org.efs.dispatcher.EfsDispatcher: Invalid event NullPointerException message is "event is null".
NULL_EXECUTOR - Static variable in class org.efs.timer.EfsScheduledExecutor: null scheduled service message is "executor is null".
NULL_INIT_DELAY - Static variable in class org.efs.timer.EfsScheduledExecutor: null initial delay message is "initial delay is null".
NULL_PERIOD - Static variable in class org.efs.timer.EfsScheduledExecutor: Invalid null period message is "period is null".
NULL_STATE - Static variable in class org.efs.activator.event.ActivatorEvent: Common failure reason.
NULL_TASK - Static variable in class org.efs.dispatcher.EfsDispatcher: Invalid dispatch task NullPointerException message is "task is null".
NULL_TYPE - Static variable in class org.efs.dispatcher.EfsDispatcher: Invalid dispatcher type NullPointerException message is "type is null".
NULL_TYPE - Static variable in class org.efs.timer.EfsScheduledExecutor: Invalid thread type message is "type is null".
NUM_THREADS_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "numThreads" contains number of underlying dispatcher threads.
NUM_THREADS_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "numThreads" sets dispatcher thread count;
numThreads(int) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets dispatcher thread count.

O

offer(E) - Method in class org.efs.event.ConflationEvent: Sets encapsulate event and returns true if encapsulated event was initially null and false otherwise.
openFeed(EfsFeedKey<E>) - Static method in class org.efs.feed.EfsFeed: Returns efs feed associated with the given feed key.
org.efs.activator - package org.efs.activator: Provides ability to transition efs agents between stopped, stand by, and active states according to user-defined workflow.
org.efs.activator.config - package org.efs.activator.config: This package provides typesafe configuration bean classes which may be loaded from a file as follows:
org.efs.activator.event - package org.efs.activator.event: This package defines the ActivatorEvent posted by EfsActivator to registered agents.
org.efs.dispatcher - package org.efs.dispatcher: Dispatcher forwards events to agents in an effectively single-threaded manner.
org.efs.dispatcher.config - package org.efs.dispatcher.config: This package provides typesafe configuration bean classes which may be loaded from a file as follows:
org.efs.event - package org.efs.event: Contains classes which define efs events.
org.efs.event.type - package org.efs.event.type: Contains EfsEventLayout class which provides a reflective definition of an IEfsEvent class.
org.efs.feed - package org.efs.feed
org.efs.logging - package org.efs.logging: This package extends slf4j package with an asynchronous logger.
org.efs.timer - package org.efs.timer: efs timer package provides EfsScheduledExecutor which encapsulates a ScheduledExecutorService.

P

PARK_TIME_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "parkTime" contains park time for spin+park thread type.
PARK_TIME_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "parkTime" sets park time for spin+park dispatcher thread.
parkTime() - Method in class org.efs.dispatcher.EfsDispatcherThread: Returns nanosecond park time for spin+park thread type.
parkTime(Duration) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets spin+park park time limit.
PAST - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.IntervalLocation: Interval endpoint is in the past.
peek() - Method in class org.efs.event.ConflationEvent: Returns latest event contained in this conflation event without removing this latest event.
performanceStats() - Method in class org.efs.dispatcher.EfsDispatcherThread: Returns this dispatcher thread's performance statistics.
performanceStats(String) - Static method in class org.efs.dispatcher.EfsDispatcher: Returns named dispatcher's performance statistics snapshot.
poll() - Method in class org.efs.event.ConflationEvent: Returns latest event contained in this conflation event.
priority() - Method in class org.efs.dispatcher.EfsDispatcher: Returns priority of dispatcher threads.
priority(int) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets the thread priority.
PRIORITY_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "priority" contains underlying dispatcher thread priority.
PRIORITY_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "priority" sets dispatcher thread priority.
publish(E) - Method in class org.efs.feed.EfsFeed: Posts given event to feed and forwards event to active subscribers.
publisherId() - Method in class org.efs.event.EfsEventWrapper: Returns event publisher identifier.
publisherId(long) - Method in class org.efs.event.EfsEventWrapper.Builder: Sets event publisher identifier.
publishTimestamp() - Method in class org.efs.event.EfsEventWrapper: Returns timestamp when event was published to efs.
publishTimestamp(Instant) - Method in class org.efs.event.EfsEventWrapper.Builder: Sets event publish timestamp.

R

register(IEfsAgent, String) - Static method in class org.efs.dispatcher.EfsDispatcher: Registers agent with named dispatcher.
registerListener(Consumer<ActivatorEvent>, IEfsAgent) - Method in class org.efs.activator.EfsActivator: Registers agent for listening to activator state changes.
ReplyTo<E> - Class in org.efs.dispatcher: This class is used when an agent posting an event to a second agent expecting a reply to its event.
ReplyTo(Consumer<E>, IEfsAgent) - Constructor for class org.efs.dispatcher.ReplyTo: Creates a new reply-to instance with the given callback and agent.
ReplyTo Example - Search tag in class org.efs.dispatcher.ReplyTo: Section
run() - Method in class org.efs.dispatcher.EfsDispatcherThread: A dispatcher thread continues processing ready efs clients until the JVM exits.
RUN_QUEUE_CAPACITY_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "runQueueCapacity" contains dispatcher run queue capacity.
RUN_QUEUE_CAPACITY_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "runQueueCapacity" sets run queue maximum size.
runQueueCapacity(int) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets efs dispatcher agent queue capacity.

S

schedule(String, Object, Consumer<EfsTimerEvent>, IEfsAgent, Duration) - Method in class org.efs.timer.EfsScheduledExecutor: Submits a single-shot timer which expires after the given delay.
scheduleAtFixedRate(String, Object, Consumer<EfsTimerEvent>, IEfsAgent, Duration, Duration) - Method in class org.efs.timer.EfsScheduledExecutor: Submits a periodic action that becomes enabled first after initial delay, and subsequently with the given period; that is, executions will commence after initialDelay, then initialDelay + period, then initialDelay + 2 * period, and so on.
SCHEDULER_CONFIG_OPTION - Static variable in class org.efs.timer.EfsScheduledExecutor: Use command line option -D"org.efs.timer.configFile"=<file> to specify file containing a typesafe HOCON {a form of JSON} configuration for one or more's EfsScheduledExcutors.
scheduleWithFixedDelay(String, Object, Consumer<EfsTimerEvent>, IEfsAgent, Duration, Duration) - Method in class org.efs.timer.EfsScheduledExecutor: Submits a periodic task which expires for the first time after the initial delay and then repeatedly with the given delay between the termination of the previous expiration and the commencement of the next.
Scheduling Timers - Search tag in package org.efs.timer: Section
service() - Method in class org.efs.timer.EfsScheduledExecutor: Returns encapsulated Java scheduled executor service.
set(EfsActivatorConfig) - Method in class org.efs.activator.EfsActivator.Builder: Sets activator properties according to given activator configuration.
set(WorkflowConfig) - Method in class org.efs.activator.Workflow.Builder: Sets workflow properties according to given workflow configuration.
set(WorkflowStageConfig) - Method in class org.efs.activator.WorkflowStage.Builder: Sets stage properties according to given workflow stage configuration.
set(WorkflowStepConfig) - Method in class org.efs.activator.WorkflowStep.Builder: Fills in builder with given workflow step configuration.
set(EfsDispatcherConfig) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Configures efs dispatcher as per given configuration.
setAffinity(ThreadAffinityConfig) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Sets core affinity applied to underlying threads.
setAffinityType(ThreadAffinityConfig.AffinityType) - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Sets affinity type to the given value.
setAgent(String) - Method in class org.efs.activator.config.WorkflowStepConfig: Sets agent name.
setAllowedTransitionTime(Duration) - Method in class org.efs.activator.config.WorkflowStepConfig: Sets time allowed to agent to complete transition from begin to end state.
setBeginState(EfsAgentState) - Method in class org.efs.activator.config.WorkflowStepConfig: Sets agent begin state.
setBindFlag(boolean) - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Sets flag for binding thread to affinity lock.
setCpuId(int) - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Sets CPU_ID identifier used by ThreadAffinityConfig.AffinityType.CPU_ID affinity type.
setDispatcherName(String) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Sets unique dispatcher name.
setDispatchers(List<EfsDispatcherConfig>) - Method in class org.efs.dispatcher.config.EfsDispatchersConfig: Sets efs dispatchers list.
setEndState(EfsAgentState) - Method in class org.efs.activator.config.WorkflowStepConfig: Sets agent end state.
setEventQueueCapacity(int) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Sets efs agent event queue capacity.
setFeedDispatcher(Class<E>, String) - Static method in class org.efs.feed.EfsFeed: Maps efs event class to efs dispatcher used for feeds for that event class.
setFeedDispatchers(Map<Class<? extends IEfsEvent>, String>) - Static method in class org.efs.feed.EfsFeed: Places given event class-to-dispatcher name mappings into internal mappings.
setLastMinusOffset(int) - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Sets positive integer offset used by ThreadAffinityConfig.AffinityType.CPU_LAST_MINUS affinity type.
setMaxEvents(int) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Sets maximum number of events an efs agent associated with this dispatcher may process when dispatched.
setName(String) - Method in class org.efs.activator.config.WorkflowConfig: Sets unique workflow name.
setNumThreads(int) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Sets number of underlying dispatcher threads.
setParkTime(Duration) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Sets park time for spin+park underlying dispatcher threads.
setPriority(int) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Sets priority for all underlying dispatcher threads.
setRunQueueCapacity(int) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Set efs dispatcher agent queue capacity.
setSpinLimit(long) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Sets spin limit for spin+park and spin+yield underlying threads.
setStages(List<WorkflowStageConfig>) - Method in class org.efs.activator.config.WorkflowConfig: Stages defining this workflow.
setSteps(List<WorkflowStepConfig>) - Method in class org.efs.activator.config.WorkflowStageConfig: Sets workflow stage steps to given list.
setStrategies(List<AffinityStrategies>) - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Sets CPU selection strategies used by ThreadAffinityConfig.AffinityType.CPU_STRATEGIES affinity type.
setter() - Method in class org.efs.event.type.EfsEventLayout.EfsEventField: Returns field setter method handle.
setThreadType(ThreadType) - Method in class org.efs.dispatcher.config.EfsDispatcherConfig: Sets dispatcher underlying thread type.
setWholeCoreFlag(boolean) - Method in class org.efs.dispatcher.config.ThreadAffinityConfig: Sets flag reserving the entire core and not allowing hyper-threading on that core.
setWorkflows(List<WorkflowConfig>) - Method in class org.efs.activator.config.EfsActivatorConfig: Sets activator workflows.
setWorkflowStage(int, int) - Method in class org.efs.activator.EfsActivator: Sets workflow position to given stage and step index.
shutdown() - Method in class org.efs.timer.EfsScheduledExecutor: Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.
shutdownNow() - Method in class org.efs.timer.EfsScheduledExecutor: Attempts to stop all actively executing tasks and halts processing of waiting tasks, and returns list of tasks awaiting execution.
SPECIAL - Enum constant in enum class org.efs.dispatcher.EfsDispatcher.DispatcherType: Means that a user-defined dispatcher is being used.
SPIN_LIMIT_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "spinLimit" contains spin limit for spin+park and spin+yield thread types.
SPIN_LIMIT_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "spinLimit" sets thread spin limit for spin+park or ThreadType.SPINYIELD thread types.
spinLimit() - Method in class org.efs.dispatcher.EfsDispatcherThread: Returns spin limit for spin+park/spin+yield thread type.
spinLimit(long) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets ThreadType.SPINPARK or ThreadType.SPINYIELD spin limit.
SPINNING - Enum constant in enum class org.efs.dispatcher.config.ThreadType: The thread repeatedly checks if the event has arrived using a non-blocking call without pausing in between checks.
SPINPARK - Enum constant in enum class org.efs.dispatcher.config.ThreadType: This thread repeatedly checks for the event using a non-blocking call but only for a fixed number of times (the spin limit).
SPINYIELD - Enum constant in enum class org.efs.dispatcher.config.ThreadType: This thread repeatedly check for the event using a non-blocking call but only for a fixed number of times (the spin limit).
stageCount() - Method in class org.efs.activator.Workflow: Returns number of stages within this workflow.
Staged Event-Driven Architecture (SEDA) - Search tag in package org.efs.dispatcher: Section
stageIndex() - Method in class org.efs.activator.WorkflowStage: Returns this stage's index within the workflow.
stageIndex(int) - Method in class org.efs.activator.WorkflowStage.Builder: Sets stage index within parent workflow.
stages(List<WorkflowStage>) - Method in class org.efs.activator.Workflow.Builder: Sets stages defining workflow.
STAGES_KEY - Static variable in class org.efs.activator.config.WorkflowConfig: Key "stages" contains workflow stages.
STAND_ALONE_STEP - Static variable in class org.efs.activator.EfsActivator: Stand-alone executed steps are named "standalone-step".
STAND_BY - Enum constant in enum class org.efs.activator.EfsAgentState: Agent is successfully started but not yet active.
START_FAILED - Enum constant in enum class org.efs.dispatcher.EfsDispatcher.DispatcherState: Dispatcher failed to start and may not be re-started.
STARTED - Enum constant in enum class org.efs.dispatcher.EfsDispatcher.DispatcherState: Dispatcher is successfully started and its subordinate threads are running, and may be stopped.
STARTING - Enum constant in enum class org.efs.activator.EfsAgentState: Agent is in this temporary state while transitioning from EfsAgentState.STOPPED to EfsAgentState.STAND_BY.
startTime() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns dispatcher thread start time.
startup() - Method in interface org.efs.activator.IEfsActivateAgent: This method transitions an agent from stopped to stand-by.
stats() - Method in class org.efs.dispatcher.EfsDispatcher.AgentStats: Returns copy of the collected agent statistics collected by all subordinate dispatcher threads.
stats() - Method in class org.efs.dispatcher.EfsDispatcherThread.AgentStats: Returns copy of the collected agent statistics containing only those data points collected so far.
statsName() - Method in class org.efs.dispatcher.EfsDispatcher.AgentStats: Returns agent statistic's name.
statsName() - Method in class org.efs.dispatcher.EfsDispatcherThread.AgentStats: Returns agent statistic's name.
stepCount() - Method in class org.efs.activator.WorkflowStage: Returns number of steps in this workflow stage.
stepName(String) - Method in class org.efs.activator.event.ActivatorEvent.Builder: Sets workflow step name.
steps(List<WorkflowStep>) - Method in class org.efs.activator.WorkflowStage.Builder: Sets steps defining workflow stage.
STEPS_KEY - Static variable in class org.efs.activator.config.WorkflowStageConfig: Key "steps" contains workflow steps list.
stepState(ActivatorEvent.StepState) - Method in class org.efs.activator.event.ActivatorEvent.Builder: Sets workflow step state.
stop() - Method in interface org.efs.activator.IEfsActivateAgent: This method transitions an agent from EfsAgentState.STAND_BY to EfsAgentState.STOPPED.
STOPPED - Enum constant in enum class org.efs.activator.EfsAgentState: Agent is fully stopped.
STOPPED - Enum constant in enum class org.efs.dispatcher.EfsDispatcher.DispatcherState: Dispatcher is stopped, has no subordinate threads, and may be started.
STOPPING - Enum constant in enum class org.efs.activator.EfsAgentState: Agent is in this temporary state while transitioning from EfsAgentState.STAND_BY to EfsAgentState.STOPPED.
STRATEGIES_KEY - Static variable in class org.efs.dispatcher.config.ThreadAffinityConfig: Key "cpuStrategies" contains CPU selection strategies array used when ThreadAffinityConfig.AFFINITY_TYPE_KEY is set to ThreadAffinityConfig.AffinityType.CPU_STRATEGIES.
subject() - Method in class org.efs.feed.EfsFeedKey: Returns feed key's subject.
subscribe(IEfsAgent, Consumer<E>, EfsInterval) - Method in class org.efs.feed.EfsFeed: Posts given subscriber and subscription interval to dispatcher thread and returns closable subscription instance.
subscriber() - Method in class org.efs.feed.EfsSubscription: Returns subscribing agent.
subscriberCount() - Method in class org.efs.event.EfsEventWrapper: Returns number of subscribers to which event was forwarded when event was first published.
subscriberCount(int) - Method in class org.efs.event.EfsEventWrapper.Builder: Sets number of subscribers which received event when published.

T

terminateWorkflow() - Method in class org.efs.activator.EfsActivator: Terminates an in-progress workflow.
textName() - Method in enum class org.efs.dispatcher.config.ThreadType: Returns the thread type text name.
THREAD_TYPE_KEY - Static variable in class org.efs.dispatcher.config.EfsDispatcherConfig: Key "threadType" contains dispatcher thread type.
THREAD_TYPE_KEY - Static variable in class org.efs.dispatcher.EfsDispatcher: Key "threadType" sets dispatcher thread type.
threadAffinity(ThreadAffinityConfig) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets optional thread affinity to the given configuration list.
ThreadAffinity - Class in org.efs.dispatcher.config: Provides interface to OpenHFT Thread Affinity Library based on a given ThreadAffinityConfig.
ThreadAffinityConfig - Class in org.efs.dispatcher.config: A typesafe configuration bean class containing necessary information needed to create an affinity between a thread and a core using OpenHFT Thread Affinity Library.
ThreadAffinityConfig() - Constructor for class org.efs.dispatcher.config.ThreadAffinityConfig: Default constructor sets fields to invalid values.
ThreadAffinityConfig.AffinityType - Enum Class in org.efs.dispatcher.config: These affinity types map to a specific AffinityLock static method used to acquire an affinity lock.
threadCount() - Method in class org.efs.dispatcher.EfsDispatcher: Returns dispatcher's subordinate thread count.
threadCount() - Method in interface org.efs.dispatcher.IEfsDispatcher: Returns dispatcher's subordinate thread count.
threadName() - Method in class org.efs.dispatcher.EfsDispatcherThread.AgentStats: Returns dispatcher thread's name.
threadName() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns dispatcher thread name.
threadName() - Method in exception class org.efs.dispatcher.ThreadStartException: Returns failed thread's name.
ThreadStartException - Exception Class in org.efs.dispatcher: Exception thrown when a dispatcher thread fails to start.
ThreadStartException(String, String) - Constructor for exception class org.efs.dispatcher.ThreadStartException: Creates new ThreadStartException instance without detail message.
ThreadStartException(String, String, String) - Constructor for exception class org.efs.dispatcher.ThreadStartException: Creates new ThreadStartException instance with a detail message.
ThreadStartException(String, String, String, Throwable) - Constructor for exception class org.efs.dispatcher.ThreadStartException: Create new ThreadStartException instance with detail message and cause.
threadState() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns dispatcher thread current state.
threadType() - Method in class org.efs.dispatcher.EfsDispatcher.DispatcherStats: Returns underlying dispatcher thread type.
threadType() - Method in class org.efs.dispatcher.EfsDispatcher: Returns underlying thread type.
threadType() - Method in class org.efs.dispatcher.EfsDispatcherThread: Returns dispatcher thread type.
threadType(ThreadType) - Method in class org.efs.dispatcher.EfsDispatcher.Builder: Sets dispatcher thread type.
ThreadType - Enum Class in org.efs.dispatcher.config: Lists thread types available to efs users when configuring efs dispatchers.
time() - Method in class org.efs.feed.EfsTimeEndpoint: Returns endpoint time.
time(Instant, EfsIntervalEndpoint.Clusivity) - Method in class org.efs.feed.EfsTimeEndpoint.Builder: Sets interval time and clusivity.
TIME_NULL - Static variable in class org.efs.feed.EfsTimeEndpoint.Builder: When attempting to set endpoint time to null, then NullPointerException contains message "time is null".
TIME_OFFSET - Enum constant in enum class org.efs.feed.EfsIntervalEndpoint.EndpointType: A time offset endpoint is relative to the feed's current time.
TIME_OFFSET_NULL - Static variable in class org.efs.feed.EfsDurationEndpoint.Builder: When attempting to set time offset to null, then NullPointerException contains message "offset is null".
timeOffset() - Method in class org.efs.feed.EfsDurationEndpoint: Returns time offset.
timeOffset(Duration, EfsIntervalEndpoint.Clusivity) - Method in class org.efs.feed.EfsDurationEndpoint.Builder: Sets time offset to given values and clusivity.
timerName() - Method in class org.efs.timer.EfsTimerEvent: Returns expired timer's name as configured by agent.
toString() - Method in class org.efs.activator.config.EfsActivatorConfig
toString() - Method in class org.efs.activator.config.WorkflowConfig
toString() - Method in class org.efs.activator.config.WorkflowStageConfig
toString() - Method in class org.efs.activator.config.WorkflowStepConfig
toString() - Method in class org.efs.activator.event.ActivatorEvent: Returns a single text line containing agent name, initial state, and final state.
toString() - Method in class org.efs.activator.Workflow: Returns text containing workflow name and its stages.
toString() - Method in class org.efs.activator.WorkflowStage: Returns text containing workflow stage index and subordinate steps.
toString() - Method in class org.efs.activator.WorkflowStep: Returns text containing agent name, transition begin and end states, and allowed transition time.
toString() - Method in class org.efs.dispatcher.config.EfsDispatcherConfig
toString() - Method in class org.efs.dispatcher.config.EfsDispatchersConfig
toString() - Method in class org.efs.dispatcher.config.ThreadAffinityConfig
toString() - Method in enum class org.efs.dispatcher.config.ThreadType
toString() - Method in class org.efs.dispatcher.EfsDispatcher.AgentStats
toString() - Method in class org.efs.dispatcher.EfsDispatcher.DispatcherStats: Returns dispatcher stats snapshot as text.
toString() - Method in class org.efs.dispatcher.EfsDispatcher: Returns text containing efs dispatcher settings.
toString() - Method in class org.efs.dispatcher.EfsDispatcherThread.AgentStats
toString() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns dispatcher thread information as text.
toString() - Method in class org.efs.dispatcher.EfsDispatcherThread
toString() - Method in class org.efs.event.EfsEventWrapper
toString() - Method in class org.efs.event.type.EfsEventLayout.EfsEventField
toString() - Method in class org.efs.event.type.EfsEventLayout: Returns textual representation of this efs event layout.
toString() - Method in class org.efs.feed.EfsDurationEndpoint: Returns time offset duration as text.
toString() - Method in class org.efs.feed.EfsFeedKey: Returns efs event key textual representation.
toString() - Method in class org.efs.feed.EfsIndexEndpoint: Returns index offset only as text.
toString() - Method in class org.efs.feed.EfsInterval: Returns textual representation of end point times and clusivities.
toString() - Method in enum class org.efs.feed.EfsIntervalEndpoint.IntervalLocation
toString() - Method in class org.efs.feed.EfsTimeEndpoint: Returns time as text.
toString() - Method in class org.efs.timer.EfsTimerEvent: Returns textual representation of timer event.
toString(EfsIntervalEndpoint.IntervalSide) - Method in class org.efs.feed.EfsIntervalEndpoint: Outputs this endpoint in format appropriate to which side of the interval the endpoint is on.
totalAgentRunCount() - Method in class org.efs.dispatcher.EfsDispatcher.DispatcherStats: Returns total agent run count across all dispatcher threads.
totalRunTime() - Method in class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadStats: Returns total dispatcher thread run time from its start time until now.
trace(String) - Method in class org.efs.logging.AsyncLogger
trace(String, Object) - Method in class org.efs.logging.AsyncLogger
trace(String, Object...) - Method in class org.efs.logging.AsyncLogger
trace(String, Object, Object) - Method in class org.efs.logging.AsyncLogger
trace(String, Throwable) - Method in class org.efs.logging.AsyncLogger
trace(Marker, String) - Method in class org.efs.logging.AsyncLogger
trace(Marker, String, Object) - Method in class org.efs.logging.AsyncLogger
trace(Marker, String, Object...) - Method in class org.efs.logging.AsyncLogger
trace(Marker, String, Object, Object) - Method in class org.efs.logging.AsyncLogger
trace(Marker, String, Throwable) - Method in class org.efs.logging.AsyncLogger

U

Under the covers - Search tag in package org.efs.dispatcher: Section
unit() - Method in class org.efs.dispatcher.EfsDispatcher.AgentStats: Returns unit name for stored data.
unit() - Method in class org.efs.dispatcher.EfsDispatcherThread.AgentStats: Returns unit name for stored data.
UNREGISTERED_AGENT - Static variable in class org.efs.timer.EfsScheduledExecutor: Unregistered agent message is " is not registered with a dispatcher".
Usage Example - Search tag in class org.efs.timer.EfsScheduledExecutor: Section

V

validate(Validator) - Method in class org.efs.feed.EfsDurationEndpoint.Builder: Verifies that time offset is set.
validate(Validator) - Method in class org.efs.feed.EfsIndexEndpoint.Builder: Verifies that index offset is set.
validate(Validator) - Method in class org.efs.feed.EfsIntervalEndpoint.EndpointBuilder: Verifies that clusivity and location are set.
validate(Validator) - Method in class org.efs.feed.EfsTimeEndpoint.Builder: Verifies that time is set.
validate(ThreadAffinityConfig) - Static method in class org.efs.dispatcher.config.ThreadAffinity: Validates affinity configuration.
valueOf(String) - Static method in enum class org.efs.activator.EfsAgentState: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.activator.event.ActivatorEvent.StepState: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.activator.WorkflowDirection: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.dispatcher.config.ThreadAffinityConfig.AffinityType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.dispatcher.config.ThreadType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.dispatcher.EfsDispatcher.DispatcherState: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.dispatcher.EfsDispatcher.DispatcherType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadState: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.feed.EfsIntervalEndpoint.Clusivity: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.feed.EfsIntervalEndpoint.EndpointType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.feed.EfsIntervalEndpoint.IntervalLocation: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.efs.feed.EfsIntervalEndpoint.IntervalSide: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.efs.activator.EfsAgentState: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.activator.event.ActivatorEvent.StepState: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.activator.WorkflowDirection: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.dispatcher.config.ThreadAffinityConfig.AffinityType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.dispatcher.config.ThreadType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.dispatcher.EfsDispatcher.DispatcherState: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.dispatcher.EfsDispatcher.DispatcherType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.dispatcher.EfsDispatcherThread.DispatcherThreadState: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.feed.EfsIntervalEndpoint.Clusivity: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.feed.EfsIntervalEndpoint.EndpointType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.feed.EfsIntervalEndpoint.IntervalLocation: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.efs.feed.EfsIntervalEndpoint.IntervalSide: Returns an array containing the constants of this enum class, in the order they are declared.

W

warn(String) - Method in class org.efs.logging.AsyncLogger
warn(String, Object) - Method in class org.efs.logging.AsyncLogger
warn(String, Object...) - Method in class org.efs.logging.AsyncLogger
warn(String, Object, Object) - Method in class org.efs.logging.AsyncLogger
warn(String, Throwable) - Method in class org.efs.logging.AsyncLogger
warn(Marker, String) - Method in class org.efs.logging.AsyncLogger
warn(Marker, String, Object) - Method in class org.efs.logging.AsyncLogger
warn(Marker, String, Object...) - Method in class org.efs.logging.AsyncLogger
warn(Marker, String, Object, Object) - Method in class org.efs.logging.AsyncLogger
warn(Marker, String, Throwable) - Method in class org.efs.logging.AsyncLogger
WHOLE_CORE_KEY - Static variable in class org.efs.dispatcher.config.ThreadAffinityConfig: Key "wholeCore" contains reserve-whole-core flag.
workflow() - Method in class org.efs.activator.EfsActivator: Returns current, in-progress workflow name.
Workflow - Class in org.efs.activator: A workflow contains one or more workflow stages which take agent(s) from a start state to an end state.
Workflow.Builder - Class in org.efs.activator: Provides ability to programmatically define a Workflow instance.
WorkflowConfig - Class in org.efs.activator.config: An activator work flow takes one or more agents from a given start state to a target end state.
WorkflowConfig() - Constructor for class org.efs.activator.config.WorkflowConfig: Default constructor required for a typesafe bean class.
WorkflowDirection - Enum Class in org.efs.activator: Workflow either advances agents from a lower to a higher state or descends agents from a higher to a lower state.
workflows(List<Workflow>) - Method in class org.efs.activator.EfsActivator.Builder: Sets activator workflows.
WORKFLOWS_KEY - Static variable in class org.efs.activator.config.EfsActivatorConfig: Key "workflows" contains activator workflow definitions.
WorkflowStage - Class in org.efs.activator: A workflow stage contains one or more steps which take agent(s) from a start state to end state.
WorkflowStage.Builder - Class in org.efs.activator: Provides ability to programmatically define a WorkflowStage instance.
WorkflowStageConfig - Class in org.efs.activator.config: A typesafe bean configuration used to define steps within a workflow stage.
WorkflowStageConfig() - Constructor for class org.efs.activator.config.WorkflowStageConfig: Default constructor required for a typesafe bean class.
WorkflowStep - Class in org.efs.activator: A workflow step takes a single IEfsActivateAgent from an expected begin state to an adjacent next state.
WorkflowStep.Builder - Class in org.efs.activator: Provides ability to programmatically define a WorkflowStep instance.
WorkflowStepConfig - Class in org.efs.activator.config: A typesafe bean configuration used to define a workflow step within a workflow stage.
WorkflowStepConfig() - Constructor for class org.efs.activator.config.WorkflowStepConfig: Default constructor required for a typesafe bean class.

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form