Package com.couchbase.client.core.msg.kv

Class CarrierGlobalConfigRequest

java.lang.Object

com.couchbase.client.core.msg.BaseRequest<R>

com.couchbase.client.core.msg.kv.BaseKeyValueRequest<CarrierGlobalConfigResponse>

com.couchbase.client.core.msg.kv.CarrierGlobalConfigRequest

All Implemented Interfaces:

KeyValueRequest<CarrierGlobalConfigResponse>, Request<CarrierGlobalConfigResponse>, ScopedRequest, TargetedRequest, UnmonitoredRequest

public class CarrierGlobalConfigRequest
extends BaseKeyValueRequest<CarrierGlobalConfigResponse>
implements TargetedRequest, UnmonitoredRequest

A request to fetch a global configuration.

Note that this request is technicall the same as a CarrierBucketConfigRequest, but it makes it clear that it is not tied to a bucket (and as a result does not accept one when being constructed).

Constructor Summary

Constructors

Constructor	Description
CarrierGlobalConfigRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, NodeIdentifier target, ConfigVersion ifNewerThan)

Method Summary

Modifier and Type	Method	Description
CarrierGlobalConfigResponse	decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response, KeyValueChannelContext ctx)	Decode the encoded response into its message representation.
com.couchbase.client.core.deps.io.netty.buffer.ByteBuf	encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc, int opaque, KeyValueChannelContext ctx)	Encode this request with the given allocator and opaque.
boolean	idempotent()	Returns if the given request is idempotent or not.
String	name()	The unique name of the request, usually related to the type but not necessarily.
Map<String,Object>	serviceContext()	Returns contextual information for each individual service.
NodeIdentifier	target()	Returns the node that should service this request, or null to let the service locator decide.
String	toString()

Methods inherited from class com.couchbase.client.core.msg.kv.BaseKeyValueRequest

bucket, collectionIdentifier, encodedExternalKeyWithCollection, encodedKeyWithCollection, errorCode, indicateRejectedWithNotMyVbucket, key, nextOpaque, opaque, operationId, partition, partition, rejectedWithNotMyVbucket, serviceType

Methods inherited from class com.couchbase.client.core.msg.BaseRequest

absoluteTimeout, cancel, cancellationReason, cancelled, completed, context, createdAt, fail, failed, id, requestSpan, response, retryStrategy, succeed, succeeded, timeout, timeoutElapsed, timeoutRegistration

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.couchbase.client.core.msg.Request

absoluteTimeout, cancel, cancel, cancellationReason, cancelled, completed, context, createdAt, fail, failed, id, requestSpan, response, retryStrategy, succeed, succeeded, timeout, timeoutElapsed, timeoutRegistration

Constructor Details

CarrierGlobalConfigRequest

public CarrierGlobalConfigRequest(Duration timeout,
 CoreContext ctx,
 RetryStrategy retryStrategy,
 NodeIdentifier target,
 @Nullable
 ConfigVersion ifNewerThan)

Method Details

target

public NodeIdentifier target()

Description copied from interface: Request

Returns the node that should service this request, or null to let the service locator decide.

Specified by:

target in interface Request<CarrierGlobalConfigResponse>

Returns:

(nullable)

encode

public com.couchbase.client.core.deps.io.netty.buffer.ByteBuf encode(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc,
 int opaque,
 KeyValueChannelContext ctx)

Description copied from interface: KeyValueRequest

Encode this request with the given allocator and opaque.

Specified by:

encode in interface KeyValueRequest<CarrierGlobalConfigResponse>

Parameters:

alloc - the allocator where to grab the buffers from.

opaque - the opaque value to use.

ctx - more encode context.

Returns:

the encoded request as a ByteBuf.

decode

public CarrierGlobalConfigResponse decode(com.couchbase.client.core.deps.io.netty.buffer.ByteBuf response,
 KeyValueChannelContext ctx)

Description copied from interface: KeyValueRequest

Decode the encoded response into its message representation.

Specified by:

decode in interface KeyValueRequest<CarrierGlobalConfigResponse>

Parameters:

response - the response to decode.

Returns:

the decoded response as the generic type R.

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!

Specified by:

idempotent in interface Request<CarrierGlobalConfigResponse>

Returns:

true if idempotent.

serviceContext

public Map<String,Object> serviceContext()

Description copied from interface: Request

Returns contextual information for each individual service.

Specified by:

serviceContext in interface Request<CarrierGlobalConfigResponse>

Overrides:

serviceContext in class BaseKeyValueRequest<CarrierGlobalConfigResponse>

Returns:

the service context.

name

public String name()

Description copied from interface: Request

The unique name of the request, usually related to the type but not necessarily.

The default implementation is derived from the class name (i.e. FooRequest returns foo), but if that does not match up it should be overridden in the actual class.

Specified by:

name in interface Request<CarrierGlobalConfigResponse>

Returns:

the name of the request type.

toString

public String toString()

Overrides:

toString in class Object