Uses of Class
com.couchbase.client.core.endpoint.ProtostellarEndpoint

Packages that use ProtostellarEndpoint

Package	Description
com.couchbase.client.core
com.couchbase.client.core.endpoint
com.couchbase.client.core.protostellar

Uses of ProtostellarEndpoint in com.couchbase.client.core

Methods in com.couchbase.client.core that return ProtostellarEndpoint

Modifier and Type	Method	Description
ProtostellarEndpoint	CoreProtostellar.endpoint()

Uses of ProtostellarEndpoint in com.couchbase.client.core.endpoint

Methods in com.couchbase.client.core.endpoint that return ProtostellarEndpoint

Modifier and Type	Method	Description
ProtostellarEndpoint	ProtostellarPool.endpoint()

Methods in com.couchbase.client.core.endpoint that return types with arguments of type ProtostellarEndpoint

Modifier and Type	Method	Description
List<ProtostellarEndpoint>	ProtostellarPool.endpoints()

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

Method parameters in com.couchbase.client.core.protostellar with type arguments of type ProtostellarEndpoint

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 <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).