Class AnalyticsRequest
- java.lang.Object
-
- com.couchbase.client.core.msg.BaseRequest<AnalyticsResponse>
-
- com.couchbase.client.core.msg.analytics.AnalyticsRequest
-
- All Implemented Interfaces:
ChunkDecodable<AnalyticsChunkHeader,AnalyticsChunkRow,AnalyticsChunkTrailer,AnalyticsResponse>
,Encodable<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest>
,HttpRequest<AnalyticsChunkHeader,AnalyticsChunkRow,AnalyticsChunkTrailer,AnalyticsResponse>
,Request<AnalyticsResponse>
public class AnalyticsRequest extends BaseRequest<AnalyticsResponse> implements HttpRequest<AnalyticsChunkHeader,AnalyticsChunkRow,AnalyticsChunkTrailer,AnalyticsResponse>
-
-
Field Summary
Fields Modifier and Type Field Description static int
NO_PRIORITY
-
Constructor Summary
Constructors Constructor Description AnalyticsRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Credentials credentials, byte[] query, int priority)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AnalyticsResponse
decode(ResponseStatus status, AnalyticsChunkHeader header, Flux<AnalyticsChunkRow> rows, Mono<AnalyticsChunkTrailer> trailer)
Decodes a chunked response into the response format.com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest
encode()
ServiceType
serviceType()
The service type of this request.-
Methods inherited from class com.couchbase.client.core.msg.BaseRequest
cancel, cancellationReason, cancelled, completed, context, fail, failed, id, response, retryStrategy, serviceContext, succeed, succeeded, timeout
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.couchbase.client.core.msg.Request
cancel, cancellationReason, cancelled, completed, context, fail, failed, id, response, retryStrategy, serviceContext, succeed, succeeded, timeout
-
-
-
-
Field Detail
-
NO_PRIORITY
public static final int NO_PRIORITY
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
AnalyticsRequest
public AnalyticsRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Credentials credentials, byte[] query, int priority)
-
-
Method Detail
-
encode
public com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest encode()
-
decode
public AnalyticsResponse decode(ResponseStatus status, AnalyticsChunkHeader header, Flux<AnalyticsChunkRow> rows, Mono<AnalyticsChunkTrailer> trailer)
Description copied from interface:ChunkDecodable
Decodes a chunked response into the response format.- Specified by:
decode
in interfaceChunkDecodable<AnalyticsChunkHeader,AnalyticsChunkRow,AnalyticsChunkTrailer,AnalyticsResponse>
- Parameters:
status
- the http response status.header
- the chunk header.rows
- the chunk rows.trailer
- the chunk trailer.- Returns:
- a decoded response including all the chunk parts.
-
serviceType
public ServiceType serviceType()
Description copied from interface:Request
The service type of this request.- Specified by:
serviceType
in interfaceRequest<AnalyticsResponse>
- Returns:
- the service type for this request.
-
-