handleResponse(List, IndexBatchResponse) | | 0% | | 0% | 17 | 17 | 42 | 42 | 1 | 1 |
lambda$sendBatch$13(List, List, Context, HttpResponseException) | | 0% | | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
SearchIndexingPublisher(SearchIndexClientImpl, JsonSerializer, Function, boolean, int, int, Duration, Duration, Consumer, Consumer, Consumer, Consumer) | | 0% | | 0% | 2 | 2 | 24 | 24 | 1 | 1 |
sendBatch(List, List, Context) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
createBatch() | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
fillFromQueue(List, List, int, Set) | | 0% | | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
addActions(Collection, Context, Runnable) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
getActions() | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
flush(boolean, boolean, Context) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
calculateRetryDelay(int) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
createAndProcessBatch(Context) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
reinsertFailedActions(List) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$addActions$2(TryTrackingIndexAction) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
batchAvailableForProcessing() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
isRetryable(int) | | 0% | | 0% | 4 | 4 | 1 | 1 | 1 | 1 |
lambda$sendBatch$10(List, Response) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$sendBatch$12(List, IndexBatchException) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$flushLoop$5(boolean, Context) | | 0% | | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
lambda$addActions$1(IndexAction) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
flushLoop(boolean, Context) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
isSuccess(int) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
lambda$sendBatch$14(List, Throwable) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$sendBatch$11(List) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$sendBatch$9(TryTrackingIndexAction) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createAndProcessBatch$8(List, IndexBatchResponse) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$createAndProcessBatch$7(TryTrackingIndexAction) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$flushLoop$6(boolean, Context, IndexBatchResponse) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$new$0(Integer) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createDocumentTooLargeException() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createDocumentHitRetryLimitException() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$handleResponse$15(String, TryTrackingIndexAction) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$flush$4(SignalType) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$flush$3(SignalType) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getBatchActionCount() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCurrentRetryDelay() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |