Uses of Class
com.couchbase.client.core.retry.ProtostellarRequestBehaviour
-
Uses of ProtostellarRequestBehaviour in com.couchbase.client.core.protostellar
Modifier and TypeMethodDescriptionProtostellarRequest.cancel
(CancellationReason reason) static ProtostellarRequestBehaviour
CoreProtostellarErrorHandlingUtil.convertException
(CoreProtostellar core, ProtostellarRequest<?> request, Throwable t) static ProtostellarRequestBehaviour
CoreProtostellarErrorHandlingUtil.convertStatus
(CoreProtostellar core, ProtostellarRequest<?> request, com.couchbase.client.core.deps.io.grpc.StatusRuntimeException t, com.couchbase.client.core.deps.com.google.rpc.Status status) Modifier and TypeMethodDescriptionstatic <TGrpcRequest,
TGrpcResponse>
CoreAsyncResponse<List<TGrpcResponse>> CoreProtostellarAccessorsStreaming.async
(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, BiConsumer<ProtostellarEndpoint, com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall, Function<Throwable, ProtostellarRequestBehaviour> convertException) static <TGrpcRequest,
TGrpcResponse>
List<TGrpcResponse> CoreProtostellarAccessorsStreaming.blocking
(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, BiConsumer<ProtostellarEndpoint, com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall, Function<Throwable, ProtostellarRequestBehaviour> convertException) static <TGrpcRequest,
TGrpcResponse>
Flux<TGrpcResponse> CoreProtostellarAccessorsStreaming.reactive
(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, BiConsumer<ProtostellarEndpoint, com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall, Function<Throwable, ProtostellarRequestBehaviour> convertException) -
Uses of ProtostellarRequestBehaviour in com.couchbase.client.core.retry
Modifier and TypeMethodDescriptionstatic ProtostellarRequestBehaviour
ProtostellarRequestBehaviour.fail
(RuntimeException err) static ProtostellarRequestBehaviour
static ProtostellarRequestBehaviour
RetryOrchestratorProtostellar.shouldRetry
(CoreProtostellar core, ProtostellarRequest<?> request, RetryReason reason) static ProtostellarRequestBehaviour
ProtostellarRequestBehaviour.success()