Index (Couchbase JVM Core IO 1.3.1 API)

A B C D E F G H I J K L M N O P Q R S T U V W Z

A

AbstractBinaryMemcacheDecoder<M extends BinaryMemcacheMessage> - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: Decoder for both BinaryMemcacheRequest and BinaryMemcacheResponse.
AbstractBinaryMemcacheDecoder() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheDecoder: Create a new AbstractBinaryMemcacheDecoder with default settings.
AbstractBinaryMemcacheDecoder(int) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheDecoder: Create a new AbstractBinaryMemcacheDecoder with custom settings.
AbstractBinaryMemcacheEncoder<M extends BinaryMemcacheMessage> - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: A MessageToByteEncoder that encodes binary memache messages into bytes.
AbstractBinaryMemcacheEncoder() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheEncoder
AbstractBinaryMemcacheMessage - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: Default implementation of a BinaryMemcacheMessage.
AbstractBinaryMemcacheMessage(byte[], ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage: Create a new instance with all properties set.
AbstractBucketConfig - Class in com.couchbase.client.core.config
AbstractBucketConfig(String, BucketNodeLocator, String, String, List<NodeInfo>, List<PortInfo>) - Constructor for class com.couchbase.client.core.config.AbstractBucketConfig
AbstractCouchbaseLogger - Class in com.couchbase.client.core.logging: A skeletal implementation of CouchbaseLogger.
AbstractCouchbaseLogger(String) - Constructor for class com.couchbase.client.core.logging.AbstractCouchbaseLogger: Creates a new instance.
AbstractCouchbaseRequest - Class in com.couchbase.client.core.message: Default implementation for a CouchbaseRequest, should be extended by child messages.
AbstractCouchbaseRequest(String, String) - Constructor for class com.couchbase.client.core.message.AbstractCouchbaseRequest: Create a new AbstractCouchbaseRequest.
AbstractCouchbaseRequest(String, String, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.AbstractCouchbaseRequest: Create a new AbstractCouchbaseRequest.
AbstractCouchbaseResponse - Class in com.couchbase.client.core.message: The default representation of a CouchbaseResponse.
AbstractCouchbaseResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.AbstractCouchbaseResponse: Sets the required properties for the response.
AbstractDCPMessage - Class in com.couchbase.client.core.message.dcp: Default implementation of DCPRequest.
AbstractDCPMessage(int, short, String, String, String) - Constructor for class com.couchbase.client.core.message.dcp.AbstractDCPMessage: Creates a new AbstractDCPMessage.
AbstractDCPMessage(int, short, String, String, String, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.dcp.AbstractDCPMessage
AbstractDCPRequest - Class in com.couchbase.client.core.message.dcp: Default implementation of DCPRequest.
AbstractDCPRequest(String, String) - Constructor for class com.couchbase.client.core.message.dcp.AbstractDCPRequest: Creates a new AbstractDCPRequest.
AbstractDCPRequest(String, String, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.dcp.AbstractDCPRequest
AbstractDCPResponse - Class in com.couchbase.client.core.message.dcp: Default implementation of DCPResponse.
AbstractDCPResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.dcp.AbstractDCPResponse: Creates AbstractDCPResponse.
AbstractDynamicService - Class in com.couchbase.client.core.service: Parent implementation of a dynamic Service.
AbstractDynamicService(String, String, String, int, CoreEnvironment, int, RingBuffer<ResponseEvent>, Service.EndpointFactory) - Constructor for class com.couchbase.client.core.service.AbstractDynamicService
AbstractEndpoint - Class in com.couchbase.client.core.endpoint: The common parent implementation for all Endpoints.
AbstractEndpoint(String, String, BootstrapAdapter, boolean) - Constructor for class com.couchbase.client.core.endpoint.AbstractEndpoint: Constructor to which allows to pass in an artificial bootstrap adapter.
AbstractEndpoint(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>, boolean) - Constructor for class com.couchbase.client.core.endpoint.AbstractEndpoint: Create a new AbstractEndpoint.
AbstractGenericHandler<RESPONSE,ENCODED,REQUEST extends CouchbaseRequest> - Class in com.couchbase.client.core.endpoint: Generic handler which acts as the common base type for all implementing handlers.
AbstractGenericHandler(AbstractEndpoint, EventSink<ResponseEvent>, boolean) - Constructor for class com.couchbase.client.core.endpoint.AbstractGenericHandler: Creates a new AbstractGenericHandler with the default queue.
AbstractGenericHandler(AbstractEndpoint, EventSink<ResponseEvent>, Queue<REQUEST>, boolean) - Constructor for class com.couchbase.client.core.endpoint.AbstractGenericHandler: Creates a new AbstractGenericHandler with a custom queue.
AbstractKeyValueRequest - Class in com.couchbase.client.core.message.kv: Default implementation of a BinaryRequest.
AbstractKeyValueRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueRequest: Creates a new AbstractKeyValueRequest.
AbstractKeyValueRequest(String, String, String, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueRequest: Creates a new AbstractKeyValueRequest.
AbstractKeyValueResponse - Class in com.couchbase.client.core.message.kv
AbstractKeyValueResponse(ResponseStatus, short, String, ByteBuf, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
AbstractLatencyMetricsCollector<I extends LatencyMetricsIdentifier,E extends LatencyMetricsEvent> - Class in com.couchbase.client.core.metrics: The default abstract implementation for a latency metrics collector.
AbstractLatencyMetricsCollector(EventBus, Scheduler, LatencyMetricsCollectorConfig) - Constructor for class com.couchbase.client.core.metrics.AbstractLatencyMetricsCollector
AbstractLazyService - Class in com.couchbase.client.core.service: This service lazily creates an Endpoint if needed and reuses it.
AbstractLazyService(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>, Service.EndpointFactory) - Constructor for class com.couchbase.client.core.service.AbstractLazyService
AbstractLoader - Class in com.couchbase.client.core.config.loader: An AbstractLoader which provides common basic processing for all implementing loaders.
AbstractLoader(LoaderType, ServiceType, ClusterFacade, CoreEnvironment) - Constructor for class com.couchbase.client.core.config.loader.AbstractLoader: Create a new AbstractLoader.
AbstractMemcacheObject - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache: The default MemcacheObject implementation.
AbstractMemcacheObject() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObject
AbstractMemcacheObjectAggregator - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache: A ChannelHandler that aggregates an MemcacheMessage and its following MemcacheContents into a single MemcacheMessage with no following MemcacheContents.
AbstractMemcacheObjectAggregator(int) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator
AbstractMemcacheObjectDecoder - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache: Abstract super class for both ascii and binary decoders.
AbstractMemcacheObjectDecoder() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectDecoder
AbstractMemcacheObjectEncoder<M extends MemcacheMessage> - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache: A general purpose AbstractMemcacheObjectEncoder that encodes MemcacheMessages.
AbstractMemcacheObjectEncoder() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectEncoder
AbstractMetricsCollector - Class in com.couchbase.client.core.metrics: A common base class for all metrics collectors which emit events.
AbstractMetricsCollector(EventBus, Scheduler, MetricsCollectorConfig) - Constructor for class com.couchbase.client.core.metrics.AbstractMetricsCollector
AbstractOnDemandService - Class in com.couchbase.client.core.service: Abstract implementation of a service which enables and disables endpoints on demand.
AbstractOnDemandService(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>, Service.EndpointFactory) - Constructor for class com.couchbase.client.core.service.AbstractOnDemandService
AbstractPoolingService - Class in com.couchbase.client.core.service: Abstract implementation of a (fixed size) pooling Service.
AbstractPoolingService(String, String, String, int, CoreEnvironment, int, int, SelectionStrategy, RingBuffer<ResponseEvent>, Service.EndpointFactory) - Constructor for class com.couchbase.client.core.service.AbstractPoolingService
AbstractRefresher - Class in com.couchbase.client.core.config.refresher: Common implementation for all refreshers.
AbstractRefresher(ClusterFacade) - Constructor for class com.couchbase.client.core.config.refresher.AbstractRefresher: Creates a new AbstractRefresher.
AbstractStateMachine<S extends Enum> - Class in com.couchbase.client.core.state: Abstract Stateful implementation which acts like a simple state machine.
AbstractStateMachine(S) - Constructor for class com.couchbase.client.core.state.AbstractStateMachine: Creates a new state machine.
AbstractStateZipper<T,S extends Enum> - Class in com.couchbase.client.core.state: The default implementation of a StateZipper.
AbstractStateZipper(S) - Constructor for class com.couchbase.client.core.state.AbstractStateZipper
AbstractStringAwareBufProcessor - Class in com.couchbase.client.core.endpoint.util: Base class for ByteBufProcessor that need to take JSON string escaping into account, through the AbstractStringAwareBufProcessor.isEscaped(byte) method.
AbstractStringAwareBufProcessor() - Constructor for class com.couchbase.client.core.endpoint.util.AbstractStringAwareBufProcessor
AbstractSubdocMutationRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: Base class for all BinarySubdocMutationRequest.
AbstractSubdocMutationRequest(String, String, ByteBuf, String, int, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest: Creates a new AbstractSubdocMutationRequest.
AbstractSubdocMutationRequest(String, String, ByteBuf, String, int, long, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest: Creates a new AbstractSubdocMutationRequest.
AbstractSubdocRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: Base class for all BinarySubdocRequest.
AbstractSubdocRequest(String, String, String, ByteBuf...) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest: Creates a new AbstractSubdocRequest.
AbstractSubdocRequest(String, String, String, Subject<CouchbaseResponse, CouchbaseResponse>, ByteBuf...) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest: Creates a new AbstractSubdocRequest.
acceptOutboundMessage(Object) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectEncoder
ACK - Static variable in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
ack() - Method in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
add(StatResponse) - Method in class com.couchbase.client.core.message.kv.StatRequest
ADD - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
addHttpBasicAuth(ChannelHandlerContext, HttpRequest, String, String) - Static method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Add basic authentication headers to a HttpRequest.
addNode(InetAddress) - Method in class com.couchbase.client.core.RequestHandler: Add a Node identified by its hostname.
AddNodeRequest - Class in com.couchbase.client.core.message.internal
AddNodeRequest(InetAddress) - Constructor for class com.couchbase.client.core.message.internal.AddNodeRequest
AddNodeResponse - Class in com.couchbase.client.core.message.internal
AddNodeResponse(ResponseStatus, InetAddress) - Constructor for class com.couchbase.client.core.message.internal.AddNodeResponse
ADDQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
addService(AddServiceRequest) - Method in class com.couchbase.client.core.node.CouchbaseNode
addService(Service, String) - Method in class com.couchbase.client.core.node.DefaultServiceRegistry
addService(AddServiceRequest) - Method in interface com.couchbase.client.core.node.Node
addService(Service, String) - Method in interface com.couchbase.client.core.node.ServiceRegistry
addService(AddServiceRequest) - Method in class com.couchbase.client.core.RequestHandler: Add the service to the node.
AddServiceRequest - Class in com.couchbase.client.core.message.internal
AddServiceRequest(ServiceType, String, String, int, InetAddress) - Constructor for class com.couchbase.client.core.message.internal.AddServiceRequest
AddServiceResponse - Class in com.couchbase.client.core.message.internal
AddServiceResponse(ResponseStatus, InetAddress) - Constructor for class com.couchbase.client.core.message.internal.AddServiceResponse
addStream(short) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnection
addStream(short, long, long, long, long, long) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnection
all() - Method in class com.couchbase.client.core.event.metrics.RuntimeMetricsEvent
APPEND - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
APPENDQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
AppendRequest - Class in com.couchbase.client.core.message.kv
AppendRequest(String, long, ByteBuf, String) - Constructor for class com.couchbase.client.core.message.kv.AppendRequest
AppendResponse - Class in com.couchbase.client.core.message.kv
AppendResponse(ResponseStatus, short, long, String, ByteBuf, MutationToken, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.AppendResponse
arrayOperation() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest
AUTH_CONTINUE - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
AUTH_ERROR - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
AuthenticationException - Exception in com.couchbase.client.core.endpoint.kv
AuthenticationException() - Constructor for exception com.couchbase.client.core.endpoint.kv.AuthenticationException
AuthenticationException(String) - Constructor for exception com.couchbase.client.core.endpoint.kv.AuthenticationException
AuthenticationException(String, Throwable) - Constructor for exception com.couchbase.client.core.endpoint.kv.AuthenticationException
AuthenticationException(Throwable) - Constructor for exception com.couchbase.client.core.endpoint.kv.AuthenticationException
AUTORELEASE_AFTER - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
autoreleaseAfter() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The time in milliseconds after which a non-subscribed observable is going to be automatically released.
autoreleaseAfter() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
autoreleaseAfter(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the time after which any non-consumed buffers will be automatically released.

B

BackpressureException - Exception in com.couchbase.client.core: Identifies the need to back off on the supplier side when using a service, because the consumer is overloaded.
BackpressureException() - Constructor for exception com.couchbase.client.core.BackpressureException
Base64 - Class in com.couchbase.client.core.utils: Utility class to perform base64 encoding/decoding.
BestEffortRetryStrategy - Class in com.couchbase.client.core.retry: A RetryStrategy that will retry until the max request lifetime is reached.
BinaryMemcacheClientCodec - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: The client codec that combines the proper encoder and decoder.
BinaryMemcacheClientCodec() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheClientCodec: Create a new BinaryMemcacheClientCodec with the default settings applied.
BinaryMemcacheClientCodec(int) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheClientCodec: Create a new BinaryMemcacheClientCodec and set a custom chunk size.
BinaryMemcacheClientCodec(int, boolean) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheClientCodec: Create a new BinaryMemcacheClientCodec with custom settings.
BinaryMemcacheMessage - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: An interface that defines a binary Memcache message, providing common properties for BinaryMemcacheRequest and BinaryMemcacheResponse.
BinaryMemcacheObjectAggregator - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: An object aggregator for the memcache binary protocol.
BinaryMemcacheObjectAggregator(int) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheObjectAggregator
BinaryMemcacheOpcodes - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: Represents all Opcodes that can occur in a BinaryMemcacheMessage.
BinaryMemcacheRequest - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: Represents a full BinaryMemcacheRequest, which contains the header and optional key and extras.
BinaryMemcacheRequestDecoder - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: The decoder part which takes care of decoding the request-specific headers.
BinaryMemcacheRequestDecoder() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheRequestDecoder
BinaryMemcacheRequestDecoder(int) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheRequestDecoder
BinaryMemcacheRequestEncoder - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: The encoder part which takes care of encoding the request headers.
BinaryMemcacheRequestEncoder() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheRequestEncoder
BinaryMemcacheResponse - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: Represents a full BinaryMemcacheResponse, which contains the header and optional key and extras.
BinaryMemcacheResponseDecoder - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: The decoder which takes care of decoding the response headers.
BinaryMemcacheResponseDecoder() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseDecoder
BinaryMemcacheResponseDecoder(int) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseDecoder
BinaryMemcacheResponseEncoder - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: The encoder which takes care of encoding the response headers.
BinaryMemcacheResponseEncoder() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseEncoder
BinaryMemcacheResponseStatus - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: Contains all possible status values a response can return.
BinaryRequest - Interface in com.couchbase.client.core.message.kv: Common marker interface for all BinaryRequests.
BinaryResponse - Interface in com.couchbase.client.core.message.kv: Marker interface which signals a binary response.
BinaryStoreRequest - Interface in com.couchbase.client.core.message.kv
BinarySubdocMultiLookupRequest - Interface in com.couchbase.client.core.message.kv.subdoc: A BinarySubdocRequest that describes multiple lookup operations on a single document.
BinarySubdocMultiMutationRequest - Interface in com.couchbase.client.core.message.kv.subdoc: A BinarySubdocRequest that describes multiple mutations on a single document.
BinarySubdocMutationRequest - Interface in com.couchbase.client.core.message.kv.subdoc: A BinarySubdocRequest that describes a mutation operation.
BinarySubdocRequest - Interface in com.couchbase.client.core.message.kv.subdoc: A type of BinaryRequest that deals with getting or mutating parts of a JSON document, aka a Sub-Document.
bind(ChannelHandlerContext, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler
bind(ChannelHandlerContext, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
bind(ChannelHandlerContext, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
blockForSingle(Observable<? extends T>, long, TimeUnit) - Static method in class com.couchbase.client.core.utils.Blocking: Blocks on an Observable and returns a single event or throws an Exception.
Blocking - Class in com.couchbase.client.core.utils: Contains various utility methods related to blocking operations.
Blocking() - Constructor for class com.couchbase.client.core.utils.Blocking
body() - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentRequest
booleanPropertyOr(String, boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
BOOTSTRAP_CARRIER_DIRECT_PORT - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
BOOTSTRAP_CARRIER_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
BOOTSTRAP_CARRIER_SSL_PORT - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
BOOTSTRAP_HTTP_DIRECT_PORT - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
BOOTSTRAP_HTTP_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
BOOTSTRAP_HTTP_SSL_PORT - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
BootstrapAdapter - Class in com.couchbase.client.core.endpoint: A wrapper for the IO Bootstrap class.
BootstrapAdapter(Bootstrap) - Constructor for class com.couchbase.client.core.endpoint.BootstrapAdapter: Create a new BootstrapAdapter.
bootstrapCarrierDirectPort() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The port to use when bootstrapping through carrier publication without SSL.
bootstrapCarrierDirectPort() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
bootstrapCarrierDirectPort(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: If carrier publication bootstrap is enabled and not SSL, sets the port to use (default value ).
bootstrapCarrierEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment: If bootstrapping through the advanced carrier publication is enabled.
bootstrapCarrierEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
bootstrapCarrierEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Toggles bootstrap via carrier publication (default value ).
bootstrapCarrierSslPort() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The port to use when bootstrapping through carrier publication with SSL.
bootstrapCarrierSslPort() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
bootstrapCarrierSslPort(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: If carrier publication bootstrap and SSL are enabled, sets the port to use (default value ).
bootstrapHttpDirectPort() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The port to use when bootstrapping through HTTP without SSL.
bootstrapHttpDirectPort() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
bootstrapHttpDirectPort(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: If Http bootstrap is enabled and not SSL, sets the port to use (default value ).
bootstrapHttpEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment: If bootstrapping through HTTP is enabled.
bootstrapHttpEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
bootstrapHttpEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Toggles bootstrap via Http (default value ).
bootstrapHttpSslPort() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The port to use when bootstrapping through HTTP with SSL.
bootstrapHttpSslPort() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
bootstrapHttpSslPort(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: If Http bootstrap and SSL are enabled, sets the port to use (default value ).
BootstrapMessage - Interface in com.couchbase.client.core.message: Marker interface for messages that should be allowed to go through the RequestHandler, despite no bucket configuration available to check upon.
bucket() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint: The name of the bucket.
bucket() - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnection
bucket() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
bucket() - Method in interface com.couchbase.client.core.message.CouchbaseRequest: The associated bucket name for this request.
bucket() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
bucket() - Method in interface com.couchbase.client.core.message.kv.BinaryResponse: The name of the bucket where this response is coming from.
bucket() - Method in class com.couchbase.client.core.message.kv.MutationToken
BucketClosedEvent - Class in com.couchbase.client.core.event.system: Event published when a bucket is closed.
BucketClosedEvent(String) - Constructor for class com.couchbase.client.core.event.system.BucketClosedEvent
BucketClosedException - Exception in com.couchbase.client.core: A RuntimeException being thrown whenever an operation on a bucket that has been closed is attempted.
BucketClosedException() - Constructor for exception com.couchbase.client.core.BucketClosedException
BucketClosedException(String) - Constructor for exception com.couchbase.client.core.BucketClosedException
BucketClosedException(String, Throwable) - Constructor for exception com.couchbase.client.core.BucketClosedException
BucketConfig - Interface in com.couchbase.client.core.config: Represents a Couchbase Bucket Configuration.
bucketConfig(String) - Method in interface com.couchbase.client.core.config.ClusterConfig: Returns the BucketConfig for the given bucket name.
bucketConfig(String) - Method in class com.couchbase.client.core.config.DefaultClusterConfig
BucketConfigParser - Class in com.couchbase.client.core.config.parser: .
BucketConfigParser() - Constructor for class com.couchbase.client.core.config.parser.BucketConfigParser
BucketConfigRequest - Class in com.couchbase.client.core.message.config
BucketConfigRequest(String, InetAddress, String, String) - Constructor for class com.couchbase.client.core.message.config.BucketConfigRequest
BucketConfigResponse - Class in com.couchbase.client.core.message.config
BucketConfigResponse(String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.config.BucketConfigResponse
bucketConfigs() - Method in interface com.couchbase.client.core.config.ClusterConfig
bucketConfigs() - Method in class com.couchbase.client.core.config.DefaultClusterConfig
BucketNodeLocator - Enum in com.couchbase.client.core.config: Represents the node locator used for the specific bucket type.
BucketOpenedEvent - Class in com.couchbase.client.core.event.system: Event published when a bucket is opened.
BucketOpenedEvent(String) - Constructor for class com.couchbase.client.core.event.system.BucketOpenedEvent
BucketsConfigRequest - Class in com.couchbase.client.core.message.config
BucketsConfigRequest(String, String) - Constructor for class com.couchbase.client.core.message.config.BucketsConfigRequest
BucketsConfigResponse - Class in com.couchbase.client.core.message.config
BucketsConfigResponse(String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.config.BucketsConfigResponse
BucketServiceMapping - Enum in com.couchbase.client.core.service: Defines the relationship between a bucket and a service.
BucketStreamingRequest - Class in com.couchbase.client.core.message.config
BucketStreamingRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.config.BucketStreamingRequest
BucketStreamingResponse - Class in com.couchbase.client.core.message.config
BucketStreamingResponse(Observable<String>, String, ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.config.BucketStreamingResponse
BucketType - Enum in com.couchbase.client.core.config: Represents the possible bucket types.
BUFFER_POOLING_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
bufferPoolingEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns if buffer pooling is enabled for greater GC efficiency.
bufferPoolingEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
bufferPoolingEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Forcefully disable buffer pooling by setting the value to false.
Buffers - Class in com.couchbase.client.core.utils: Collection of utilities around ByteBuf.
Buffers() - Constructor for class com.couchbase.client.core.utils.Buffers
build() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
build() - Method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig.Builder
build() - Method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig.Builder
builder() - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
Builder() - Constructor for class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
builder() - Static method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
Builder() - Constructor for class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig.Builder
Builder() - Constructor for class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig.Builder
buildInvalidMessage() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheDecoder: Helper method to create a upstream message when the incoming parsing did fail.
buildInvalidMessage() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheRequestDecoder
buildInvalidMessage() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseDecoder
bySequenceNumber() - Method in class com.couchbase.client.core.message.dcp.ExpirationMessage
bySequenceNumber() - Method in class com.couchbase.client.core.message.dcp.MutationMessage
bySequenceNumber() - Method in class com.couchbase.client.core.message.dcp.RemoveMessage
BYTE_BUF_RELEASER - Static variable in class com.couchbase.client.core.utils.Buffers: An rx Action1 that releases (once) a non-null ByteBuf provided its refCnt is > 0.
ByteBufJsonHelper - Class in com.couchbase.client.core.endpoint.util: An helper class providing utility methods to deal with parsing of structured data (like JSON) inside a ByteBuf buffer.
ByteBufJsonHelper() - Constructor for class com.couchbase.client.core.endpoint.util.ByteBufJsonHelper

C

calculate(long) - Method in class com.couchbase.client.core.time.Delay: Calculate a specific delay based on the attempt passed in.
calculate(long) - Method in class com.couchbase.client.core.time.ExponentialDelay
calculate(long) - Method in class com.couchbase.client.core.time.FixedDelay
calculate(long) - Method in class com.couchbase.client.core.time.LinearDelay
calculateAlternatePower(long) - Method in class com.couchbase.client.core.time.ExponentialDelay
calculatePowerOfTwo(long) - Method in class com.couchbase.client.core.time.ExponentialDelay
call(ClusterFacade, String, String, long, boolean, Observe.PersistTo, Observe.ReplicateTo, RetryStrategy) - Static method in class com.couchbase.client.core.message.observe.Observe
call(ClusterFacade, String, String, long, boolean, Observe.PersistTo, Observe.ReplicateTo, Delay, RetryStrategy) - Static method in class com.couchbase.client.core.message.observe.Observe
call(ClusterFacade, String, String, long, boolean, MutationToken, Observe.PersistTo, Observe.ReplicateTo, Delay, RetryStrategy) - Static method in class com.couchbase.client.core.message.observe.Observe
call(ClusterFacade, String, String, long, boolean, Observe.PersistTo, Observe.ReplicateTo, Delay, RetryStrategy) - Static method in class com.couchbase.client.core.message.observe.ObserveViaCAS
call(ClusterFacade, String, String, MutationToken, Observe.PersistTo, Observe.ReplicateTo, Delay, RetryStrategy) - Static method in class com.couchbase.client.core.message.observe.ObserveViaMutationToken
call(ClusterFacade, String, String) - Static method in class com.couchbase.client.core.message.stat.Stat
CALLBACKS_ON_IO_POOL - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
callbacksOnIoPool() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns true if the Observable callbacks are completed on the IO event loops.
callbacksOnIoPool(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Set to true if the Observable callbacks should be completed on the IO event loops.
callbacksOnIoPool() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
CarrierLoader - Class in com.couchbase.client.core.config.loader: Loads a raw bucket configuration through the carrier mechanism (also commonly referred to as CCCP).
CarrierLoader(ClusterFacade, CoreEnvironment) - Constructor for class com.couchbase.client.core.config.loader.CarrierLoader: Creates a new CarrierLoader.
CarrierRefresher - Class in com.couchbase.client.core.config.refresher: Keeps the bucket config fresh through carrier configuration management.
CarrierRefresher(CoreEnvironment, ClusterFacade) - Constructor for class com.couchbase.client.core.config.refresher.CarrierRefresher: Creates a new CarrierRefresher.
cas() - Method in class com.couchbase.client.core.message.dcp.ExpirationMessage
cas() - Method in class com.couchbase.client.core.message.dcp.MutationMessage
cas() - Method in class com.couchbase.client.core.message.dcp.RemoveMessage
cas() - Method in class com.couchbase.client.core.message.kv.AppendRequest
cas() - Method in class com.couchbase.client.core.message.kv.AppendResponse
cas() - Method in class com.couchbase.client.core.message.kv.CounterResponse
cas() - Method in class com.couchbase.client.core.message.kv.GetResponse
cas() - Method in class com.couchbase.client.core.message.kv.InsertResponse
cas() - Method in class com.couchbase.client.core.message.kv.ObserveRequest
cas() - Method in class com.couchbase.client.core.message.kv.ObserveResponse
cas() - Method in class com.couchbase.client.core.message.kv.PrependRequest
cas() - Method in class com.couchbase.client.core.message.kv.PrependResponse
cas() - Method in class com.couchbase.client.core.message.kv.RemoveRequest: The CAS value of the request.
cas() - Method in class com.couchbase.client.core.message.kv.RemoveResponse
cas() - Method in class com.couchbase.client.core.message.kv.ReplaceRequest: The CAS value of the request.
cas() - Method in class com.couchbase.client.core.message.kv.ReplaceResponse
cas() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMultiMutationRequest
cas() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMutationRequest
cas() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiLookupResponse
cas() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse
cas() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationRequest
cas() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
cas() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SimpleSubdocResponse
cas() - Method in class com.couchbase.client.core.message.kv.UnlockRequest
cas() - Method in class com.couchbase.client.core.message.kv.UpsertResponse
channelActive(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
channelActive(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler: Once the channel is marked as active, the open DCP connection.
channelActive(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler: Once the channel is marked as active, the SASL negotiation is started.
channelActive(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
channelInactive(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
channelInactive(ChannelHandlerContext) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator
channelInactive(ChannelHandlerContext) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheDecoder: When the channel goes inactive, release all frames to prevent data leaks.
channelRead0(ChannelHandlerContext, FullBinaryMemcacheResponse) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler: Dispatches incoming OPEN_CONNECTION responses and also initialize flow control.
channelRead0(ChannelHandlerContext, FullBinaryMemcacheResponse) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler: Dispatches incoming SASL responses to the appropriate handler methods.
channelRead0(ChannelHandlerContext, FullBinaryMemcacheResponse) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
channelWritabilityChanged(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
CHARSET - Static variable in class com.couchbase.client.core.endpoint.AbstractGenericHandler: The default charset to use for all requests and responses.
checkFeaturesForRequest(CouchbaseRequest, BucketConfig) - Method in class com.couchbase.client.core.RequestHandler: Checks, for a sub-set of CouchbaseRequest, if the current environment has the necessary feature activated.
checkNode(Node) - Method in class com.couchbase.client.core.node.locate.QueryLocator
checkNode(Node) - Method in class com.couchbase.client.core.node.locate.SearchLocator
checkNode(Node, CouchbaseBucketConfig) - Method in class com.couchbase.client.core.node.locate.ViewLocator
CHECKPOINT - Static variable in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
checkpoint() - Method in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
cleanUpAndThrow(RuntimeException) - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest: Utility method to ensure good cleanup when throwing an exception from a constructor.
clientRequestId() - Method in class com.couchbase.client.core.message.query.GenericQueryResponse
close(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler
close(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
close(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
closeBucket(String) - Method in interface com.couchbase.client.core.config.ConfigurationProvider
closeBucket(String) - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
CloseBucketRequest - Class in com.couchbase.client.core.message.cluster
CloseBucketRequest(String) - Constructor for class com.couchbase.client.core.message.cluster.CloseBucketRequest
CloseBucketResponse - Class in com.couchbase.client.core.message.cluster
CloseBucketResponse(ResponseStatus) - Constructor for class com.couchbase.client.core.message.cluster.CloseBucketResponse
closeBuckets() - Method in interface com.couchbase.client.core.config.ConfigurationProvider
closeBuckets() - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
ClosingPositionBufProcessor - Class in com.couchbase.client.core.endpoint.util: A ByteBufProcessor to find a closing character position.
ClosingPositionBufProcessor(char, char) - Constructor for class com.couchbase.client.core.endpoint.util.ClosingPositionBufProcessor
ClosingPositionBufProcessor(char, char, boolean) - Constructor for class com.couchbase.client.core.endpoint.util.ClosingPositionBufProcessor
cluster() - Method in class com.couchbase.client.core.config.loader.AbstractLoader: Returns the ClusterFacade for child implementations.
cluster() - Method in class com.couchbase.client.core.config.refresher.AbstractRefresher: Returns the cluster reference.
ClusterConfig - Interface in com.couchbase.client.core.config: Represents a Couchbase Cluster Configuration.
ClusterConfigRequest - Class in com.couchbase.client.core.message.config
ClusterConfigRequest(String, String) - Constructor for class com.couchbase.client.core.message.config.ClusterConfigRequest
ClusterConfigResponse - Class in com.couchbase.client.core.message.config
ClusterConfigResponse(String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.config.ClusterConfigResponse
ClusterFacade - Interface in com.couchbase.client.core: Represents a Couchbase Cluster.
clusterNodes() - Method in class com.couchbase.client.core.event.system.ConfigUpdatedEvent: Returns the InetAddress of all nodes that are part of the cluster config.
ClusterRequest - Interface in com.couchbase.client.core.message.cluster
code() - Method in enum com.couchbase.client.core.endpoint.kv.KeyValueStatus
collect() - Static method in class com.couchbase.client.core.env.Diagnostics: Collects all available infos in one map.
collectAndFormat() - Static method in class com.couchbase.client.core.env.Diagnostics: Collects all available infos and formats it in a better readable way.
com.couchbase.client.core - package com.couchbase.client.core: Couchbase Core IO - Domain Model and Architecture
com.couchbase.client.core.annotations - package com.couchbase.client.core.annotations
com.couchbase.client.core.config - package com.couchbase.client.core.config
com.couchbase.client.core.config.loader - package com.couchbase.client.core.config.loader
com.couchbase.client.core.config.parser - package com.couchbase.client.core.config.parser
com.couchbase.client.core.config.refresher - package com.couchbase.client.core.config.refresher
com.couchbase.client.core.endpoint - package com.couchbase.client.core.endpoint
com.couchbase.client.core.endpoint.config - package com.couchbase.client.core.endpoint.config
com.couchbase.client.core.endpoint.dcp - package com.couchbase.client.core.endpoint.dcp
com.couchbase.client.core.endpoint.kv - package com.couchbase.client.core.endpoint.kv
com.couchbase.client.core.endpoint.query - package com.couchbase.client.core.endpoint.query
com.couchbase.client.core.endpoint.search - package com.couchbase.client.core.endpoint.search
com.couchbase.client.core.endpoint.util - package com.couchbase.client.core.endpoint.util
com.couchbase.client.core.endpoint.view - package com.couchbase.client.core.endpoint.view
com.couchbase.client.core.env - package com.couchbase.client.core.env
com.couchbase.client.core.env.resources - package com.couchbase.client.core.env.resources
com.couchbase.client.core.event - package com.couchbase.client.core.event
com.couchbase.client.core.event.consumers - package com.couchbase.client.core.event.consumers
com.couchbase.client.core.event.metrics - package com.couchbase.client.core.event.metrics
com.couchbase.client.core.event.system - package com.couchbase.client.core.event.system
com.couchbase.client.core.lang - package com.couchbase.client.core.lang
com.couchbase.client.core.logging - package com.couchbase.client.core.logging
com.couchbase.client.core.message - package com.couchbase.client.core.message
com.couchbase.client.core.message.cluster - package com.couchbase.client.core.message.cluster
com.couchbase.client.core.message.config - package com.couchbase.client.core.message.config
com.couchbase.client.core.message.dcp - package com.couchbase.client.core.message.dcp
com.couchbase.client.core.message.internal - package com.couchbase.client.core.message.internal
com.couchbase.client.core.message.kv - package com.couchbase.client.core.message.kv
com.couchbase.client.core.message.kv.subdoc - package com.couchbase.client.core.message.kv.subdoc
com.couchbase.client.core.message.kv.subdoc.multi - package com.couchbase.client.core.message.kv.subdoc.multi
com.couchbase.client.core.message.kv.subdoc.simple - package com.couchbase.client.core.message.kv.subdoc.simple
com.couchbase.client.core.message.observe - package com.couchbase.client.core.message.observe
com.couchbase.client.core.message.query - package com.couchbase.client.core.message.query
com.couchbase.client.core.message.search - package com.couchbase.client.core.message.search
com.couchbase.client.core.message.stat - package com.couchbase.client.core.message.stat
com.couchbase.client.core.message.view - package com.couchbase.client.core.message.view
com.couchbase.client.core.metrics - package com.couchbase.client.core.metrics
com.couchbase.client.core.node - package com.couchbase.client.core.node
com.couchbase.client.core.node.locate - package com.couchbase.client.core.node.locate
com.couchbase.client.core.retry - package com.couchbase.client.core.retry
com.couchbase.client.core.security.sasl - package com.couchbase.client.core.security.sasl
com.couchbase.client.core.service - package com.couchbase.client.core.service
com.couchbase.client.core.service.strategies - package com.couchbase.client.core.service.strategies
com.couchbase.client.core.state - package com.couchbase.client.core.state
com.couchbase.client.core.time - package com.couchbase.client.core.time
com.couchbase.client.core.utils - package com.couchbase.client.core.utils
com.couchbase.client.deps.io.netty.handler.codec.memcache - package com.couchbase.client.deps.io.netty.handler.codec.memcache: Common superset of ascii and binary classes.
com.couchbase.client.deps.io.netty.handler.codec.memcache.binary - package com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: Implementations and Interfaces for the Memcache Binary protocol.
commands() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMultiLookupRequest
commands() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMultiMutationRequest
commands() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiLookupRequest
commands() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationRequest
CommonsLoggerFactory - Class in com.couchbase.client.core.logging: Logger factory which creates an Apache Commons Logging logger.
CommonsLoggerFactory() - Constructor for class com.couchbase.client.core.logging.CommonsLoggerFactory
compareTo(LatencyMetricsIdentifier) - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
COMPUTATION_POOL_SIZE - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
computationPoolSize() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the pool size (number of threads) for all computation tasks.
computationPoolSize(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the pool size (number of threads to use) for all non blocking operations in the core and clients (default value is the number of CPUs).
computationPoolSize() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
config() - Method in interface com.couchbase.client.core.config.ConfigurationProvider: Returns the current config or null if not set.
config() - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
config() - Method in class com.couchbase.client.core.message.cluster.GetClusterConfigResponse
config() - Method in class com.couchbase.client.core.message.config.BucketConfigResponse
config() - Method in class com.couchbase.client.core.message.config.BucketsConfigResponse
config() - Method in class com.couchbase.client.core.message.config.ClusterConfigResponse
config() - Method in class com.couchbase.client.core.message.config.InsertBucketResponse
config() - Method in class com.couchbase.client.core.message.config.UpdateBucketResponse
config() - Method in class com.couchbase.client.core.metrics.AbstractLatencyMetricsCollector
config() - Method in class com.couchbase.client.core.metrics.AbstractMetricsCollector
config() - Method in interface com.couchbase.client.core.metrics.LatencyMetricsCollector
config() - Method in interface com.couchbase.client.core.metrics.MetricsCollector: Its high-level configuration.
ConfigEndpoint - Class in com.couchbase.client.core.endpoint.config
ConfigEndpoint(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.endpoint.config.ConfigEndpoint
ConfigHandler - Class in com.couchbase.client.core.endpoint.config: The ConfigHandler is responsible for encoding ConfigRequests into lower level HttpRequests as well as decoding HttpObjects into CouchbaseResponses.
ConfigHandler(AbstractEndpoint, EventSink<ResponseEvent>, boolean) - Constructor for class com.couchbase.client.core.endpoint.config.ConfigHandler: Creates a new ConfigHandler with the default queue for requests.
ConfigLocator - Class in com.couchbase.client.core.node.locate
ConfigLocator() - Constructor for class com.couchbase.client.core.node.locate.ConfigLocator
ConfigRequest - Interface in com.couchbase.client.core.message.config: Common marker interface for all ConfigRequests.
configs() - Method in interface com.couchbase.client.core.config.ConfigurationProvider: Returns an Observable, which pushes a new ClusterConfig once available.
configs() - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
configs() - Method in class com.couchbase.client.core.config.refresher.AbstractRefresher
configs() - Method in interface com.couchbase.client.core.config.refresher.Refresher: Returns the Observable which will push out new configuration updates.
configs() - Method in class com.couchbase.client.core.message.config.BucketStreamingResponse
ConfigService - Class in com.couchbase.client.core.service
ConfigService(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.service.ConfigService
ConfigUpdatedEvent - Class in com.couchbase.client.core.event.system: Event published when a new bucket config is applied to the core.
ConfigUpdatedEvent(ClusterConfig) - Constructor for class com.couchbase.client.core.event.system.ConfigUpdatedEvent
ConfigurationException - Exception in com.couchbase.client.core.config
ConfigurationException() - Constructor for exception com.couchbase.client.core.config.ConfigurationException
ConfigurationException(String) - Constructor for exception com.couchbase.client.core.config.ConfigurationException
ConfigurationException(String, Throwable) - Constructor for exception com.couchbase.client.core.config.ConfigurationException
ConfigurationException(Throwable) - Constructor for exception com.couchbase.client.core.config.ConfigurationException
ConfigurationProvider - Interface in com.couchbase.client.core.config
connect() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
connect(boolean) - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint: An internal alternative to AbstractEndpoint.connect() where signalling that this is post-bootstrapping can be done.
connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
connect() - Method in class com.couchbase.client.core.endpoint.BootstrapAdapter: Connect the underlying Bootstrap and return a ChannelFuture.
connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler
connect() - Method in interface com.couchbase.client.core.endpoint.Endpoint: Connect the Endpoint to the underlying channel.
connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
connect() - Method in class com.couchbase.client.core.node.CouchbaseNode
connect() - Method in interface com.couchbase.client.core.node.Node: Connects all currently enabled Services.
connect() - Method in class com.couchbase.client.core.service.AbstractDynamicService
connect() - Method in interface com.couchbase.client.core.service.Service: Connects all currently enabled Service Endpoints.
connection() - Method in class com.couchbase.client.core.message.dcp.OpenConnectionResponse
connection() - Method in class com.couchbase.client.core.message.dcp.StreamRequestRequest
connectionName() - Method in class com.couchbase.client.core.message.dcp.OpenConnectionRequest
ConnectionType - Enum in com.couchbase.client.core.message.dcp: Type of DCP connection.
consumed(DCPMessage) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnection
content() - Method in class com.couchbase.client.core.message.config.FlushResponse
content() - Method in class com.couchbase.client.core.message.config.GetDesignDocumentsResponse
content() - Method in class com.couchbase.client.core.message.dcp.MutationMessage
content() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
content() - Method in class com.couchbase.client.core.message.kv.AppendRequest
content() - Method in interface com.couchbase.client.core.message.kv.BinaryResponse: Contains the content of the response, potentially null or empty.
content() - Method in interface com.couchbase.client.core.message.kv.BinaryStoreRequest
content() - Method in class com.couchbase.client.core.message.kv.InsertRequest: The content of the document.
content() - Method in class com.couchbase.client.core.message.kv.PrependRequest
content() - Method in class com.couchbase.client.core.message.kv.ReplaceRequest: The content of the document.
content() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMultiLookupRequest: The ByteBuf representing the whole list of BinarySubdocMultiLookupRequest.commands().
content() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMultiMutationRequest: The ByteBuf representing the whole list of BinarySubdocMultiMutationRequest.commands().
content() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocRequest: The ByteBuf bearing the full content for this request.
content() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiLookupRequest
content() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationRequest
content() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest
content() - Method in class com.couchbase.client.core.message.kv.UpsertRequest: The content of the document.
content() - Method in class com.couchbase.client.core.message.view.GetDesignDocumentResponse
content() - Method in class com.couchbase.client.core.message.view.RemoveDesignDocumentResponse
content() - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentResponse
content() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest
content() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse
content() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent
ControlParameter - Enum in com.couchbase.client.core.message.dcp
copy() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest
copy() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse
copy() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.FullBinaryMemcacheRequest
copy() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.FullBinaryMemcacheResponse
copy() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultLastMemcacheContent
copy() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent
copy() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.FullMemcacheMessage
copy() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.LastMemcacheContent
copy() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.MemcacheContent
CORE_GIT_VERSION - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
CORE_VERSION - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
coreBuild() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns build information on the Couchbase Java SDK core.
coreBuild() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
CoreEnvironment - Interface in com.couchbase.client.core.env: A CoreEnvironment provides all the core building blocks like environment settings and thread pools so that the application can work with it properly.
CoreScheduler - Class in com.couchbase.client.core.env: The Core scheduler which is modeled after the Event Loops Scheduler (which is package private).
CoreScheduler(int) - Constructor for class com.couchbase.client.core.env.CoreScheduler: Create a scheduler with specified pool size and using least-recent worker selection policy.
coreVersion() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns version information on the core.
coreVersion() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
CouchbaseBucketConfig - Interface in com.couchbase.client.core.config: A configuration representing the couchbase bucket.
CouchbaseCore - Class in com.couchbase.client.core: The general implementation of a ClusterFacade.
CouchbaseCore() - Constructor for class com.couchbase.client.core.CouchbaseCore: Creates a new CouchbaseCore.
CouchbaseCore(CoreEnvironment) - Constructor for class com.couchbase.client.core.CouchbaseCore: Creates a new CouchbaseCore.
CouchbaseEvent - Interface in com.couchbase.client.core.event: Defines the generic couchbase event pushed through the event bus.
CouchbaseException - Exception in com.couchbase.client.core: Common parent exception to build a proper exception hierachy inside the driver.
CouchbaseException() - Constructor for exception com.couchbase.client.core.CouchbaseException
CouchbaseException(String) - Constructor for exception com.couchbase.client.core.CouchbaseException
CouchbaseException(String, Throwable) - Constructor for exception com.couchbase.client.core.CouchbaseException
CouchbaseException(Throwable) - Constructor for exception com.couchbase.client.core.CouchbaseException
CouchbaseLogger - Interface in com.couchbase.client.core.logging: Internal-use-only logger used by the SDK.
CouchbaseLoggerFactory - Class in com.couchbase.client.core.logging: Creates an CouchbaseLogger or changes the default factory implementation.
CouchbaseLoggerFactory() - Constructor for class com.couchbase.client.core.logging.CouchbaseLoggerFactory
CouchbaseLogLevel - Enum in com.couchbase.client.core.logging: The log level that CouchbaseLogger can log at.
CouchbaseMessage - Interface in com.couchbase.client.core.message
CouchbaseNode - Class in com.couchbase.client.core.node: The general implementation of a Node.
CouchbaseNode(InetAddress, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.node.CouchbaseNode
CouchbasePartitionInfo - Class in com.couchbase.client.core.config: Represents the partition information for a bucket.
CouchbaseRequest - Interface in com.couchbase.client.core.message: High-Level marker interface for all CouchbaseRequests.
CouchbaseResponse - Interface in com.couchbase.client.core.message
count() - Method in class com.couchbase.client.core.event.metrics.LatencyMetric: The number of latency entries recorded in the interval.
CounterRequest - Class in com.couchbase.client.core.message.kv: Request to handle increment/decrement of a counter.
CounterRequest(String, long, long, int, String) - Constructor for class com.couchbase.client.core.message.kv.CounterRequest
CounterResponse - Class in com.couchbase.client.core.message.kv
CounterResponse(ResponseStatus, short, String, long, long, MutationToken, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.CounterResponse
create() - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
create() - Static method in class com.couchbase.client.core.event.consumers.LoggingConsumer
create(CouchbaseLogLevel, LoggingConsumer.OutputFormat) - Static method in class com.couchbase.client.core.event.consumers.LoggingConsumer
create(T1, T2) - Static method in class com.couchbase.client.core.lang.Tuple: Creates a tuple with two values.
create(T1, T2, T3) - Static method in class com.couchbase.client.core.lang.Tuple: Creates a tuple with three values.
create(T1, T2, T3, T4) - Static method in class com.couchbase.client.core.lang.Tuple: Creates a tuple with four values.
create(T1, T2, T3, T4, T5) - Static method in class com.couchbase.client.core.lang.Tuple: Creates a tuple with five values.
create(short, ResponseStatus, String, Lookup, ByteBuf) - Static method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
create(short, ResponseStatus, String, Mutation, ByteBuf) - Static method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
create() - Static method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
create(long, TimeUnit) - Static method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
create() - Static method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
create(long, TimeUnit) - Static method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
create(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Method in interface com.couchbase.client.core.service.Service.EndpointFactory: Create a new Endpoint.
create(String, String, String, int, CoreEnvironment, ServiceType, RingBuffer<ResponseEvent>) - Static method in class com.couchbase.client.core.service.ServiceFactory
create(long, TimeUnit) - Static method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
create(long, TimeUnit, Action0) - Static method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
create(long, TimeUnit, Scheduler) - Static method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
create(long, TimeUnit, Scheduler, Action0) - Static method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
createContent(ByteBuf, ByteBuf...) - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest
createEndpoint() - Method in class com.couchbase.client.core.service.AbstractDynamicService: Helper method to create a new endpoint.
createIntermediaryPath() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMutationRequest: Sets whether missing nodes in the BinarySubdocRequest.path() should be created as part of this mutation, when possible.
createIntermediaryPath() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
createIntermediaryPath() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
createIntermediaryPath(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest: Modifies the request so that it requires the creation of missing intermediary nodes in the path if set to true.
createKeepAliveRequest() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Override to return a non-null request to be fired in the pipeline in case a keep alive is triggered.
createKeepAliveRequest() - Method in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
createKeepAliveRequest() - Method in class com.couchbase.client.core.endpoint.query.QueryHandler
createKeepAliveRequest() - Method in class com.couchbase.client.core.endpoint.view.ViewHandler
createSaslClient(String[], String, String, String, Map<String, ?>, CallbackHandler) - Static method in class com.couchbase.client.core.security.sasl.Sasl: Creates a new SaslClient and first tries the JVM built in clients before falling back to our custom implementations.
createSaslClient(String[], String, String, String, Map<String, ?>, CallbackHandler) - Method in class com.couchbase.client.core.security.sasl.ShaSaslClientFactory
createWithoutNoSubscriptionTimeout(Action0) - Static method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject: Creates a new UnicastAutoReleaseSubject without a no subscription timeout.
createWithoutNoSubscriptionTimeout() - Static method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject: Creates a new UnicastAutoReleaseSubject without a no subscription timeout.
createWorker() - Method in class com.couchbase.client.core.env.CoreScheduler
creationTime() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
creationTime() - Method in class com.couchbase.client.core.message.AbstractCouchbaseResponse
creationTime() - Method in interface com.couchbase.client.core.message.CouchbaseMessage: Returns the time in nanoseconds when the message was created.
ctx - Variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator: Holds the current channel handler context if set.
currentMessage - Variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator: Contains the current message that gets aggregated.
currentRequest() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Returns the current request if set.
currentRequest(REQUEST) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Sets current request.
currentSeqNo() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
currentSeqNo() - Method in class com.couchbase.client.core.message.kv.NoFailoverObserveSeqnoResponse
currentStates() - Method in class com.couchbase.client.core.state.AbstractStateZipper: Helper method to export the current internal states.
currentSubscriptions() - Method in class com.couchbase.client.core.state.AbstractStateZipper: Helper method to export the current internal subscriptions.
customEndpointHandlers(ChannelPipeline) - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint: Add custom endpoint handlers to the ChannelPipeline.
customEndpointHandlers(ChannelPipeline) - Method in class com.couchbase.client.core.endpoint.config.ConfigEndpoint
customEndpointHandlers(ChannelPipeline) - Method in class com.couchbase.client.core.endpoint.dcp.DCPEndpoint
customEndpointHandlers(ChannelPipeline) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueEndpoint
customEndpointHandlers(ChannelPipeline) - Method in class com.couchbase.client.core.endpoint.query.QueryEndpoint
customEndpointHandlers(ChannelPipeline) - Method in class com.couchbase.client.core.endpoint.search.SearchEndpoint
customEndpointHandlers(ChannelPipeline) - Method in class com.couchbase.client.core.endpoint.view.ViewEndpoint

D

DCP_CONNECTION_BUFFER_ACK_THRESHOLD - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
DCP_CONNECTION_BUFFER_SIZE - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
DCP_CONNECTION_NAME - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
DCP_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
DCPConnection - Class in com.couchbase.client.core.endpoint.dcp: DCP connection used to subscribe to DCP streams.
DCPConnection(CoreEnvironment, ClusterFacade, String, String) - Constructor for class com.couchbase.client.core.endpoint.dcp.DCPConnection
DCPConnection(CoreEnvironment, ClusterFacade, String, String, SerializedSubject<DCPRequest, DCPRequest>) - Constructor for class com.couchbase.client.core.endpoint.dcp.DCPConnection
dcpConnectionBufferAckThreshold() - Method in interface com.couchbase.client.core.env.CoreEnvironment: When a DCP connection read bytes reaches this percentage of the CoreEnvironment.dcpConnectionBufferSize(), a DCP Buffer Acknowledge message is sent to the server
dcpConnectionBufferAckThreshold(double) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: When a DCP connection read bytes reaches this percentage of the DefaultCoreEnvironment.Builder.dcpConnectionBufferSize, a DCP Buffer Acknowledge message is sent to the server to signal producer how much data has been processed.
dcpConnectionBufferAckThreshold() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
dcpConnectionBufferSize() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Size of the buffer to control speed of DCP producer.
dcpConnectionBufferSize(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the size of the buffer to control speed of DCP producer.
dcpConnectionBufferSize() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
DCPConnectionHandler - Class in com.couchbase.client.core.endpoint.dcp: DCP connection handler makes sure that all channels have DCP connection initialized.
DCPConnectionHandler(CoreEnvironment) - Constructor for class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler: Creates a new DCPConnectionHandler.
dcpConnectionName() - Method in interface com.couchbase.client.core.env.CoreEnvironment
dcpConnectionName(String) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets default name for DCP connection.
dcpConnectionName() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
dcpEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Identifies if DCP should be enabled.
dcpEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Set if DCP should be enabled (only makes sense with server versions >= 3.0.0, default ).
dcpEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
DCPEndpoint - Class in com.couchbase.client.core.endpoint.dcp: This endpoint defines the pipeline for DCP requests and responses.
DCPEndpoint(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.endpoint.dcp.DCPEndpoint
DCPHandler - Class in com.couchbase.client.core.endpoint.dcp
DCPHandler(AbstractEndpoint, EventSink<ResponseEvent>, boolean) - Constructor for class com.couchbase.client.core.endpoint.dcp.DCPHandler: Creates a new DCPHandler with the default queue for requests.
DCPHandler(AbstractEndpoint, EventSink<ResponseEvent>, Queue<DCPRequest>, boolean) - Constructor for class com.couchbase.client.core.endpoint.dcp.DCPHandler: Creates a new DCPHandler with a custom queue for requests (suitable for tests).
DCPLocator - Class in com.couchbase.client.core.node.locate: This Locator finds the proper Nodes for every incoming DCPRequest.
DCPLocator() - Constructor for class com.couchbase.client.core.node.locate.DCPLocator
DCPMessage - Interface in com.couchbase.client.core.message.dcp
DCPRequest - Interface in com.couchbase.client.core.message.dcp: Common interface for all DCP requests.
DCPResponse - Interface in com.couchbase.client.core.message.dcp: Common interface for all DCP responses.
DCPService - Class in com.couchbase.client.core.service
DCPService(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.service.DCPService
debug(Throwable) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
debug(String) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the DEBUG level.
debug(String, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the DEBUG level according to the specified format and argument.
debug(String, Object, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the DEBUG level according to the specified format and arguments.
debug(String, Object...) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the DEBUG level according to the specified format and arguments.
debug(String, Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the DEBUG level with an accompanying message.
debug(Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the DEBUG level.
decode(ChannelHandlerContext, RESPONSE, List<Object>) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
decode(String) - Static method in class com.couchbase.client.core.utils.Base64: Decode a Base64 encoded string
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheDecoder
decode(ChannelHandlerContext, MemcacheObject, List<Object>) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheObjectAggregator
decodeHeader(ByteBuf) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheDecoder: Decode and return the parsed BinaryMemcacheMessage.
decodeHeader(ByteBuf) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheRequestDecoder
decodeHeader(ByteBuf) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseDecoder
decodeResponse(ChannelHandlerContext, RESPONSE) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Decodes the incoming response and transforms it into a CouchbaseResponse.
decodeResponse(ChannelHandlerContext, HttpObject) - Method in class com.couchbase.client.core.endpoint.config.ConfigHandler
decodeResponse(ChannelHandlerContext, FullBinaryMemcacheResponse) - Method in class com.couchbase.client.core.endpoint.dcp.DCPHandler
decodeResponse(ChannelHandlerContext, FullBinaryMemcacheResponse) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
decodeResponse(ChannelHandlerContext, HttpObject) - Method in class com.couchbase.client.core.endpoint.query.QueryHandler
decodeResponse(ChannelHandlerContext, HttpObject) - Method in class com.couchbase.client.core.endpoint.search.SearchHandler
decodeResponse(ChannelHandlerContext, HttpObject) - Method in class com.couchbase.client.core.endpoint.view.ViewHandler
DecodingState - Enum in com.couchbase.client.core.endpoint: Describes the states of the decoding process.
DECREMENT - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
DECREMENTQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
DEFAULT_FORMAT - Static variable in class com.couchbase.client.core.event.consumers.LoggingConsumer
DEFAULT_MAX_CHUNK_SIZE - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheDecoder
DEFAULT_MAX_COMPOSITEBUFFER_COMPONENTS - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator
DEFAULT_PARTITION - Static variable in class com.couchbase.client.core.message.dcp.AbstractDCPRequest
DEFAULT_PARTITION - Static variable in class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
DefaultBinaryMemcacheRequest - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: The default implementation of the BinaryMemcacheRequest.
DefaultBinaryMemcacheRequest() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest: Create a new DefaultBinaryMemcacheRequest with the header only.
DefaultBinaryMemcacheRequest(byte[]) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest: Create a new DefaultBinaryMemcacheRequest with the header and key.
DefaultBinaryMemcacheRequest(ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest: Create a new DefaultBinaryMemcacheRequest with the header and extras.
DefaultBinaryMemcacheRequest(byte[], ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest: Create a new DefaultBinaryMemcacheRequest with the header only.
DefaultBinaryMemcacheResponse - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: The default implementation of the BinaryMemcacheResponse.
DefaultBinaryMemcacheResponse() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheResponse: Create a new DefaultBinaryMemcacheResponse with the header only.
DefaultBinaryMemcacheResponse(byte[]) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheResponse: Create a new DefaultBinaryMemcacheResponse with the header and key.
DefaultBinaryMemcacheResponse(ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheResponse: Create a new DefaultBinaryMemcacheResponse with the header and extras.
DefaultBinaryMemcacheResponse(byte[], ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheResponse: Create a new DefaultBinaryMemcacheResponse with the header, key and extras.
DefaultClusterConfig - Class in com.couchbase.client.core.config: Default implementation of a ClusterConfig.
DefaultClusterConfig() - Constructor for class com.couchbase.client.core.config.DefaultClusterConfig: Creates a new DefaultClusterConfig.
DefaultConfigurationProvider - Class in com.couchbase.client.core.config: The default implementation of a ConfigurationProvider.
DefaultConfigurationProvider(ClusterFacade, CoreEnvironment) - Constructor for class com.couchbase.client.core.config.DefaultConfigurationProvider: Create a new DefaultConfigurationProvider.
DefaultConfigurationProvider(ClusterFacade, CoreEnvironment, List<Loader>, Map<LoaderType, Refresher>) - Constructor for class com.couchbase.client.core.config.DefaultConfigurationProvider: Create a new DefaultConfigurationProvider.
DefaultCoreEnvironment - Class in com.couchbase.client.core.env
DefaultCoreEnvironment(DefaultCoreEnvironment.Builder) - Constructor for class com.couchbase.client.core.env.DefaultCoreEnvironment
DefaultCoreEnvironment.Builder - Class in com.couchbase.client.core.env
DefaultCouchbaseBucketConfig - Class in com.couchbase.client.core.config
DefaultCouchbaseBucketConfig(long, String, String, String, CouchbasePartitionInfo, List<NodeInfo>, List<PortInfo>) - Constructor for class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig: Creates a new CouchbaseBucketConfig.
DefaultEventBus - Class in com.couchbase.client.core.event: The default event bus implementation.
DefaultEventBus(Scheduler) - Constructor for class com.couchbase.client.core.event.DefaultEventBus
DefaultFullBinaryMemcacheRequest - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: The default implementation of a FullBinaryMemcacheRequest.
DefaultFullBinaryMemcacheRequest(byte[], ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest: Create a new DefaultBinaryMemcacheRequest with the header, key and extras.
DefaultFullBinaryMemcacheRequest(byte[], ByteBuf, ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest: Create a new DefaultBinaryMemcacheRequest with the header, key, extras and content.
DefaultFullBinaryMemcacheResponse - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: The default implementation of a FullBinaryMemcacheResponse.
DefaultFullBinaryMemcacheResponse(byte[], ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse: Create a new DefaultFullBinaryMemcacheResponse with the header, key and extras.
DefaultFullBinaryMemcacheResponse(byte[], ByteBuf, ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse: Create a new DefaultFullBinaryMemcacheResponse with the header, key, extras and content.
DefaultLastMemcacheContent - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache: The default implementation for the LastMemcacheContent.
DefaultLastMemcacheContent() - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultLastMemcacheContent
DefaultLastMemcacheContent(ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultLastMemcacheContent
DefaultLatencyMetricsCollectorConfig - Class in com.couchbase.client.core.metrics: The default configuration for the latency metrics collectors.
DefaultLatencyMetricsCollectorConfig.Builder - Class in com.couchbase.client.core.metrics
DefaultMemcacheContent - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache: The default MemcacheContent implementation.
DefaultMemcacheContent(ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent: Creates a new instance with the specified content.
DefaultMemcachedBucketConfig - Class in com.couchbase.client.core.config
DefaultMemcachedBucketConfig(long, String, String, String, List<NodeInfo>, List<PortInfo>) - Constructor for class com.couchbase.client.core.config.DefaultMemcachedBucketConfig: Creates a new MemcachedBucketConfig.
DefaultMetricsCollectorConfig - Class in com.couchbase.client.core.metrics: The default implementation with a builder for the MetricsCollectorConfig.
DefaultMetricsCollectorConfig(DefaultMetricsCollectorConfig.Builder) - Constructor for class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
DefaultMetricsCollectorConfig.Builder - Class in com.couchbase.client.core.metrics
defaultMetricsLoggingConsumer(boolean, CouchbaseLogLevel, LoggingConsumer.OutputFormat) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
defaultMetricsLoggingConsumer(boolean, CouchbaseLogLevel) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
DefaultNodeInfo - Class in com.couchbase.client.core.config: Default implementation of NodeInfo.
DefaultNodeInfo(String, String, Map<String, Integer>) - Constructor for class com.couchbase.client.core.config.DefaultNodeInfo: Creates a new DefaultNodeInfo with no SSL services.
DefaultNodeInfo(InetAddress, Map<ServiceType, Integer>, Map<ServiceType, Integer>) - Constructor for class com.couchbase.client.core.config.DefaultNodeInfo: Creates a new DefaultNodeInfo with SSL services.
DefaultPartition - Class in com.couchbase.client.core.config
DefaultPartition(short, short[]) - Constructor for class com.couchbase.client.core.config.DefaultPartition: Creates a new DefaultPartition.
DefaultPortInfo - Class in com.couchbase.client.core.config
DefaultPortInfo(Map<String, Integer>, String) - Constructor for class com.couchbase.client.core.config.DefaultPortInfo: Creates a new DefaultPortInfo.
DefaultServiceRegistry - Class in com.couchbase.client.core.node: The default implementation of a ServiceRegistry.
DefaultServiceRegistry() - Constructor for class com.couchbase.client.core.node.DefaultServiceRegistry: Create a new DefaultServiceRegistry.
Delay - Class in com.couchbase.client.core.time: Parent class of Delays and provides factory methods to create them.
DELETE - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
deleteBucketConfig(String) - Method in interface com.couchbase.client.core.config.ClusterConfig
deleteBucketConfig(String) - Method in class com.couchbase.client.core.config.DefaultClusterConfig
DELETEQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
delta() - Method in class com.couchbase.client.core.message.kv.CounterRequest
DELTA_BADVAL - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
deregister(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler
deregister(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
deregister(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
deregister(T) - Method in class com.couchbase.client.core.state.AbstractStateZipper
deregister(T) - Method in interface com.couchbase.client.core.state.StateZipper: Deregisters a stream identified by the identifier from the state computation.
deregisterBucket(String) - Method in class com.couchbase.client.core.config.refresher.AbstractRefresher
deregisterBucket(String) - Method in interface com.couchbase.client.core.config.refresher.Refresher: De-registers a bucket from watching.
description() - Method in enum com.couchbase.client.core.endpoint.kv.KeyValueStatus
design() - Method in class com.couchbase.client.core.message.view.ViewQueryRequest
development() - Method in class com.couchbase.client.core.message.view.GetDesignDocumentRequest
development() - Method in class com.couchbase.client.core.message.view.GetDesignDocumentResponse
development() - Method in class com.couchbase.client.core.message.view.RemoveDesignDocumentRequest
development() - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentRequest
development() - Method in class com.couchbase.client.core.message.view.ViewQueryRequest
Diagnostics - Class in com.couchbase.client.core.env: Provides access to various metrics helpful for system diagnosis.
Diagnostics() - Constructor for class com.couchbase.client.core.env.Diagnostics
disabled() - Static method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
disabled() - Static method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
disconnect() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
disconnect(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler
disconnect() - Method in interface com.couchbase.client.core.endpoint.Endpoint: Disconnect the Endpoint from the underlying channel.
disconnect(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
disconnect(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
disconnect() - Method in class com.couchbase.client.core.node.CouchbaseNode
disconnect() - Method in interface com.couchbase.client.core.node.Node: Disconnects all currently enabled Services.
disconnect() - Method in class com.couchbase.client.core.service.AbstractDynamicService
disconnect() - Method in interface com.couchbase.client.core.service.Service: Disconnects all currently enabled Service Endpoints.
DISCONNECT_TIMEOUT - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
DisconnectRequest - Class in com.couchbase.client.core.message.cluster: Disconnects all open buckets.
DisconnectRequest() - Constructor for class com.couchbase.client.core.message.cluster.DisconnectRequest
DisconnectResponse - Class in com.couchbase.client.core.message.cluster: A response to a DisconnectRequest.
DisconnectResponse(ResponseStatus) - Constructor for class com.couchbase.client.core.message.cluster.DisconnectResponse
disconnectTimeout() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The default timeout for disconnect operations, set to DefaultCoreEnvironment.DISCONNECT_TIMEOUT.
disconnectTimeout(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets a custom disconnect timeout.
disconnectTimeout() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
discoverConfig(String, String, InetAddress) - Method in class com.couchbase.client.core.config.loader.AbstractLoader: Run the BucketConfig discovery process.
discoverConfig(String, String, InetAddress) - Method in class com.couchbase.client.core.config.loader.CarrierLoader
discoverConfig(String, String, InetAddress) - Method in class com.couchbase.client.core.config.loader.HttpLoader
DISK - Static variable in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
disk() - Method in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
dispatch(CouchbaseRequest) - Method in class com.couchbase.client.core.service.AbstractDynamicService
dispatch(CouchbaseRequest) - Method in class com.couchbase.client.core.service.AbstractLazyService
dispatch(CouchbaseRequest) - Method in class com.couchbase.client.core.service.AbstractOnDemandService
dispatch(CouchbaseRequest) - Method in class com.couchbase.client.core.service.AbstractPoolingService
dispose() - Method in class com.couchbase.client.core.security.sasl.ShaSaslClient
disposeIfNotSubscribed() - Method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject: This will eagerly dispose this Subject without waiting for the no subscription timeout period, if configured.
doConnect(Subject<LifecycleState, LifecycleState>, boolean) - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint: Helper method to perform the actual connect and reconnect.
DocumentConcurrentlyModifiedException - Exception in com.couchbase.client.core: Exception indicating that the document which is observed has been modified in the meantime.
DocumentConcurrentlyModifiedException() - Constructor for exception com.couchbase.client.core.DocumentConcurrentlyModifiedException
DocumentConcurrentlyModifiedException(String) - Constructor for exception com.couchbase.client.core.DocumentConcurrentlyModifiedException
DocumentConcurrentlyModifiedException(String, Throwable) - Constructor for exception com.couchbase.client.core.DocumentConcurrentlyModifiedException
DocumentConcurrentlyModifiedException(Throwable) - Constructor for exception com.couchbase.client.core.DocumentConcurrentlyModifiedException
DocumentMutationLostException - Exception in com.couchbase.client.core: The observed document was lost during a hard failover, because the document did not reach the replica in time.
DocumentMutationLostException() - Constructor for exception com.couchbase.client.core.DocumentMutationLostException
DocumentMutationLostException(String) - Constructor for exception com.couchbase.client.core.DocumentMutationLostException
DocumentMutationLostException(String, Throwable) - Constructor for exception com.couchbase.client.core.DocumentMutationLostException
DocumentMutationLostException(Throwable) - Constructor for exception com.couchbase.client.core.DocumentMutationLostException
doublePropertyOr(String, double) - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
dumpParameters(StringBuilder) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment: Dumps the environment parameters known to this implementation into a StringBuilder, which is returned for method chaining.
duplicate() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest
duplicate() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse
duplicate() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.FullBinaryMemcacheRequest
duplicate() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.FullBinaryMemcacheResponse
duplicate() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultLastMemcacheContent
duplicate() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent
duplicate() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.FullMemcacheMessage
duplicate() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.LastMemcacheContent
duplicate() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.MemcacheContent

E

E2BIG - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
EINVAL - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
EMIT_FREQUENCY - Static variable in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
EMIT_FREQUENCY_UNIT - Static variable in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
emitFrequency(long) - Method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig.Builder
emitFrequency(long) - Method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig.Builder: Overrides the default emit frequency for this metric collector.
emitFrequency() - Method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
emitFrequency() - Method in interface com.couchbase.client.core.metrics.MetricsCollectorConfig: The interval frequency when to emit the metrics.
emitFrequencyUnit(TimeUnit) - Method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig.Builder
emitFrequencyUnit(TimeUnit) - Method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig.Builder: Overrides the default emit frequency unit for this metric collector.
emitFrequencyUnit() - Method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
emitFrequencyUnit() - Method in interface com.couchbase.client.core.metrics.MetricsCollectorConfig: The time unit for the emit frequency.
EMPTY_BYTES - Static variable in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Empty bytes to reuse.
EMPTY_LAST_CONTENT - Static variable in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.LastMemcacheContent
encode(ChannelHandlerContext, REQUEST, List<Object>) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
encode(byte[]) - Static method in class com.couchbase.client.core.utils.Base64: Base64 encode a textual string according to RFC 3548
encode(ChannelHandlerContext, Object, List<Object>) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectEncoder
encodeHeader(ByteBuf, M) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheEncoder: Encode the header.
encodeHeader(ByteBuf, BinaryMemcacheRequest) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheRequestEncoder
encodeHeader(ByteBuf, BinaryMemcacheResponse) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseEncoder
encodeMessage(ChannelHandlerContext, M) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectEncoder: Take the given MemcacheMessage and encode it into a writable ByteBuf.
encodeMessage(ChannelHandlerContext, M) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheEncoder
encodeRequest(ChannelHandlerContext, REQUEST) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Encode the outgoing request and return it in encoded format.
encodeRequest(ChannelHandlerContext, ConfigRequest) - Method in class com.couchbase.client.core.endpoint.config.ConfigHandler
encodeRequest(ChannelHandlerContext, DCPRequest) - Method in class com.couchbase.client.core.endpoint.dcp.DCPHandler
encodeRequest(ChannelHandlerContext, BinaryRequest) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
encodeRequest(ChannelHandlerContext, QueryRequest) - Method in class com.couchbase.client.core.endpoint.query.QueryHandler
encodeRequest(ChannelHandlerContext, SearchRequest) - Method in class com.couchbase.client.core.endpoint.search.SearchHandler
encodeRequest(ChannelHandlerContext, ViewRequest) - Method in class com.couchbase.client.core.endpoint.view.ViewHandler
endpoint() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: The parent endpoint.
Endpoint - Interface in com.couchbase.client.core.endpoint: Represents a stateful Endpoint which abstracts the underlying channel.
endpoints() - Method in class com.couchbase.client.core.service.AbstractDynamicService: Returns the current list of endpoints.
endpointStates() - Method in class com.couchbase.client.core.service.AbstractDynamicService: Returns the underlying endpoint state zipper.
EndpointStateZipper - Class in com.couchbase.client.core.service: Calculates a merged state for all registered endpoints.
EndpointStateZipper(LifecycleState) - Constructor for class com.couchbase.client.core.service.EndpointStateZipper
endSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
endSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.StreamRequestRequest
ENOMEM - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
env() - Method in class com.couchbase.client.core.config.loader.AbstractLoader: Returns the CoreEnvironment for child implementations.
env() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Returns environment.
environment() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint: The CoreEnvironment reference.
EnvironmentException - Exception in com.couchbase.client.core.env
EnvironmentException(String) - Constructor for exception com.couchbase.client.core.env.EnvironmentException
EnvironmentException(String, Throwable) - Constructor for exception com.couchbase.client.core.env.EnvironmentException
equals(Object) - Method in class com.couchbase.client.core.message.kv.MutationToken
equals(Object) - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
equals(Object) - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
equals(Object) - Method in class com.couchbase.client.core.node.CouchbaseNode
error(Throwable) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
error(String) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the ERROR level.
error(String, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the ERROR level according to the specified format and argument.
error(String, Object, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the ERROR level according to the specified format and arguments.
error(String, Object...) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the ERROR level according to the specified format and arguments.
error(String, Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the ERROR level with an accompanying message.
error(Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the ERROR level.
error() - Method in class com.couchbase.client.core.message.view.ViewQueryResponse
errors() - Method in class com.couchbase.client.core.message.query.GenericQueryResponse: If there were errors and/or warnings while executing the query, contains a ByteBuf for each error and each warning.
evaluateChallenge(byte[]) - Method in class com.couchbase.client.core.security.sasl.ShaSaslClient
eventBus() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the event bus where events are broadcasted on and can be published to.
eventBus(EventBus) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the event bus to an alternative implementation.
eventBus() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
EventBus - Interface in com.couchbase.client.core.event: Defines the interface for a generic event bus.
Events - Class in com.couchbase.client.core.utils: Utility methods for event handling.
Events() - Constructor for class com.couchbase.client.core.utils.Events
EventType - Enum in com.couchbase.client.core.event: Different event types available.
EXCEPTION_EMPTY_PATH - Static variable in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest: An IllegalArgumentException that is thrown by constructors when a empty path is provided on an operation that doesn’t allow them.
EXCEPTION_NULL_PATH - Static variable in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest: A NullPointerException that is thrown by constructors when a null path is provided.
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
expiration() - Method in class com.couchbase.client.core.message.dcp.MutationMessage
expiration() - Method in interface com.couchbase.client.core.message.kv.BinaryStoreRequest
expiration() - Method in class com.couchbase.client.core.message.kv.InsertRequest: Returns the expiration time for this document.
expiration() - Method in class com.couchbase.client.core.message.kv.ReplaceRequest: Returns the expiration time for this document.
expiration() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMultiMutationRequest
expiration() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMutationRequest
expiration() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationRequest
expiration() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
expiration() - Method in class com.couchbase.client.core.message.kv.UpsertRequest: Returns the expiration time for this document.
ExpirationMessage - Class in com.couchbase.client.core.message.dcp: A message representing event that removes or expires a document.
ExpirationMessage(int, short, String, long, long, long, String) - Constructor for class com.couchbase.client.core.message.dcp.ExpirationMessage
ExpirationMessage(int, short, String, long, long, long, String, String) - Constructor for class com.couchbase.client.core.message.dcp.ExpirationMessage
expiry() - Method in class com.couchbase.client.core.message.kv.CounterRequest
expiry() - Method in class com.couchbase.client.core.message.kv.GetRequest
expiry() - Method in class com.couchbase.client.core.message.kv.TouchRequest
exponential(TimeUnit) - Static method in class com.couchbase.client.core.time.Delay: Creates a new ExponentialDelay with default boundaries and factor (1, 2, 4, 8, 16, 32…).
exponential(TimeUnit, long) - Static method in class com.couchbase.client.core.time.Delay: Creates a new ExponentialDelay with custom upper boundary and default factor (eg.
exponential(TimeUnit, long, long) - Static method in class com.couchbase.client.core.time.Delay: Creates a new ExponentialDelay with custom boundaries and default factor (eg.
exponential(TimeUnit, long, long, long) - Static method in class com.couchbase.client.core.time.Delay: Creates a new ExponentialDelay with custom boundaries and factor (eg.
exponential(TimeUnit, long, long, long, int) - Static method in class com.couchbase.client.core.time.Delay: Creates a new ExponentialDelay on a base different from powers of two, with custom boundaries and factor (eg.
ExponentialDelay - Class in com.couchbase.client.core.time: Delay which increases exponentially on every attempt.
export() - Method in class com.couchbase.client.core.event.metrics.LatencyMetric: Exports this object to a plain map structure which can be easily converted into other target formats.

F

FailFastRetryStrategy - Class in com.couchbase.client.core.retry: A RetryStrategy that will never retry and cancel right away.
failoverLog() - Method in class com.couchbase.client.core.message.dcp.GetFailoverLogResponse
failoverLog() - Method in class com.couchbase.client.core.message.dcp.StreamRequestResponse
FailoverLogEntry - Class in com.couchbase.client.core.message.dcp: Failover log entry.
FailoverLogEntry(long, long) - Constructor for class com.couchbase.client.core.message.dcp.FailoverLogEntry
FailoverObserveSeqnoResponse - Class in com.couchbase.client.core.message.kv: Represents a observe seqno response.
FailoverObserveSeqnoResponse(boolean, short, long, long, long, long, long, ResponseStatus, short, String, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
findNextChar(ByteBuf, char) - Static method in class com.couchbase.client.core.endpoint.util.ByteBufJsonHelper: Shorthand for ByteBuf.bytesBefore(byte) with a simple char c, finds the number of bytes until next occurrence of the character c from the current readerIndex() in buf.
findNextCharNotPrefixedBy(ByteBuf, char, char) - Static method in class com.couchbase.client.core.endpoint.util.ByteBufJsonHelper: Find the number of bytes until next occurrence of the character c from the current readerIndex in buf, with the twist that if this occurrence is prefixed by the prefix character, we try to find another occurrence.
findSectionClosingPosition(ByteBuf, char, char) - Static method in class com.couchbase.client.core.endpoint.util.ByteBufJsonHelper: Finds the position of the correct closing character, taking into account the fact that before the correct one, other sub section with same opening and closing characters can be encountered.
findSectionClosingPosition(ByteBuf, int, char, char) - Static method in class com.couchbase.client.core.endpoint.util.ByteBufJsonHelper: Finds the position of the correct closing character, taking into account the fact that before the correct one, other sub section with same opening and closing characters can be encountered.
findSplitPosition(ByteBuf, char) - Static method in class com.couchbase.client.core.endpoint.util.ByteBufJsonHelper: Finds the position of the split character, taking into account the fact that the character could be found escaped in strings (such occurrences are ignored).
finishedDecoding() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Notify that decoding is finished.
finishedDecoding() - Method in class com.couchbase.client.core.endpoint.config.ConfigHandler
firstErrorIndex() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse
firstErrorStatus() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse
fixed(long, TimeUnit) - Static method in class com.couchbase.client.core.time.Delay: Creates a new FixedDelay.
FixedDelay - Class in com.couchbase.client.core.time: Delay which is fixed for every attempt.
flags() - Method in enum com.couchbase.client.core.message.dcp.ConnectionType
flags() - Method in class com.couchbase.client.core.message.dcp.MutationMessage
flags() - Method in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
flags() - Method in enum com.couchbase.client.core.message.dcp.StreamEndMessage.Reason
flags() - Method in interface com.couchbase.client.core.message.kv.BinaryStoreRequest
flags() - Method in class com.couchbase.client.core.message.kv.GetResponse
flags() - Method in class com.couchbase.client.core.message.kv.InsertRequest: Returns the flags for this document.
flags() - Method in class com.couchbase.client.core.message.kv.ReplaceRequest: Returns the flags for this document.
flags() - Method in class com.couchbase.client.core.message.kv.UpsertRequest: Returns the flags for this document.
flush(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler
flush(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
flush(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
FLUSH - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
FLUSHQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
FlushRequest - Class in com.couchbase.client.core.message.config: Sends a flush command to the cluster.
FlushRequest(String, String) - Constructor for class com.couchbase.client.core.message.config.FlushRequest
FlushResponse - Class in com.couchbase.client.core.message.config
FlushResponse(boolean, String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.config.FlushResponse
forwardPartitions() - Method in class com.couchbase.client.core.config.CouchbasePartitionInfo
fragment() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMutationRequest: A ByteBuf containing the JSON fragment for the mutation.
fragment() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
fromBinary(short) - Static method in class com.couchbase.client.core.endpoint.ResponseStatusConverter: Convert the binary protocol status in a typesafe enum that can be acted upon later.
fromHttp(int) - Static method in class com.couchbase.client.core.endpoint.ResponseStatusConverter: Convert the http protocol status in a typesafe enum that can be acted upon later.
fromValue(short) - Static method in enum com.couchbase.client.core.endpoint.ServerFeatures
FullBinaryMemcacheRequest - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: A BinaryMemcacheRequest that also includes the content.
FullBinaryMemcacheResponse - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary: A BinaryMemcacheResponse that also includes the content.
FullMemcacheMessage - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache: Combines MemcacheMessage and LastMemcacheContent into one message.

G

GAT - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
GATK - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
GATKQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
GATQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
gcInfo(Map<String, Object>) - Static method in class com.couchbase.client.core.env.Diagnostics: Collects system information as delivered from the GarbageCollectorMXBean.
generateCouchbaseEvent() - Method in class com.couchbase.client.core.metrics.AbstractLatencyMetricsCollector
generateCouchbaseEvent() - Method in class com.couchbase.client.core.metrics.AbstractMetricsCollector: Generate the actual CouchbaseEvent to emit on every interval.
generateCouchbaseEvent() - Method in class com.couchbase.client.core.metrics.RuntimeMetricsCollector
generateLatencyMetricsEvent(Map<I, LatencyStats>) - Method in class com.couchbase.client.core.metrics.AbstractLatencyMetricsCollector
generateLatencyMetricsEvent(Map<NetworkLatencyMetricsIdentifier, LatencyStats>) - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsCollector
GenericQueryRequest - Class in com.couchbase.client.core.message.query: For the lack of a better name, a query request against a query server.
GenericQueryResponse - Class in com.couchbase.client.core.message.query: The base response for Query (N1QL) requests.
GenericQueryResponse(Observable<ByteBuf>, Observable<ByteBuf>, Observable<ByteBuf>, Observable<String>, Observable<ByteBuf>, CouchbaseRequest, ResponseStatus, String, String) - Constructor for class com.couchbase.client.core.message.query.GenericQueryResponse
get() - Method in class com.couchbase.client.core.endpoint.SSLEngineFactory: Returns a new SSLEngine constructed from the config settings.
get() - Method in class com.couchbase.client.core.event.DefaultEventBus
get() - Method in interface com.couchbase.client.core.event.EventBus: Subscribe to the event bus to retrieve CouchbaseEvents.
GET - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
GetAllMutationTokensRequest - Class in com.couchbase.client.core.message.kv: Get the current high sequence numbers one could initialize streams for all partitions that are located on the server, or use in ObserveViaMutationToken.
GetAllMutationTokensRequest(InetAddress, String) - Constructor for class com.couchbase.client.core.message.kv.GetAllMutationTokensRequest
GetAllMutationTokensRequest(GetAllMutationTokensRequest.PartitionState, InetAddress, String) - Constructor for class com.couchbase.client.core.message.kv.GetAllMutationTokensRequest
GetAllMutationTokensRequest.PartitionState - Enum in com.couchbase.client.core.message.kv
GetAllMutationTokensResponse - Class in com.couchbase.client.core.message.kv: Represents response to GetAllMutationTokensRequest.
GetAllMutationTokensResponse(MutationToken[], ResponseStatus, short, String, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.GetAllMutationTokensResponse
GetBucketConfigRequest - Class in com.couchbase.client.core.message.kv: Request which fetches a bucket configuration through carrier publication.
GetBucketConfigRequest(String, InetAddress) - Constructor for class com.couchbase.client.core.message.kv.GetBucketConfigRequest: Creates a new GetBucketConfigRequest.
GetBucketConfigResponse - Class in com.couchbase.client.core.message.kv: Represents a response with a bucket configuration.
GetBucketConfigResponse(ResponseStatus, short, String, ByteBuf, InetAddress) - Constructor for class com.couchbase.client.core.message.kv.GetBucketConfigResponse
getCAS() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getCAS() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Returns the CAS identifier.
GetClusterConfigRequest - Class in com.couchbase.client.core.message.cluster
GetClusterConfigRequest() - Constructor for class com.couchbase.client.core.message.cluster.GetClusterConfigRequest
GetClusterConfigResponse - Class in com.couchbase.client.core.message.cluster
GetClusterConfigResponse(ClusterConfig, ResponseStatus) - Constructor for class com.couchbase.client.core.message.cluster.GetClusterConfigResponse
GetConfigProviderRequest - Class in com.couchbase.client.core.message.internal: Request to fetch the configuration provider from the core.
GetConfigProviderRequest() - Constructor for class com.couchbase.client.core.message.internal.GetConfigProviderRequest
GetConfigProviderResponse - Class in com.couchbase.client.core.message.internal: Response to fetch the configuration provider from the core.
GetConfigProviderResponse(ConfigurationProvider) - Constructor for class com.couchbase.client.core.message.internal.GetConfigProviderResponse
getCurrentState() - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnection
getDataType() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getDataType() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Returns the data type of the message.
getDecoderResult() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObject
getDecoderResult() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.MemcacheObject: Returns the result of decoding this message.
getDefaultFactory() - Static method in class com.couchbase.client.core.logging.CouchbaseLoggerFactory: Returns the default factory.
GetDesignDocumentRequest - Class in com.couchbase.client.core.message.view
GetDesignDocumentRequest(String, boolean, String, String) - Constructor for class com.couchbase.client.core.message.view.GetDesignDocumentRequest
GetDesignDocumentResponse - Class in com.couchbase.client.core.message.view
GetDesignDocumentResponse(String, boolean, ByteBuf, ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.view.GetDesignDocumentResponse
GetDesignDocumentsRequest - Class in com.couchbase.client.core.message.config
GetDesignDocumentsRequest(String, String) - Constructor for class com.couchbase.client.core.message.config.GetDesignDocumentsRequest
GetDesignDocumentsResponse - Class in com.couchbase.client.core.message.config
GetDesignDocumentsResponse(String, ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.config.GetDesignDocumentsResponse
getExtras() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getExtras() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Returns a ByteBuf representation of the optional extras.
getExtrasLength() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getExtrasLength() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Return the extras length of the message.
GetFailoverLogRequest - Class in com.couchbase.client.core.message.dcp: Get the current failover logs for partition.
GetFailoverLogRequest(short, String) - Constructor for class com.couchbase.client.core.message.dcp.GetFailoverLogRequest
GetFailoverLogRequest(short, String, String) - Constructor for class com.couchbase.client.core.message.dcp.GetFailoverLogRequest
GetFailoverLogResponse - Class in com.couchbase.client.core.message.dcp
GetFailoverLogResponse(ResponseStatus, List<FailoverLogEntry>, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.dcp.GetFailoverLogResponse: Creates GetFailoverLogResponse.
getInstance(Class<?>) - Static method in class com.couchbase.client.core.logging.CouchbaseLoggerFactory: Creates a new logger instance with the name of the specified class.
getInstance(String) - Static method in class com.couchbase.client.core.logging.CouchbaseLoggerFactory: Creates a new logger instance with the specified name.
GETK - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
getKey() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getKey() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Returns the optional key of the document.
getKeyLength() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getKeyLength() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Returns the key length of the message.
GETKQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
GetLastCheckpointRequest - Class in com.couchbase.client.core.message.dcp: Returns the last checkpoint for a particular VBucket.
GetLastCheckpointRequest(short, String) - Constructor for class com.couchbase.client.core.message.dcp.GetLastCheckpointRequest
GetLastCheckpointRequest(short, String, String) - Constructor for class com.couchbase.client.core.message.dcp.GetLastCheckpointRequest
GetLastCheckpointResponse - Class in com.couchbase.client.core.message.dcp
GetLastCheckpointResponse(ResponseStatus, long, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.dcp.GetLastCheckpointResponse: Creates GetLastCheckpointResponse.
getMagic() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getMagic() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Returns the magic byte for the message.
getMaxContentLength() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator
getMaxCumulationBufferComponents() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator: Returns the maximum number of components in the cumulation buffer.
getMechanismName() - Method in class com.couchbase.client.core.security.sasl.ShaSaslClient
getMechanismNames(Map<String, ?>) - Method in class com.couchbase.client.core.security.sasl.ShaSaslClientFactory
getMessage() - Method in class com.couchbase.client.core.ResponseEvent: Get the response from the payload.
getNegotiatedProperty(String) - Method in class com.couchbase.client.core.security.sasl.ShaSaslClient
getObservable() - Method in class com.couchbase.client.core.ResponseEvent
getOpaque() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getOpaque() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Returns the opaque value.
getOpcode() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getOpcode() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Returns the opcode for the message.
GETQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
GetRequest - Class in com.couchbase.client.core.message.kv: Fetch a document from the cluster and return it if found.
GetRequest(String, String) - Constructor for class com.couchbase.client.core.message.kv.GetRequest
GetRequest(String, String, boolean, boolean, int) - Constructor for class com.couchbase.client.core.message.kv.GetRequest
getRequest() - Method in class com.couchbase.client.core.RequestEvent
getReserved() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheRequest: Returns the reserved field value.
getReserved() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest
GetResponse - Class in com.couchbase.client.core.message.kv: Represents a response to a GetRequest.
GetResponse(ResponseStatus, short, long, int, String, ByteBuf, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.GetResponse
GetSearchIndexRequest - Class in com.couchbase.client.core.message.search: Retrieves full text index definition.
GetSearchIndexRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.search.GetSearchIndexRequest
GetSearchIndexResponse - Class in com.couchbase.client.core.message.search: Carries full text index definition as a payload.
GetSearchIndexResponse(String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.search.GetSearchIndexResponse
getStatus() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponse: Returns the status of the response.
getStatus() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheResponse
getTotalBodyLength() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
getTotalBodyLength() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Returns the total body length.

H

handle(Callback[]) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler: Callback handler needed for the SaslClient which supplies username and password.
handlerAdded(ChannelHandlerContext) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.config.ConfigHandler
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.dcp.DCPHandler
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.query.QueryHandler
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.view.ViewHandler
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator
hasBucket(String) - Method in interface com.couchbase.client.core.config.ClusterConfig: True if there is a bucket config with the given name, false otherwise.
hasBucket(String) - Method in class com.couchbase.client.core.config.DefaultClusterConfig
hasFastForwardMap() - Method in interface com.couchbase.client.core.config.BucketConfig: If this config instance contains a fast forward map.
hasFastForwardMap() - Method in class com.couchbase.client.core.config.CouchbasePartitionInfo
hasFastForwardMap() - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
hasFastForwardMap() - Method in class com.couchbase.client.core.config.DefaultMemcachedBucketConfig
hashCode() - Method in class com.couchbase.client.core.message.kv.MutationToken
hashCode() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
hashCode() - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
hashCode() - Method in class com.couchbase.client.core.node.CouchbaseNode
hasInitialResponse() - Method in class com.couchbase.client.core.security.sasl.ShaSaslClient
hasObservers() - Method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
hasPrimaryPartitionsOnNode(InetAddress) - Method in interface com.couchbase.client.core.config.CouchbaseBucketConfig: Checks if the given hostname has active primary partitions assigned to it.
hasPrimaryPartitionsOnNode(InetAddress) - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
hasSubscribers() - Method in class com.couchbase.client.core.event.DefaultEventBus
hasSubscribers() - Method in interface com.couchbase.client.core.event.EventBus: Checks if the event bus has subscribers.
hasSubscribers() - Method in class com.couchbase.client.core.state.AbstractStateMachine
hasSubscribers() - Method in interface com.couchbase.client.core.state.Stateful: Returns true if there are subscribers observing the state stream.
host() - Method in class com.couchbase.client.core.event.system.NodeConnectedEvent: The host address of the connected node.
host() - Method in class com.couchbase.client.core.event.system.NodeDisconnectedEvent: The host address of the disconnected node.
host() - Method in class com.couchbase.client.core.message.config.BucketStreamingResponse
host() - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
hostname() - Method in class com.couchbase.client.core.config.DefaultNodeInfo
hostname() - Method in class com.couchbase.client.core.config.DefaultPortInfo
hostname() - Method in interface com.couchbase.client.core.config.NodeInfo: The inet address of the node.
hostname() - Method in interface com.couchbase.client.core.config.PortInfo
hostname() - Method in class com.couchbase.client.core.message.config.BucketConfigRequest
hostname() - Method in class com.couchbase.client.core.message.internal.AddNodeRequest
hostname() - Method in class com.couchbase.client.core.message.internal.AddNodeResponse
hostname() - Method in class com.couchbase.client.core.message.internal.AddServiceRequest
hostname() - Method in class com.couchbase.client.core.message.internal.AddServiceResponse
hostname() - Method in class com.couchbase.client.core.message.internal.RemoveNodeRequest
hostname() - Method in class com.couchbase.client.core.message.internal.RemoveServiceRequest
hostname() - Method in class com.couchbase.client.core.message.kv.GetAllMutationTokensRequest
hostname() - Method in class com.couchbase.client.core.message.kv.GetBucketConfigRequest: Returns the hostname of the node from where the config should be loaded.
hostname() - Method in class com.couchbase.client.core.message.kv.GetBucketConfigResponse
hostname() - Method in class com.couchbase.client.core.message.kv.StatRequest
hostname() - Method in class com.couchbase.client.core.message.kv.StatResponse
hostname() - Method in class com.couchbase.client.core.node.CouchbaseNode
hostname() - Method in interface com.couchbase.client.core.node.Node: Returns the configured hostname for the Node.
HTTP_ACCEPTED - Static variable in class com.couchbase.client.core.endpoint.ResponseStatusConverter
HTTP_BAD_REQUEST - Static variable in class com.couchbase.client.core.endpoint.ResponseStatusConverter
HTTP_CREATED - Static variable in class com.couchbase.client.core.endpoint.ResponseStatusConverter
HTTP_INTERNAL_ERROR - Static variable in class com.couchbase.client.core.endpoint.ResponseStatusConverter
HTTP_NOT_FOUND - Static variable in class com.couchbase.client.core.endpoint.ResponseStatusConverter
HTTP_OK - Static variable in class com.couchbase.client.core.endpoint.ResponseStatusConverter
HttpLoader - Class in com.couchbase.client.core.config.loader: Loads a raw bucket configuration through the Couchbase Server HTTP config interface.
HttpLoader(ClusterFacade, CoreEnvironment) - Constructor for class com.couchbase.client.core.config.loader.HttpLoader: Creates a new HttpLoader.
HttpRefresher - Class in com.couchbase.client.core.config.refresher: Keeps the bucket config fresh through a HTTP streaming connection.
HttpRefresher(ClusterFacade) - Constructor for class com.couchbase.client.core.config.refresher.HttpRefresher

I

identityMap(CouchbaseEvent) - Static method in class com.couchbase.client.core.utils.Events: Takes a CouchbaseEvent and returns a map with event information.
INCREMENT - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
INCREMENTQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
incrementRetryCount() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
incrementRetryCount() - Method in interface com.couchbase.client.core.message.CouchbaseRequest: Returns the old retry count and increments it by one.
info(Throwable) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
info(String) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the INFO level.
info(String, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the INFO level according to the specified format and argument.
info(String, Object, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the INFO level according to the specified format and arguments.
info(String, Object...) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the INFO level according to the specified format and arguments.
info(String, Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the INFO level with an accompanying message.
info(Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the INFO level.
info() - Method in class com.couchbase.client.core.message.query.GenericQueryResponse: Contains a single ByteBuf representing the JSON object of query execution metrics (or empty if metrics haven’t been activated).
info() - Method in class com.couchbase.client.core.message.view.ViewQueryResponse
initial() - Method in class com.couchbase.client.core.message.kv.CounterRequest
InsertBucketRequest - Class in com.couchbase.client.core.message.config
InsertBucketRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.config.InsertBucketRequest
InsertBucketResponse - Class in com.couchbase.client.core.message.config
InsertBucketResponse(String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.config.InsertBucketResponse
InsertRequest - Class in com.couchbase.client.core.message.kv: Insert a document.
InsertRequest(String, ByteBuf, String) - Constructor for class com.couchbase.client.core.message.kv.InsertRequest: Creates a new InsertRequest.
InsertRequest(String, ByteBuf, String, boolean) - Constructor for class com.couchbase.client.core.message.kv.InsertRequest
InsertRequest(String, ByteBuf, int, int, String, boolean) - Constructor for class com.couchbase.client.core.message.kv.InsertRequest: Creates a new InsertRequest.
InsertRequest(String, ByteBuf, int, int, String) - Constructor for class com.couchbase.client.core.message.kv.InsertRequest
InsertResponse - Class in com.couchbase.client.core.message.kv: Response to an InsertRequest.
InsertResponse(ResponseStatus, short, long, String, ByteBuf, MutationToken, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.InsertResponse
INSTANCE - Static variable in class com.couchbase.client.core.message.internal.SignalConfigReload
INSTANCE - Static variable in class com.couchbase.client.core.message.internal.SignalFlush
INSTANCE - Static variable in class com.couchbase.client.core.retry.BestEffortRetryStrategy: A reusable instance of this strategy.
INSTANCE - Static variable in class com.couchbase.client.core.retry.FailFastRetryStrategy: A reusable instance of this strategy.
INSTANCE - Static variable in class com.couchbase.client.core.service.strategies.PartitionSelectionStrategy
InterfaceAudience - Class in com.couchbase.client.core.annotations: Defines the intended audience for each entity.
InterfaceAudience() - Constructor for class com.couchbase.client.core.annotations.InterfaceAudience
InterfaceAudience.Private - Annotation Type in com.couchbase.client.core.annotations: Intended to be only used within this library.
InterfaceAudience.Public - Annotation Type in com.couchbase.client.core.annotations: Intended to be used by any project or application that depends on this library.
InterfaceStability - Class in com.couchbase.client.core.annotations: Defines the stability annotations for each public or private class.
InterfaceStability() - Constructor for class com.couchbase.client.core.annotations.InterfaceStability
InterfaceStability.Committed - Annotation Type in com.couchbase.client.core.annotations: The annotated entity is considered committed and can only break compatibility at a major release.
InterfaceStability.Experimental - Annotation Type in com.couchbase.client.core.annotations: The annotated entity is considered experimental and no guarantees can be given in terms of compatibility and stability.
InterfaceStability.Uncommitted - Annotation Type in com.couchbase.client.core.annotations: The annotated entity is considered stable, but compatibility can be broken at each minor release.
InternalRequest - Interface in com.couchbase.client.core.message.internal: Marker interface for all internal CouchbaseRequests that are potentially treated differently and with priority.
intPropertyOr(String, int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
IO_POOL_SIZE - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
ioPool() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the IO pool for the underlying IO framework.
ioPool(EventLoopGroup) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Deprecated.
use DefaultCoreEnvironment.Builder.ioPool(EventLoopGroup, ShutdownHook) to also provide a shutdown hook.
ioPool(EventLoopGroup, ShutdownHook) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the I/O Pool implementation for the underlying IO framework, along with the action to execute when this environment is shut down.
ioPool() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
IoPoolShutdownHook - Class in com.couchbase.client.core.env.resources: ShutdownHook hook for an EventLoopGroup.
IoPoolShutdownHook(EventLoopGroup) - Constructor for class com.couchbase.client.core.env.resources.IoPoolShutdownHook
ioPoolSize() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the configured IO pool size.
ioPoolSize(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the pool size (number of threads to use) for I/O operations (default value is the number of CPUs).
ioPoolSize() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
isComplete() - Method in class com.couchbase.client.core.security.sasl.ShaSaslClient
isDebugEnabled() - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Is the logger instance enabled for the DEBUG level?
isDone() - Method in class com.couchbase.client.core.message.config.FlushResponse
isEnabled(CouchbaseLogLevel) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
isEnabled(CouchbaseLogLevel) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Is the logger instance enabled for the specified level?
isEnabled() - Method in class com.couchbase.client.core.metrics.AbstractMetricsCollector
isEnabled() - Method in interface com.couchbase.client.core.metrics.MetricsCollector: True if this collector actually emits something.
isErrorEnabled() - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Is the logger instance enabled for the ERROR level?
isEscaped(byte) - Method in class com.couchbase.client.core.endpoint.util.AbstractStringAwareBufProcessor: Detects opening and closing of JSON strings and keep track of it in order to mark characters in the string (delimiter quotes included) as escaped.
isInfoEnabled() - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Is the logger instance enabled for the INFO level?
isJson() - Method in interface com.couchbase.client.core.message.kv.BinaryStoreRequest
isJson() - Method in class com.couchbase.client.core.message.kv.InsertRequest
isJson() - Method in class com.couchbase.client.core.message.kv.ReplaceRequest
isJson() - Method in class com.couchbase.client.core.message.kv.UpsertRequest
isJsonFormat() - Method in class com.couchbase.client.core.message.query.GenericQueryRequest
isShutdown() - Method in class com.couchbase.client.core.env.CoreScheduler
isShutdown() - Method in class com.couchbase.client.core.env.resources.IoPoolShutdownHook
isShutdown() - Method in class com.couchbase.client.core.env.resources.NettyShutdownHook
isShutdown() - Method in class com.couchbase.client.core.env.resources.NoOpShutdownHook
isShutdown() - Method in interface com.couchbase.client.core.env.resources.ShutdownHook
isState(S) - Method in class com.couchbase.client.core.state.AbstractStateMachine
isState(S) - Method in interface com.couchbase.client.core.state.Stateful: Check if the given state is the same as the current one.
isSuccess() - Method in enum com.couchbase.client.core.message.ResponseStatus: Check if the current ResponseStatus is success.
isTraceEnabled() - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Is the logger instance enabled for the TRACE level?
isWarnEnabled() - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Is the logger instance enabled for the WARN level?

J

JdkLoggerFactory - Class in com.couchbase.client.core.logging: Logger factory which creates a java.util.logging logger.
JdkLoggerFactory() - Constructor for class com.couchbase.client.core.logging.JdkLoggerFactory
jsonQuery(String, String, String) - Static method in class com.couchbase.client.core.message.query.GenericQueryRequest: Create a GenericQueryRequest and mark it as containing a full N1QL query in Json form (including additional query parameters like named arguments, etc…).
jsonQuery(String, String, String, InetAddress) - Static method in class com.couchbase.client.core.message.query.GenericQueryRequest: Create a GenericQueryRequest and mark it as containing a full N1QL query in Json form (including additional query parameters like named arguments, etc…).

K

keepAliveInterval() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The time in milliseconds after which some service will issue a form of keep-alive request.
keepAliveInterval(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the time of inactivity, in milliseconds, after which some services will issue a form of keep-alive request to their corresponding server/nodes (default is 30s, values <= 0 deactivate the idle check).
KEEPALIVEINTERVAL - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
keepAliveInterval() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
KeepAliveRequest() - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueHandler.KeepAliveRequest
KeepAliveRequest() - Constructor for class com.couchbase.client.core.endpoint.query.QueryHandler.KeepAliveRequest
KeepAliveRequest() - Constructor for class com.couchbase.client.core.endpoint.view.ViewHandler.KeepAliveRequest
KeepAliveResponse(ResponseStatus, short, CouchbaseRequest) - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueHandler.KeepAliveResponse
KeepAliveResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.endpoint.query.QueryHandler.KeepAliveResponse
KeepAliveResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.endpoint.view.ViewHandler.KeepAliveResponse
ketamaNodes() - Method in class com.couchbase.client.core.config.DefaultMemcachedBucketConfig
ketamaNodes() - Method in interface com.couchbase.client.core.config.MemcachedBucketConfig
key() - Method in class com.couchbase.client.core.message.dcp.AbstractDCPMessage
key() - Method in interface com.couchbase.client.core.message.dcp.DCPMessage
key() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
key() - Method in interface com.couchbase.client.core.message.kv.BinaryRequest: The key of the document.
key() - Method in class com.couchbase.client.core.message.kv.StatResponse
KEY_EEXISTS - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
KEY_ENOENT - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
keyBytes() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
keyBytes() - Method in interface com.couchbase.client.core.message.kv.BinaryRequest: The raw byte representation of the key.
keys() - Method in class com.couchbase.client.core.message.view.ViewQueryRequest
KEYVALUE_ENDPOINTS - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
KeyValueAuthHandler - Class in com.couchbase.client.core.endpoint.kv: A SASL Client which communicates through the memcache binary protocol.
KeyValueAuthHandler(String, String) - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler: Creates a new KeyValueAuthHandler.
KeyValueEndpoint - Class in com.couchbase.client.core.endpoint.kv: This endpoint defines the pipeline for binary requests and responses.
KeyValueEndpoint(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueEndpoint: Create a new KeyValueEndpoint.
KeyValueFeatureHandler - Class in com.couchbase.client.core.endpoint.kv: This handler negotiates the enabled features through the HELLO command.
KeyValueFeatureHandler(CoreEnvironment) - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
KeyValueHandler - Class in com.couchbase.client.core.endpoint.kv: The KeyValueHandler is responsible for encoding BinaryRequests into lower level BinaryMemcacheRequests as well as decoding FullBinaryMemcacheResponses into CouchbaseResponses.
KeyValueHandler(AbstractEndpoint, EventSink<ResponseEvent>, boolean) - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueHandler: Creates a new KeyValueHandler with the default queue for requests.
KeyValueHandler.KeepAliveRequest - Class in com.couchbase.client.core.endpoint.kv
KeyValueHandler.KeepAliveResponse - Class in com.couchbase.client.core.endpoint.kv
KeyValueLocator - Class in com.couchbase.client.core.node.locate: This Locator finds the proper Nodes for every incoming BinaryRequest.
KeyValueLocator() - Constructor for class com.couchbase.client.core.node.locate.KeyValueLocator
KeyValueService - Class in com.couchbase.client.core.service
KeyValueService(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.service.KeyValueService: Creates a new KeyValueService.
KeyValueStatus - Enum in com.couchbase.client.core.endpoint.kv: Enum describing all known response status codes that could be seen on the KeyValue protocol.
kvEndpoints() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The number of key/value service endpoints.
kvEndpoints(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the number of Key/Value endpoints to open per nodes in the cluster (default value ).
kvEndpoints() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment

L

LastMemcacheContent - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache: The MemcacheContent which signals the end of the content batch.
lastPersistedSeqNo() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
lastPersistedSeqNo() - Method in class com.couchbase.client.core.message.kv.NoFailoverObserveSeqnoResponse
lastSeqNoReceived() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
latencies() - Method in class com.couchbase.client.core.event.metrics.LatencyMetricsEvent: Returns all latency metrics per unique identifier.
LatencyMetric - Class in com.couchbase.client.core.event.metrics: A latency metric value object which contains percentile and other related information.
LatencyMetric(long, long, long, Map<Double, Long>, TimeUnit) - Constructor for class com.couchbase.client.core.event.metrics.LatencyMetric
LatencyMetricsCollector<I extends LatencyMetricsIdentifier> - Interface in com.couchbase.client.core.metrics: A collector which collects and emits latency measurements.
LatencyMetricsCollectorConfig - Interface in com.couchbase.client.core.metrics: Additional configuration for the latency metrics collector.
LatencyMetricsEvent<I extends LatencyMetricsIdentifier> - Class in com.couchbase.client.core.event.metrics: A common base class for latency metric events.
LatencyMetricsEvent(Map<I, LatencyMetric>) - Constructor for class com.couchbase.client.core.event.metrics.LatencyMetricsEvent
LatencyMetricsIdentifier - Interface in com.couchbase.client.core.metrics: A class which uniquely identifies a latency metric.
LifecycleState - Enum in com.couchbase.client.core.state: Represents common lifecycle states of components.
linear(TimeUnit) - Static method in class com.couchbase.client.core.time.Delay: Creates a new LinearDelay with no bounds and default factor.
linear(TimeUnit, long) - Static method in class com.couchbase.client.core.time.Delay: Creates a new LinearDelay with a custom upper boundary and the default factor.
linear(TimeUnit, long, long) - Static method in class com.couchbase.client.core.time.Delay: Creates a new LinearDelay with a custom boundaries and the default factor.
linear(TimeUnit, long, long, long) - Static method in class com.couchbase.client.core.time.Delay: Creates a new LinearDelay with a custom boundaries and factor.
LinearDelay - Class in com.couchbase.client.core.time: Delay which increases linearly for every attempt.
loadConfig(InetAddress, String, String) - Method in class com.couchbase.client.core.config.loader.AbstractLoader: Initiate the config loading process.
loadConfig(InetAddress, String, String) - Method in interface com.couchbase.client.core.config.loader.Loader
Loader - Interface in com.couchbase.client.core.config.loader
LoaderType - Enum in com.couchbase.client.core.config: .
locate(CouchbaseRequest) - Method in class com.couchbase.client.core.node.DefaultServiceRegistry
locate(CouchbaseRequest) - Method in interface com.couchbase.client.core.node.ServiceRegistry
locateAndDispatch(CouchbaseRequest, List<Node>, ClusterConfig, CoreEnvironment, RingBuffer<ResponseEvent>) - Method in class com.couchbase.client.core.node.locate.ConfigLocator
locateAndDispatch(CouchbaseRequest, List<Node>, ClusterConfig, CoreEnvironment, RingBuffer<ResponseEvent>) - Method in class com.couchbase.client.core.node.locate.DCPLocator
locateAndDispatch(CouchbaseRequest, List<Node>, ClusterConfig, CoreEnvironment, RingBuffer<ResponseEvent>) - Method in class com.couchbase.client.core.node.locate.KeyValueLocator
locateAndDispatch(CouchbaseRequest, List<Node>, ClusterConfig, CoreEnvironment, RingBuffer<ResponseEvent>) - Method in interface com.couchbase.client.core.node.locate.Locator: Given with the environment and node information, the implementation locates the right set of nodes and dispatches the request into them.
locateAndDispatch(CouchbaseRequest, List<Node>, ClusterConfig, CoreEnvironment, RingBuffer<ResponseEvent>) - Method in class com.couchbase.client.core.node.locate.QueryLocator
locateAndDispatch(CouchbaseRequest, List<Node>, ClusterConfig, CoreEnvironment, RingBuffer<ResponseEvent>) - Method in class com.couchbase.client.core.node.locate.ViewLocator
locator() - Method in class com.couchbase.client.core.config.AbstractBucketConfig
locator() - Method in interface com.couchbase.client.core.config.BucketConfig: The type of node locator in use for this bucket.
Locator - Interface in com.couchbase.client.core.node.locate
locator(CouchbaseRequest) - Method in class com.couchbase.client.core.RequestHandler: Helper method to detect the correct locator for the given request type.
lock() - Method in class com.couchbase.client.core.message.kv.GetRequest
lockTime() - Method in class com.couchbase.client.core.message.dcp.MutationMessage
log(CouchbaseLogLevel, String, Throwable) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
log(CouchbaseLogLevel, Throwable) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
log(CouchbaseLogLevel, String) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
log(CouchbaseLogLevel, String, Object) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
log(CouchbaseLogLevel, String, Object, Object) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
log(CouchbaseLogLevel, String, Object...) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
log(CouchbaseLogLevel, String) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the specified level.
log(CouchbaseLogLevel, String, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the specified level according to the specified format and argument.
log(CouchbaseLogLevel, String, Object, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the specified level according to the specified format and arguments.
log(CouchbaseLogLevel, String, Object...) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the specified level according to the specified format and arguments.
log(CouchbaseLogLevel, String, Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the specified level with an accompanying message.
log(CouchbaseLogLevel, Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the specified level.
Log4JLoggerFactory - Class in com.couchbase.client.core.logging: Logger factory which creates an Apache Log4J logger.
Log4JLoggerFactory() - Constructor for class com.couchbase.client.core.logging.Log4JLoggerFactory
LoggingConsumer - Class in com.couchbase.client.core.event.consumers: Consumes CouchbaseEvents and logs them.
LoggingConsumer.OutputFormat - Enum in com.couchbase.client.core.event.consumers: The target output format to log.
logIdent(Channel, Endpoint) - Static method in class com.couchbase.client.core.endpoint.AbstractEndpoint: Simple log helper to give logs a common prefix.
logIdent(ChannelHandlerContext, Endpoint) - Static method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Simple log helper to give logs a common prefix.
logIdent(InetAddress) - Static method in class com.couchbase.client.core.node.CouchbaseNode: Simple log helper to give logs a common prefix.
logIdent(String, Service) - Static method in class com.couchbase.client.core.service.AbstractDynamicService: Simple log helper to give logs a common prefix.
longPropertyOr(String, long) - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
Lookup - Enum in com.couchbase.client.core.message.kv.subdoc.multi: Enumeration of possible mutations inside a sub-document LookupCommand.
lookup() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommand
LookupCommand - Class in com.couchbase.client.core.message.kv.subdoc.multi: A single lookup description inside a TODO.
LookupCommand(Lookup, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommand: Create a multi-lookup command.

M

mapping() - Method in class com.couchbase.client.core.service.AbstractDynamicService
mapping() - Method in interface com.couchbase.client.core.service.Service: Returns the mapping for the given Service.
mapping() - Method in enum com.couchbase.client.core.service.ServiceType
markTainted(BucketConfig) - Method in class com.couchbase.client.core.config.refresher.CarrierRefresher
markTainted(BucketConfig) - Method in class com.couchbase.client.core.config.refresher.HttpRefresher
markTainted(BucketConfig) - Method in interface com.couchbase.client.core.config.refresher.Refresher: Marks the given bucket as tainted.
markUntainted(BucketConfig) - Method in class com.couchbase.client.core.config.refresher.CarrierRefresher
markUntainted(BucketConfig) - Method in class com.couchbase.client.core.config.refresher.HttpRefresher
markUntainted(BucketConfig) - Method in interface com.couchbase.client.core.config.refresher.Refresher: Mark the given bucket as not tainted.
master() - Method in class com.couchbase.client.core.config.DefaultPartition
master() - Method in interface com.couchbase.client.core.config.Partition: Returns the master node index for this partition.
master() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
master() - Method in class com.couchbase.client.core.message.kv.NoFailoverObserveSeqnoResponse
master() - Method in class com.couchbase.client.core.message.kv.ObserveRequest
master() - Method in class com.couchbase.client.core.message.kv.ObserveResponse
master() - Method in class com.couchbase.client.core.message.kv.ObserveSeqnoRequest
max() - Method in class com.couchbase.client.core.event.metrics.LatencyMetric: The maximum latency recorded in the interval.
MAX_REQUEST_LIFETIME - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
maxRequestLifetime() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the maximum time in milliseconds a request is allowed to life.
maxRequestLifetime(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the maximum time in milliseconds a request is allowed to live.
maxRequestLifetime() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
MEM_BEAN - Static variable in class com.couchbase.client.core.env.Diagnostics
MemcacheContent - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache: An Memcache content chunk.
MemcachedBucketConfig - Interface in com.couchbase.client.core.config: A configuration representing a memcached bucket.
MemcacheMessage - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache: Marker interface for both ascii and binary messages.
MemcacheObject - Interface in com.couchbase.client.deps.io.netty.handler.codec.memcache: Defines a common interface for all MemcacheObject implementations.
memInfo(Map<String, Object>) - Static method in class com.couchbase.client.core.env.Diagnostics: Collects system information as delivered from the MemoryMXBean.
MEMORY - Static variable in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
memory() - Method in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
MetricsCollector - Interface in com.couchbase.client.core.metrics: A generic metrics collector.
MetricsCollectorConfig - Interface in com.couchbase.client.core.metrics: A generic configuration for a metrics collector.
min() - Method in class com.couchbase.client.core.event.metrics.LatencyMetric: The minimum latency recorded in the interval.
MINIMUM_WINDOW_FOR_CLIENTID_TOKEN - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler: This is a window of characters allowing to detect the clientContextID token (including room for JSON separators, etc…).
MultiLookupResponse - Class in com.couchbase.client.core.message.kv.subdoc.multi: The response for a BinarySubdocMultiLookupRequest.
MultiLookupResponse(ResponseStatus, short, String, List<MultiResult<Lookup>>, BinarySubdocMultiLookupRequest, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MultiLookupResponse
MultiMutationResponse - Class in com.couchbase.client.core.message.kv.subdoc.multi: The response for a BinarySubdocMultiMutationRequest.
MultiMutationResponse(ResponseStatus, short, String, int, short, BinarySubdocMultiMutationRequest, long, MutationToken) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse: Creates a MultiMutationResponse that failed at subdocument level.
MultiMutationResponse(ResponseStatus, short, String, BinarySubdocMultiMutationRequest, long, MutationToken) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse: Creates a unsuccessful MultiMutationResponse that failed at document level.
MultiMutationResponse(String, BinarySubdocMultiMutationRequest, long, MutationToken, List<MultiResult<Mutation>>) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse: Creates an successful MultiMutationResponse.
MultiResult<OPERATION> - Class in com.couchbase.client.core.message.kv.subdoc.multi: The result corresponding to an individual LookupCommand or MutationCommand.
Mutation - Enum in com.couchbase.client.core.message.kv.subdoc.multi: Enumeration of possible mutations inside a sub-document MutationCommand.
mutation() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
MUTATION_TOKENS_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
MutationCommand - Class in com.couchbase.client.core.message.kv.subdoc.multi: A single mutation description inside a BinarySubdocMultiMutationRequest.
MutationCommand(Mutation, String, ByteBuf, boolean) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand: Create a multi-mutation command.
MutationCommand(Mutation, String, ByteBuf) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand: Create a multi-mutation command, without attempting to create intermediary paths.
MutationCommand(Mutation, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand: Create a multi-mutation without a fragment (should be restricted to DELETE, not to be confused with an empty string fragment where ByteBuf contains “”“”, or the null fragment where ByteBuf contains “NULL”).
MutationMessage - Class in com.couchbase.client.core.message.dcp: A message representing event that creates or updates a document.
MutationMessage(int, short, String, ByteBuf, int, long, long, int, int, long, String) - Constructor for class com.couchbase.client.core.message.dcp.MutationMessage
MutationMessage(int, short, String, ByteBuf, int, long, long, int, int, long, String, String) - Constructor for class com.couchbase.client.core.message.dcp.MutationMessage
mutationToken() - Method in class com.couchbase.client.core.message.kv.AppendResponse
mutationToken() - Method in class com.couchbase.client.core.message.kv.CounterResponse
mutationToken() - Method in class com.couchbase.client.core.message.kv.InsertResponse
MutationToken - Class in com.couchbase.client.core.message.kv: Value object to contain vbucket UUID and sequence number.
MutationToken(long, long, long, String) - Constructor for class com.couchbase.client.core.message.kv.MutationToken
mutationToken() - Method in class com.couchbase.client.core.message.kv.PrependResponse
mutationToken() - Method in class com.couchbase.client.core.message.kv.RemoveResponse
mutationToken() - Method in class com.couchbase.client.core.message.kv.ReplaceResponse
mutationToken() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse
mutationToken() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SimpleSubdocResponse
mutationToken() - Method in class com.couchbase.client.core.message.kv.UpsertResponse
mutationTokens() - Method in class com.couchbase.client.core.message.kv.GetAllMutationTokensResponse
mutationTokensEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns true if extended mutation tokens are enabled.
mutationTokensEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: If mutation tokens are enabled, they can be used for advanced durability requirements, as well as optimized RYOW consistency.
mutationTokensEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment

N

name() - Method in class com.couchbase.client.core.config.AbstractBucketConfig
name() - Method in interface com.couchbase.client.core.config.BucketConfig: The name of the bucket.
name() - Method in class com.couchbase.client.core.event.system.BucketClosedEvent
name() - Method in class com.couchbase.client.core.event.system.BucketOpenedEvent
name() - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
name() - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Return the name of this CouchbaseLogger instance.
name() - Method in class com.couchbase.client.core.message.view.GetDesignDocumentRequest
name() - Method in class com.couchbase.client.core.message.view.GetDesignDocumentResponse
name() - Method in class com.couchbase.client.core.message.view.RemoveDesignDocumentRequest
name() - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentRequest
NettyShutdownHook - Class in com.couchbase.client.core.env.resources: ShutdownHook hook that attempts to terminate Netty threads gracefully.
NettyShutdownHook() - Constructor for class com.couchbase.client.core.env.resources.NettyShutdownHook
networkLatencyMetricsCollector() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the collector responsible for aggregating and publishing network latency information.
networkLatencyMetricsCollector() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
NetworkLatencyMetricsCollector - Class in com.couchbase.client.core.metrics: The collector for core network latencies.
NetworkLatencyMetricsCollector(EventBus, Scheduler, LatencyMetricsCollectorConfig) - Constructor for class com.couchbase.client.core.metrics.NetworkLatencyMetricsCollector
networkLatencyMetricsCollectorConfig(LatencyMetricsCollectorConfig) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets a custom configuration for the NetworkLatencyMetricsCollector.
NetworkLatencyMetricsEvent - Class in com.couchbase.client.core.event.metrics: This event represents network latencies captured in the core layer.
NetworkLatencyMetricsEvent(Map<NetworkLatencyMetricsIdentifier, LatencyMetric>) - Constructor for class com.couchbase.client.core.event.metrics.NetworkLatencyMetricsEvent
NetworkLatencyMetricsIdentifier - Class in com.couchbase.client.core.metrics: The unique identifier for a network latency metric.
NetworkLatencyMetricsIdentifier(String, String, String, String) - Constructor for class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
newInstance(String) - Method in class com.couchbase.client.core.logging.CommonsLoggerFactory
newInstance(String) - Method in class com.couchbase.client.core.logging.CouchbaseLoggerFactory: Creates a new logger instance with the specified name.
newInstance(String) - Method in class com.couchbase.client.core.logging.JdkLoggerFactory
newInstance(String) - Method in class com.couchbase.client.core.logging.Log4JLoggerFactory
newInstance(String) - Method in class com.couchbase.client.core.logging.Slf4JLoggerFactory
newInstance() - Method in class com.couchbase.client.core.RequestEventFactory
newInstance() - Method in class com.couchbase.client.core.ResponseEventFactory
newVbucketUUID() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
newWaitStrategy() - Method in interface com.couchbase.client.core.env.WaitStrategyFactory
Node - Interface in com.couchbase.client.core.node: Represents a Couchbase Node.
nodeAtIndex(int) - Method in interface com.couchbase.client.core.config.CouchbaseBucketConfig: Returns information for the node at the given index.
nodeAtIndex(int) - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
nodeBy(InetAddress) - Method in class com.couchbase.client.core.RequestHandler: Returns the node by its hostname.
NodeConnectedEvent - Class in com.couchbase.client.core.event.system: Event published when a node is connected.
NodeConnectedEvent(InetAddress) - Constructor for class com.couchbase.client.core.event.system.NodeConnectedEvent
NodeDisconnectedEvent - Class in com.couchbase.client.core.event.system: Event published when a node is disconnected.
NodeDisconnectedEvent(InetAddress) - Constructor for class com.couchbase.client.core.event.system.NodeDisconnectedEvent
nodeForId(byte[]) - Method in class com.couchbase.client.core.config.DefaultMemcachedBucketConfig
nodeForId(byte[]) - Method in interface com.couchbase.client.core.config.MemcachedBucketConfig: Returns the target node address for the given document id.
nodeIndexForMaster(int, boolean) - Method in interface com.couchbase.client.core.config.CouchbaseBucketConfig: Returns the node index for the given partition index and master.
nodeIndexForMaster(int, boolean) - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
nodeIndexForReplica(int, int, boolean) - Method in interface com.couchbase.client.core.config.CouchbaseBucketConfig: Returns the node index for the given partition index and the replica.
nodeIndexForReplica(int, int, boolean) - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
NodeInfo - Interface in com.couchbase.client.core.config
nodes() - Method in class com.couchbase.client.core.config.AbstractBucketConfig
nodes() - Method in interface com.couchbase.client.core.config.BucketConfig: The list of nodes associated with this bucket.
nodes() - Method in class com.couchbase.client.core.message.cluster.SeedNodesRequest: Returns the set list of seed hostnames.
NoFailoverObserveSeqnoResponse - Class in com.couchbase.client.core.message.kv: Represents a observe seqno response.
NoFailoverObserveSeqnoResponse(boolean, short, long, long, long, ResponseStatus, short, String, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.NoFailoverObserveSeqnoResponse
NOOP - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
NoOpShutdownHook - Class in com.couchbase.client.core.env.resources: ShutdownHook hook that does nothing and returns true.
NoOpShutdownHook() - Constructor for class com.couchbase.client.core.env.resources.NoOpShutdownHook
NOT_STORED - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
NotConnectedException - Exception in com.couchbase.client.core.state: Thrown if the stateful component is not connected.
NotConnectedException() - Constructor for exception com.couchbase.client.core.state.NotConnectedException
NotConnectedException(String) - Constructor for exception com.couchbase.client.core.state.NotConnectedException
NotConnectedException(String, Throwable) - Constructor for exception com.couchbase.client.core.state.NotConnectedException
NotConnectedException(Throwable) - Constructor for exception com.couchbase.client.core.state.NotConnectedException
notifyChannelInactive() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint: Helper method that is called from inside the event loop to notify the upper Endpoint of a disconnect.
numberOfPartitions() - Method in interface com.couchbase.client.core.config.CouchbaseBucketConfig: Returns the total number of partitions.
numberOfPartitions() - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
numberOfReplicas() - Method in interface com.couchbase.client.core.config.CouchbaseBucketConfig: The number of configured replicas for this bucket.
numberOfReplicas() - Method in class com.couchbase.client.core.config.CouchbasePartitionInfo
numberOfReplicas() - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig

O

observable() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
observable() - Method in interface com.couchbase.client.core.message.CouchbaseRequest: Get the underlying Observable.
Observe - Class in com.couchbase.client.core.message.observe: Utility class to handle observe calls and polling logic.
Observe() - Constructor for class com.couchbase.client.core.message.observe.Observe
Observe.PersistTo - Enum in com.couchbase.client.core.message.observe: Defines the possible disk persistence constraints to observe.
Observe.ReplicateTo - Enum in com.couchbase.client.core.message.observe: Defines the possible replication constraints to observe.
OBSERVE_INTERVAL_DELAY - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
observeIntervalDelay() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the Delay for Observe poll operations.
observeIntervalDelay(Delay) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the Delay for Observe poll operations (default value is a delay growing exponentially between 10us and 100ms).
observeIntervalDelay() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
ObserveRequest - Class in com.couchbase.client.core.message.kv
ObserveRequest(String, long, boolean, short, String) - Constructor for class com.couchbase.client.core.message.kv.ObserveRequest
ObserveResponse - Class in com.couchbase.client.core.message.kv: .
ObserveResponse(ResponseStatus, short, byte, boolean, long, String, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.ObserveResponse
ObserveResponse.ObserveStatus - Enum in com.couchbase.client.core.message.kv
ObserveSeqnoRequest - Class in com.couchbase.client.core.message.kv: Observe through sequence numbers instead of cas.
ObserveSeqnoRequest(long, boolean, short, String, String) - Constructor for class com.couchbase.client.core.message.kv.ObserveSeqnoRequest
observeStatus() - Method in class com.couchbase.client.core.message.kv.ObserveResponse
ObserveViaCAS - Class in com.couchbase.client.core.message.observe: Utility class to handle observe calls and polling logic.
ObserveViaCAS() - Constructor for class com.couchbase.client.core.message.observe.ObserveViaCAS
ObserveViaMutationToken - Class in com.couchbase.client.core.message.observe: Document observe through mutation token information.
ObserveViaMutationToken() - Constructor for class com.couchbase.client.core.message.observe.ObserveViaMutationToken
oldVbucketUUID() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
onCompleted() - Method in class com.couchbase.client.core.event.consumers.LoggingConsumer
onCompleted() - Method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
onError(Throwable) - Method in class com.couchbase.client.core.event.consumers.LoggingConsumer
onError(Throwable) - Method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
onEvent(RequestEvent, long, boolean) - Method in class com.couchbase.client.core.RequestHandler
onEvent(ResponseEvent, long, boolean) - Method in class com.couchbase.client.core.ResponseHandler: Handles ResponseEvents that come into the response RingBuffer.
onKeepAliveFired(ChannelHandlerContext, CouchbaseRequest) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Override to customize the behavior when a keep alive has been triggered and a keep alive request sent.
onKeepAliveResponse(ChannelHandlerContext, CouchbaseResponse) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Override to customize the behavior when a keep alive has been responded to.
onNext(CouchbaseEvent) - Method in class com.couchbase.client.core.event.consumers.LoggingConsumer
onNext(T) - Method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
OP_APPEND - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_BUFFER_ACK - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_CONTROL - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_COUNTER_DECR - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_COUNTER_INCR - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_EXPIRATION - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_GET - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_GET_ALL_MUTATION_TOKENS - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_GET_AND_LOCK - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_GET_AND_TOUCH - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_GET_BUCKET_CONFIG - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_GET_FAILOVER_LOG - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_GET_LAST_CHECKPOINT - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_GET_REPLICA - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_INSERT - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_MUTATION - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_NOOP - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_OBSERVE - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_OBSERVE_SEQ - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_OPEN_CONNECTION - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_PREPEND - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_REMOVE - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_REMOVE - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_REPLACE - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SNAPSHOT_MARKER - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_STAT - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_STREAM_CLOSE - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_STREAM_END - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_STREAM_REQUEST - Static variable in class com.couchbase.client.core.endpoint.dcp.DCPHandler
OP_SUB_ARRAY_ADD_UNIQUE - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_ARRAY_INSERT - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_ARRAY_PUSH_FIRST - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_ARRAY_PUSH_LAST - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_COUNTER - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_DELETE - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_DICT_ADD - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_DICT_UPSERT - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_EXIST - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_GET - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_MULTI_LOOKUP - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_MULTI_MUTATION - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_SUB_REPLACE - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_TOUCH - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_UNLOCK - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
OP_UPSERT - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
opaque() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
opaque() - Method in interface com.couchbase.client.core.message.kv.BinaryRequest: A opaque value representing this request.
opcode() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocRequest
opCode() - Method in enum com.couchbase.client.core.message.kv.subdoc.multi.Lookup
opCode() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommand
opCode() - Method in enum com.couchbase.client.core.message.kv.subdoc.multi.Mutation
opCode() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
opCode() - Method in enum com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest.ArrayOperation
opcode() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest
opcode() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubCounterRequest
opcode() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubDeleteRequest
opcode() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubDictAddRequest
opcode() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubDictUpsertRequest
opcode() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubExistRequest
opcode() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubGetRequest
opcode() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubReplaceRequest
openBucket(String, String) - Method in interface com.couchbase.client.core.config.ConfigurationProvider: Start to fetch a config for the given bucket and also watch for changes, depending on the mechanism used.
openBucket(String, String) - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
OpenBucketRequest - Class in com.couchbase.client.core.message.cluster
OpenBucketRequest(String, String) - Constructor for class com.couchbase.client.core.message.cluster.OpenBucketRequest
OpenBucketResponse - Class in com.couchbase.client.core.message.cluster
OpenBucketResponse(ResponseStatus) - Constructor for class com.couchbase.client.core.message.cluster.OpenBucketResponse
openBuckets() - Method in class com.couchbase.client.core.event.system.ConfigUpdatedEvent: Returns all open bucket names.
OpenConnectionRequest - Class in com.couchbase.client.core.message.dcp
OpenConnectionRequest(String, String) - Constructor for class com.couchbase.client.core.message.dcp.OpenConnectionRequest
OpenConnectionResponse - Class in com.couchbase.client.core.message.dcp
OpenConnectionResponse(DCPConnection, ResponseStatus) - Constructor for class com.couchbase.client.core.message.dcp.OpenConnectionResponse
operation() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
OS_BEAN - Static variable in class com.couchbase.client.core.env.Diagnostics

P

PACKAGE_NAME_AND_VERSION - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
packageNameAndVersion() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns name and the version of the package.
packageNameAndVersion(String) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the String to be used as identifier for the library namespace and version.
packageNameAndVersion() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
parse(String) - Static method in class com.couchbase.client.core.config.parser.BucketConfigParser: Parse a raw configuration into a BucketConfig.
Partition - Interface in com.couchbase.client.core.config
partition() - Method in class com.couchbase.client.core.message.dcp.AbstractDCPRequest
partition(short) - Method in class com.couchbase.client.core.message.dcp.AbstractDCPRequest
partition() - Method in class com.couchbase.client.core.message.dcp.AbstractDCPResponse
partition(short) - Method in class com.couchbase.client.core.message.dcp.AbstractDCPResponse
partition() - Method in interface com.couchbase.client.core.message.dcp.DCPMessage: The partition (vBucket) to use for this request.
partition() - Method in interface com.couchbase.client.core.message.dcp.DCPRequest: The partition (vBucket) to use for this request.
partition(short) - Method in interface com.couchbase.client.core.message.dcp.DCPRequest: Set the partition ID.
partition() - Method in interface com.couchbase.client.core.message.dcp.DCPResponse: The partition (vBucket) to use for this request.
partition(short) - Method in interface com.couchbase.client.core.message.dcp.DCPResponse: Set the partition ID.
partition() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
partition(short) - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
partition() - Method in interface com.couchbase.client.core.message.kv.BinaryRequest: The partition (vbucket) to use for this request.
partition(short) - Method in interface com.couchbase.client.core.message.kv.BinaryRequest: Set the partition ID.
partition() - Method in class com.couchbase.client.core.message.kv.GetAllMutationTokensRequest
partition() - Method in class com.couchbase.client.core.message.kv.GetBucketConfigRequest
partition() - Method in class com.couchbase.client.core.message.kv.StatRequest
partitionHosts() - Method in class com.couchbase.client.core.config.CouchbasePartitionInfo
partitions() - Method in class com.couchbase.client.core.config.CouchbasePartitionInfo
PartitionSelectionStrategy - Class in com.couchbase.client.core.service.strategies: Selects the Endpoint based on the information enclosed in the CouchbaseRequest.
partitionState() - Method in class com.couchbase.client.core.message.kv.GetAllMutationTokensRequest
password() - Method in class com.couchbase.client.core.config.AbstractBucketConfig
password(String) - Method in class com.couchbase.client.core.config.AbstractBucketConfig
password() - Method in interface com.couchbase.client.core.config.BucketConfig: The password of the bucket.
password(String) - Method in interface com.couchbase.client.core.config.BucketConfig: Setter to inject the password manually into the config.
password() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint: The password of the bucket.
password() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
password() - Method in interface com.couchbase.client.core.message.CouchbaseRequest: The password associated with the bucket for this request.
path() - Method in class com.couchbase.client.core.message.config.BucketConfigRequest
path() - Method in class com.couchbase.client.core.message.config.BucketsConfigRequest
path() - Method in class com.couchbase.client.core.message.config.BucketStreamingRequest
path() - Method in class com.couchbase.client.core.message.config.ClusterConfigRequest
path() - Method in interface com.couchbase.client.core.message.config.ConfigRequest
path() - Method in class com.couchbase.client.core.message.config.FlushRequest
path() - Method in class com.couchbase.client.core.message.config.GetDesignDocumentsRequest
path() - Method in class com.couchbase.client.core.message.config.InsertBucketRequest
path() - Method in class com.couchbase.client.core.message.config.RemoveBucketRequest
path() - Method in class com.couchbase.client.core.message.config.UpdateBucketRequest
path() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocRequest: Returns the path inside a JSON document where values will be obtained/mutated.
path() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommand
path() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
path() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
path() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest
path() - Method in class com.couchbase.client.core.message.search.GetSearchIndexRequest
path() - Method in class com.couchbase.client.core.message.search.RemoveSearchIndexRequest
path() - Method in class com.couchbase.client.core.message.search.SearchQueryRequest
path() - Method in interface com.couchbase.client.core.message.search.SearchRequest
path() - Method in class com.couchbase.client.core.message.search.UpsertSearchIndexRequest
pathLength() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocRequest
pathLength() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest
payload() - Method in class com.couchbase.client.core.message.config.InsertBucketRequest
payload() - Method in class com.couchbase.client.core.message.config.UpdateBucketRequest
payload() - Method in class com.couchbase.client.core.message.search.GetSearchIndexResponse
payload() - Method in class com.couchbase.client.core.message.search.RemoveSearchIndexResponse
payload() - Method in class com.couchbase.client.core.message.search.SearchQueryRequest
payload() - Method in class com.couchbase.client.core.message.search.SearchQueryResponse
payload() - Method in class com.couchbase.client.core.message.search.UpsertSearchIndexRequest
payload() - Method in class com.couchbase.client.core.message.search.UpsertSearchIndexResponse
percentiles() - Method in class com.couchbase.client.core.event.metrics.LatencyMetric: Configured latencies with their values recorded in the interval.
port() - Method in class com.couchbase.client.core.config.loader.AbstractLoader: Port to use for the ServiceType.
port() - Method in class com.couchbase.client.core.config.loader.CarrierLoader
port() - Method in class com.couchbase.client.core.config.loader.HttpLoader
port() - Method in class com.couchbase.client.core.message.internal.AddServiceRequest
PortInfo - Interface in com.couchbase.client.core.config
ports() - Method in class com.couchbase.client.core.config.DefaultPortInfo
ports() - Method in interface com.couchbase.client.core.config.PortInfo
PrelocatedRequest - Interface in com.couchbase.client.core.message: A CouchbaseRequest that can be targeted at a specific node through the corresponding InetAddress, shortcutting the dispatch usually performed by a Locator..
PREPEND - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
PREPENDQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
PrependRequest - Class in com.couchbase.client.core.message.kv
PrependRequest(String, long, ByteBuf, String) - Constructor for class com.couchbase.client.core.message.kv.PrependRequest
PrependResponse - Class in com.couchbase.client.core.message.kv: .
PrependResponse(ResponseStatus, short, long, String, ByteBuf, MutationToken, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.PrependResponse
process(byte) - Method in class com.couchbase.client.core.endpoint.util.ClosingPositionBufProcessor
process(byte) - Method in class com.couchbase.client.core.endpoint.util.SplitPositionBufProcessor
process(byte) - Method in class com.couchbase.client.core.endpoint.util.StringClosingPositionBufProcessor
process(byte) - Method in class com.couchbase.client.core.endpoint.util.WhitespaceSkipper
proposeBucketConfig(String, String) - Method in interface com.couchbase.client.core.config.ConfigurationProvider
proposeBucketConfig(String, String) - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
provider() - Method in class com.couchbase.client.core.config.refresher.AbstractRefresher
provider(ConfigurationProvider) - Method in class com.couchbase.client.core.config.refresher.AbstractRefresher
provider(ConfigurationProvider) - Method in interface com.couchbase.client.core.config.refresher.Refresher
provider() - Method in class com.couchbase.client.core.message.internal.GetConfigProviderResponse
publish(CouchbaseEvent) - Method in class com.couchbase.client.core.event.DefaultEventBus
publish(CouchbaseEvent) - Method in interface com.couchbase.client.core.event.EventBus: Publish a CouchbaseEvent into the bus.
publishResponse(CouchbaseResponse, Subject<CouchbaseResponse, CouchbaseResponse>) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Publishes a response with the attached observable.
pushConfig(String) - Method in class com.couchbase.client.core.config.refresher.AbstractRefresher: Push a BucketConfig into the config stream.

Q

query() - Method in class com.couchbase.client.core.message.query.GenericQueryRequest
query() - Method in class com.couchbase.client.core.message.view.ViewQueryRequest
QUERY_ENDPOINTS - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
QueryEndpoint - Class in com.couchbase.client.core.endpoint.query: This endpoint defines the pipeline for query requests and responses (N1QL).
QueryEndpoint(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.endpoint.query.QueryEndpoint
queryEndpoints() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The number of query service endpoints.
queryEndpoints(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the number of Query (N1QL) endpoints to open per node in the cluster (default value ).
queryEndpoints() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
QueryHandler - Class in com.couchbase.client.core.endpoint.query: The QueryHandler is responsible for encoding QueryRequests into lower level HttpRequests as well as decoding HttpObjects into CouchbaseResponses.
QueryHandler(AbstractEndpoint, RingBuffer<ResponseEvent>, boolean) - Constructor for class com.couchbase.client.core.endpoint.query.QueryHandler: Creates a new QueryHandler with the default queue for requests.
QueryHandler.KeepAliveRequest - Class in com.couchbase.client.core.endpoint.query
QueryHandler.KeepAliveResponse - Class in com.couchbase.client.core.endpoint.query
QueryLocator - Class in com.couchbase.client.core.node.locate
QueryLocator() - Constructor for class com.couchbase.client.core.node.locate.QueryLocator
QueryRequest - Interface in com.couchbase.client.core.message.query
QueryService - Class in com.couchbase.client.core.service: The QueryService is composed of and manages QueryEndpoints.
QueryService(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.service.QueryService: Creates a new ViewService.
queryStatus() - Method in class com.couchbase.client.core.message.query.GenericQueryResponse: Contains a single String denoting the status of the query (success, running, errors, completed, stopped, timeout, fatal).
QUIT - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
QUITQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes

R

RandomSelectionStrategy - Class in com.couchbase.client.core.service.strategies: Selects the Endpoint based on a random selection of connected Endpoints.
RandomSelectionStrategy() - Constructor for class com.couchbase.client.core.service.strategies.RandomSelectionStrategy
read(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler
read(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
read(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
readResolve() - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
reason() - Method in class com.couchbase.client.core.message.dcp.StreamEndMessage: Specify to the consumer why the stream was closed
reconfigure(ClusterConfig) - Method in class com.couchbase.client.core.RequestHandler: Helper method which grabs the current configuration and checks if the node setup is out of sync.
RECONNECT_DELAY - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
reconnectDelay() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the Delay for node reconnects.
reconnectDelay(Delay) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the Delay for node reconnects (default value is a delay growing exponentially between 32ms and 4096ms).
reconnectDelay() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
record(I, long) - Method in class com.couchbase.client.core.metrics.AbstractLatencyMetricsCollector
record(I, long) - Method in interface com.couchbase.client.core.metrics.LatencyMetricsCollector: Records a latency for the given identifier.
refCnt() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
refCnt() - Method in class com.couchbase.client.core.message.view.GetDesignDocumentResponse
refCnt() - Method in class com.couchbase.client.core.message.view.RemoveDesignDocumentResponse
refCnt() - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentResponse
refCnt() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
refCnt() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest
refCnt() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse
refCnt() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent
refresh(ClusterConfig) - Method in class com.couchbase.client.core.config.refresher.CarrierRefresher
refresh(ClusterConfig) - Method in class com.couchbase.client.core.config.refresher.HttpRefresher
refresh(ClusterConfig) - Method in interface com.couchbase.client.core.config.refresher.Refresher: If pull based, refresh configs for registered buckets.
Refresher - Interface in com.couchbase.client.core.config.refresher: A Refresher keeps bucket configs up to date.
register(T, Stateful<S>) - Method in class com.couchbase.client.core.state.AbstractStateZipper
register(T, Stateful<S>) - Method in interface com.couchbase.client.core.state.StateZipper: Register the given stream to be zipped into the state computation.
registerBucket(String, String) - Method in class com.couchbase.client.core.config.refresher.AbstractRefresher
registerBucket(String, String) - Method in class com.couchbase.client.core.config.refresher.HttpRefresher
registerBucket(String, String) - Method in interface com.couchbase.client.core.config.refresher.Refresher: Registers a bucket to be watched for new configurations.
registrations() - Method in class com.couchbase.client.core.config.refresher.AbstractRefresher
release() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
release(int) - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
release() - Method in class com.couchbase.client.core.message.view.GetDesignDocumentResponse
release(int) - Method in class com.couchbase.client.core.message.view.GetDesignDocumentResponse
release() - Method in class com.couchbase.client.core.message.view.RemoveDesignDocumentResponse
release(int) - Method in class com.couchbase.client.core.message.view.RemoveDesignDocumentResponse
release() - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentResponse
release(int) - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentResponse
release() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
release(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
release() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest
release(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest
release() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse
release(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse
release() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent
release(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent
remoteHostname() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
remoteHttpHost(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Helper method to return the remote http host, cached.
remove(I) - Method in class com.couchbase.client.core.metrics.AbstractLatencyMetricsCollector: Helper method to remove an item out of the stored metrics.
RemoveBucketRequest - Class in com.couchbase.client.core.message.config
RemoveBucketRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.config.RemoveBucketRequest
RemoveBucketResponse - Class in com.couchbase.client.core.message.config
RemoveBucketResponse(ResponseStatus) - Constructor for class com.couchbase.client.core.message.config.RemoveBucketResponse
RemoveDesignDocumentRequest - Class in com.couchbase.client.core.message.view
RemoveDesignDocumentRequest(String, boolean, String, String) - Constructor for class com.couchbase.client.core.message.view.RemoveDesignDocumentRequest
RemoveDesignDocumentResponse - Class in com.couchbase.client.core.message.view
RemoveDesignDocumentResponse(ResponseStatus, ByteBuf, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.view.RemoveDesignDocumentResponse
RemoveMessage - Class in com.couchbase.client.core.message.dcp: A message representing event that removes or expires a document.
RemoveMessage(int, short, String, long, long, long, String) - Constructor for class com.couchbase.client.core.message.dcp.RemoveMessage
RemoveMessage(int, short, String, long, long, long, String, String) - Constructor for class com.couchbase.client.core.message.dcp.RemoveMessage
removeNode(InetAddress) - Method in class com.couchbase.client.core.RequestHandler: Remove a Node identified by its hostname.
RemoveNodeRequest - Class in com.couchbase.client.core.message.internal
RemoveNodeRequest(InetAddress) - Constructor for class com.couchbase.client.core.message.internal.RemoveNodeRequest
RemoveNodeResponse - Class in com.couchbase.client.core.message.internal
RemoveNodeResponse(ResponseStatus) - Constructor for class com.couchbase.client.core.message.internal.RemoveNodeResponse
RemoveRequest - Class in com.couchbase.client.core.message.kv
RemoveRequest(String, String) - Constructor for class com.couchbase.client.core.message.kv.RemoveRequest
RemoveRequest(String, long, String) - Constructor for class com.couchbase.client.core.message.kv.RemoveRequest
RemoveResponse - Class in com.couchbase.client.core.message.kv: Represents a response to a RemoveRequest.
RemoveResponse(ResponseStatus, short, long, String, ByteBuf, MutationToken, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.RemoveResponse
RemoveSearchIndexRequest - Class in com.couchbase.client.core.message.search: Removes full text search index.
RemoveSearchIndexRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.search.RemoveSearchIndexRequest
RemoveSearchIndexResponse - Class in com.couchbase.client.core.message.search: Result of full text search index removing.
RemoveSearchIndexResponse(String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.search.RemoveSearchIndexResponse
removeService(RemoveServiceRequest) - Method in class com.couchbase.client.core.node.CouchbaseNode
removeService(Service, String) - Method in class com.couchbase.client.core.node.DefaultServiceRegistry
removeService(RemoveServiceRequest) - Method in interface com.couchbase.client.core.node.Node
removeService(Service, String) - Method in interface com.couchbase.client.core.node.ServiceRegistry
removeService(RemoveServiceRequest) - Method in class com.couchbase.client.core.RequestHandler: Remove a service from a node.
RemoveServiceRequest - Class in com.couchbase.client.core.message.internal
RemoveServiceRequest(ServiceType, String, InetAddress) - Constructor for class com.couchbase.client.core.message.internal.RemoveServiceRequest
RemoveServiceResponse - Class in com.couchbase.client.core.message.internal
RemoveServiceResponse(ResponseStatus) - Constructor for class com.couchbase.client.core.message.internal.RemoveServiceResponse
removeStream(short) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnection
REPLACE - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
replaceHostWildcard(String, InetAddress) - Method in class com.couchbase.client.core.config.loader.AbstractLoader: Replaces the host wildcard from an incoming config with a proper hostname.
REPLACEQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
ReplaceRequest - Class in com.couchbase.client.core.message.kv
ReplaceRequest(String, ByteBuf, String) - Constructor for class com.couchbase.client.core.message.kv.ReplaceRequest: Creates a new ReplaceRequest.
ReplaceRequest(String, ByteBuf, String, boolean) - Constructor for class com.couchbase.client.core.message.kv.ReplaceRequest
ReplaceRequest(String, ByteBuf, long, String) - Constructor for class com.couchbase.client.core.message.kv.ReplaceRequest: Creates a new ReplaceRequest.
ReplaceRequest(String, ByteBuf, long, String, boolean) - Constructor for class com.couchbase.client.core.message.kv.ReplaceRequest
ReplaceRequest(String, ByteBuf, long, int, int, String) - Constructor for class com.couchbase.client.core.message.kv.ReplaceRequest: Creates a new ReplaceRequest.
ReplaceRequest(String, ByteBuf, long, int, int, String, boolean) - Constructor for class com.couchbase.client.core.message.kv.ReplaceRequest
ReplaceResponse - Class in com.couchbase.client.core.message.kv
ReplaceResponse(ResponseStatus, short, long, String, ByteBuf, MutationToken, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.ReplaceResponse
replica(int) - Method in class com.couchbase.client.core.config.DefaultPartition
replica(int) - Method in interface com.couchbase.client.core.config.Partition: Returns the replica index for this partition.
replica() - Method in class com.couchbase.client.core.message.kv.ObserveRequest
replica() - Method in class com.couchbase.client.core.message.kv.ObserveSeqnoRequest
replica() - Method in class com.couchbase.client.core.message.kv.ReplicaGetRequest
ReplicaGetRequest - Class in com.couchbase.client.core.message.kv: Fetch a document from one or more and/or active nodes replicas.
ReplicaGetRequest(String, String, short) - Constructor for class com.couchbase.client.core.message.kv.ReplicaGetRequest
ReplicaNotAvailableException - Exception in com.couchbase.client.core: This exception is thrown when the given operation targeting a specific replica is not fulfillable because the replica is not available (the node has been failed over or is marked as down).
ReplicaNotAvailableException() - Constructor for exception com.couchbase.client.core.ReplicaNotAvailableException
ReplicaNotAvailableException(String) - Constructor for exception com.couchbase.client.core.ReplicaNotAvailableException
ReplicaNotAvailableException(String, Throwable) - Constructor for exception com.couchbase.client.core.ReplicaNotAvailableException
ReplicaNotAvailableException(Throwable) - Constructor for exception com.couchbase.client.core.ReplicaNotAvailableException
ReplicaNotConfiguredException - Exception in com.couchbase.client.core: This exception is thrown when the given operation targeting a specific replica is not fulfillable because the replica is not configured (for example replica 2 is asked for, but only 1 is configured).
ReplicaNotConfiguredException() - Constructor for exception com.couchbase.client.core.ReplicaNotConfiguredException
ReplicaNotConfiguredException(String) - Constructor for exception com.couchbase.client.core.ReplicaNotConfiguredException
ReplicaNotConfiguredException(String, Throwable) - Constructor for exception com.couchbase.client.core.ReplicaNotConfiguredException
ReplicaNotConfiguredException(Throwable) - Constructor for exception com.couchbase.client.core.ReplicaNotConfiguredException
request() - Method in class com.couchbase.client.core.message.AbstractCouchbaseResponse: Stub method implementation which needs to be overriden by all responses that support cloning.
request() - Method in interface com.couchbase.client.core.message.CouchbaseResponse: Potentially has the associated request attached.
request() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiLookupResponse
request() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse
request() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SimpleSubdocResponse
request() - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
REQUEST_BUFFER_SIZE - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
REQUEST_MAGIC_BYTE - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest: Default magic byte for a request.
requestBufferSize() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the size of the request ringbuffer.
requestBufferSize(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the size of the RingBuffer structure that queues requests (default value ).
requestBufferSize() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
requestBufferWaitStrategy() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Waiting strategy used by request EventProcessors to wait for data from RingBuffer
requestBufferWaitStrategy(WaitStrategyFactory) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets a custom waiting strategy for requests.
requestBufferWaitStrategy() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
RequestCancelledException - Exception in com.couchbase.client.core
RequestCancelledException() - Constructor for exception com.couchbase.client.core.RequestCancelledException
RequestCancelledException(String) - Constructor for exception com.couchbase.client.core.RequestCancelledException
RequestCancelledException(String, Throwable) - Constructor for exception com.couchbase.client.core.RequestCancelledException
RequestCancelledException(Throwable) - Constructor for exception com.couchbase.client.core.RequestCancelledException
RequestEvent - Class in com.couchbase.client.core: A pre allocated event which carries a CouchbaseRequest and associated information.
RequestEvent() - Constructor for class com.couchbase.client.core.RequestEvent
RequestEventFactory - Class in com.couchbase.client.core: A factory to preallocate RequestEvents.
RequestEventFactory() - Constructor for class com.couchbase.client.core.RequestEventFactory
RequestHandler - Class in com.couchbase.client.core: The RequestHandler is responsible for adding and removing Nodes as well as dispatching Service management operations.
RequestHandler(CoreEnvironment, Observable<ClusterConfig>, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.RequestHandler: Create a new RequestHandler.
requestId() - Method in class com.couchbase.client.core.message.query.GenericQueryResponse
resetDecoder() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheDecoder: Prepare for next decoding iteration.
RESPONSE_BUFFER_SIZE - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
RESPONSE_MAGIC_BYTE - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheResponse: Default magic byte for a request.
RESPONSE_TRANSLATOR - Static variable in class com.couchbase.client.core.ResponseHandler: Translates CouchbaseRequests into RequestEvents.
responseBuffer() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint: The RingBuffer response buffer reference.
responseBufferSize() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the size of the response ringbuffer.
responseBufferSize(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the size of the RingBuffer structure that queues responses (default value ).
responseBufferSize() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
responseCode() - Method in class com.couchbase.client.core.message.view.ViewQueryResponse
ResponseEvent - Class in com.couchbase.client.core: A pre allocated event which carries a CouchbaseResponse and associated information.
ResponseEvent() - Constructor for class com.couchbase.client.core.ResponseEvent
ResponseEventFactory - Class in com.couchbase.client.core: A factory to preallocate ResponseEvents.
ResponseEventFactory() - Constructor for class com.couchbase.client.core.ResponseEventFactory
ResponseHandler - Class in com.couchbase.client.core
ResponseHandler(CoreEnvironment, ClusterFacade, ConfigurationProvider) - Constructor for class com.couchbase.client.core.ResponseHandler: Creates a new ResponseHandler.
responsePhrase() - Method in class com.couchbase.client.core.message.view.ViewQueryResponse
responses() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiLookupResponse
responses() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse
ResponseStatus - Enum in com.couchbase.client.core.message: Typesafe status code returned by CouchbaseResponses.
ResponseStatusConverter - Class in com.couchbase.client.core.endpoint: Helper class to easily convert different handler status types to a common one.
ResponseStatusConverter() - Constructor for class com.couchbase.client.core.endpoint.ResponseStatusConverter
retain() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
retain(int) - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
retain() - Method in class com.couchbase.client.core.message.view.GetDesignDocumentResponse
retain(int) - Method in class com.couchbase.client.core.message.view.GetDesignDocumentResponse
retain() - Method in class com.couchbase.client.core.message.view.RemoveDesignDocumentResponse
retain(int) - Method in class com.couchbase.client.core.message.view.RemoveDesignDocumentResponse
retain() - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentResponse
retain(int) - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentResponse
retain() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
retain(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
retain() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest
retain(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest
retain() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheResponse
retain(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheResponse
retain() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest
retain(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheRequest
retain() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse
retain(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultFullBinaryMemcacheResponse
retain(int) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.FullBinaryMemcacheRequest
retain() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.FullBinaryMemcacheRequest
retain(int) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.FullBinaryMemcacheResponse
retain() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.FullBinaryMemcacheResponse
retain() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultLastMemcacheContent
retain(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultLastMemcacheContent
retain() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent
retain(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent
retain(int) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.FullMemcacheMessage
retain() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.FullMemcacheMessage
retain(int) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.LastMemcacheContent
retain() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.LastMemcacheContent
RETRY_DELAY - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
RETRY_STRATEGY - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
retryCount() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
retryCount() - Method in interface com.couchbase.client.core.message.CouchbaseRequest: Returns the current retry count.
retryDelay() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the Delay for request retries.
retryDelay(Delay) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the Delay for retries of requests (default value is a delay growing exponentially between 100us and 100ms).
retryDelay() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
RetryHelper - Class in com.couchbase.client.core.retry: A helper class which contains methods related to retrying operations.
RetryHelper() - Constructor for class com.couchbase.client.core.retry.RetryHelper
retryOrCancel(CoreEnvironment, CouchbaseRequest, RingBuffer<ResponseEvent>) - Static method in class com.couchbase.client.core.retry.RetryHelper: Either retry or cancel a request, based on the strategy used.
retryStrategy() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The retry strategy on how to dispatch requests in the failure case.
retryStrategy(RetryStrategy) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the RetryStrategy to be used during request retries (default value is a BestEffortRetryStrategy).
retryStrategy() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
RetryStrategy - Interface in com.couchbase.client.core.retry: Base interface for all RetryStrategy implementations.
rev() - Method in interface com.couchbase.client.core.config.BucketConfig: Revision number (optional) for that configuration.
rev() - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
rev() - Method in class com.couchbase.client.core.config.DefaultMemcachedBucketConfig
revisionSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.ExpirationMessage
revisionSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.MutationMessage
revisionSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.RemoveMessage
rollbackToSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.StreamRequestResponse
rows() - Method in class com.couchbase.client.core.message.query.GenericQueryResponse: Contains one ByteBuf for each result item returned by the server.
rows() - Method in class com.couchbase.client.core.message.view.ViewQueryResponse
RUNTIME_BEAN - Static variable in class com.couchbase.client.core.env.Diagnostics
runtimeInfo(Map<String, Object>) - Static method in class com.couchbase.client.core.env.Diagnostics: Collects system information as delivered from the RuntimeMXBean.
runtimeMetricsCollector() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the collector responsible for aggregating and publishing runtime information like gc and memory.
runtimeMetricsCollector() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
RuntimeMetricsCollector - Class in com.couchbase.client.core.metrics: A MetricsCollector which collects and emits system information like gc, memory or thread usage.
RuntimeMetricsCollector(EventBus, Scheduler, MetricsCollectorConfig) - Constructor for class com.couchbase.client.core.metrics.RuntimeMetricsCollector
runtimeMetricsCollectorConfig(MetricsCollectorConfig) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets a custom configuration for the RuntimeMetricsCollector.
RuntimeMetricsEvent - Class in com.couchbase.client.core.event.metrics: This event contains collected system stats, like GC, Thread and Memory usage.
RuntimeMetricsEvent(Map<String, Object>) - Constructor for class com.couchbase.client.core.event.metrics.RuntimeMetricsEvent

S

Sasl - Class in com.couchbase.client.core.security.sasl: A wrapper for Sasl which first tries the mechanisms that are supported out of the box and then tries our extended range (provided by ShaSaslClient.
Sasl() - Constructor for class com.couchbase.client.core.security.sasl.Sasl
SASL_AUTH - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
SASL_LIST_MECHS - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
SASL_LIST_MECHS_OPCODE - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler: The memcache opcode for the SASL mechs list.
SASL_STEP - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
scheduleDirect(Action0) - Method in class com.couchbase.client.core.env.CoreScheduler: Schedules the action directly on one of the event loop workers without the additional infrastructure and checking.
scheduler() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the scheduler which should be used for all core actions that need to happen asynchronously.
scheduler(Scheduler) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Deprecated.
use DefaultCoreEnvironment.Builder.ioPool(EventLoopGroup, ShutdownHook) to also provide a shutdown hook.
scheduler(Scheduler, ShutdownHook) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the Scheduler implementation for the underlying computation framework, along with the action to execute when this environment is shut down.
scheduler() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
SEARCH_ENDPOINTS - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
SearchEndpoint - Class in com.couchbase.client.core.endpoint.search: This endpoint defines the pipeline for search requests and responses (CBFT).
SearchEndpoint(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.endpoint.search.SearchEndpoint
searchEndpoints() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The number of search service endpoints.
searchEndpoints(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the number of Search (CBFT) endpoints to open per node in the cluster (default value ).
searchEndpoints() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
SearchHandler - Class in com.couchbase.client.core.endpoint.search: The SearchHandler is responsible for encoding SearchRequests into lower level HttpRequests as well as decoding HttpObjects into CouchbaseResponses.
SearchHandler(AbstractEndpoint, EventSink<ResponseEvent>, boolean) - Constructor for class com.couchbase.client.core.endpoint.search.SearchHandler
SearchLocator - Class in com.couchbase.client.core.node.locate: Round robin node locator for CBFT.
SearchLocator() - Constructor for class com.couchbase.client.core.node.locate.SearchLocator
SearchQueryRequest - Class in com.couchbase.client.core.message.search: Runs query against search index.
SearchQueryRequest(String, String, String, String) - Constructor for class com.couchbase.client.core.message.search.SearchQueryRequest
SearchQueryResponse - Class in com.couchbase.client.core.message.search: Result of the full text search query.
SearchQueryResponse(String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.search.SearchQueryResponse
SearchRequest - Interface in com.couchbase.client.core.message.search: Common marker interface for all SearchRequests.
SearchService - Class in com.couchbase.client.core.service
SearchService(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.service.SearchService: Creates a new ViewService.
seedHosts(Set<InetAddress>, boolean) - Method in interface com.couchbase.client.core.config.ConfigurationProvider: Set the initial seed hosts for bootstrap.
seedHosts(Set<InetAddress>, boolean) - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
SeedNodesRequest - Class in com.couchbase.client.core.message.cluster: Set up the bootstrap nodes for a ClusterFacade.
SeedNodesRequest() - Constructor for class com.couchbase.client.core.message.cluster.SeedNodesRequest: Creates a SeedNodesRequest with the default hostname (“localhost”).
SeedNodesRequest(String...) - Constructor for class com.couchbase.client.core.message.cluster.SeedNodesRequest: Creates a SeedNodesRequest with the given hostnames.
SeedNodesRequest(List<String>) - Constructor for class com.couchbase.client.core.message.cluster.SeedNodesRequest: Creates a SeedNodesRequest with the given list of hostnames.
SeedNodesResponse - Class in com.couchbase.client.core.message.cluster: Returns the status of a SeedNodesRequest.
SeedNodesResponse(ResponseStatus) - Constructor for class com.couchbase.client.core.message.cluster.SeedNodesResponse: Create a new SeedNodesResponse.
select(CouchbaseRequest, Endpoint[]) - Method in class com.couchbase.client.core.service.strategies.PartitionSelectionStrategy
select(CouchbaseRequest, Endpoint[]) - Method in class com.couchbase.client.core.service.strategies.RandomSelectionStrategy
select(CouchbaseRequest, Endpoint[]) - Method in interface com.couchbase.client.core.service.strategies.SelectionStrategy: Selects an Endpoint for the given CouchbaseRequest.
SelectionStrategy - Interface in com.couchbase.client.core.service.strategies: Interface which defines a generic selection strategy to select a Endpoint.
send(CouchbaseRequest) - Method in interface com.couchbase.client.core.ClusterFacade: Sends a CouchbaseRequest into the cluster and eventually returns a CouchbaseResponse.
send(CouchbaseRequest) - Method in class com.couchbase.client.core.CouchbaseCore
send(CouchbaseRequest) - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
send(CouchbaseRequest) - Method in interface com.couchbase.client.core.endpoint.Endpoint: Sends a CouchbaseRequest into the endpoint and eventually returns a CouchbaseResponse.
send(CouchbaseRequest) - Method in class com.couchbase.client.core.node.CouchbaseNode
send(CouchbaseRequest) - Method in interface com.couchbase.client.core.node.Node: Sends a CouchbaseRequest into the node and eventually returns a CouchbaseResponse.
send(CouchbaseRequest) - Method in class com.couchbase.client.core.service.AbstractDynamicService
send(CouchbaseRequest) - Method in interface com.couchbase.client.core.service.Service: Sends a CouchbaseRequest into the service and eventually returns a CouchbaseResponse.
sendTo() - Method in interface com.couchbase.client.core.message.PrelocatedRequest: The node to send this request to, or null to use default node location process.
sendTo() - Method in class com.couchbase.client.core.message.query.GenericQueryRequest
sequenceNumber() - Method in class com.couchbase.client.core.message.dcp.FailoverLogEntry
sequenceNumber() - Method in class com.couchbase.client.core.message.dcp.GetLastCheckpointResponse: Each mutation that occurs on a vBucket is assigned a number, which strictly increases as events are assigned sequence numbers, that can be used to order that event against other mutations within the same vBucket.
sequenceNumber() - Method in class com.couchbase.client.core.message.kv.MutationToken
ServerFeatures - Enum in com.couchbase.client.core.endpoint: Features the client negotiates with the server on a per-connection basis.
ServerFeaturesEvent - Class in com.couchbase.client.core.endpoint: An event sent by the KeyValueFeatureHandler to list all the negotiated features.
ServerFeaturesEvent(List<ServerFeatures>) - Constructor for class com.couchbase.client.core.endpoint.ServerFeaturesEvent
serverStatusCode() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
serverStatusCode() - Method in interface com.couchbase.client.core.message.kv.BinaryResponse
service() - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
Service - Interface in com.couchbase.client.core.service: Represents a Service on a Node.
Service.EndpointFactory - Interface in com.couchbase.client.core.service: A helper factory which generates endpoints.
serviceBy(ServiceType, String) - Method in class com.couchbase.client.core.node.DefaultServiceRegistry
serviceBy(ServiceType, String) - Method in interface com.couchbase.client.core.node.ServiceRegistry
serviceEnabled(ServiceType) - Method in class com.couchbase.client.core.config.AbstractBucketConfig
serviceEnabled(ServiceType) - Method in interface com.couchbase.client.core.config.BucketConfig: Check if the service is enabled on the bucket.
serviceEnabled(ServiceType) - Method in class com.couchbase.client.core.node.CouchbaseNode
serviceEnabled(ServiceType) - Method in interface com.couchbase.client.core.node.Node: True if the given ServiceType is currently enabled on this node, false otherwise.
ServiceFactory - Class in com.couchbase.client.core.service
ServiceNotAvailableException - Exception in com.couchbase.client.core: Exception which states that the service is not available for the bucket.
ServiceNotAvailableException() - Constructor for exception com.couchbase.client.core.ServiceNotAvailableException
ServiceNotAvailableException(String) - Constructor for exception com.couchbase.client.core.ServiceNotAvailableException
ServiceNotAvailableException(String, Throwable) - Constructor for exception com.couchbase.client.core.ServiceNotAvailableException
ServiceNotAvailableException(Throwable) - Constructor for exception com.couchbase.client.core.ServiceNotAvailableException
ServiceRegistry - Interface in com.couchbase.client.core.node: Handles the registration of services and their associated buckets.
services() - Method in class com.couchbase.client.core.config.DefaultNodeInfo
services() - Method in interface com.couchbase.client.core.config.NodeInfo: The exposed non-ssl services.
services() - Method in class com.couchbase.client.core.node.DefaultServiceRegistry
services() - Method in interface com.couchbase.client.core.node.ServiceRegistry: Returns all currently stored services, across buckets and globally.
ServiceStateZipper - Class in com.couchbase.client.core.node: Calculates a merged state for all registered services.
ServiceStateZipper(LifecycleState) - Constructor for class com.couchbase.client.core.node.ServiceStateZipper
serviceType() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: Returns the ServiceType associated with this handler.
serviceType() - Method in class com.couchbase.client.core.endpoint.config.ConfigHandler
serviceType() - Method in class com.couchbase.client.core.endpoint.dcp.DCPHandler
serviceType() - Method in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
serviceType() - Method in class com.couchbase.client.core.endpoint.query.QueryHandler
serviceType() - Method in class com.couchbase.client.core.endpoint.search.SearchHandler
serviceType() - Method in class com.couchbase.client.core.endpoint.view.ViewHandler
ServiceType - Enum in com.couchbase.client.core.service: Represents the different ServiceTypes and how they map onto buckets.
SET - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
setBucketConfig(String, BucketConfig) - Method in interface com.couchbase.client.core.config.ClusterConfig: Set a bucket config for the given bucket name.
setBucketConfig(String, BucketConfig) - Method in class com.couchbase.client.core.config.DefaultClusterConfig
setCAS(long) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setCAS(long) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Sets the CAS identifier.
setDataType(byte) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setDataType(byte) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Sets the data type of the message.
setDecoderResult(DecoderResult) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObject
setDecoderResult(DecoderResult) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.MemcacheObject: Updates the result of decoding this message.
setDefaultFactory(CouchbaseLoggerFactory) - Static method in class com.couchbase.client.core.logging.CouchbaseLoggerFactory: Changes the default factory.
setExtras(ByteBuf) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setExtras(ByteBuf) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Sets the extras buffer on the message.
setExtrasLength(byte) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setExtrasLength(byte) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Set the extras length of the message.
setKey(byte[]) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setKey(byte[]) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Sets the key of the document.
setKeyLength(short) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setKeyLength(short) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Set the key length of the message.
setMagic(byte) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setMagic(byte) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Sets the magic byte.
setMaxCumulationBufferComponents(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator: Sets the maximum number of components in the cumulation buffer.
setMessage(CouchbaseMessage) - Method in class com.couchbase.client.core.ResponseEvent: Set the new response as a payload for this event.
setObservable(Subject<CouchbaseResponse, CouchbaseResponse>) - Method in class com.couchbase.client.core.ResponseEvent
setOpaque(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setOpaque(int) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Sets the opaque value.
setOpcode(byte) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setOpcode(byte) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Sets the opcode for the message.
SETQ - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
setRequest(CouchbaseRequest) - Method in class com.couchbase.client.core.RequestEvent: Set the new request as a payload for this event.
setReserved(short) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheRequest: Sets the reserved field value.
setReserved(short) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest
setStatus(short) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponse: Sets the status of the response.
setStatus(short) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheResponse
setTotalBodyLength(int) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
setTotalBodyLength(int) - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage: Sets the total body length.
ShaSaslClient - Class in com.couchbase.client.core.security.sasl: Implementation of a SCRAM-SHA512, SCRAM-SHA256 and SCRAM-SHA1 enabled SaslClient.
ShaSaslClient(CallbackHandler, int) - Constructor for class com.couchbase.client.core.security.sasl.ShaSaslClient
ShaSaslClientFactory - Class in com.couchbase.client.core.security.sasl: The SaslClientFactory supporting SCRAM-SHA512, SCRAM-SHA256 and SCRAM-SHA1 authentication methods.
ShaSaslClientFactory() - Constructor for class com.couchbase.client.core.security.sasl.ShaSaslClientFactory
shouldRetry(CouchbaseRequest, CoreEnvironment) - Method in class com.couchbase.client.core.retry.BestEffortRetryStrategy
shouldRetry(CouchbaseRequest, CoreEnvironment) - Method in class com.couchbase.client.core.retry.FailFastRetryStrategy
shouldRetry(CouchbaseRequest, CoreEnvironment) - Method in interface com.couchbase.client.core.retry.RetryStrategy: Decides whether the given CouchbaseRequest should be retried or cancelled.
shouldRetryObserve() - Method in class com.couchbase.client.core.retry.BestEffortRetryStrategy
shouldRetryObserve() - Method in class com.couchbase.client.core.retry.FailFastRetryStrategy
shouldRetryObserve() - Method in interface com.couchbase.client.core.retry.RetryStrategy: Decides whether ObserveRequests should be retried or cancelled when an error happens.
shutdown() - Method in class com.couchbase.client.core.config.refresher.CarrierRefresher
shutdown() - Method in class com.couchbase.client.core.config.refresher.HttpRefresher
shutdown() - Method in interface com.couchbase.client.core.config.refresher.Refresher: Shuts down all open registration streams.
shutdown() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Shutdown the CoreEnvironment with the default timeout.
shutdown(long, TimeUnit) - Method in interface com.couchbase.client.core.env.CoreEnvironment: Shutdown the CoreEnvironment with a custom timeout.
shutdown() - Method in class com.couchbase.client.core.env.CoreScheduler
shutdown() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
shutdown(long, TimeUnit) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
shutdown() - Method in class com.couchbase.client.core.env.resources.IoPoolShutdownHook
shutdown() - Method in class com.couchbase.client.core.env.resources.NettyShutdownHook
shutdown() - Method in class com.couchbase.client.core.env.resources.NoOpShutdownHook
shutdown() - Method in interface com.couchbase.client.core.env.resources.ShutdownHook
shutdown() - Method in class com.couchbase.client.core.metrics.AbstractMetricsCollector
shutdown() - Method in interface com.couchbase.client.core.metrics.MetricsCollector: Shuts down the collector (non-reversible) and frees bound resources.
shutdownAsync() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Shutdown the CoreEnvironment in an asynchronous fashion.
shutdownAsync() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
ShutdownHook - Interface in com.couchbase.client.core.env.resources: Interface to describe shutdown behavior for a resource that can be asynchronously shut down.
sideEffectRequestToCancel(REQUEST) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler: This method can be overridden as it is called every time an operation is cancelled.
sideEffectRequestToCancel(BinaryRequest) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueHandler: Releasing the content of requests that are to be cancelled.
signalConfigReload() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint: Signal a “config reload” event to the upper config layers.
SignalConfigReload - Class in com.couchbase.client.core.message.internal
SignalFlush - Class in com.couchbase.client.core.message.internal
signalOutdated() - Method in interface com.couchbase.client.core.config.ConfigurationProvider
signalOutdated() - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
signature() - Method in class com.couchbase.client.core.message.query.GenericQueryResponse: Contains a single ByteBuf representing the N1QL json signature of the results.
simpleStatement(String, String, String) - Static method in class com.couchbase.client.core.message.query.GenericQueryRequest: Creates a GenericQueryRequest and mark it as containing a single simple statement (e.g.
SimpleSubdocResponse - Class in com.couchbase.client.core.message.kv.subdoc.simple: A general-purpose response suitable for most “simple” sub-document operations (BinarySubdocRequest and BinarySubdocMutationRequest), as opposed to “multi-specification” sub-document operations.
SimpleSubdocResponse(ResponseStatus, short, String, ByteBuf, BinarySubdocRequest, long, MutationToken) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SimpleSubdocResponse
Slf4JLoggerFactory - Class in com.couchbase.client.core.logging: Logger factory which creates a SLF4J logger.
Slf4JLoggerFactory() - Constructor for class com.couchbase.client.core.logging.Slf4JLoggerFactory
snapshotEndSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.StreamRequestRequest
SnapshotMarkerMessage - Class in com.couchbase.client.core.message.dcp: Snapshot marker.
SnapshotMarkerMessage(int, short, long, long, int, String) - Constructor for class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
SnapshotMarkerMessage(int, short, long, long, int, String, String) - Constructor for class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
snapshotStartSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.StreamRequestRequest
SOCKET_CONNECT_TIMEOUT - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
socketConnectTimeout() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns the amount of time the SDK will wait on the socket connect until an error is raised and handled.
socketConnectTimeout(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets a custom socket connect timeout.
socketConnectTimeout() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
spatial() - Method in class com.couchbase.client.core.message.view.ViewQueryRequest
SplitPositionBufProcessor - Class in com.couchbase.client.core.endpoint.util: A ByteBufProcessor to find the position of a single character usable as a split pivot.
SplitPositionBufProcessor(char) - Constructor for class com.couchbase.client.core.endpoint.util.SplitPositionBufProcessor
SplitPositionBufProcessor(char, boolean) - Constructor for class com.couchbase.client.core.endpoint.util.SplitPositionBufProcessor
SSL_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
SSL_KEYSTORE - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
SSL_KEYSTORE_FILE - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
SSL_KEYSTORE_PASSWORD - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
sslEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Identifies if SSL should be enabled.
sslEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Set if SSL should be enabled (default value ).
sslEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
SSLEngineFactory - Class in com.couchbase.client.core.endpoint: Creates a SSLEngine which will be passed into the handler if SSL is enabled.
SSLEngineFactory(CoreEnvironment) - Constructor for class com.couchbase.client.core.endpoint.SSLEngineFactory: Create a new engine factory.
SSLException - Exception in com.couchbase.client.core.endpoint: Generic SSLException.
SSLException() - Constructor for exception com.couchbase.client.core.endpoint.SSLException
SSLException(String) - Constructor for exception com.couchbase.client.core.endpoint.SSLException
SSLException(String, Throwable) - Constructor for exception com.couchbase.client.core.endpoint.SSLException
SSLException(Throwable) - Constructor for exception com.couchbase.client.core.endpoint.SSLException
sslKeystore() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Allows to directly configure a KeyStore.
sslKeystore(KeyStore) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the SSL Keystore directly and not indirectly via filepath.
sslKeystore() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
sslKeystoreFile() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Identifies the filepath to the ssl keystore.
sslKeystoreFile(String) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Defines the location of the SSL Keystore file (default value null, none).
sslKeystoreFile() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
sslKeystorePassword() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The password which is used to protect the keystore.
sslKeystorePassword(String) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the SSL Keystore password to be used with the Keystore file (default value null, none).
sslKeystorePassword() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
sslPorts() - Method in class com.couchbase.client.core.config.DefaultPortInfo
sslPorts() - Method in interface com.couchbase.client.core.config.PortInfo
sslServices() - Method in class com.couchbase.client.core.config.DefaultNodeInfo
sslServices() - Method in interface com.couchbase.client.core.config.NodeInfo: The exposed ssl services.
start() - Method in class com.couchbase.client.core.env.CoreScheduler
startSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
startSequenceNumber() - Method in class com.couchbase.client.core.message.dcp.StreamRequestRequest
Stat - Class in com.couchbase.client.core.message.stat: Utility class to handle STAT calls logic.
Stat() - Constructor for class com.couchbase.client.core.message.stat.Stat
STAT - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
state() - Method in class com.couchbase.client.core.state.AbstractStateMachine
state() - Method in interface com.couchbase.client.core.state.Stateful: Returns the current state.
Stateful<S extends Enum> - Interface in com.couchbase.client.core.state: A stateful component that changes its state and notifies subscribed parties.
states() - Method in class com.couchbase.client.core.state.AbstractStateMachine
states() - Method in interface com.couchbase.client.core.state.Stateful: Returns a infinite observable which gets updated when the state of the component changes.
StateZipper<T,S extends Enum> - Interface in com.couchbase.client.core.state: Describes a generic StateZipper.
StatRequest - Class in com.couchbase.client.core.message.kv
StatRequest(String, InetAddress, String) - Constructor for class com.couchbase.client.core.message.kv.StatRequest
StatResponse - Class in com.couchbase.client.core.message.kv
StatResponse(ResponseStatus, short, String, String, String, String, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.StatResponse
status() - Method in class com.couchbase.client.core.message.AbstractCouchbaseResponse
status() - Method in interface com.couchbase.client.core.message.CouchbaseResponse: The typesafe status of the response.
status() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult: Returns the individual operation’s status.
status() - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
statusCode() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
StreamCloseRequest - Class in com.couchbase.client.core.message.dcp
StreamCloseRequest(short, String, String) - Constructor for class com.couchbase.client.core.message.dcp.StreamCloseRequest
StreamCloseResponse - Class in com.couchbase.client.core.message.dcp
StreamCloseResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.dcp.StreamCloseResponse: Sets the required properties for the response.
StreamEndMessage - Class in com.couchbase.client.core.message.dcp
StreamEndMessage(int, short, StreamEndMessage.Reason, String) - Constructor for class com.couchbase.client.core.message.dcp.StreamEndMessage
StreamEndMessage(int, short, StreamEndMessage.Reason, String, String) - Constructor for class com.couchbase.client.core.message.dcp.StreamEndMessage
StreamEndMessage.Reason - Enum in com.couchbase.client.core.message.dcp
streamingUri() - Method in class com.couchbase.client.core.config.AbstractBucketConfig
streamingUri() - Method in interface com.couchbase.client.core.config.BucketConfig: The HTTP Streaming URI for this bucket.
StreamRequestRequest - Class in com.couchbase.client.core.message.dcp: Stream request.
StreamRequestRequest(short, long, long, long, long, long, String, String, DCPConnection) - Constructor for class com.couchbase.client.core.message.dcp.StreamRequestRequest
StreamRequestResponse - Class in com.couchbase.client.core.message.dcp
StreamRequestResponse(ResponseStatus, List<FailoverLogEntry>, long, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.dcp.StreamRequestResponse: Sets the required properties for the response.
StringClosingPositionBufProcessor - Class in com.couchbase.client.core.endpoint.util: A ByteBufProcessor to find the closing position of a JSON string.
StringClosingPositionBufProcessor() - Constructor for class com.couchbase.client.core.endpoint.util.StringClosingPositionBufProcessor
stringPropertyOr(String, String) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
SubArrayRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: A request covering all sub-document array operations (see SubArrayRequest.ArrayOperation).
SubArrayRequest(String, String, SubArrayRequest.ArrayOperation, ByteBuf, String, int, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest: Creates a new SubArrayRequest of type arrayOp.
SubArrayRequest(String, String, SubArrayRequest.ArrayOperation, ByteBuf, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest: Creates a new SubArrayRequest of type arrayOp.
SubArrayRequest.ArrayOperation - Enum in com.couchbase.client.core.message.kv.subdoc.simple
SubCounterRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: A sub-document counter operation.
SubCounterRequest(String, String, long, String, int, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubCounterRequest: Creates a new SubCounterRequest.
SubCounterRequest(String, String, long, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubCounterRequest: Creates a new SubCounterRequest.
SubDeleteRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: A sub-document delete operation.
SubDeleteRequest(String, String, String, int, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubDeleteRequest: Creates a new SubDeleteRequest.
SubDeleteRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubDeleteRequest: Creates a new SubDeleteRequest.
SubDictAddRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: A sub-document dictionary add operation.
SubDictAddRequest(String, String, ByteBuf, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubDictAddRequest: Creates a new SubDictAddRequest.
SubDictAddRequest(String, String, ByteBuf, String, int, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubDictAddRequest: Creates a new SubDictAddRequest.
SubDictUpsertRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: A sub-document dictionnary upsert operation.
SubDictUpsertRequest(String, String, ByteBuf, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubDictUpsertRequest: Creates a new SubDictUpsertRequest.
SubDictUpsertRequest(String, String, ByteBuf, String, int, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubDictUpsertRequest: Creates a new SubDictUpsertRequest.
SUBDOC_BITMASK_MKDIR_P - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler: The bitmask for sub-document extras “command” section (third byte of the extras) that activates the creation of missing intermediate nodes in the JSON path.
SubExistRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: A sub-document exist operation.
SubExistRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubExistRequest: Creates a new SubExistRequest.
SubGetRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: A sub-document get operation.
SubGetRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubGetRequest: Creates a new SubGetRequest.
subject() - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnection
SubMultiLookupRequest - Class in com.couchbase.client.core.message.kv.subdoc.multi: Concrete implementation of a BinarySubdocMultiLookupRequest.
SubMultiLookupRequest(String, String, LookupCommand...) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiLookupRequest: Creates a new SubMultiLookupRequest.
SubMultiMutationRequest - Class in com.couchbase.client.core.message.kv.subdoc.multi: Concrete implementation of a BinarySubdocMultiMutationRequest.
SubMultiMutationRequest(String, String, int, long, List<MutationCommand>) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationRequest: Create a new SubMultiMutationRequest.
SubMultiMutationRequest(String, String, int, long, MutationCommand...) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationRequest: Create a new SubMultiMutationRequest.
SubMultiMutationRequest(String, String, List<MutationCommand>) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationRequest: Create a new SubMultiMutationRequest.
SubMultiMutationRequest(String, String, MutationCommand...) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationRequest: Create a new SubMultiMutationRequest.
SubReplaceRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple: A sub-document replace operation.
SubReplaceRequest(String, String, ByteBuf, String, int, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubReplaceRequest: Creates a new SubReplaceRequest.
SubReplaceRequest(String, String, ByteBuf, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.SubReplaceRequest: Creates a new SubReplaceRequest.
SUCCESS - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
supportedFeatures() - Method in class com.couchbase.client.core.endpoint.ServerFeaturesEvent
swap() - Method in class com.couchbase.client.core.lang.Tuple2: Create a new Tuple2 where the two values are swapped.
systemInfo(Map<String, Object>) - Static method in class com.couchbase.client.core.env.Diagnostics: Collects system information as delivered from the OperatingSystemMXBean.

T

tainted() - Method in interface com.couchbase.client.core.config.BucketConfig: If a config is marked as tainted.
tainted() - Method in class com.couchbase.client.core.config.CouchbasePartitionInfo
tainted() - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
tainted() - Method in class com.couchbase.client.core.config.DefaultMemcachedBucketConfig
TARGET_PERCENTILES - Static variable in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
TARGET_UNIT - Static variable in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
targetPercentiles(Double[]) - Method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig.Builder: Overrides the emitted percentiles.
targetPercentiles() - Method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
targetPercentiles() - Method in interface com.couchbase.client.core.metrics.LatencyMetricsCollectorConfig: The percentiles which should be exposed in the metric.
targetUnit(TimeUnit) - Method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig.Builder: Overrides the target unit for the latencies recorded.
targetUnit() - Method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
targetUnit() - Method in interface com.couchbase.client.core.metrics.LatencyMetricsCollectorConfig: The target unit for the emitted latencies.
TCP_NODELAY_ENALED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
tcpNodelayEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Returns true if TCP_NODELAY is enabled (therefore Nagle’ing is disabled).
tcpNodelayEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: If TCP_NODELAY is manually disabled, Nagle’ing will take effect on both the client and (if supported) the server side.
tcpNodelayEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
terminate() - Method in class com.couchbase.client.core.state.AbstractStateZipper
terminate() - Method in interface com.couchbase.client.core.state.StateZipper: Terminate the zipper and deregister all registered streams.
THREAD_BEAN - Static variable in class com.couchbase.client.core.env.Diagnostics
threadInfo(Map<String, Object>) - Static method in class com.couchbase.client.core.env.Diagnostics: Collects system information as delivered from the ThreadMXBean.
timeUnit() - Method in class com.couchbase.client.core.event.metrics.LatencyMetric: Returns the time unit for the percentiles, min and max values.
toJson(CouchbaseEvent, boolean) - Static method in class com.couchbase.client.core.utils.Events: Takes a CouchbaseEvent and generates a JSON string.
toMap() - Method in interface com.couchbase.client.core.event.CouchbaseEvent: Converts the event into a map representation of simple types.
toMap() - Method in class com.couchbase.client.core.event.metrics.NetworkLatencyMetricsEvent
toMap() - Method in class com.couchbase.client.core.event.metrics.RuntimeMetricsEvent
toMap() - Method in class com.couchbase.client.core.event.system.BucketClosedEvent
toMap() - Method in class com.couchbase.client.core.event.system.BucketOpenedEvent
toMap() - Method in class com.couchbase.client.core.event.system.ConfigUpdatedEvent
toMap() - Method in class com.couchbase.client.core.event.system.NodeConnectedEvent
toMap() - Method in class com.couchbase.client.core.event.system.NodeDisconnectedEvent
toString() - Method in class com.couchbase.client.core.config.CouchbasePartitionInfo
toString() - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
toString() - Method in class com.couchbase.client.core.config.DefaultMemcachedBucketConfig
toString() - Method in class com.couchbase.client.core.config.DefaultNodeInfo
toString() - Method in class com.couchbase.client.core.config.DefaultPartition
toString() - Method in class com.couchbase.client.core.config.DefaultPortInfo
toString() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
toString() - Method in class com.couchbase.client.core.event.metrics.LatencyMetric
toString() - Method in class com.couchbase.client.core.event.metrics.LatencyMetricsEvent
toString() - Method in class com.couchbase.client.core.event.metrics.NetworkLatencyMetricsEvent
toString() - Method in class com.couchbase.client.core.event.metrics.RuntimeMetricsEvent
toString() - Method in class com.couchbase.client.core.event.system.BucketClosedEvent
toString() - Method in class com.couchbase.client.core.event.system.BucketOpenedEvent
toString() - Method in class com.couchbase.client.core.event.system.ConfigUpdatedEvent
toString() - Method in class com.couchbase.client.core.event.system.NodeConnectedEvent
toString() - Method in class com.couchbase.client.core.event.system.NodeDisconnectedEvent
toString() - Method in class com.couchbase.client.core.lang.Tuple2
toString() - Method in class com.couchbase.client.core.lang.Tuple3
toString() - Method in class com.couchbase.client.core.lang.Tuple4
toString() - Method in class com.couchbase.client.core.lang.Tuple5
toString() - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
toString() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
toString() - Method in class com.couchbase.client.core.message.AbstractCouchbaseResponse
toString() - Method in class com.couchbase.client.core.message.config.BucketConfigResponse
toString() - Method in class com.couchbase.client.core.message.config.BucketsConfigResponse
toString() - Method in class com.couchbase.client.core.message.config.ClusterConfigResponse
toString() - Method in class com.couchbase.client.core.message.config.InsertBucketResponse
toString() - Method in class com.couchbase.client.core.message.config.UpdateBucketResponse
toString() - Method in class com.couchbase.client.core.message.dcp.AbstractDCPRequest
toString() - Method in class com.couchbase.client.core.message.dcp.MutationMessage
toString() - Method in class com.couchbase.client.core.message.dcp.SnapshotMarkerMessage
toString() - Method in class com.couchbase.client.core.message.internal.AddServiceRequest
toString() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
toString() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
toString() - Method in class com.couchbase.client.core.message.kv.GetAllMutationTokensResponse
toString() - Method in class com.couchbase.client.core.message.kv.GetResponse
toString() - Method in class com.couchbase.client.core.message.kv.MutationToken
toString() - Method in class com.couchbase.client.core.message.kv.NoFailoverObserveSeqnoResponse
toString() - Method in class com.couchbase.client.core.message.kv.ObserveResponse
toString() - Method in class com.couchbase.client.core.message.kv.StatResponse
toString() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
toString() - Method in class com.couchbase.client.core.message.search.GetSearchIndexResponse
toString() - Method in class com.couchbase.client.core.message.search.RemoveSearchIndexResponse
toString() - Method in class com.couchbase.client.core.message.search.SearchQueryResponse
toString() - Method in class com.couchbase.client.core.message.search.UpsertSearchIndexResponse
toString() - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
toString() - Method in class com.couchbase.client.core.node.CouchbaseNode
toString() - Method in class com.couchbase.client.core.node.DefaultServiceRegistry
toString() - Method in class com.couchbase.client.core.RequestEvent
toString() - Method in class com.couchbase.client.core.ResponseEvent
toString() - Method in class com.couchbase.client.core.retry.BestEffortRetryStrategy
toString() - Method in class com.couchbase.client.core.retry.FailFastRetryStrategy
toString() - Method in class com.couchbase.client.core.time.ExponentialDelay
toString() - Method in class com.couchbase.client.core.time.FixedDelay
toString() - Method in class com.couchbase.client.core.time.LinearDelay
toString() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.DefaultMemcacheContent
totalBodyLength() - Method in class com.couchbase.client.core.message.dcp.AbstractDCPMessage
totalBodyLength() - Method in interface com.couchbase.client.core.message.dcp.DCPMessage
touch() - Method in class com.couchbase.client.core.message.kv.GetRequest
TOUCH - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
touchesReplica() - Method in enum com.couchbase.client.core.message.observe.Observe.PersistTo: Identifies if this enum property will touch a replica or just the master.
touchesReplica() - Method in enum com.couchbase.client.core.message.observe.Observe.ReplicateTo: Identifies if this enum property will touch a replica or just the master.
TouchRequest - Class in com.couchbase.client.core.message.kv
TouchRequest(String, int, String) - Constructor for class com.couchbase.client.core.message.kv.TouchRequest
TouchResponse - Class in com.couchbase.client.core.message.kv: .
TouchResponse(ResponseStatus, short, String, ByteBuf, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.TouchResponse
trace(Throwable) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
trace(String) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the TRACE level.
trace(String, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the TRACE level according to the specified format and argument.
trace(String, Object, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the TRACE level according to the specified format and arguments.
trace(String, Object...) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the TRACE level according to the specified format and arguments.
trace(String, Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the TRACE level with an accompanying message.
trace(Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the TRACE level.
transitionState(S) - Method in class com.couchbase.client.core.state.AbstractStateMachine: Transition into a new state.
triggerEmit() - Method in class com.couchbase.client.core.metrics.AbstractMetricsCollector
triggerEmit() - Method in interface com.couchbase.client.core.metrics.MetricsCollector: Triggers the immediate emission of whatever is currently collected.
Tuple - Class in com.couchbase.client.core.lang: Static factory class for various Tuples.
Tuple2<T1,T2> - Class in com.couchbase.client.core.lang: A container for two values.
Tuple3<T1,T2,T3> - Class in com.couchbase.client.core.lang: A container for three values.
Tuple4<T1,T2,T3,T4> - Class in com.couchbase.client.core.lang: A container for four values.
Tuple5<T1,T2,T3,T4,T5> - Class in com.couchbase.client.core.lang: A container for five values.
type() - Method in interface com.couchbase.client.core.config.BucketConfig: The bucket type.
type() - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
type() - Method in class com.couchbase.client.core.config.DefaultMemcachedBucketConfig
type() - Method in interface com.couchbase.client.core.event.CouchbaseEvent: The type of the event.
type() - Method in class com.couchbase.client.core.event.metrics.LatencyMetricsEvent
type() - Method in class com.couchbase.client.core.event.metrics.RuntimeMetricsEvent
type() - Method in class com.couchbase.client.core.event.system.BucketClosedEvent
type() - Method in class com.couchbase.client.core.event.system.BucketOpenedEvent
type() - Method in class com.couchbase.client.core.event.system.ConfigUpdatedEvent
type() - Method in class com.couchbase.client.core.event.system.NodeConnectedEvent
type() - Method in class com.couchbase.client.core.event.system.NodeDisconnectedEvent
type() - Method in class com.couchbase.client.core.message.internal.AddServiceRequest
type() - Method in class com.couchbase.client.core.message.internal.RemoveServiceRequest
type() - Method in class com.couchbase.client.core.service.ConfigService
type() - Method in class com.couchbase.client.core.service.DCPService
type() - Method in class com.couchbase.client.core.service.KeyValueService
type() - Method in class com.couchbase.client.core.service.QueryService
type() - Method in class com.couchbase.client.core.service.SearchService
type() - Method in interface com.couchbase.client.core.service.Service: Returns the type for the given Service.
type() - Method in class com.couchbase.client.core.service.ViewService

U

UnicastAutoReleaseSubject<T> - Class in com.couchbase.client.core.utils: This Subject can be used to auto-release reference counted objects when not subscribed before.
unit() - Method in class com.couchbase.client.core.time.Delay: Returns the TimeUnit associated with this Delay.
UNKNOWN_COMMAND - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
UnlockRequest - Class in com.couchbase.client.core.message.kv
UnlockRequest(String, long, String) - Constructor for class com.couchbase.client.core.message.kv.UnlockRequest
UnlockResponse - Class in com.couchbase.client.core.message.kv
UnlockResponse(ResponseStatus, short, String, ByteBuf, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.UnlockResponse
unwrap(byte[], int, int) - Method in class com.couchbase.client.core.security.sasl.ShaSaslClient
UpdateBucketRequest - Class in com.couchbase.client.core.message.config
UpdateBucketRequest(String, String, String, String) - Constructor for class com.couchbase.client.core.message.config.UpdateBucketRequest
UpdateBucketResponse - Class in com.couchbase.client.core.message.config
UpdateBucketResponse(String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.config.UpdateBucketResponse
UpsertDesignDocumentRequest - Class in com.couchbase.client.core.message.view
UpsertDesignDocumentRequest(String, String, boolean, String, String) - Constructor for class com.couchbase.client.core.message.view.UpsertDesignDocumentRequest
UpsertDesignDocumentResponse - Class in com.couchbase.client.core.message.view
UpsertDesignDocumentResponse(ResponseStatus, ByteBuf, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.view.UpsertDesignDocumentResponse
UpsertRequest - Class in com.couchbase.client.core.message.kv: Insert or update a document.
UpsertRequest(String, ByteBuf, String, boolean) - Constructor for class com.couchbase.client.core.message.kv.UpsertRequest
UpsertRequest(String, ByteBuf, String) - Constructor for class com.couchbase.client.core.message.kv.UpsertRequest: Creates a new UpsertRequest.
UpsertRequest(String, ByteBuf, int, int, String) - Constructor for class com.couchbase.client.core.message.kv.UpsertRequest
UpsertRequest(String, ByteBuf, int, int, String, boolean) - Constructor for class com.couchbase.client.core.message.kv.UpsertRequest: Creates a new UpsertRequest.
UpsertResponse - Class in com.couchbase.client.core.message.kv: Response to an UpsertRequest.
UpsertResponse(ResponseStatus, short, long, String, ByteBuf, MutationToken, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.UpsertResponse
UpsertSearchIndexRequest - Class in com.couchbase.client.core.message.search: Inserts or updates full text search index definition.
UpsertSearchIndexRequest(String, String, String, String) - Constructor for class com.couchbase.client.core.message.search.UpsertSearchIndexRequest
UpsertSearchIndexResponse - Class in com.couchbase.client.core.message.search: Contains result of the create/update action on full text search index.
UpsertSearchIndexResponse(String, ResponseStatus) - Constructor for class com.couchbase.client.core.message.search.UpsertSearchIndexResponse
uri() - Method in class com.couchbase.client.core.config.AbstractBucketConfig
uri() - Method in interface com.couchbase.client.core.config.BucketConfig: The HTTP Uri for this bucket configuration.
USER_AGENT - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
userAgent() - Method in interface com.couchbase.client.core.env.CoreEnvironment: Library identification string, which can be used as User-Agent header in HTTP requests.
userAgent(String) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the USER-AGENT String to be sent in HTTP requests headers (should usually not be tweaked, default value is computed from the SDK DefaultCoreEnvironment.packageNameAndVersion()).
userAgent() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
userEventTriggered(ChannelHandlerContext, Object) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
userEventTriggered(ChannelHandlerContext, Object) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueHandler

V

value() - Method in enum com.couchbase.client.core.endpoint.ServerFeatures: Returns the actual byte value for the wire protocol.
value() - Method in enum com.couchbase.client.core.message.dcp.ControlParameter
value() - Method in class com.couchbase.client.core.message.kv.CounterResponse
value() - Method in enum com.couchbase.client.core.message.kv.GetAllMutationTokensRequest.PartitionState
value() - Method in enum com.couchbase.client.core.message.kv.ObserveResponse.ObserveStatus
value() - Method in class com.couchbase.client.core.message.kv.StatResponse
value() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
value() - Method in enum com.couchbase.client.core.message.observe.Observe.PersistTo: Returns the actual internal persistence representation for the enum.
value() - Method in enum com.couchbase.client.core.message.observe.Observe.ReplicateTo: Returns the actual internal replication representation for the enum.
value1() - Method in class com.couchbase.client.core.lang.Tuple2: Get the first value.
value1() - Method in class com.couchbase.client.core.lang.Tuple3: Get the first value.
value1() - Method in class com.couchbase.client.core.lang.Tuple4: Get the first value.
value1() - Method in class com.couchbase.client.core.lang.Tuple5: Get the first value.
value2() - Method in class com.couchbase.client.core.lang.Tuple2: Get the second value.
value2() - Method in class com.couchbase.client.core.lang.Tuple3: Get the second value.
value2() - Method in class com.couchbase.client.core.lang.Tuple4: Get the second value.
value2() - Method in class com.couchbase.client.core.lang.Tuple5: Get the second value.
value3() - Method in class com.couchbase.client.core.lang.Tuple3: Get the third value.
value3() - Method in class com.couchbase.client.core.lang.Tuple4: Get the third value.
value3() - Method in class com.couchbase.client.core.lang.Tuple5: Get the third value.
value4() - Method in class com.couchbase.client.core.lang.Tuple4: Get the fourth value.
value4() - Method in class com.couchbase.client.core.lang.Tuple5: Get the fourth value.
value5() - Method in class com.couchbase.client.core.lang.Tuple5: Get the fifth value.
valueOf(String) - Static method in enum com.couchbase.client.core.config.BucketNodeLocator: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.config.BucketType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.config.LoaderType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.endpoint.DecodingState: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.endpoint.kv.KeyValueStatus: Returns the enum constant of this type with the specified name.
valueOf(short) - Static method in enum com.couchbase.client.core.endpoint.kv.KeyValueStatus: Determine the right KeyValueStatus for the given status code.
valueOf(String) - Static method in enum com.couchbase.client.core.endpoint.ServerFeatures: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.event.consumers.LoggingConsumer.OutputFormat: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.event.EventType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.logging.CouchbaseLogLevel: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.message.dcp.ConnectionType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.message.dcp.ControlParameter: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.message.dcp.StreamEndMessage.Reason: Returns the enum constant of this type with the specified name.
valueOf(int) - Static method in enum com.couchbase.client.core.message.dcp.StreamEndMessage.Reason
valueOf(String) - Static method in enum com.couchbase.client.core.message.kv.GetAllMutationTokensRequest.PartitionState: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.message.kv.ObserveResponse.ObserveStatus: Returns the enum constant of this type with the specified name.
valueOf(byte) - Static method in enum com.couchbase.client.core.message.kv.ObserveResponse.ObserveStatus
valueOf(String) - Static method in enum com.couchbase.client.core.message.kv.subdoc.multi.Lookup: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.message.kv.subdoc.multi.Mutation: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest.ArrayOperation: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.message.observe.Observe.PersistTo: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.message.observe.Observe.ReplicateTo: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.message.ResponseStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.service.BucketServiceMapping: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.service.ServiceType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.couchbase.client.core.state.LifecycleState: Returns the enum constant of this type with the specified name.
values() - Static method in enum com.couchbase.client.core.config.BucketNodeLocator: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.config.BucketType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.config.LoaderType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.endpoint.DecodingState: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.endpoint.kv.KeyValueStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.endpoint.ServerFeatures: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.event.consumers.LoggingConsumer.OutputFormat: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.event.EventType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.logging.CouchbaseLogLevel: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.dcp.ConnectionType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.dcp.ControlParameter: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.dcp.StreamEndMessage.Reason: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.kv.GetAllMutationTokensRequest.PartitionState: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.kv.ObserveResponse.ObserveStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.kv.subdoc.multi.Lookup: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.kv.subdoc.multi.Mutation: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest.ArrayOperation: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.observe.Observe.PersistTo: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.observe.Observe.ReplicateTo: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.message.ResponseStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.service.BucketServiceMapping: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.service.ServiceType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.couchbase.client.core.state.LifecycleState: Returns an array containing the constants of this enum type, in the order they are declared.
vbucketID() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
vbucketID() - Method in class com.couchbase.client.core.message.kv.MutationToken
vbucketID() - Method in class com.couchbase.client.core.message.kv.NoFailoverObserveSeqnoResponse
vbucketUUID() - Method in class com.couchbase.client.core.message.dcp.FailoverLogEntry
vbucketUUID() - Method in class com.couchbase.client.core.message.dcp.StreamRequestRequest
vbucketUUID() - Method in class com.couchbase.client.core.message.kv.MutationToken
vbucketUUID() - Method in class com.couchbase.client.core.message.kv.NoFailoverObserveSeqnoResponse
vbucketUUID() - Method in class com.couchbase.client.core.message.kv.ObserveSeqnoRequest
VERSION - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
view() - Method in class com.couchbase.client.core.message.view.ViewQueryRequest
VIEW_ENDPOINTS - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
ViewEndpoint - Class in com.couchbase.client.core.endpoint.view: This endpoint defines the pipeline for binary requests and responses.
ViewEndpoint(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.endpoint.view.ViewEndpoint: Create a new ViewEndpoint.
viewEndpoints() - Method in interface com.couchbase.client.core.env.CoreEnvironment: The number of view service endpoints.
viewEndpoints(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder: Sets the number of View endpoints to open per node in the cluster (default value ).
viewEndpoints() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
ViewHandler - Class in com.couchbase.client.core.endpoint.view: The ViewHandler is responsible for encoding ViewRequests into lower level HttpRequests as well as decoding HttpObjects into CouchbaseResponses.
ViewHandler(AbstractEndpoint, RingBuffer<ResponseEvent>, boolean) - Constructor for class com.couchbase.client.core.endpoint.view.ViewHandler: Creates a new ViewHandler with the default queue for requests.
ViewHandler.KeepAliveRequest - Class in com.couchbase.client.core.endpoint.view
ViewHandler.KeepAliveResponse - Class in com.couchbase.client.core.endpoint.view
ViewLocator - Class in com.couchbase.client.core.node.locate
ViewLocator() - Constructor for class com.couchbase.client.core.node.locate.ViewLocator
ViewQueryRequest - Class in com.couchbase.client.core.message.view
ViewQueryRequest(String, String, boolean, String, String, String, String) - Constructor for class com.couchbase.client.core.message.view.ViewQueryRequest
ViewQueryRequest(String, String, boolean, boolean, String, String, String, String) - Constructor for class com.couchbase.client.core.message.view.ViewQueryRequest
ViewQueryResponse - Class in com.couchbase.client.core.message.view
ViewQueryResponse(Observable<ByteBuf>, Observable<ByteBuf>, Observable<String>, int, String, ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.view.ViewQueryResponse
ViewRequest - Interface in com.couchbase.client.core.message.view
ViewService - Class in com.couchbase.client.core.service: The ViewService is composed of and manages ViewEndpoints.
ViewService(String, String, String, int, CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.service.ViewService: Creates a new ViewService.

W

WaitStrategyFactory - Interface in com.couchbase.client.core.env: Factory to create a new WaitStrategy when called.
warn(Throwable) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
warn(String) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the WARN level.
warn(String, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the WARN level according to the specified format and argument.
warn(String, Object...) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the WARN level according to the specified format and arguments.
warn(String, Object, Object) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log a message at the WARN level according to the specified format and arguments.
warn(String, Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the WARN level with an accompanying message.
warn(Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger: Log an exception (throwable) at the WARN level.
whenState(Endpoint, LifecycleState, Action1<LifecycleState>) - Static method in class com.couchbase.client.core.service.AbstractDynamicService: Waits until the endpoint goes into the given state, calls the action and then unsubscribes.
WhitespaceSkipper - Class in com.couchbase.client.core.endpoint.util: This ByteBufProcessor loops while it encounters whitespace or new lines (‘ ’, ‘\t’, ‘\r’ and ‘\n’).
WhitespaceSkipper() - Constructor for class com.couchbase.client.core.endpoint.util.WhitespaceSkipper
wrap(byte[], int, int) - Method in class com.couchbase.client.core.security.sasl.ShaSaslClient
wrapColdWithAutoRelease(Observable<T>) - Static method in class com.couchbase.client.core.utils.Buffers: Wrap an observable and free a reference counted item if unsubscribed in the meantime.
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.dcp.DCPConnectionHandler
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler

Z

zipWith(Collection<LifecycleState>) - Method in class com.couchbase.client.core.node.ServiceStateZipper
zipWith(Collection<LifecycleState>) - Method in class com.couchbase.client.core.service.EndpointStateZipper
zipWith(Collection<S>) - Method in class com.couchbase.client.core.state.AbstractStateZipper: The zip function to map from N states to one that represents the state of the zipper.

A B C D E F G H I J K L M N O P Q R S T U V W Z