Package com.netflix.hystrix

Class ExecutionResult

java.lang.Object

com.netflix.hystrix.ExecutionResult

public class ExecutionResult
extends java.lang.Object

Immutable holder class for the status of command execution.

This object can be referenced and "modified" by parent and child threads as well as by different instances of HystrixCommand since 1 instance could create an ExecutionResult, cache a Future that refers to it, a 2nd instance execution then retrieves a Future from cache and wants to append RESPONSE_FROM_CACHE to whatever the ExecutionResult was from the first command execution.

This being immutable forces and ensure thread-safety instead of using AtomicInteger/ConcurrentLinkedQueue and determining when it's safe to mutate the object directly versus needing to deep-copy clone to a new instance.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExecutionResult.EventCounts

Method Summary

Modifier and Type	Method and Description
ExecutionResult	addEvent(int executionLatency, HystrixEventType eventType)
ExecutionResult	addEvent(HystrixEventType eventType) Creates a new ExecutionResult by adding the defined 'event' to the ones on the current instance.
boolean	executionOccurred()
static ExecutionResult	from(HystrixEventType... eventTypes)
HystrixCollapserKey	getCollapserKey()
long	getCommandRunStartTimeInNanos()
ExecutionResult.EventCounts	getEventCounts()
java.lang.Exception	getException()
java.lang.Exception	getExecutionException()
int	getExecutionLatency()
java.util.List<HystrixEventType>	getOrderedList()
long	getStartTimestamp()
int	getUserThreadLatency()
boolean	isExecutedInThread()
boolean	isResponseRejected()
boolean	isResponseSemaphoreRejected()
boolean	isResponseThreadPoolRejected()
ExecutionResult	markCollapsed(HystrixCollapserKey collapserKey, int sizeOfBatch)
ExecutionResult	markUserThreadCompletion(long userThreadLatency)
ExecutionResult	setException(java.lang.Exception e)
ExecutionResult	setExecutedInThread()
ExecutionResult	setExecutionException(java.lang.Exception executionException)
ExecutionResult	setExecutionLatency(int executionLatency)
ExecutionResult	setExecutionOccurred()
ExecutionResult	setInvocationStartTime(long startTimestamp)
ExecutionResult	setNotExecutedInThread()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

from

public static ExecutionResult from(HystrixEventType... eventTypes)

setExecutionOccurred

public ExecutionResult setExecutionOccurred()

setExecutionLatency

public ExecutionResult setExecutionLatency(int executionLatency)

setException

public ExecutionResult setException(java.lang.Exception e)

setExecutionException

public ExecutionResult setExecutionException(java.lang.Exception executionException)

setInvocationStartTime

public ExecutionResult setInvocationStartTime(long startTimestamp)

setExecutedInThread

public ExecutionResult setExecutedInThread()

setNotExecutedInThread

public ExecutionResult setNotExecutedInThread()

markCollapsed

public ExecutionResult markCollapsed(HystrixCollapserKey collapserKey,
                                     int sizeOfBatch)

markUserThreadCompletion

public ExecutionResult markUserThreadCompletion(long userThreadLatency)

addEvent

public ExecutionResult addEvent(HystrixEventType eventType)

Creates a new ExecutionResult by adding the defined 'event' to the ones on the current instance.

Parameters:

eventType - event to add

Returns:

new ExecutionResult with event added

addEvent

public ExecutionResult addEvent(int executionLatency,
                                HystrixEventType eventType)

getEventCounts

public ExecutionResult.EventCounts getEventCounts()

getStartTimestamp

public long getStartTimestamp()

getExecutionLatency

public int getExecutionLatency()

getUserThreadLatency

public int getUserThreadLatency()

getCommandRunStartTimeInNanos

public long getCommandRunStartTimeInNanos()

getException

public java.lang.Exception getException()

getExecutionException

public java.lang.Exception getExecutionException()

getCollapserKey

public HystrixCollapserKey getCollapserKey()

isResponseSemaphoreRejected

public boolean isResponseSemaphoreRejected()

isResponseThreadPoolRejected

public boolean isResponseThreadPoolRejected()

isResponseRejected

public boolean isResponseRejected()

getOrderedList

public java.util.List<HystrixEventType> getOrderedList()

isExecutedInThread

public boolean isExecutedInThread()

executionOccurred

public boolean executionOccurred()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object