Class BucketConfigStreamingRequest
java.lang.Object
com.couchbase.client.core.msg.BaseRequest<BucketConfigStreamingResponse>
com.couchbase.client.core.msg.manager.BaseManagerRequest<BucketConfigStreamingResponse>
com.couchbase.client.core.msg.manager.BucketConfigStreamingRequest
- All Implemented Interfaces:
Encodable<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest>
,ManagerRequest<BucketConfigStreamingResponse>
,Request<BucketConfigStreamingResponse>
Performs a (potential endless) streaming request against the cluster manager for the given bucket.
-
Constructor Summary
ConstructorDescriptionBucketConfigStreamingRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String bucketName, Authenticator authenticator) -
Method Summary
Modifier and TypeMethodDescriptiondecode
(com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpResponse response, byte[] content) Decodes a manager response into its response entity.com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest
encode()
boolean
Returns if the given request is idempotent or not.Methods inherited from class com.couchbase.client.core.msg.manager.BaseManagerRequest
serviceType
Methods inherited from class com.couchbase.client.core.msg.BaseRequest
absoluteTimeout, cancel, cancellationReason, cancelled, completed, context, createdAt, fail, failed, id, requestSpan, response, retryStrategy, serviceContext, succeed, succeeded, timeout, timeoutElapsed, timeoutRegistration
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
absoluteTimeout, bucket, cancel, cancel, cancellationReason, cancelled, completed, context, createdAt, fail, failed, id, name, operationId, requestSpan, response, retryStrategy, serviceContext, succeed, succeeded, target, timeout, timeoutElapsed, timeoutRegistration
-
Constructor Details
-
BucketConfigStreamingRequest
public BucketConfigStreamingRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String bucketName, Authenticator authenticator)
-
-
Method Details
-
decode
public BucketConfigStreamingResponse decode(com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpResponse response, byte[] content) Description copied from interface:ManagerRequest
Decodes a manager response into its response entity.- Parameters:
response
- the http header of the response.content
- the actual content of the response.- Returns:
- the decoded value.
-
encode
public com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest encode() -
idempotent
public boolean idempotent()Description copied from interface:Request
Returns if the given request is idempotent or not.By default, this method always returns false for data consistency reasons. Only specific idempotent operations should override this default since it impacts retry handling quite a bit. DO NOT SET THIS TO TRUE ON MUTATING OPERATIONS!
- Returns:
- true if idempotent.
-