Uses of Class
com.couchbase.client.core.protostellar.ProtostellarRequest
Packages that use ProtostellarRequest
Package
Description
-
Uses of ProtostellarRequest in com.couchbase.client.core.protostellar
Subclasses of ProtostellarRequest in com.couchbase.client.core.protostellarModifier and TypeClassDescriptionclass
ProtostellarCollectionManagerRequest<TGrpcRequest>
class
ProtostellarKeyValueRequest<TGrpcRequest>
Methods in com.couchbase.client.core.protostellar with parameters of type ProtostellarRequestModifier and TypeMethodDescriptionstatic <TSdkResult,
TGrpcRequest, TGrpcResponse>
CoreAsyncResponse<TSdkResult>CoreProtostellarAccessors.async
(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint, com.couchbase.client.core.deps.com.google.common.util.concurrent.ListenableFuture<TGrpcResponse>> executeFutureGrpcCall, Function<TGrpcResponse, TSdkResult> convertResponse) Convenience overload that uses the default exception handling.static <TSdkResult,
TGrpcRequest, TGrpcResponse>
CoreAsyncResponse<TSdkResult>CoreProtostellarAccessors.async
(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint, com.couchbase.client.core.deps.com.google.common.util.concurrent.ListenableFuture<TGrpcResponse>> executeFutureGrpcCall, Function<TGrpcResponse, TSdkResult> convertResponse, Function<Throwable, ProtostellarRequestBehaviour> convertException) static <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 <TSdkResult,
TGrpcRequest, TGrpcResponse>
voidCoreProtostellarAccessors.asyncInternal
(CompletableFuture<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint, com.couchbase.client.core.deps.com.google.common.util.concurrent.ListenableFuture<TGrpcResponse>> executeFutureGrpcCall, Function<TGrpcResponse, TSdkResult> convertResponse, Function<Throwable, ProtostellarRequestBehaviour> convertException) static <TSdkResult,
TGrpcRequest, TGrpcResponse>
TSdkResultCoreProtostellarAccessors.blocking
(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint, TGrpcResponse> executeBlockingGrpcCall, Function<TGrpcResponse, TSdkResult> convertResponse) Convenience overload that uses the default exception handling.static <TSdkResult,
TGrpcRequest, TGrpcResponse>
TSdkResultCoreProtostellarAccessors.blocking
(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint, TGrpcResponse> executeBlockingGrpcCall, Function<TGrpcResponse, TSdkResult> convertResponse, 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 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) static <T> boolean
CoreProtostellarUtil.handleShutdownAsync
(CoreProtostellar core, CompletableFuture<T> ret, ProtostellarRequest<?> request) static void
CoreProtostellarUtil.handleShutdownBlocking
(CoreProtostellar core, ProtostellarRequest<?> request) static <T> Mono<T>
CoreProtostellarUtil.handleShutdownReactive
(CoreProtostellar core, ProtostellarRequest<?> request) static <TSdkResult>
booleanCoreProtostellarUtil.handleShutdownReactive
(Sinks.Many<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<?> request) static <TSdkResult>
booleanCoreProtostellarUtil.handleShutdownReactive
(Sinks.One<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<?> request) static <TSdkResult,
TGrpcRequest, TGrpcResponse>
Mono<TSdkResult>CoreProtostellarAccessors.reactive
(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint, com.couchbase.client.core.deps.com.google.common.util.concurrent.ListenableFuture<TGrpcResponse>> executeFutureGrpcCall, Function<TGrpcResponse, TSdkResult> convertResponse) Convenience overload that uses the default exception handling.static <TSdkResult,
TGrpcRequest, TGrpcResponse>
Mono<TSdkResult>CoreProtostellarAccessors.reactive
(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint, com.couchbase.client.core.deps.com.google.common.util.concurrent.ListenableFuture<TGrpcResponse>> executeFutureGrpcCall, Function<TGrpcResponse, TSdkResult> convertResponse, 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) static <TSdkResult,
TGrpcRequest, TGrpcResponse>
voidCoreProtostellarAccessors.reactiveInternal
(Sinks.One<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint, com.couchbase.client.core.deps.com.google.common.util.concurrent.ListenableFuture<TGrpcResponse>> executeFutureGrpcCall, Function<TGrpcResponse, TSdkResult> convertResponse, Function<Throwable, ProtostellarRequestBehaviour> convertException) This method must always be called at Reactive runtime, not build-time (e.g., inside a Mono.defer or similar).Constructors in com.couchbase.client.core.protostellar with parameters of type ProtostellarRequestModifierConstructorDescriptionProtostellarBaseRequest
(CoreProtostellar core, ProtostellarRequest<?> request) -
Uses of ProtostellarRequest in com.couchbase.client.core.protostellar.kv
Methods in com.couchbase.client.core.protostellar.kv that return ProtostellarRequestModifier and TypeMethodDescriptionstatic ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.AppendRequest>
CoreProtoStellarKvBinaryRequests.appendRequest
(CoreProtostellar core, String key, CoreKeyspace keyspace, CoreCommonOptions opts, byte[] content, long cas, CoreDurability durability) For creating Protostellar GRPC requests.static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.DecrementRequest>
CoreProtoStellarKvBinaryRequests.decrementRequest
(CoreProtostellar core, String key, CoreKeyspace keyspace, CoreCommonOptions opts, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.ExistsRequest>
CoreProtostellarKeyValueRequests.existsRequest
(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.GetAndLockRequest>
CoreProtostellarKeyValueRequests.getAndLockRequest
(CoreProtostellar core, CoreCommonOptions opts, CoreKeyspace keyspace, String key, Duration lockTime, CompressionConfig compressionConfig) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.GetAndTouchRequest>
CoreProtostellarKeyValueRequests.getAndTouchRequest
(CoreProtostellar core, CoreCommonOptions opts, CoreKeyspace keyspace, String key, CoreExpiry expiry, CompressionConfig compressionConfig) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.GetRequest>
CoreProtostellarKeyValueRequests.getRequest
(CoreProtostellar core, CoreCommonOptions opts, CoreKeyspace keyspace, String key, List<String> projections, boolean withExpiry, CompressionConfig compressionConfig) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.IncrementRequest>
CoreProtoStellarKvBinaryRequests.incrementRequest
(CoreProtostellar core, String key, CoreKeyspace keyspace, CoreCommonOptions opts, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.InsertRequest>
CoreProtostellarKeyValueRequests.insertRequest
(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, CompressionConfig compressionConfig) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.LookupInRequest>
CoreProtostellarKeyValueRequests.lookupInRequest
(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.MutateInRequest>
CoreProtostellarKeyValueRequests.mutateInRequest
(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, List<CoreSubdocMutateCommand> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.PrependRequest>
CoreProtoStellarKvBinaryRequests.prependRequest
(CoreProtostellar core, String key, CoreKeyspace keyspace, CoreCommonOptions opts, byte[] content, long cas, CoreDurability durability) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.RemoveRequest>
CoreProtostellarKeyValueRequests.removeRequest
(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, long cas, CoreDurability durability) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.ReplaceRequest>
CoreProtostellarKeyValueRequests.replaceRequest
(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, CompressionConfig compressionConfig) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.TouchRequest>
CoreProtostellarKeyValueRequests.touchRequest
(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, CoreExpiry expiry) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.UnlockRequest>
CoreProtostellarKeyValueRequests.unlockRequest
(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, long cas) static ProtostellarRequest<com.couchbase.client.protostellar.kv.v1.UpsertRequest>
CoreProtostellarKeyValueRequests.upsertRequest
(CoreProtostellar core, CoreKeyspace keyspace, CoreCommonOptions opts, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, CompressionConfig compressionConfig) Methods in com.couchbase.client.core.protostellar.kv with parameters of type ProtostellarRequestModifier and TypeMethodDescriptionstatic CoreSubdocGetResult
CoreProtostellarKeyValueResponses.convertResponse
(CoreProtostellar core, ProtostellarRequest<?> request, CoreKeyspace keyspace, String key, com.couchbase.client.protostellar.kv.v1.LookupInResponse response, List<CoreSubdocGetCommand> specs) -
Uses of ProtostellarRequest in com.couchbase.client.core.protostellar.manager
Methods in com.couchbase.client.core.protostellar.manager that return ProtostellarRequestModifier and TypeMethodDescriptionstatic ProtostellarRequest<com.couchbase.client.protostellar.admin.bucket.v1.CreateBucketRequest>
ProtostellarCoreBucketManagerRequests.createBucketRequest
(CoreProtostellar core, CoreBucketSettings settings, CoreCommonOptions opts) static ProtostellarRequest<com.couchbase.client.protostellar.admin.collection.v1.CreateCollectionRequest>
CoreProtostellarCollectionManagerRequests.createCollectionRequest
(CoreProtostellar core, String bucketName, String scopeName, String collectionName, CoreCreateOrUpdateCollectionSettings settings, CoreCommonOptions opts) static ProtostellarRequest<com.couchbase.client.protostellar.admin.collection.v1.CreateScopeRequest>
CoreProtostellarCollectionManagerRequests.createScopeRequest
(CoreProtostellar core, String bucketName, String scopeName, CoreCommonOptions opts) static ProtostellarRequest<com.couchbase.client.protostellar.admin.bucket.v1.DeleteBucketRequest>
ProtostellarCoreBucketManagerRequests.deleteBucketRequest
(CoreProtostellar core, String bucketName, CoreCommonOptions opts) static ProtostellarRequest<com.couchbase.client.protostellar.admin.collection.v1.DeleteCollectionRequest>
CoreProtostellarCollectionManagerRequests.deleteCollectionRequest
(CoreProtostellar core, String bucketName, String scopeName, String collectionName, CoreCommonOptions opts) static ProtostellarRequest<com.couchbase.client.protostellar.admin.collection.v1.DeleteScopeRequest>
CoreProtostellarCollectionManagerRequests.deleteScopeRequest
(CoreProtostellar core, String bucketName, String scopeName, CoreCommonOptions opts) static ProtostellarRequest<com.couchbase.client.protostellar.admin.bucket.v1.ListBucketsRequest>
ProtostellarCoreBucketManagerRequests.listBucketsRequest
(CoreProtostellar core, CoreCommonOptions opts) static ProtostellarRequest<com.couchbase.client.protostellar.admin.collection.v1.ListCollectionsRequest>
CoreProtostellarCollectionManagerRequests.listCollectionsRequest
(CoreProtostellar core, String bucketName, CoreCommonOptions opts) static ProtostellarRequest<com.couchbase.client.protostellar.admin.bucket.v1.UpdateBucketRequest>
ProtostellarCoreBucketManagerRequests.updateBucketRequest
(CoreProtostellar core, CoreBucketSettings settings, CoreCommonOptions opts) -
Uses of ProtostellarRequest in com.couchbase.client.core.retry
Methods in com.couchbase.client.core.retry with parameters of type ProtostellarRequestModifier and TypeMethodDescriptionstatic Duration
RetryOrchestratorProtostellar.capDuration
(Duration uncappedDuration, ProtostellarRequest<?> request) static ProtostellarRequestBehaviour
RetryOrchestratorProtostellar.shouldRetry
(CoreProtostellar core, ProtostellarRequest<?> request, RetryReason reason)