Package com.couchbase.analytics.client.java

Class InternalUnsupportedHttpClient

java.lang.Object

com.couchbase.analytics.client.java.InternalUnsupportedHttpClient

@ThreadSafe
@Internal
public class InternalUnsupportedHttpClient
extends Object

An HTTP client intended for use by other Couchbase libraries.

NOT PART OF THE PUBLIC API! This class may change without notice.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	InternalUnsupportedHttpClient.RequestBuilder
static class	InternalUnsupportedHttpClient.Response

Method Summary

Modifier and Type	Method	Description
InternalUnsupportedHttpClient.Response	execute(Consumer<InternalUnsupportedHttpClient.RequestBuilder> requestCustomizer, Duration timeout)	Executes an arbitrary HTTP request.
RawQueryMetadata	executeStreaming(Consumer<InternalUnsupportedHttpClient.RequestBuilder> requestCustomizer, Duration timeout, Consumer<Row> rowAction, @Nullable Deserializer deserializer)	Executes an HTTP request for an Analytics query.
static InternalUnsupportedHttpClient	from(Cluster cluster)

Methods inherited from class java.lang.Object

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

Method Details

from

public static InternalUnsupportedHttpClient from(Cluster cluster)

execute

public InternalUnsupportedHttpClient.Response execute(Consumer<InternalUnsupportedHttpClient.RequestBuilder> requestCustomizer,
 Duration timeout)

Executes an arbitrary HTTP request.

Throws:

AnalyticsTimeoutException - if request times out.

CancellationException - if thread is interrupted.

AnalyticsException - for all other IO errors.

executeStreaming

public RawQueryMetadata executeStreaming(Consumer<InternalUnsupportedHttpClient.RequestBuilder> requestCustomizer,
 Duration timeout,
 Consumer<Row> rowAction,
 @Nullable Deserializer deserializer)

Executes an HTTP request for an Analytics query.

Throws:

QueryException - if response has a non-empty "errors" field.

AnalyticsTimeoutException - if request times out.

CancellationException - if thread is interrupted.

AnalyticsException - for all other IO errors.