Uses of Class
com.couchbase.client.core.CoreProtostellar

Packages that use CoreProtostellar

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

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

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

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 RequestSpan	CoreProtostellarUtil.createSpan(CoreProtostellar core, String spanName, CoreDurability durability, RequestSpan parent)
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> boolean	CoreProtostellarUtil.handleShutdownReactive(Sinks.Many<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<?> request)
static <TSdkResult> boolean	CoreProtostellarUtil.handleShutdownReactive(Sinks.One<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<?> request)
static Duration	CoreProtostellarUtil.kvDurableTimeout(Optional<Duration> customTimeout, CoreDurability dl, CoreProtostellar core)
static Duration	CoreProtostellarUtil.kvDurableTimeout(Optional<Duration> customTimeout, Optional<DurabilityLevel> dl, CoreProtostellar core)
static Duration	CoreProtostellarUtil.kvTimeout(Optional<Duration> customTimeout, CoreProtostellar core)
static Duration	CoreProtostellarUtil.managementTimeout(Optional<Duration> customTimeout, CoreProtostellar core)
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> void	CoreProtostellarAccessors.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 CoreProtostellar

Modifier	Constructor	Description
	ProtostellarBaseRequest(CoreProtostellar core, ProtostellarRequest<?> request)
	ProtostellarCollectionManagerRequest(TGrpcRequest request, CoreProtostellar core, String bucketName, String scopeName, String collectionName, String requestName, RequestSpan span, Duration timeout, boolean readonly, RetryStrategy retryStrategy, Map<String,Object> clientContext)
	ProtostellarKeyValueRequest(TGrpcRequest request, CoreProtostellar core, CoreKeyspace keyspace, String key, CoreDurability durability, String requestName, RequestSpan span, Duration timeout, boolean readonly, RetryStrategy retryStrategy, Map<String,Object> clientContext, long encodeDurationNanos)
	ProtostellarRequest(TGrpcRequest request, CoreProtostellar core, ServiceType serviceType, String requestName, RequestSpan span, Duration timeout, boolean readonly, RetryStrategy retryStrategy, Map<String,Object> clientContext, long encodeDurationNanos, Consumer<Map<String,Object>> contextSupplier)

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

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

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 CoreSubdocGetResult	CoreProtostellarKeyValueResponses.convertResponse(CoreProtostellar core, ProtostellarRequest<?> request, CoreKeyspace keyspace, String key, com.couchbase.client.protostellar.kv.v1.LookupInResponse response, List<CoreSubdocGetCommand> specs)
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)

Constructors in com.couchbase.client.core.protostellar.kv with parameters of type CoreProtostellar

Modifier	Constructor	Description
	ProtostellarCoreKvBinaryOps(CoreProtostellar core, CoreKeyspace keyspace)
	ProtostellarCoreKvOps(CoreProtostellar core, CoreKeyspace keyspace)

Uses of CoreProtostellar in com.couchbase.client.core.protostellar.manager

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

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)

Constructors in com.couchbase.client.core.protostellar.manager with parameters of type CoreProtostellar

Modifier	Constructor	Description
	ProtostellarCoreBucketManager(CoreProtostellar core)
	ProtostellarCoreCollectionManagerOps(CoreProtostellar core, String bucketName)
	ProtostellarCoreSearchIndexManager(CoreProtostellar protostellar, CoreBucketAndScope bucketAndScope)

Uses of CoreProtostellar in com.couchbase.client.core.protostellar.query

Constructors in com.couchbase.client.core.protostellar.query with parameters of type CoreProtostellar

Modifier	Constructor	Description
	ProtostellarCoreQueryOps(CoreProtostellar core)

Uses of CoreProtostellar in com.couchbase.client.core.protostellar.search

Constructors in com.couchbase.client.core.protostellar.search with parameters of type CoreProtostellar

Modifier	Constructor	Description
	ProtostellarCoreSearchOps(CoreProtostellar core, CoreBucketAndScope scope)

Uses of CoreProtostellar in com.couchbase.client.core.retry

Methods in com.couchbase.client.core.retry with parameters of type CoreProtostellar

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