Interface | Description |
---|---|
LockStatus |
Interface to get status of a Lock without getting access to acquire/release lock.
|
ProcedureExecutor.ProcedureExecutorListener | |
ProcedureMetrics |
With this interface, the procedure framework provides means to collect following set of metrics
per procedure type for all procedures:
Count of submitted procedure instances
Time histogram for successfully completed procedure instances
Count of failed procedure instances
Please implement this interface to return appropriate metrics.
|
ProcedureScheduler |
Keep track of the runnable procedures
|
ProcedureStateSerializer | |
RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote> |
Account of what procedures are running on remote node.
|
RemoteProcedureDispatcher.RemoteProcedure<TEnv,TRemote> |
Remote procedure reference.
|
Class | Description |
---|---|
AbstractProcedureScheduler | |
CompletedProcedureCleaner<TEnvironment> |
Internal cleaner that removes the completed procedure results after a TTL.
|
CompletedProcedureRetainer<TEnvironment> |
Hold the reference to a completed root procedure.
|
DelayedProcedure<TEnvironment> |
Vessel that carries a Procedure and a timeout.
|
FailedProcedure<TEnvironment> | |
InlineChore |
Inline Chores (executors internal chores).
|
LockAndQueue |
Locking for mutual exclusion between procedures.
|
LockedResource | |
OnePhaseProcedure<TEnvironment> | |
Procedure<TEnvironment> |
Base Procedure class responsible for Procedure Metadata; e.g.
|
ProcedureDeque |
Type class.
|
ProcedureEvent<T> |
Basic ProcedureEvent that contains an "object", which can be a description or a reference to the
resource to wait on, and a queue for suspended procedures.
|
ProcedureExecutor<TEnvironment> |
Thread Pool that executes the submitted procedures.
|
ProcedureExecutor.Testing |
Class with parameters describing how to fail/die when in testing-context.
|
ProcedureInMemoryChore<TEnvironment> |
Special procedure used as a chore.
|
ProcedureUtil |
Helper to convert to/from ProcedureProtos
|
ProcedureUtil.CompatStateSerializer |
A serializer (deserializer) for those Procedures which were serialized
before this patch.
|
ProcedureUtil.StateSerializer |
A serializer for our Procedures.
|
RemoteProcedureDispatcher<TEnv,TRemote extends Comparable<TRemote>> |
A procedure dispatcher that aggregates and sends after elapsed time or after we hit
count threshold.
|
RemoteProcedureDispatcher.DelayedTask |
Delayed object that holds a FutureTask.
|
RemoteProcedureDispatcher.RemoteOperation |
Data structure with reference to remote operation.
|
RootProcedureState<TEnvironment> |
Internal state of the ProcedureExecutor that describes the state of a "Root Procedure".
|
SequentialProcedure<TEnvironment> |
A SequentialProcedure describes one step in a procedure chain:
|
SimpleProcedureScheduler |
Simple scheduler for procedures
|
StateMachineProcedure<TEnvironment,TState> |
Procedure described by a series of steps.
|
StoppableThread | |
TimeoutExecutorThread<TEnvironment> |
Runs task on a period such as check for stuck workers.
|
TwoPhaseProcedure<TEnvironment> |
Enum | Description |
---|---|
LockedResourceType | |
LockType | |
Procedure.LockState | |
RootProcedureState.State | |
StateMachineProcedure.Flow |
Exception | Description |
---|---|
BadProcedureException | |
FailedRemoteDispatchException |
Used internally signaling failed queue of a remote procedure
operation.
|
NoNodeDispatchException |
Used internally signaling failed queue of a remote procedure operation.
|
NoServerDispatchException |
Used internally signaling failed queue of a remote procedure operation.
|
NullTargetServerDispatchException |
Used internally signaling failed queue of a remote procedure operation.
|
ProcedureAbortedException |
Thrown when a procedure is aborted
|
ProcedureException | |
ProcedureSuspendedException | |
ProcedureYieldException | |
RemoteProcedureException |
A RemoteProcedureException is an exception from another thread or process.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.