Package com.couchbase.client.core.protostellar

Class CoreProtostellarUtil

java.lang.Object

com.couchbase.client.core.protostellar.CoreProtostellarUtil

@Internal
public class CoreProtostellarUtil
extends Object

Method Summary

Modifier and Type	Method	Description
static com.couchbase.client.protostellar.kv.v1.DurabilityLevel	convert(CoreDurability dl)
static com.couchbase.client.protostellar.kv.v1.DurabilityLevel	convert(DurabilityLevel dl)
static Instant	convertExpiry(boolean hasExpiry, com.couchbase.client.core.deps.com.google.protobuf.Timestamp expiry)
static com.couchbase.client.core.deps.io.grpc.Deadline	convertTimeout(Duration timeout)
static com.couchbase.client.core.deps.io.grpc.Deadline	convertTimeout(Optional<Duration> customTimeout, Duration defaultTimeout)
static RequestSpan	createSpan(CoreProtostellar core, String spanName, CoreDurability durability, RequestSpan parent)
static <T> boolean	handleShutdownAsync(CoreProtostellar core, CompletableFuture<T> ret, ProtostellarRequest<?> request)
static void	handleShutdownBlocking(CoreProtostellar core, ProtostellarRequest<?> request)
static <T> Mono<T>	handleShutdownReactive(CoreProtostellar core, ProtostellarRequest<?> request)
static <TSdkResult> boolean	handleShutdownReactive(Sinks.Many<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<?> request)
static <TSdkResult> boolean	handleShutdownReactive(Sinks.One<TSdkResult> ret, CoreProtostellar core, ProtostellarRequest<?> request)
static RuntimeException	incompatibleProtostellar(String error)
static Duration	kvDurableTimeout(Optional<Duration> customTimeout, CoreDurability dl, CoreProtostellar core)
static Duration	kvDurableTimeout(Optional<Duration> customTimeout, Optional<DurabilityLevel> dl, CoreProtostellar core)
static Duration	kvTimeout(Optional<Duration> customTimeout, CoreProtostellar core)
static Duration	managementTimeout(Optional<Duration> customTimeout, CoreProtostellar core)
static int	toExpirySeconds(Duration expiry)
static com.couchbase.client.core.deps.com.google.protobuf.Timestamp	toExpiryTime(Instant expiry)
static com.couchbase.client.protostellar.search.v1.LatLng	toLatLng(CoreGeoPoint point)
static RuntimeException	unsupportedCurrentlyInProtostellar()
static RuntimeException	unsupportedInProtostellar(String feature)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

kvTimeout

public static Duration kvTimeout(Optional<Duration> customTimeout,
 CoreProtostellar core)

kvDurableTimeout

public static Duration kvDurableTimeout(Optional<Duration> customTimeout,
 CoreDurability dl,
 CoreProtostellar core)

kvDurableTimeout

public static Duration kvDurableTimeout(Optional<Duration> customTimeout,
 Optional<DurabilityLevel> dl,
 CoreProtostellar core)

convertTimeout

public static com.couchbase.client.core.deps.io.grpc.Deadline convertTimeout(Optional<Duration> customTimeout,
 Duration defaultTimeout)

convertTimeout

public static com.couchbase.client.core.deps.io.grpc.Deadline convertTimeout(Duration timeout)

managementTimeout

public static Duration managementTimeout(Optional<Duration> customTimeout,
 CoreProtostellar core)

handleShutdownBlocking

public static void handleShutdownBlocking(CoreProtostellar core,
 ProtostellarRequest<?> request)

handleShutdownAsync

public static <T> boolean handleShutdownAsync(CoreProtostellar core,
 CompletableFuture<T> ret,
 ProtostellarRequest<?> request)

handleShutdownReactive

public static <TSdkResult> boolean handleShutdownReactive(Sinks.One<TSdkResult> ret,
 CoreProtostellar core,
 ProtostellarRequest<?> request)

handleShutdownReactive

public static <TSdkResult> boolean handleShutdownReactive(Sinks.Many<TSdkResult> ret,
 CoreProtostellar core,
 ProtostellarRequest<?> request)

handleShutdownReactive

@Nullable
public static <T> Mono<T> handleShutdownReactive(CoreProtostellar core,
 ProtostellarRequest<?> request)

convert

public static com.couchbase.client.protostellar.kv.v1.DurabilityLevel convert(DurabilityLevel dl)

convert

public static com.couchbase.client.protostellar.kv.v1.DurabilityLevel convert(CoreDurability dl)

convertExpiry

@Nullable
public static Instant convertExpiry(boolean hasExpiry,
 com.couchbase.client.core.deps.com.google.protobuf.Timestamp expiry)

toExpiryTime

public static com.couchbase.client.core.deps.com.google.protobuf.Timestamp toExpiryTime(Instant expiry)

toExpirySeconds

public static int toExpirySeconds(Duration expiry)

createSpan

public static RequestSpan createSpan(CoreProtostellar core,
 String spanName,
 CoreDurability durability,
 @Nullable
 RequestSpan parent)

toLatLng

public static com.couchbase.client.protostellar.search.v1.LatLng toLatLng(CoreGeoPoint point)

unsupportedInProtostellar

public static RuntimeException unsupportedInProtostellar(String feature)

unsupportedCurrentlyInProtostellar

public static RuntimeException unsupportedCurrentlyInProtostellar()

incompatibleProtostellar

public static RuntimeException incompatibleProtostellar(String error)