Class and Description |
---|
LockedResource |
LockType |
Procedure
Base Procedure class responsible for Procedure Metadata; e.g.
|
ProcedureEvent
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
Thread Pool that executes the submitted procedures.
|
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.
|
Class and Description |
---|
Procedure
Base Procedure class responsible for Procedure Metadata; e.g.
|
Procedure.LockState |
ProcedureEvent
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.
|
ProcedureInMemoryChore
Special procedure used as a chore.
|
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.
|
ProcedureStateSerializer |
ProcedureSuspendedException |
ProcedureYieldException |
RemoteProcedureDispatcher.RemoteOperation
Data structure with reference to remote operation.
|
RemoteProcedureDispatcher.RemoteProcedure
Remote procedure reference.
|
StateMachineProcedure
Procedure described by a series of steps.
|
StateMachineProcedure.Flow |
Class and Description |
---|
LockType |
Procedure
Base Procedure class responsible for Procedure Metadata; e.g.
|
Procedure.LockState |
ProcedureEvent
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.
|
ProcedureStateSerializer |
ProcedureSuspendedException |
Class and Description |
---|
AbstractProcedureScheduler |
LockAndQueue
Locking for mutual exclusion between procedures.
|
LockedResource |
LockedResourceType |
LockStatus
Interface to get status of a Lock without getting access to acquire/release lock.
|
Procedure
Base Procedure class responsible for Procedure Metadata; e.g.
|
Procedure.LockState |
ProcedureDeque
Type class.
|
ProcedureEvent
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
Thread Pool that executes the submitted procedures.
|
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 |
ProcedureSuspendedException |
ProcedureYieldException |
RemoteProcedureDispatcher
A procedure dispatcher that aggregates and sends after elapsed time or after we hit
count threshold.
|
RemoteProcedureDispatcher.RemoteOperation
Data structure with reference to remote operation.
|
RemoteProcedureDispatcher.RemoteProcedure
Remote procedure reference.
|
StateMachineProcedure
Procedure described by a series of steps.
|
StateMachineProcedure.Flow |
Class and Description |
---|
AbstractProcedureScheduler |
BadProcedureException |
CompletedProcedureRetainer
Hold the reference to a completed root procedure.
|
DelayedProcedure
Vessel that carries a Procedure and a timeout.
|
FailedRemoteDispatchException
Used internally signaling failed queue of a remote procedure
operation.
|
InlineChore
Inline Chores (executors internal chores).
|
LockAndQueue
Locking for mutual exclusion between procedures.
|
LockedResource |
LockedResourceType |
LockStatus
Interface to get status of a Lock without getting access to acquire/release lock.
|
LockType |
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.
|
Procedure
Base Procedure class responsible for Procedure Metadata; e.g.
|
Procedure.LockState |
ProcedureDeque
Type class.
|
ProcedureEvent
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.
|
ProcedureException |
ProcedureExecutor
Thread Pool that executes the submitted procedures.
|
ProcedureExecutor.ProcedureExecutorListener |
ProcedureExecutor.Testing
Class with parameters describing how to fail/die when in testing-context.
|
ProcedureExecutor.WorkerThread |
ProcedureInMemoryChore
Special procedure used as a chore.
|
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 |
ProcedureSuspendedException |
ProcedureYieldException |
RemoteProcedureDispatcher.BufferNode
Node that contains a set of RemoteProcedures
|
RemoteProcedureDispatcher.RemoteNode
Account of what procedures are running on remote node.
|
RemoteProcedureDispatcher.RemoteOperation
Data structure with reference to remote operation.
|
RemoteProcedureDispatcher.RemoteProcedure
Remote procedure reference.
|
RemoteProcedureDispatcher.TimeoutExecutorThread |
RemoteProcedureException
A RemoteProcedureException is an exception from another thread or process.
|
RootProcedureState
Internal state of the ProcedureExecutor that describes the state of a "Root Procedure".
|
RootProcedureState.State |
StateMachineProcedure.Flow |
StoppableThread |
TimeoutExecutorThread
Runs task on a period such as check for stuck workers.
|
Class and Description |
---|
Procedure
Base Procedure class responsible for Procedure Metadata; e.g.
|
Class and Description |
---|
Procedure
Base Procedure class responsible for Procedure Metadata; e.g.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.