Package | Description |
---|---|
com.netflix.hystrix |
Core functionality of Hystrix including the HystrixCommand and HystrixCollapser to be extended from.
|
com.netflix.hystrix.collapser |
Modifier and Type | Method and Description |
---|---|
protected Collection<Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>>> |
HystrixCollapser.shardRequests(Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests)
Override to split (shard) a batch of requests into multiple batches that will each call
createCommand separately. |
protected Collection<Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>>> |
HystrixObservableCollapser.shardRequests(Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests)
Override to split (shard) a batch of requests into multiple batches that will each call
createCommand separately. |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
HystrixObservableCollapser.onMissingResponse(HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType> r)
Invoked if a
HystrixCollapser.CollapsedRequest in the batch does not have a response set on it. |
Modifier and Type | Method and Description |
---|---|
protected abstract HystrixCommand<BatchReturnType> |
HystrixCollapser.createCommand(Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests)
Factory method to create a new
HystrixCommand <BatchReturnType> command object each time a batch needs to be executed. |
protected abstract HystrixObservableCommand<BatchReturnType> |
HystrixObservableCollapser.createCommand(Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests)
Factory method to create a new
HystrixObservableCommand <BatchReturnType> command object each time a batch needs to be executed. |
protected abstract void |
HystrixCollapser.mapResponseToRequests(BatchReturnType batchResponse,
Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests)
Executed after the
HystrixCommand <BatchReturnType> command created by HystrixCollapser.createCommand(java.util.Collection<com.netflix.hystrix.HystrixCollapser.CollapsedRequest<ResponseType, RequestArgumentType>>) finishes processing (unless it fails) for mapping the <BatchReturnType> to
the list of CollapsedRequest<ResponseType, RequestArgumentType> objects. |
protected Collection<Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>>> |
HystrixCollapser.shardRequests(Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests)
Override to split (shard) a batch of requests into multiple batches that will each call
createCommand separately. |
protected Collection<Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>>> |
HystrixObservableCollapser.shardRequests(Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests)
Override to split (shard) a batch of requests into multiple batches that will each call
createCommand separately. |
Modifier and Type | Method and Description |
---|---|
Collection<Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>>> |
HystrixCollapserBridge.shardRequests(Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests) |
Modifier and Type | Method and Description |
---|---|
rx.Observable<BatchReturnType> |
HystrixCollapserBridge.createObservableCommand(Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests) |
rx.Observable<Void> |
HystrixCollapserBridge.mapResponseToRequests(rx.Observable<BatchReturnType> batchResponse,
Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests) |
Collection<Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>>> |
HystrixCollapserBridge.shardRequests(Collection<HystrixCollapser.CollapsedRequest<ResponseType,RequestArgumentType>> requests) |
Copyright © 2017. All Rights Reserved.