Dependencies
Declarations
-
com
-
netflix
-
hystrix
-
AbstractCommand
-
logger: Logger
-
circuitBreaker: HystrixCircuitBreaker
-
threadPool: HystrixThreadPool
-
threadPoolKey: HystrixThreadPoolKey
-
properties: HystrixCommandProperties
-
TimedOutStatus
-
CommandState
-
ThreadState
-
metrics: HystrixCommandMetrics
-
commandKey: HystrixCommandKey
-
commandGroup: HystrixCommandGroupKey
-
eventNotifier: HystrixEventNotifier
-
concurrencyStrategy: HystrixConcurrencyStrategy
-
executionHook: HystrixCommandExecutionHook
-
fallbackSemaphoreOverride: TryableSemaphore
-
fallbackSemaphorePerCircuit: ConcurrentHashMap<String, TryableSemaphore>
-
executionSemaphoreOverride: TryableSemaphore
-
executionSemaphorePerCircuit: ConcurrentHashMap<String, TryableSemaphore>
-
timeoutTimer: AtomicReference<Reference<TimerListener>>
-
commandState: AtomicReference<CommandState>
-
threadState: AtomicReference<ThreadState>
-
executionResult: ExecutionResult
-
isResponseFromCache: boolean
-
executionResultAtTimeOfCancellation: ExecutionResult
-
commandStartTimestamp: long
-
isCommandTimedOut: AtomicReference<TimedOutStatus>
-
endCurrentThreadExecutingCommand: Action0
-
requestCache: HystrixRequestCache
-
currentRequestLog: HystrixRequestLog
-
defaultNameCache: ConcurrentHashMap<Class<Object>, String>
-
commandContainsFallback: ConcurrentHashMap<HystrixCommandKey, Boolean>
-
getDefaultNameFromClass(Class<Object>): String
-
AbstractCommand(HystrixCommandGroupKey, HystrixCommandKey, HystrixThreadPoolKey, HystrixCircuitBreaker, HystrixThreadPool, Setter, Setter, HystrixCommandMetrics, TryableSemaphore, TryableSemaphore, HystrixPropertiesStrategy, HystrixCommandExecutionHook): void
-
initGroupKey(HystrixCommandGroupKey): HystrixCommandGroupKey
-
commandIsScalar(): boolean
-
initCommandKey(HystrixCommandKey, Class<Object>): HystrixCommandKey
-
initCommandProperties(HystrixCommandKey, HystrixPropertiesStrategy, Setter): HystrixCommandProperties
-
initThreadPoolKey(HystrixThreadPoolKey, HystrixCommandGroupKey, String): HystrixThreadPoolKey
-
initMetrics(HystrixCommandMetrics, HystrixCommandGroupKey, HystrixThreadPoolKey, HystrixCommandKey, HystrixCommandProperties): HystrixCommandMetrics
-
initCircuitBreaker(boolean, HystrixCircuitBreaker, HystrixCommandGroupKey, HystrixCommandKey, HystrixCommandProperties, HystrixCommandMetrics): HystrixCircuitBreaker
-
initExecutionHook(HystrixCommandExecutionHook): HystrixCommandExecutionHook
-
initThreadPool(HystrixThreadPool, HystrixThreadPoolKey, Setter): HystrixThreadPool
-
initRequestLog(boolean, HystrixConcurrencyStrategy): HystrixRequestLog
-
markAsCollapsedCommand(HystrixCollapserKey, int): void
-
observe(): Observable<Object>
-
getExecutionObservable(): Observable<Object>
-
getFallbackObservable(): Observable<Object>
-
toObservable(): Observable<Object>
-
applyHystrixSemantics(AbstractCommand<Object>): Observable<Object>
-
executeCommandAndObserve(AbstractCommand<Object>): Observable<Object>
-
executeCommandWithSpecifiedIsolation(AbstractCommand<Object>): Observable<Object>
-
getFallbackOrThrowException(AbstractCommand<Object>, HystrixEventType, FailureType, String, Exception): Observable<Object>
-
getPublicCacheKey(): String
-
getUserExecutionObservable(AbstractCommand<Object>): Observable<Object>
-
handleRequestCacheHitAndEmitValues(HystrixCommandResponseFromCache<Object>, AbstractCommand<Object>): Observable<Object>
-
cleanUpAfterResponseFromCache(boolean): void
-
handleCommandEnd(boolean): void
-
handleSemaphoreRejectionViaFallback(): Observable<Object>
-
handleShortCircuitViaFallback(): Observable<Object>
-
handleThreadPoolRejectionViaFallback(Exception): Observable<Object>
-
handleTimeoutViaFallback(): Observable<Object>
-
handleBadRequestByEmittingError(Exception): Observable<Object>
-
handleFailureViaFallback(Exception): Observable<Object>
-
handleFallbackRejectionByEmittingError(): Observable<Object>
-
handleFallbackDisabledByEmittingError(Exception, FailureType, String): Observable<Object>
-
shouldNotBeWrapped(Throwable): boolean
-
isUnrecoverable(Throwable): boolean
-
isRecoverableError(Throwable): boolean
-
handleThreadEnd(AbstractCommand<Object>): void
-
shouldOutputOnNextEvents(): boolean
-
HystrixObservableTimeoutOperator
-
setRequestContextIfNeeded(HystrixRequestContext): void
-
getFallbackSemaphore(): TryableSemaphore
-
getExecutionSemaphore(): TryableSemaphore
-
getFallbackMethodName(): String
-
isFallbackUserDefined(): boolean
-
getCommandGroup(): HystrixCommandGroupKey
-
getCommandKey(): HystrixCommandKey
-
getThreadPoolKey(): HystrixThreadPoolKey
-
getCircuitBreaker(): HystrixCircuitBreaker
-
getMetrics(): HystrixCommandMetrics
-
getProperties(): HystrixCommandProperties
-
ExecutionHookApplication
-
FallbackHookApplication
-
DeprecatedOnRunHookApplication
-
DeprecatedOnFallbackHookApplication
-
wrapWithOnExecutionErrorHook(Throwable): Exception
-
wrapWithOnFallbackErrorHook(Throwable): Exception
-
wrapWithOnErrorHook(FailureType, Throwable): Exception
-
wrapWithOnExecutionEmitHook(Object): Object
-
wrapWithOnFallbackEmitHook(Object): Object
-
wrapWithOnEmitHook(Object): Object
-
decomposeException(Exception): Throwable
-
TryableSemaphoreActual
-
TryableSemaphoreNoOp
-
TryableSemaphore
-
getCacheKey(): String
-
isRequestCachingEnabled(): boolean
-
getLogMessagePrefix(): String
-
isCircuitBreakerOpen(): boolean
-
isExecutionComplete(): boolean
-
isExecutedInThread(): boolean
-
isSuccessfulExecution(): boolean
-
isFailedExecution(): boolean
-
getFailedExecutionException(): Throwable
-
getExecutionException(): Throwable
-
isResponseFromFallback(): boolean
-
isResponseTimedOut(): boolean
-
isResponseShortCircuited(): boolean
-
isResponseFromCache(): boolean
-
isResponseSemaphoreRejected(): boolean
-
isResponseThreadPoolRejected(): boolean
-
isResponseRejected(): boolean
-
getExecutionEvents(): List<HystrixEventType>
-
getCommandResult(): ExecutionResult
-
getNumberEmissions(): int
-
getNumberFallbackEmissions(): int
-
getNumberCollapsed(): int
-
getOriginatingCollapserKey(): HystrixCollapserKey
-
getExecutionTimeInMilliseconds(): int
-
getCommandRunStartTimeInNanos(): long
-
getEventCounts(): EventCounts
-
getExceptionFromThrowable(Throwable): Exception
-
ExecutionHookDeprecationWrapper
-
ExecutionResult
-
eventCounts: EventCounts
-
failedExecutionException: Exception
-
executionException: Exception
-
startTimestamp: long
-
executionLatency: int
-
userThreadLatency: int
-
executionOccurred: boolean
-
isExecutedInThread: boolean
-
collapserKey: HystrixCollapserKey
-
ALL_EVENT_TYPES: HystrixEventType[]
-
NUM_EVENT_TYPES: int
-
EXCEPTION_PRODUCING_EVENTS: BitSet
-
TERMINAL_EVENTS: BitSet
-
static class initializer
-
EventCounts
-
setException(Exception): ExecutionResult
-
ExecutionResult(EventCounts, long, int, int, Exception, Exception, boolean, boolean, HystrixCollapserKey): void
-
EMPTY: ExecutionResult
-
from(HystrixEventType[]): ExecutionResult
-
didExecutionOccur(HystrixEventType): boolean
-
setExecutionOccurred(): ExecutionResult
-
setExecutionLatency(int): ExecutionResult
-
setExecutionException(Exception): ExecutionResult
-
setInvocationStartTime(long): ExecutionResult
-
setExecutedInThread(): ExecutionResult
-
setNotExecutedInThread(): ExecutionResult
-
markCollapsed(HystrixCollapserKey, int): ExecutionResult
-
markUserThreadCompletion(long): ExecutionResult
-
addEvent(HystrixEventType): ExecutionResult
-
addEvent(int, HystrixEventType): ExecutionResult
-
getEventCounts(): EventCounts
-
getStartTimestamp(): long
-
getExecutionLatency(): int
-
getUserThreadLatency(): int
-
getCommandRunStartTimeInNanos(): long
-
getException(): Exception
-
getExecutionException(): Exception
-
getCollapserKey(): HystrixCollapserKey
-
isResponseSemaphoreRejected(): boolean
-
isResponseThreadPoolRejected(): boolean
-
isResponseRejected(): boolean
-
getOrderedList(): List<HystrixEventType>
-
isExecutedInThread(): boolean
-
executionOccurred(): boolean
-
containsTerminalEvent(): boolean
-
toString(): String
-
Hystrix
-
HystrixCachedObservable
-
HystrixCircuitBreaker
-
HystrixCollapser
-
logger: Logger
-
collapserFactory: RequestCollapserFactory<Object, Object, Object>
-
requestCache: HystrixRequestCache
-
collapserInstanceWrapper: HystrixCollapserBridge<Object, Object, Object>
-
metrics: HystrixCollapserMetrics
-
Scope
-
HystrixCollapser(): void
-
HystrixCollapser(HystrixCollapserKey): void
-
HystrixCollapser(Setter): void
-
HystrixCollapser(HystrixCollapserKey, Scope, CollapserTimer, Setter): void
-
HystrixCollapser(HystrixCollapserKey, Scope, CollapserTimer, Setter, HystrixCollapserMetrics): void
-
getProperties(): HystrixCollapserProperties
-
getCollapserKey(): HystrixCollapserKey
-
getScope(): Scope
-
getMetrics(): HystrixCollapserMetrics
-
getRequestArgument(): Object
-
createCommand(Collection<CollapsedRequest<Object, Object>>): HystrixCommand<Object>
-
shardRequests(Collection<CollapsedRequest<Object, Object>>): Collection<Collection<CollapsedRequest<Object, Object>>>
-
mapResponseToRequests(Object, Collection<CollapsedRequest<Object, Object>>): void
-
observe(): Observable<Object>
-
toObservable(): Observable<Object>
-
toObservable(Scheduler): Observable<Object>
-
execute(): Object
-
queue(): Future<Object>
-
getCacheKey(): String
-
reset(): void
-
getDefaultNameFromClass(Class<HystrixCollapser>): String
-
CollapsedRequest
-
Setter
-
defaultNameCache: ConcurrentHashMap<Class<HystrixCollapser>, String>
-
HystrixCollapserKey
-
HystrixCollapserMetrics
-
HystrixCollapserProperties
-
metricsRollingPercentileBucketSize: HystrixProperty<Integer>
-
default_maxRequestsInBatch: Integer
-
default_timerDelayInMilliseconds: Integer
-
default_requestCacheEnabled: Boolean
-
default_metricsRollingStatisticalWindow: Integer
-
default_metricsRollingStatisticalWindowBuckets: Integer
-
default_metricsRollingPercentileEnabled: Boolean
-
default_metricsRollingPercentileWindow: Integer
-
default_metricsRollingPercentileWindowBuckets: Integer
-
default_metricsRollingPercentileBucketSize: Integer
-
maxRequestsInBatch: HystrixProperty<Integer>
-
timerDelayInMilliseconds: HystrixProperty<Integer>
-
requestCacheEnabled: HystrixProperty<Boolean>
-
metricsRollingStatisticalWindowInMilliseconds: HystrixProperty<Integer>
-
metricsRollingStatisticalWindowBuckets: HystrixProperty<Integer>
-
metricsRollingPercentileEnabled: HystrixProperty<Boolean>
-
metricsRollingPercentileWindowInMilliseconds: HystrixProperty<Integer>
-
metricsRollingPercentileWindowBuckets: HystrixProperty<Integer>
-
HystrixCollapserProperties(HystrixCollapserKey): void
-
HystrixCollapserProperties(HystrixCollapserKey, Setter): void
-
HystrixCollapserProperties(HystrixCollapserKey, Setter, String): void
-
getProperty(String, HystrixCollapserKey, String, Integer, Integer): HystrixProperty<Integer>
-
getProperty(String, HystrixCollapserKey, String, Boolean, Boolean): HystrixProperty<Boolean>
-
requestCachingEnabled(): HystrixProperty<Boolean>
-
requestCacheEnabled(): HystrixProperty<Boolean>
-
maxRequestsInBatch(): HystrixProperty<Integer>
-
timerDelayInMilliseconds(): HystrixProperty<Integer>
-
metricsRollingStatisticalWindowInMilliseconds(): HystrixProperty<Integer>
-
metricsRollingStatisticalWindowBuckets(): HystrixProperty<Integer>
-
metricsRollingPercentileEnabled(): HystrixProperty<Boolean>
-
metricsRollingPercentileWindowInMilliseconds(): HystrixProperty<Integer>
-
metricsRollingPercentileWindowBuckets(): HystrixProperty<Integer>
-
metricsRollingPercentileBucketSize(): HystrixProperty<Integer>
-
Setter(): Setter
-
defaultSetter(): Setter
-
Setter
-
HystrixCommand
-
HystrixCommand(HystrixCommandGroupKey): void
-
HystrixCommand(HystrixCommandGroupKey, HystrixThreadPoolKey): void
-
HystrixCommand(HystrixCommandGroupKey, int): void
-
HystrixCommand(HystrixCommandGroupKey, HystrixThreadPoolKey, int): void
-
HystrixCommand(Setter): void
-
commandIsScalar(): boolean
-
HystrixCommand(HystrixCommandGroupKey, HystrixCommandKey, HystrixThreadPoolKey, HystrixCircuitBreaker, HystrixThreadPool, Setter, Setter, HystrixCommandMetrics, TryableSemaphore, TryableSemaphore, HystrixPropertiesStrategy, HystrixCommandExecutionHook): void
-
Setter
-
executionThread: AtomicReference<Thread>
-
interruptOnFutureCancel: AtomicBoolean
-
run(): Object
-
getFallback(): Object
-
getExecutionObservable(): Observable<Object>
-
getFallbackObservable(): Observable<Object>
-
execute(): Object
-
queue(): Future<Object>
-
getFallbackMethodName(): String
-
isFallbackUserDefined(): boolean
-
HystrixCommandGroupKey
-
HystrixCommandKey
-
HystrixCommandMetrics
-
logger: Logger
-
ALL_EVENT_TYPES: HystrixEventType[]
-
appendEventToBucket: Func2<long[], HystrixCommandCompletion, long[]>
-
bucketAggregator: Func2<long[], long[], long[]>
-
metrics: ConcurrentHashMap<String, HystrixCommandMetrics>
-
getInstance(HystrixCommandKey, HystrixCommandGroupKey, HystrixCommandProperties): HystrixCommandMetrics
-
getInstance(HystrixCommandKey, HystrixCommandGroupKey, HystrixThreadPoolKey, HystrixCommandProperties): HystrixCommandMetrics
-
getInstance(HystrixCommandKey): HystrixCommandMetrics
-
getInstances(): Collection<HystrixCommandMetrics>
-
reset(): void
-
properties: HystrixCommandProperties
-
key: HystrixCommandKey
-
group: HystrixCommandGroupKey
-
threadPoolKey: HystrixThreadPoolKey
-
concurrentExecutionCount: AtomicInteger
-
healthCountsStream: HealthCountsStream
-
rollingCommandEventCounterStream: RollingCommandEventCounterStream
-
cumulativeCommandEventCounterStream: CumulativeCommandEventCounterStream
-
rollingCommandLatencyDistributionStream: RollingCommandLatencyDistributionStream
-
rollingCommandUserLatencyDistributionStream: RollingCommandUserLatencyDistributionStream
-
rollingCommandMaxConcurrencyStream: RollingCommandMaxConcurrencyStream
-
HystrixCommandMetrics(HystrixCommandKey, HystrixCommandGroupKey, HystrixThreadPoolKey, HystrixCommandProperties, HystrixEventNotifier): void
-
resetStream(): void
-
getCommandKey(): HystrixCommandKey
-
getCommandGroup(): HystrixCommandGroupKey
-
getThreadPoolKey(): HystrixThreadPoolKey
-
getProperties(): HystrixCommandProperties
-
getRollingCount(HystrixEventType): long
-
getCumulativeCount(HystrixEventType): long
-
getCumulativeCount(HystrixRollingNumberEvent): long
-
getRollingCount(HystrixRollingNumberEvent): long
-
getExecutionTimePercentile(double): int
-
getExecutionTimeMean(): int
-
getTotalTimePercentile(double): int
-
getTotalTimeMean(): int
-
getRollingMaxConcurrentExecutions(): long
-
getCurrentConcurrentExecutionCount(): int
-
markCommandStart(HystrixCommandKey, HystrixThreadPoolKey, ExecutionIsolationStrategy): void
-
markCommandDone(ExecutionResult, HystrixCommandKey, HystrixThreadPoolKey, boolean): void
-
getHealthCounts(): HealthCounts
-
unsubscribeAll(): void
-
HealthCounts
-
HystrixCommandProperties
-
key: HystrixCommandKey
-
logger: Logger
-
default_metricsRollingStatisticalWindow: Integer
-
default_metricsRollingStatisticalWindowBuckets: Integer
-
default_circuitBreakerRequestVolumeThreshold: Integer
-
default_circuitBreakerSleepWindowInMilliseconds: Integer
-
default_circuitBreakerErrorThresholdPercentage: Integer
-
default_circuitBreakerForceOpen: Boolean
-
default_circuitBreakerForceClosed: Boolean
-
default_executionTimeoutInMilliseconds: Integer
-
default_executionTimeoutEnabled: Boolean
-
default_executionIsolationStrategy: ExecutionIsolationStrategy
-
default_executionIsolationThreadInterruptOnTimeout: Boolean
-
default_executionIsolationThreadInterruptOnFutureCancel: Boolean
-
default_metricsRollingPercentileEnabled: Boolean
-
default_requestCacheEnabled: Boolean
-
default_fallbackIsolationSemaphoreMaxConcurrentRequests: Integer
-
default_fallbackEnabled: Boolean
-
default_executionIsolationSemaphoreMaxConcurrentRequests: Integer
-
default_requestLogEnabled: Boolean
-
default_circuitBreakerEnabled: Boolean
-
default_metricsRollingPercentileWindow: Integer
-
default_metricsRollingPercentileWindowBuckets: Integer
-
default_metricsRollingPercentileBucketSize: Integer
-
default_metricsHealthSnapshotIntervalInMilliseconds: Integer
-
circuitBreakerRequestVolumeThreshold: HystrixProperty<Integer>
-
circuitBreakerSleepWindowInMilliseconds: HystrixProperty<Integer>
-
circuitBreakerEnabled: HystrixProperty<Boolean>
-
circuitBreakerErrorThresholdPercentage: HystrixProperty<Integer>
-
circuitBreakerForceOpen: HystrixProperty<Boolean>
-
circuitBreakerForceClosed: HystrixProperty<Boolean>
-
executionIsolationStrategy: HystrixProperty<ExecutionIsolationStrategy>
-
executionTimeoutInMilliseconds: HystrixProperty<Integer>
-
executionTimeoutEnabled: HystrixProperty<Boolean>
-
executionIsolationThreadPoolKeyOverride: HystrixProperty<String>
-
executionIsolationSemaphoreMaxConcurrentRequests: HystrixProperty<Integer>
-
fallbackIsolationSemaphoreMaxConcurrentRequests: HystrixProperty<Integer>
-
fallbackEnabled: HystrixProperty<Boolean>
-
executionIsolationThreadInterruptOnTimeout: HystrixProperty<Boolean>
-
executionIsolationThreadInterruptOnFutureCancel: HystrixProperty<Boolean>
-
metricsRollingStatisticalWindowInMilliseconds: HystrixProperty<Integer>
-
metricsRollingStatisticalWindowBuckets: HystrixProperty<Integer>
-
metricsRollingPercentileEnabled: HystrixProperty<Boolean>
-
metricsRollingPercentileWindowInMilliseconds: HystrixProperty<Integer>
-
metricsRollingPercentileWindowBuckets: HystrixProperty<Integer>
-
metricsRollingPercentileBucketSize: HystrixProperty<Integer>
-
metricsHealthSnapshotIntervalInMilliseconds: HystrixProperty<Integer>
-
requestLogEnabled: HystrixProperty<Boolean>
-
requestCacheEnabled: HystrixProperty<Boolean>
-
ExecutionIsolationStrategy
-
HystrixCommandProperties(HystrixCommandKey): void
-
HystrixCommandProperties(HystrixCommandKey, Setter): void
-
HystrixCommandProperties(HystrixCommandKey, Setter, String): void
-
circuitBreakerEnabled(): HystrixProperty<Boolean>
-
circuitBreakerErrorThresholdPercentage(): HystrixProperty<Integer>
-
circuitBreakerForceClosed(): HystrixProperty<Boolean>
-
circuitBreakerForceOpen(): HystrixProperty<Boolean>
-
circuitBreakerRequestVolumeThreshold(): HystrixProperty<Integer>
-
circuitBreakerSleepWindowInMilliseconds(): HystrixProperty<Integer>
-
executionIsolationSemaphoreMaxConcurrentRequests(): HystrixProperty<Integer>
-
executionIsolationStrategy(): HystrixProperty<ExecutionIsolationStrategy>
-
executionIsolationThreadInterruptOnTimeout(): HystrixProperty<Boolean>
-
executionIsolationThreadInterruptOnFutureCancel(): HystrixProperty<Boolean>
-
executionIsolationThreadPoolKeyOverride(): HystrixProperty<String>
-
executionIsolationThreadTimeoutInMilliseconds(): HystrixProperty<Integer>
-
executionTimeoutInMilliseconds(): HystrixProperty<Integer>
-
executionTimeoutEnabled(): HystrixProperty<Boolean>
-
fallbackIsolationSemaphoreMaxConcurrentRequests(): HystrixProperty<Integer>
-
fallbackEnabled(): HystrixProperty<Boolean>
-
metricsHealthSnapshotIntervalInMilliseconds(): HystrixProperty<Integer>
-
metricsRollingPercentileBucketSize(): HystrixProperty<Integer>
-
metricsRollingPercentileEnabled(): HystrixProperty<Boolean>
-
metricsRollingPercentileWindow(): HystrixProperty<Integer>
-
metricsRollingPercentileWindowInMilliseconds(): HystrixProperty<Integer>
-
metricsRollingPercentileWindowBuckets(): HystrixProperty<Integer>
-
metricsRollingStatisticalWindowInMilliseconds(): HystrixProperty<Integer>
-
metricsRollingStatisticalWindowBuckets(): HystrixProperty<Integer>
-
requestCacheEnabled(): HystrixProperty<Boolean>
-
requestLogEnabled(): HystrixProperty<Boolean>
-
getProperty(String, HystrixCommandKey, String, Boolean, Boolean): HystrixProperty<Boolean>
-
getProperty(String, HystrixCommandKey, String, Integer, Integer): HystrixProperty<Integer>
-
getProperty(String, HystrixCommandKey, String, String, String): HystrixProperty<String>
-
getProperty(String, HystrixCommandKey, String, ExecutionIsolationStrategy, ExecutionIsolationStrategy): HystrixProperty<ExecutionIsolationStrategy>
-
ExecutionIsolationStrategyHystrixProperty
-
Setter(): Setter
-
defaultSetter(): Setter
-
Setter
-
HystrixCommandResponseFromCache
-
HystrixCounters
-
HystrixEventType
-
HystrixExecutable
-
HystrixInvokable
-
HystrixInvokableInfo
-
HystrixKey
-
HystrixMetrics
-
HystrixObservable
-
HystrixObservableCollapser
-
Setter
-
logger: Logger
-
collapserFactory: RequestCollapserFactory<Object, Object, Object>
-
requestCache: HystrixRequestCache
-
collapserInstanceWrapper: HystrixCollapserBridge<Object, Object, Object>
-
metrics: HystrixCollapserMetrics
-
Scope
-
HystrixObservableCollapser(): void
-
HystrixObservableCollapser(HystrixCollapserKey): void
-
HystrixObservableCollapser(Setter): void
-
HystrixObservableCollapser(HystrixCollapserKey, Scope, CollapserTimer, Setter, HystrixCollapserMetrics): void
-
getExceptionFromThrowable(Throwable): Exception
-
getProperties(): HystrixCollapserProperties
-
getCollapserKey(): HystrixCollapserKey
-
getScope(): Scope
-
getMetrics(): HystrixCollapserMetrics
-
getRequestArgument(): Object
-
createCommand(Collection<CollapsedRequest<Object, Object>>): HystrixObservableCommand<Object>
-
shardRequests(Collection<CollapsedRequest<Object, Object>>): Collection<Collection<CollapsedRequest<Object, Object>>>
-
getBatchReturnTypeKeySelector(): Func1<Object, Object>
-
getRequestArgumentKeySelector(): Func1<Object, Object>
-
onMissingResponse(CollapsedRequest<Object, Object>): void
-
getBatchReturnTypeToResponseTypeMapper(): Func1<Object, Object>
-
observe(): Observable<Object>
-
toObservable(): Observable<Object>
-
toObservable(Scheduler): Observable<Object>
-
getCacheKey(): String
-
reset(): void
-
getDefaultNameFromClass(Class<HystrixObservableCollapser>): String
-
defaultNameCache: ConcurrentHashMap<Class<HystrixObservableCollapser>, String>
-
HystrixObservableCommand
-
HystrixObservableCommand(HystrixCommandGroupKey): void
-
shouldOutputOnNextEvents(): boolean
-
getFallbackMethodName(): String
-
isFallbackUserDefined(): boolean
-
commandIsScalar(): boolean
-
HystrixObservableCommand(Setter): void
-
HystrixObservableCommand(HystrixCommandGroupKey, HystrixCommandKey, HystrixThreadPoolKey, HystrixCircuitBreaker, HystrixThreadPool, Setter, Setter, HystrixCommandMetrics, TryableSemaphore, TryableSemaphore, HystrixPropertiesStrategy, HystrixCommandExecutionHook): void
-
Setter
-
construct(): Observable<Object>
-
resumeWithFallback(): Observable<Object>
-
getExecutionObservable(): Observable<Object>
-
getFallbackObservable(): Observable<Object>
-
HystrixRequestCache
-
HystrixRequestLog
-
HystrixThreadPool
-
HystrixThreadPoolKey
-
HystrixThreadPoolMetrics
-
HystrixThreadPoolProperties
-
Setter
-
default_coreSize: int
-
default_maximumSize: int
-
default_keepAliveTimeMinutes: int
-
default_maxQueueSize: int
-
default_allow_maximum_size_to_diverge_from_core_size: boolean
-
default_queueSizeRejectionThreshold: int
-
default_threadPoolRollingNumberStatisticalWindow: int
-
default_threadPoolRollingNumberStatisticalWindowBuckets: int
-
corePoolSize: HystrixProperty<Integer>
-
maximumPoolSize: HystrixProperty<Integer>
-
keepAliveTime: HystrixProperty<Integer>
-
maxQueueSize: HystrixProperty<Integer>
-
queueSizeRejectionThreshold: HystrixProperty<Integer>
-
allowMaximumSizeToDivergeFromCoreSize: HystrixProperty<Boolean>
-
threadPoolRollingNumberStatisticalWindowInMilliseconds: HystrixProperty<Integer>
-
threadPoolRollingNumberStatisticalWindowBuckets: HystrixProperty<Integer>
-
HystrixThreadPoolProperties(HystrixThreadPoolKey): void
-
HystrixThreadPoolProperties(HystrixThreadPoolKey, Setter): void
-
HystrixThreadPoolProperties(HystrixThreadPoolKey, Setter, String): void
-
getProperty(String, HystrixThreadPoolKey, String, Integer, Integer): HystrixProperty<Integer>
-
getProperty(String, HystrixThreadPoolKey, String, Boolean, Boolean): HystrixProperty<Boolean>
-
coreSize(): HystrixProperty<Integer>
-
maximumSize(): HystrixProperty<Integer>
-
actualMaximumSize(): Integer
-
keepAliveTimeMinutes(): HystrixProperty<Integer>
-
maxQueueSize(): HystrixProperty<Integer>
-
queueSizeRejectionThreshold(): HystrixProperty<Integer>
-
getAllowMaximumSizeToDivergeFromCoreSize(): HystrixProperty<Boolean>
-
metricsRollingStatisticalWindowInMilliseconds(): HystrixProperty<Integer>
-
metricsRollingStatisticalWindowBuckets(): HystrixProperty<Integer>
-
Setter(): Setter
-
defaultSetter(): Setter
-
HystrixTimerThreadPoolProperties
-
collapser
-
config
-
exception
-
metric
-
strategy
-
util
Java files
Class files