com.couchbase.client.java.bucket.api

Class Utils

java.lang.Object

com.couchbase.client.java.bucket.api.Utils

@InterfaceAudience.Private
 @InterfaceStability.Uncommitted
public class Utils
extends Object

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Modifier and Type	Method and Description
static <X extends CouchbaseException,R extends CouchbaseResponse> X	addDetails(X ex, R r) Helper method to encapsulate the logic of enriching the exception with detailed status info.
static void	addRequestSpan(CouchbaseEnvironment env, CouchbaseRequest request, String opName)
static void	addRequestSpanWithParent(CouchbaseEnvironment env, io.opentracing.Span parent, CouchbaseRequest request, String opName)
static <T> rx.Observable<T>	applyTimeout(rx.Observable<T> input, CouchbaseRequest request, CouchbaseEnvironment environment, long timeout, TimeUnit timeUnit)

Methods inherited from class java.lang.Object

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

Constructor Detail

Utils

public Utils()

Method Detail

addDetails

@InterfaceAudience.Private
 @InterfaceStability.Uncommitted
public static <X extends CouchbaseException,R extends CouchbaseResponse> X addDetails(X ex,
                                                                                                                                                  R r)

Helper method to encapsulate the logic of enriching the exception with detailed status info.

applyTimeout

public static <T> rx.Observable<T> applyTimeout(rx.Observable<T> input,
                                                CouchbaseRequest request,
                                                CouchbaseEnvironment environment,
                                                long timeout,
                                                TimeUnit timeUnit)

addRequestSpan

public static void addRequestSpan(CouchbaseEnvironment env,
                                  CouchbaseRequest request,
                                  String opName)

addRequestSpanWithParent

public static void addRequestSpanWithParent(CouchbaseEnvironment env,
                                            io.opentracing.Span parent,
                                            CouchbaseRequest request,
                                            String opName)