Uses of Class
com.couchbase.client.core.protostellar.ProtostellarRequest

Packages that use ProtostellarRequest

Package	Description
com.couchbase.client.core.protostellar
com.couchbase.client.core.protostellar.kv
com.couchbase.client.core.protostellar.manager
com.couchbase.client.core.retry

Uses of ProtostellarRequest in com.couchbase.client.core.protostellar

Subclasses of ProtostellarRequest in com.couchbase.client.core.protostellar

Modifier and Type	Class	Description
class	ProtostellarCollectionManagerRequest<TGrpcRequest>
class	ProtostellarKeyValueRequest<TGrpcRequest>

Methods in com.couchbase.client.core.protostellar with parameters of type ProtostellarRequest

Modifier and Type	Method	Description
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)	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> void	CoreProtostellarAccessors.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> TSdkResult	CoreProtostellarAccessors.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> TSdkResult	CoreProtostellarAccessors.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> reactor.core.publisher.Mono<T>	CoreProtostellarUtil.handleShutdownReactive(CoreProtostellar core, ProtostellarRequest<?> request)
static <TSdkResult> boolean	CoreProtostellarUtil.handleShutdownReactive(reactor.core.publisher.Sinks.Many<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<?> request)
static <TSdkResult> boolean	CoreProtostellarUtil.handleShutdownReactive(reactor.core.publisher.Sinks.One<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<?> request)
static <TSdkResult, TGrpcRequest, TGrpcResponse> reactor.core.publisher.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> reactor.core.publisher.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> reactor.core.publisher.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> void	CoreProtostellarAccessors.reactiveInternal(reactor.core.publisher.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 ProtostellarRequest

Modifier	Constructor	Description
	ProtostellarBaseRequest(CoreProtostellar core, ProtostellarRequest<?> request)

Uses of ProtostellarRequest in com.couchbase.client.core.protostellar.kv

Methods in com.couchbase.client.core.protostellar.kv that return ProtostellarRequest

Modifier and Type	Method	Description
static 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 ProtostellarRequest

Modifier and Type	Method	Description
static 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 ProtostellarRequest

Modifier and Type	Method	Description
static 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 ProtostellarRequest

Modifier and Type	Method	Description
static Duration	RetryOrchestratorProtostellar.capDuration(Duration uncappedDuration, ProtostellarRequest<?> request)
static ProtostellarRequestBehaviour	RetryOrchestratorProtostellar.shouldRetry(CoreProtostellar core, ProtostellarRequest<?> request, RetryReason reason)