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

A

AbstractBinaryMemcacheDecoder<M extends BinaryMemcacheMessage> - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary
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, String, BucketNodeLocator, String, String, List<NodeInfo>, List<PortInfo>, List<BucketCapabilities>, NetworkAddress) - 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
AbstractCouchbaseRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.AbstractCouchbaseRequest
AbstractCouchbaseRequest(String, String, String, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.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.
AbstractDynamicService - Class in com.couchbase.client.core.service
Parent implementation of a dynamic Service.
AbstractDynamicService(String, String, String, String, int, CoreContext, int, 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, String, BootstrapAdapter, boolean, CoreContext, 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, String, int, CoreContext, boolean, EventLoopGroup, 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, 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, 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) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
AbstractKeyValueRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
AbstractKeyValueRequest(String, String, String, String) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
AbstractKeyValueRequest(String, String, String, String, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.kv.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, String, int, CoreContext, 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, String, int, CoreContext, 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, String, int, CoreContext, int, int, SelectionStrategy, 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(CoreEnvironment, ClusterFacade) - Constructor for class com.couchbase.client.core.config.refresher.AbstractRefresher
Creates a new AbstractRefresher.
AbstractServiceConfig - Class in com.couchbase.client.core.env
Defines a general config for a Service.
AbstractServiceConfig(int, int, boolean, int) - Constructor for class com.couchbase.client.core.env.AbstractServiceConfig
 
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
AbstractSubdocMutationRequest(String, String, ByteBuf, String, int, long, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.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
 
accessDeleted(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiLookupDocOptionsBuilder
 
accessDeleted() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiLookupDocOptionsBuilder
 
accessDeleted() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubExistRequest
 
accessDeleted(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubExistRequest
 
accessDeleted() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubGetCountRequest
 
accessDeleted(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubGetCountRequest
 
accessDeleted() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubGetRequest
 
accessDeleted(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubGetRequest
 
activate(Span, boolean) - Method in class com.couchbase.client.core.tracing.ThresholdLogScopeManager
 
active() - Method in class com.couchbase.client.core.tracing.ThresholdLogScopeManager
 
activeSpan() - Method in class com.couchbase.client.core.tracing.ThresholdLogTracer
 
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(NetworkAddress) - 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(NetworkAddress) - Constructor for class com.couchbase.client.core.message.internal.AddNodeRequest
 
AddNodeResponse - Class in com.couchbase.client.core.message.internal
 
AddNodeResponse(ResponseStatus, NetworkAddress) - 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
 
addReference(String, SpanContext) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanBuilder
 
addRequest(CouchbaseRequest) - Method in class com.couchbase.client.core.tracing.RingBufferMonitor
 
address() - Method in class com.couchbase.client.core.utils.NetworkAddress
Returns the string IP representation for this network address.
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, NetworkAddress) - Constructor for class com.couchbase.client.core.message.internal.AddServiceRequest
 
AddServiceRequest(ServiceType, String, String, String, int, NetworkAddress) - Constructor for class com.couchbase.client.core.message.internal.AddServiceRequest
 
AddServiceResponse - Class in com.couchbase.client.core.message.internal
 
AddServiceResponse(ResponseStatus, NetworkAddress) - Constructor for class com.couchbase.client.core.message.internal.AddServiceResponse
 
after() - Method in class com.couchbase.client.core.endpoint.kv.ErrorMap.RetrySpecification
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
Use this method to add custom span values on insert.
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.analytics.GenericAnalyticsRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.analytics.PingRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.query.GenericQueryRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.query.PingRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.search.GetSearchIndexRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.search.PingRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.search.RemoveSearchIndexRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.search.SearchQueryRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.search.UpsertSearchIndexRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.view.GetDesignDocumentRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.view.PingRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.view.RemoveDesignDocumentRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.view.UpsertDesignDocumentRequest
 
afterSpanSet(Span) - Method in class com.couchbase.client.core.message.view.ViewQueryRequest
 
all() - Method in class com.couchbase.client.core.event.metrics.RuntimeMetricsEvent
 
allHosts() - Method in class com.couchbase.client.core.utils.ConnectionString
Get the list of all hosts set on the connection string.
allNodeAddresses() - Method in interface com.couchbase.client.core.config.ClusterConfig
Returns the addresses of all nodes in the cluster, accumulated from all open buckets.
allNodeAddresses() - Method in class com.couchbase.client.core.config.DefaultClusterConfig
 
ALLOW_REVERSE_DNS - Static variable in class com.couchbase.client.core.utils.NetworkAddress
Flag which controls the usage of reverse dns
AlternateAddress - Interface in com.couchbase.client.core.config
 
alternateAddresses() - Method in class com.couchbase.client.core.config.DefaultNodeInfo
 
alternateAddresses() - Method in class com.couchbase.client.core.config.DefaultPortInfo
 
alternateAddresses() - Method in interface com.couchbase.client.core.config.NodeInfo
Contains alternate addresses, if set.
alternateAddresses() - Method in interface com.couchbase.client.core.config.PortInfo
 
ANALYTICS_ENDPOINTS - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
AnalyticsEndpoint - Class in com.couchbase.client.core.endpoint.analytics
This endpoint defines the pipeline for analytics requests and responses.
AnalyticsEndpoint(String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.endpoint.analytics.AnalyticsEndpoint
 
AnalyticsEndpoint(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.endpoint.analytics.AnalyticsEndpoint
 
AnalyticsHandler - Class in com.couchbase.client.core.endpoint.analytics
The AnalyticsHandler is responsible for encoding AnalyticsRequests into lower level HttpRequests as well as decoding HttpObjects into CouchbaseResponses.
AnalyticsHandler(AbstractEndpoint, RingBuffer<ResponseEvent>, boolean, boolean) - Constructor for class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
Creates a new AnalyticsHandler with the default queue for requests.
AnalyticsHandler.KeepAliveRequest - Class in com.couchbase.client.core.endpoint.analytics
 
AnalyticsHandler.KeepAliveResponse - Class in com.couchbase.client.core.endpoint.analytics
 
analyticsIoPool() - Method in interface com.couchbase.client.core.env.CoreEnvironment
If set returns the IO Pool for the analytics service, if not returns null.
analyticsIoPool() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
analyticsIoPool(EventLoopGroup, ShutdownHook) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Sets the Analytics I/O Pool implementation for the underlying IO framework, along with the action to execute when this environment is shut down.
AnalyticsLocator - Class in com.couchbase.client.core.node.locate
Round robin node locator for Analytics.
AnalyticsLocator() - Constructor for class com.couchbase.client.core.node.locate.AnalyticsLocator
 
AnalyticsRequest - Interface in com.couchbase.client.core.message.analytics
Marker interface for all requests against the Analytics Service
AnalyticsService - Class in com.couchbase.client.core.service
The AnalyticsService is composed of and manages AnalyticsEndpoints.
AnalyticsService(String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.AnalyticsService
Deprecated.
AnalyticsService(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.AnalyticsService
Creates a new AnalyticsService.
AnalyticsServiceConfig - Class in com.couchbase.client.core.env
 
analyticsServiceConfig() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Returns the current AnalyticsService configuration.
analyticsServiceConfig() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
analyticsServiceConfig(AnalyticsServiceConfig) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to set a custom configuration for the Analytics service.
analyticsThreshold(long, TimeUnit) - Method in class com.couchbase.client.core.tracing.ThresholdLogReporter.Builder
Allows to customize the analyticsThreshold.
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
 
asChildOf(SpanContext) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanBuilder
 
asChildOf(Span) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanBuilder
 
asJson() - Method in enum com.couchbase.client.core.message.internal.PingServiceHealth.PingState
Returns the json representation for this enum.
attributes() - Method in class com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorCode
 
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
 
AUTO - Static variable in class com.couchbase.client.core.env.NetworkResolution
Based on heuristics discovers if internal or external resolution will be used.
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

BACKPRESSURE_EXCEPTION - Static variable in class com.couchbase.client.core.CouchbaseCore
A preconstructed BackpressureException.
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
 
BackpressureException(RingBufferDiagnostics) - Constructor for exception com.couchbase.client.core.BackpressureException
 
baggageItem(String, String) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanContext
Stores the given baggage item/value.
baggageItem(String) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanContext
Retrieve the baggage value by item.
baggageItems() - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanContext
 
Base64 - Class in com.couchbase.client.core.utils
Utility class to perform base64 encoding/decoding.
beforeSend(CouchbaseRequest, Observable<CouchbaseResponse>) - Method in interface com.couchbase.client.core.hooks.CouchbaseCoreSendHook
Allows to hook in before the send method on core, make sure to return either the original tuple or the modified ones from the originals.
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.kv.KeyValueAuthHandler
 
bind(ChannelHandlerContext, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueErrorMapHandler
 
bind(ChannelHandlerContext, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
 
bind(ChannelHandlerContext, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
 
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.config.RestApiRequest
 
body() - Method in class com.couchbase.client.core.message.config.RestApiResponse
 
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.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
 
BucketCapabilities - Enum in com.couchbase.client.core.config
Describes the bucket capabilities in an abstract fashion as provided by the server.
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
An abstraction over the bucket parser which takes a raw config as a string and turns it into a BucketConfig.
BucketConfigParser() - Constructor for class com.couchbase.client.core.config.parser.BucketConfigParser
 
BucketConfigRequest - Class in com.couchbase.client.core.message.config
 
BucketConfigRequest(String, NetworkAddress, String, String) - Constructor for class com.couchbase.client.core.message.config.BucketConfigRequest
 
BucketConfigRequest(String, NetworkAddress, String, 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
 
bucketName() - Method in class com.couchbase.client.core.config.ProposedBucketConfigContext
 
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
 
BucketStreamingRequest(String, 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.message.kv.subdoc.multi.LookupCommandBuilder
 
build() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
 
build() - Method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig.Builder
 
build() - Method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig.Builder
 
build() - Method in class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter.Builder
 
build() - Method in class com.couchbase.client.core.tracing.ThresholdLogReporter.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.message.kv.subdoc.multi.SubMultiLookupDocOptionsBuilder
 
builder() - Static method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationDocOptionsBuilder
 
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
 
builder() - Static method in class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter
 
Builder() - Constructor for class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter.Builder
 
builder() - Static method in class com.couchbase.client.core.tracing.ThresholdLogReporter
 
Builder() - Constructor for class com.couchbase.client.core.tracing.ThresholdLogReporter.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
 
buildSpan(String) - Method in class com.couchbase.client.core.tracing.ThresholdLogTracer
 
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
 
ByteBufJsonParser - Class in com.couchbase.client.core.utils.yasjl
The ByteBufJsonParser allows to query for values identified by JsonPointer in Netty ByteBuf.
ByteBufJsonParser(JsonPointer[]) - Constructor for class com.couchbase.client.core.utils.yasjl.ByteBufJsonParser
Creates a new ByteBufJsonParser and initializes all of its internal processors.

C

C_CURLY - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
C_SQUARE - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
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, RetryStrategy, Span) - Static method in class com.couchbase.client.core.message.observe.Observe
 
call(ClusterFacade, String, String, long, boolean, Observe.PersistTo, Observe.ReplicateTo, Delay, RetryStrategy, Span) - Static method in class com.couchbase.client.core.message.observe.Observe
 
call(ClusterFacade, String, String, long, boolean, MutationToken, Observe.PersistTo, Observe.ReplicateTo, Delay, RetryStrategy, Span) - Static method in class com.couchbase.client.core.message.observe.Observe
 
call(ClusterFacade, String, String, long, boolean, Observe.PersistTo, Observe.ReplicateTo, Delay, RetryStrategy, Span) - Static method in class com.couchbase.client.core.message.observe.ObserveViaCAS
 
call(ClusterFacade, String, String, MutationToken, Observe.PersistTo, Observe.ReplicateTo, Delay, RetryStrategy, Span, long) - 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
 
call(ByteBuf) - Method in interface com.couchbase.client.core.utils.yasjl.Callbacks.JsonPointerCB1
 
call(JsonPointer, ByteBuf) - Method in interface com.couchbase.client.core.utils.yasjl.Callbacks.JsonPointerCB2
 
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.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.ObserveSeqnoRequest
 
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
 
ceil() - Method in class com.couchbase.client.core.endpoint.kv.ErrorMap.RetrySpecification
 
CERT_AUTH_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
certAuthEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment
True if X.509 client certificate authentication is enabled.
certAuthEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to enable X.509 client certificate authentication.
certAuthEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
channelActive(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
 
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.KeyValueErrorMapHandler
 
channelActive(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
 
channelActive(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
Once the channel is marked as active, select bucket command is sent if the HELLO request has SELECT_BUCKET feature enabled.
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.kv.KeyValueAuthHandler
Dispatches incoming SASL responses to the appropriate handler methods.
channelRead0(ChannelHandlerContext, FullBinaryMemcacheResponse) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueErrorMapHandler
 
channelRead0(ChannelHandlerContext, FullBinaryMemcacheResponse) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
 
channelRead0(ChannelHandlerContext, FullBinaryMemcacheResponse) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
Handles incoming Select bucket responses.
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.AnalyticsLocator
 
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
 
childOf(ThresholdLogSpanContext) - Static method in class com.couchbase.client.core.tracing.ThresholdLogReference
Creates a reference which represents the child of the given context.
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.analytics.GenericAnalyticsResponse
 
clientRequestId() - Method in class com.couchbase.client.core.message.query.GenericQueryResponse
 
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.KeyValueErrorMapHandler
 
close(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
 
close(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
 
close() - Method in class com.couchbase.client.core.tracing.ThresholdLogScope
 
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
 
ClusterConfigRequest(String, 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
Deprecated.
clusterNodesAsNetworkAddress() - Method in class com.couchbase.client.core.event.system.ConfigUpdatedEvent
Returns the NetworkAddress 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.analytics - package com.couchbase.client.core.endpoint.analytics
 
com.couchbase.client.core.endpoint.config - package com.couchbase.client.core.endpoint.config
 
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.query.parser - package com.couchbase.client.core.endpoint.query.parser
 
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.hooks - package com.couchbase.client.core.hooks
 
com.couchbase.client.core.lang - package com.couchbase.client.core.lang
 
com.couchbase.client.core.lang.backport.java.util - package com.couchbase.client.core.lang.backport.java.util
 
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.analytics - package com.couchbase.client.core.message.analytics
 
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.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.tracing - package com.couchbase.client.core.tracing
 
com.couchbase.client.core.utils - package com.couchbase.client.core.utils
 
com.couchbase.client.core.utils.yasjl - package com.couchbase.client.core.utils.yasjl
 
com.couchbase.client.core.utils.yasjl.Callbacks - package com.couchbase.client.core.utils.yasjl.Callbacks
 
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(ErrorMap) - Method in class com.couchbase.client.core.endpoint.kv.ErrorMap
 
compareTo(LatencyMetricsIdentifier) - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
 
compareTo(ThresholdLogSpan) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
 
complete() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
complete() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
Completes the underlying state holder.
completeRequestSpan(CouchbaseRequest) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
Helper method to complete the request span, called from child instances.
compressionMinRatio() - Method in interface com.couchbase.client.core.env.CoreEnvironment
If the document is greater than the min compression size it is used for compression, but only sent if the compressed document has a greater compression ratio as the one provided.
compressionMinRatio(double) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to adjust the ratio over which the document is sent compressed over the wire - in percent.
compressionMinRatio() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
compressionMinSize() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Returns the minimum size of a document to be considered for compression in the first place.
compressionMinSize(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to adjust the minimum size of a document to be considered for compression - in bytes.
compressionMinSize() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
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.config.ProposedBucketConfigContext
 
config() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
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.
CONFIG_POLL_FLOOR_INTERVAL - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
CONFIG_POLL_INTERVAL - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
ConfigEndpoint - Class in com.couchbase.client.core.endpoint.config
 
ConfigEndpoint(String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.endpoint.config.ConfigEndpoint
Deprecated.
ConfigEndpoint(String, String, String, String, int, CoreContext) - 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, 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
Locates the proper CONFIG node for a given config request.
ConfigLocator() - Constructor for class com.couchbase.client.core.node.locate.ConfigLocator
Generates the random initial value for the round robin counter used.
ConfigParserEnvironment - Interface in com.couchbase.client.core.env
A ConfigParserEnvironment interface defines all methods which environment implementation should have to be injected into configuration parser.
configPollFloorInterval() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Returns the minimum polling interval allowed.
configPollFloorInterval(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to set the minimum config polling interval.
configPollFloorInterval() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
configPollInterval() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Returns the proactive polling interval for cluster configurations.
configPollInterval(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to set the configuration poll interval which polls the server cluster configuration proactively.
configPollInterval() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
ConfigRequest - Interface in com.couchbase.client.core.message.config
Common marker interface for all ConfigRequests.
configRev() - Method in class com.couchbase.client.core.message.internal.PingReport
 
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, CoreContext) - Constructor for class com.couchbase.client.core.service.ConfigService
Deprecated.
ConfigService(String, String, String, String, int, CoreContext) - 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() - 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.KeyValueErrorMapHandler
 
connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
 
connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
 
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 class com.couchbase.client.core.service.PooledService
 
connect() - Method in interface com.couchbase.client.core.service.Service
Connects all currently enabled Service Endpoints.
ConnectionString - Class in com.couchbase.client.core.utils
Implements a ConnectionString.
ConnectionString(String) - Constructor for class com.couchbase.client.core.utils.ConnectionString
 
ConnectionString.Scheme - Enum in com.couchbase.client.core.utils
 
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.config.GetUsersResponse
 
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
 
context() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
The CoreContext reference.
context() - Method in class com.couchbase.client.core.message.ResponseStatusDetails
 
context() - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
 
CONTINUOUS_KEEPALIVE_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
continuousKeepAliveEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment
If set to true, KeepAlives will be sent on a regular basis in the interval also if there is traffic on the socket, not only if its idle.
continuousKeepAliveEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to enable or disable the continous emitting of keepalive messages.
continuousKeepAliveEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
convert(ByteBuf) - Static method in class com.couchbase.client.core.message.ResponseStatusDetails
Helper method to convert a ByteBuf input into the details.
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
 
CoreContext - Class in com.couchbase.client.core
The CoreContext contains required assets which are shared on a per-core basis.
CoreContext(CoreEnvironment, RingBuffer<ResponseEvent>) - Constructor for class com.couchbase.client.core.CoreContext
Creates a new CoreContext with no core id.
CoreContext(CoreEnvironment, RingBuffer<ResponseEvent>, long) - Constructor for class com.couchbase.client.core.CoreContext
Creates a new CoreContext with no a core id.
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.
coreId() - Method in class com.couchbase.client.core.CoreContext
The core it, 0 if not set.
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.
couchbaseCoreSendHook() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Returns the CouchbaseCoreSendHook if set, null otherwise.
couchbaseCoreSendHook(CouchbaseCoreSendHook) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to configure a custom core send hook, see the javadocs for it for more details.
couchbaseCoreSendHook() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
CouchbaseCoreSendHook - Interface in com.couchbase.client.core.hooks
This hook allows to intercept and modify the CouchbaseRequest in the path of the CouchbaseCore.send(CouchbaseRequest) method.
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(NetworkAddress, CoreContext) - 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
 
countNonService() - Method in class com.couchbase.client.core.tracing.RingBufferDiagnostics
Returns the count of all requests not associated with a particular service
counts() - Method in class com.couchbase.client.core.tracing.RingBufferDiagnostics
Returns a map of the type of each request, along with the current count of each in the ringbuffer
create(int, int) - Static method in class com.couchbase.client.core.env.AnalyticsServiceConfig
 
create(int, int, int) - Static method in class com.couchbase.client.core.env.AnalyticsServiceConfig
 
create() - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
create(int) - Static method in class com.couchbase.client.core.env.KeyValueServiceConfig
 
create(int, int) - Static method in class com.couchbase.client.core.env.QueryServiceConfig
 
create(int, int, int) - Static method in class com.couchbase.client.core.env.QueryServiceConfig
 
create(int, int) - Static method in class com.couchbase.client.core.env.SearchServiceConfig
 
create(int, int, int) - Static method in class com.couchbase.client.core.env.SearchServiceConfig
 
create(int, int) - Static method in class com.couchbase.client.core.env.ViewServiceConfig
 
create(int, int, int) - Static method in class com.couchbase.client.core.env.ViewServiceConfig
 
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, String, int, CoreContext) - Method in interface com.couchbase.client.core.service.Service.EndpointFactory
Create a new Endpoint.
create(String, String, String, String, int, CoreContext, ServiceType) - Method in class com.couchbase.client.core.service.ServiceFactory
 
create() - Static method in class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter
 
create() - Static method in class com.couchbase.client.core.tracing.ThresholdLogReporter
 
create() - Static method in class com.couchbase.client.core.tracing.ThresholdLogTracer
Creates a new tracer with default settings.
create(ThresholdLogReporter) - Static method in class com.couchbase.client.core.tracing.ThresholdLogTracer
Creates a new tracer with a custom reporter.
create(String) - Static method in class com.couchbase.client.core.utils.ConnectionString
 
create(String) - Static method in class com.couchbase.client.core.utils.NetworkAddress
Creates a new NetworkAddress from either a hostname or ip address literal.
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
 
createDocument() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMutationRequest
Deprecated.
createDocument(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationDocOptionsBuilder
Deprecated.
createDocument() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationDocOptionsBuilder
Deprecated.
createDocument() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
 
createDocument(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
 
createEndpoint() - Method in class com.couchbase.client.core.service.AbstractDynamicService
Helper method to create a new endpoint.
createException() - Method in class com.couchbase.client.core.tracing.RingBufferMonitor
 
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.multi.MutationCommandBuilder
 
createIntermediaryPath(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
 
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.analytics.AnalyticsHandler
 
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.query.QueryHandlerV2
 
createKeepAliveRequest() - Method in class com.couchbase.client.core.endpoint.search.SearchHandler
 
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() - Method in interface com.couchbase.client.core.ClusterFacade
Exposes the currently used environment.
ctx() - Method in class com.couchbase.client.core.CouchbaseCore
 
ctx - Variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator
Holds the current channel handler context if set.
currentDispatchSpan() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
 
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.
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.
custom(String) - Static method in class com.couchbase.client.core.env.NetworkResolution
Provide a network resolution option which is not covered by the statics defined in this class.
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.analytics.AnalyticsEndpoint
 
customEndpointHandlers(ChannelPipeline) - Method in class com.couchbase.client.core.endpoint.config.ConfigEndpoint
 
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

DATATYPE_SNAPPY - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
The datatype byte used to signal snappy.
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.analytics.AnalyticsHandler
 
decodeResponse(ChannelHandlerContext, HttpObject) - Method in class com.couchbase.client.core.endpoint.config.ConfigHandler
 
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.query.QueryHandlerV2
 
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 - Static variable in class com.couchbase.client.core.env.NetworkResolution
Pick whatever the server returns in the config, this is the old and backwards compatible mode (server default).
DEFAULT_FORMAT - Static variable in class com.couchbase.client.core.event.consumers.LoggingConsumer
 
DEFAULT_IDLE_TIME - Static variable in class com.couchbase.client.core.env.AbstractServiceConfig
 
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.kv.AbstractKeyValueRequest
 
DEFAULT_SCHEME - Static variable in class com.couchbase.client.core.utils.ConnectionString
 
DefaultAlternateAddress - Class in com.couchbase.client.core.config
 
DefaultAlternateAddress(String, Map<String, Integer>) - Constructor for class com.couchbase.client.core.config.DefaultAlternateAddress
 
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
DefaultConfigurationProvider(ClusterFacade, CoreEnvironment, List<Loader>, Map<LoaderType, Refresher>) - Constructor for class com.couchbase.client.core.config.DefaultConfigurationProvider
DefaultCoreEnvironment - Class in com.couchbase.client.core.env
 
DefaultCoreEnvironment(DefaultCoreEnvironment.Builder) - Constructor for class com.couchbase.client.core.env.DefaultCoreEnvironment
 
DefaultCoreEnvironment.Builder<SELF extends DefaultCoreEnvironment.Builder<SELF>> - Class in com.couchbase.client.core.env
 
DefaultCouchbaseBucketConfig - Class in com.couchbase.client.core.config
 
DefaultCouchbaseBucketConfig(long, String, String, String, String, CouchbasePartitionInfo, List<NodeInfo>, List<PortInfo>, List<BucketCapabilities>, NetworkAddress) - 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(ConfigParserEnvironment, long, String, String, String, String, List<NodeInfo>, List<PortInfo>, List<BucketCapabilities>, NetworkAddress) - Constructor for class com.couchbase.client.core.config.DefaultMemcachedBucketConfig
Creates a new MemcachedBucketConfig.
DefaultMemcachedHashingStrategy - Class in com.couchbase.client.core.node
The default memcache bucket hashing strategy, compatible with 2.x Java SDK.
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>, Map<String, AlternateAddress>) - Constructor for class com.couchbase.client.core.config.DefaultNodeInfo
Creates a new DefaultNodeInfo with no SSL services.
DefaultNodeInfo(NetworkAddress, Map<ServiceType, Integer>, Map<ServiceType, Integer>, Map<String, AlternateAddress>) - Constructor for class com.couchbase.client.core.config.DefaultNodeInfo
Creates a new DefaultNodeInfo with SSL services.
DefaultObjectMapper - Class in com.couchbase.client.core.utils
Provides global access to the services of a Jackson ObjectMapper with default configuration.
DefaultOrphanResponseReporter - Class in com.couchbase.client.core.tracing
The DefaultOrphanResponseReporter receives requests’s of orphan responses and stores them for aggregation and logging.
DefaultOrphanResponseReporter(DefaultOrphanResponseReporter.Builder) - Constructor for class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter
Creates the OrphanResponseReporter using the given config.
DefaultOrphanResponseReporter.Builder - Class in com.couchbase.client.core.tracing
The builder to configure the DefaultOrphanResponseReporter
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, Map<String, AlternateAddress>) - 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
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.kv.KeyValueAuthHandler
 
deregister(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueErrorMapHandler
 
deregister(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
 
deregister(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
 
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 class com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorCode
 
description() - Method in enum com.couchbase.client.core.endpoint.kv.KeyValueStatus
 
design() - Method in class com.couchbase.client.core.message.view.ViewQueryRequest
 
details() - Method in exception com.couchbase.client.core.CouchbaseException
 
details(ResponseStatusDetails) - Method in exception com.couchbase.client.core.CouchbaseException
 
detailsFromBinary(byte, ByteBuf) - Static method in class com.couchbase.client.core.endpoint.ResponseStatusConverter
 
determineNetworkResolution(BucketConfig, NetworkResolution, Set<NetworkAddress>) - Static method in class com.couchbase.client.core.config.DefaultConfigurationProvider
Helper method to figure out which network resolution should be used.
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
 
DiagnosticRequest - Interface in com.couchbase.client.core.message
Marker interface for extended information.
diagnostics(ServiceType) - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
 
diagnostics(ServiceType) - Method in interface com.couchbase.client.core.endpoint.Endpoint
Returns health information for this endpoint.
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
 
diagnostics() - Method in class com.couchbase.client.core.node.CouchbaseNode
 
diagnostics() - Method in interface com.couchbase.client.core.node.Node
Returns endpoint health information for all endpoints this node is currently associated with.
diagnostics(String) - Method in class com.couchbase.client.core.RequestHandler
Performs the logistics of collecting and assembling the individual health check information on a per-service basis.
diagnostics() - Method in class com.couchbase.client.core.service.AbstractDynamicService
 
diagnostics() - Method in class com.couchbase.client.core.service.PooledService
 
diagnostics() - Method in interface com.couchbase.client.core.service.Service
Returns endpoint health information for all endpoints this service is currently associated with.
DiagnosticsReport - Class in com.couchbase.client.core.message.internal
Aggregates the health of all Endpoints.
DiagnosticsReport(List<EndpointHealth>, String, String) - Constructor for class com.couchbase.client.core.message.internal.DiagnosticsReport
 
diagnosticsReport() - Method in class com.couchbase.client.core.message.internal.DiagnosticsResponse
 
DiagnosticsRequest - Class in com.couchbase.client.core.message.internal
 
DiagnosticsRequest(String) - Constructor for class com.couchbase.client.core.message.internal.DiagnosticsRequest
 
DiagnosticsResponse - Class in com.couchbase.client.core.message.internal
 
DiagnosticsResponse(DiagnosticsReport) - Constructor for class com.couchbase.client.core.message.internal.DiagnosticsResponse
 
diagostics() - Method in exception com.couchbase.client.core.BackpressureException
Returns a RingBufferDiagnostics which, if non-null, gives a granular breakdown of the contents of the ringbuffer at the time of this exception
disabled() - Static method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
 
disabled() - Static method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
 
disabled() - Static method in class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter
 
disabled() - Static method in class com.couchbase.client.core.tracing.ThresholdLogReporter
 
disconnect() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
 
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.KeyValueErrorMapHandler
 
disconnect(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
 
disconnect(ChannelHandlerContext, ChannelPromise) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
 
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 class com.couchbase.client.core.service.PooledService
 
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, String, NetworkAddress) - Method in class com.couchbase.client.core.config.loader.AbstractLoader
Run the BucketConfig discovery process.
discoverConfig(String, String, String, NetworkAddress) - Method in class com.couchbase.client.core.config.loader.CarrierLoader
 
discoverConfig(String, String, String, NetworkAddress) - Method in class com.couchbase.client.core.config.loader.HttpLoader
 
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
 
dispatchHostname() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
dispatchHostname(String) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
dispatchHostname() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
 
dispatchHostname(String) - Method in interface com.couchbase.client.core.message.CouchbaseRequest
 
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.
doBeginRead() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
doBind(SocketAddress) - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
docFlags() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMultiLookupRequest
 
docFlags() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMultiMutationRequest
 
docFlags() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiLookupRequest
 
docFlags() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationRequest
 
doClose() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
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(String, Long) - 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(String, Long) - Constructor for exception com.couchbase.client.core.DocumentMutationLostException
 
doDisconnect() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
doublePropertyOr(String, double) - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
doWrite(ChannelOutboundBuffer) - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
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
 
durationMicros() - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
Returns the relative duration in microseconds.

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(CouchbaseResponse) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
emit(CouchbaseResponse) - Method in interface com.couchbase.client.core.message.CouchbaseRequest
Emits the CouchbaseResponse into the underlying state holder (like a subject) without completing it as per contract.
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, AnalyticsRequest) - Method in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
encodeRequest(ChannelHandlerContext, ConfigRequest) - Method in class com.couchbase.client.core.endpoint.config.ConfigHandler
 
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, QueryRequest) - Method in class com.couchbase.client.core.endpoint.query.QueryHandlerV2
 
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.
EndpointHealth - Class in com.couchbase.client.core.message.internal
Aggregates the health of one specific Endpoint.
EndpointHealth(ServiceType, LifecycleState, SocketAddress, SocketAddress, long, String) - Constructor for class com.couchbase.client.core.message.internal.EndpointHealth
 
endpoints() - Method in class com.couchbase.client.core.message.internal.DiagnosticsReport
 
endpoints(ServiceType) - Method in class com.couchbase.client.core.message.internal.DiagnosticsReport
 
endpoints() - Method in class com.couchbase.client.core.service.AbstractDynamicService
Returns the current list of endpoints.
endpoints() - Method in class com.couchbase.client.core.service.PooledService
Returns the current endpoint list, for testing verification purposes.
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
 
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.CoreContext
Returns the current 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
 
ephemeral() - Method in interface com.couchbase.client.core.config.CouchbaseBucketConfig
If this couchbase bucket is ephemeral.
ephemeral() - Method in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
 
equals(Object) - Method in class com.couchbase.client.core.config.DefaultAlternateAddress
 
equals(Object) - Method in class com.couchbase.client.core.config.ProposedBucketConfigContext
 
equals(Object) - Method in class com.couchbase.client.core.env.NetworkResolution
 
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.message.ResponseStatusDetails
 
equals(Object) - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
 
equals(Object) - Method in class com.couchbase.client.core.node.CouchbaseNode
 
equals(Object) - Method in class com.couchbase.client.core.utils.NetworkAddress
 
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
 
ErrorCode(String, String, List<ErrorMap.ErrorAttribute>, ErrorMap.RetrySpecification) - Constructor for class com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorCode
 
ErrorMap - Class in com.couchbase.client.core.endpoint.kv
The ErrorMap contains mappings from errors to their attributes, negotiated between the client and the server.
ErrorMap(int, int, Map<String, ErrorMap.ErrorCode>) - Constructor for class com.couchbase.client.core.endpoint.kv.ErrorMap
 
ErrorMap.ErrorAttribute - Enum in com.couchbase.client.core.endpoint.kv
 
ErrorMap.ErrorCode - Class in com.couchbase.client.core.endpoint.kv
 
ErrorMap.RetrySpecification - Class in com.couchbase.client.core.endpoint.kv
 
ErrorMap.RetryStrategy - Enum in com.couchbase.client.core.endpoint.kv
 
errors() - Method in class com.couchbase.client.core.endpoint.kv.ErrorMap
 
errors() - Method in class com.couchbase.client.core.message.analytics.GenericAnalyticsResponse
If there were errors and/or warnings while executing the query, contains a ByteBuf for each error and each warning.
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 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.
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.
exportToJson() - Method in class com.couchbase.client.core.message.internal.DiagnosticsReport
Exports this report into the standard JSON format which is consistent across different language SDKs.
exportToJson(boolean) - Method in class com.couchbase.client.core.message.internal.DiagnosticsReport
Exports this report into the standard JSON format which is consistent across different language SDKs.
exportToJson() - Method in class com.couchbase.client.core.message.internal.PingReport
Exports this report into the RFC JSON format.
exportToJson(boolean) - Method in class com.couchbase.client.core.message.internal.PingReport
Exports this report into the RFC JSON format.
EXTERNAL - Static variable in class com.couchbase.client.core.env.NetworkResolution
Pins it to external resolution.
extract(Format<C>, C) - Method in class com.couchbase.client.core.tracing.ThresholdLogTracer
 

F

fail(Throwable) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
fail(Throwable) - Method in interface com.couchbase.client.core.message.CouchbaseRequest
Fails the CouchbaseResponse on the state holder as per contract.
FailedChannel - Class in com.couchbase.client.core.endpoint.util
The failed channel can be used to create a channel promise when no channel is available (because it failed).
FailedChannel() - Constructor for class com.couchbase.client.core.endpoint.util.FailedChannel
 
FailFastRetryStrategy - Class in com.couchbase.client.core.retry
A RetryStrategy that will never retry and cancel right away.
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
 
failSafe(Scheduler, boolean, Subject<CouchbaseResponse, CouchbaseResponse>, Throwable) - Static method in enum com.couchbase.client.core.utils.Observables
Helper method to fail a given observable while still making sure to move it onto the proper scheduler for handling if needed (similar to onNext).
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).
finish() - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
 
finish(long) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
 
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
 
finishedDecoding() - Method in class com.couchbase.client.core.endpoint.query.QueryHandlerV2
 
finishedDecoding() - Method in class com.couchbase.client.core.endpoint.search.SearchHandler
 
finishParsingAndReset() - Method in class com.couchbase.client.core.endpoint.query.parser.YasjlQueryResponseParser
Instruct the parser to finish the parsing and reset its internal state, turning it back to uninitialized as well.
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 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.
floorDiv(long, long) - Static method in class com.couchbase.client.core.utils.MathUtils
Backport of floorDiv from the JDK since we need to support 1.6.
floorMod(long, long) - Static method in class com.couchbase.client.core.utils.MathUtils
Backport of floorMod from the JDK since we need to support 1.6.
flush(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
 
flush(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueErrorMapHandler
 
flush(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
 
flush(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
 
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
 
FlushRequest(String, 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
 
followsFrom(ThresholdLogSpanContext) - Static method in class com.couchbase.client.core.tracing.ThresholdLogReference
Creates a reference which represents the follower of the given context.
FORCE_IPV4 - Static variable in class com.couchbase.client.core.utils.NetworkAddress
Flag which controls if even if ipv6 is present, IPv4 should be preferred.
FORCE_IPV4_PROPERTY - Static variable in class com.couchbase.client.core.utils.NetworkAddress
 
FORCE_SASL_PLAIN - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
forceSaslPlain() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Forces the KeyValue SASL Authentication method to PLAIN if set to true, specifically allowing LDAP-based users to authenticate.
forceSaslPlain(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to forcre the KeyValue SASL authentication method to PLAIN which is used to allow authentication against LDAP-based users.
forceSaslPlain() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
forString(String) - Static method in class com.couchbase.client.core.utils.InetAddresses
Returns the InetAddress having the given string representation.
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(ByteBuf) - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
 
fragment() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
 
FRAMING_EXTRAS_TRACING - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
The byte used to signal this is a tracing extras frame.
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.
fromHostnames(List<String>) - Static method in class com.couchbase.client.core.utils.ConnectionString
 
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
 
ftsThreshold(long, TimeUnit) - Method in class com.couchbase.client.core.tracing.ThresholdLogReporter.Builder
Allows to customize the ftsThreshold.
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
 
GenericAnalyticsRequest - Class in com.couchbase.client.core.message.analytics
For the lack of a better name, a analytics request against a analytics server.
GenericAnalyticsRequest(String, boolean, String, String, String, InetAddress) - Constructor for class com.couchbase.client.core.message.analytics.GenericAnalyticsRequest
 
GenericAnalyticsResponse - Class in com.couchbase.client.core.message.analytics
The base response for Analytics (SQL++) requests.
GenericAnalyticsResponse(Observable<ByteBuf>, Observable<ByteBuf>, Observable<ByteBuf>, Observable<String>, Observable<ByteBuf>, CouchbaseRequest, ResponseStatus, String, String) - Constructor for class com.couchbase.client.core.message.analytics.GenericAnalyticsResponse
 
GenericQueryRequest - Class in com.couchbase.client.core.message.query
For the lack of a better name, a query request against a query server.
GenericQueryRequest(String, boolean, String, String, String, InetAddress, String) - Constructor for class com.couchbase.client.core.message.query.GenericQueryRequest
 
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>, 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(NetworkAddress, String) - Constructor for class com.couchbase.client.core.message.kv.GetAllMutationTokensRequest
 
GetAllMutationTokensRequest(GetAllMutationTokensRequest.PartitionState, NetworkAddress, 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
 
getBaggageItem(String) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
 
getBinaryErrorMap() - Static method in class com.couchbase.client.core.endpoint.ResponseStatusConverter
Get the current error map used by the response status converter
GetBucketConfigRequest - Class in com.couchbase.client.core.message.kv
Request which fetches a bucket configuration through carrier publication.
GetBucketConfigRequest(String, NetworkAddress) - 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, NetworkAddress) - 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
 
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.
getDecodingState() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
 
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
 
GetDesignDocumentRequest(String, boolean, String, 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
 
GetDesignDocumentsRequest(String, 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.
getFramingExtras() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
 
getFramingExtras() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage
Returns a ByteBuf representation of the optional framing extras.
getFramingExtrasLength() - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheMessage
 
getFramingExtrasLength() - Method in interface com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheMessage
Return the framing extras length of the message.
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
 
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 exception com.couchbase.client.core.CouchbaseException
 
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
 
getQueryParsingState() - Method in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
getQueryParsingState() - Method in class com.couchbase.client.core.endpoint.query.QueryHandler
 
getRaw() - Method in enum com.couchbase.client.core.config.BucketCapabilities
 
getRedactionLevel() - Static method in class com.couchbase.client.core.logging.CouchbaseLoggerFactory
Returns the current redaction level.
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
 
getResponseContent() - Method in class com.couchbase.client.core.endpoint.query.QueryHandlerV2
 
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.
GetUsersRequest - Class in com.couchbase.client.core.message.config
Get a user or list of users.
GetUsersResponse - Class in com.couchbase.client.core.message.config
 
GetUsersResponse(String, ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.config.GetUsersResponse
 

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.analytics.AnalyticsHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.config.ConfigHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.query.QueryHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.query.QueryHandlerV2
 
handlerRemoved(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.search.SearchHandler
 
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
Returns true if the config has a fast forward map that describes what the topology of the cluster will be after the current rebalance operation completes.
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
 
hash(NodeInfo, int) - Method in class com.couchbase.client.core.node.DefaultMemcachedHashingStrategy
 
hash(NodeInfo, int) - Method in class com.couchbase.client.core.node.LegacyMemcachedHashingStrategy
 
hash(NodeInfo, int) - Method in interface com.couchbase.client.core.node.MemcachedHashingStrategy
The hash for each node based on the node information and repetition.
hash(NodeInfo, int) - Method in class com.couchbase.client.core.node.StandardMemcachedHashingStrategy
 
hashCode() - Method in class com.couchbase.client.core.config.DefaultAlternateAddress
 
hashCode() - Method in class com.couchbase.client.core.config.ProposedBucketConfigContext
 
hashCode() - Method in class com.couchbase.client.core.env.NetworkResolution
 
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.message.ResponseStatusDetails
 
hashCode() - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsIdentifier
 
hashCode() - Method in class com.couchbase.client.core.node.CouchbaseNode
 
hashCode() - Method in class com.couchbase.client.core.utils.NetworkAddress
 
hasInitialResponse() - Method in class com.couchbase.client.core.security.sasl.ShaSaslClient
 
hasObservers() - Method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
 
hasPrimaryPartitionsOnNode(NetworkAddress) - Method in interface com.couchbase.client.core.config.CouchbaseBucketConfig
Checks if the given hostname has active primary partitions assigned to it.
hasPrimaryPartitionsOnNode(NetworkAddress) - 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.
headers() - Method in class com.couchbase.client.core.message.config.RestApiRequest
 
headers() - Method in class com.couchbase.client.core.message.config.RestApiResponse
 
HealthPinger - Class in com.couchbase.client.core.utils
The HealthPinger allows to “ping” individual services with real operations for their health.
HealthPinger() - Constructor for class com.couchbase.client.core.utils.HealthPinger
 
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 interface com.couchbase.client.core.config.AlternateAddress
The inet address of the node.
hostname() - Method in class com.couchbase.client.core.config.DefaultAlternateAddress
 
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.NoopRequest
 
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.
hostname() - Method in class com.couchbase.client.core.utils.NetworkAddress
Returns the hostname for this network address.
hosts() - Method in class com.couchbase.client.core.utils.ConnectionString
Get the list of hosts that could be resolved
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
 
HTTP_UNAUTHORIZED - 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(CoreEnvironment, ClusterFacade) - Constructor for class com.couchbase.client.core.config.refresher.HttpRefresher
 
httpStatus() - Method in class com.couchbase.client.core.message.config.RestApiResponse
 
httpStatusCode() - Method in class com.couchbase.client.core.message.analytics.RawAnalyticsResponse
 
httpStatusCode() - Method in class com.couchbase.client.core.message.query.RawQueryResponse
 
httpStatusMsg() - Method in class com.couchbase.client.core.message.analytics.RawAnalyticsResponse
 
httpStatusMsg() - Method in class com.couchbase.client.core.message.query.RawQueryResponse
 

I

id() - Method in interface com.couchbase.client.core.ClusterFacade
Deprecated.
Use ClusterFacade.ctx() which also contains the ID.
id() - Method in class com.couchbase.client.core.CouchbaseCore
 
id() - Method in class com.couchbase.client.core.message.internal.DiagnosticsReport
 
id() - Method in class com.couchbase.client.core.message.internal.DiagnosticsRequest
 
id() - Method in class com.couchbase.client.core.message.internal.EndpointHealth
 
id() - Method in class com.couchbase.client.core.message.internal.PingReport
 
id() - Method in class com.couchbase.client.core.message.internal.PingServiceHealth
 
identityMap(CouchbaseEvent) - Static method in class com.couchbase.client.core.utils.Events
Takes a CouchbaseEvent and returns a map with event information.
idleTime() - Method in class com.couchbase.client.core.env.AbstractServiceConfig
The time in seconds (minimum, approx) after when idle the socket will be closed.
ignoreActiveSpan() - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanBuilder
 
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.
InetAddresses - Class in com.couchbase.client.core.utils
 
InetAddresses() - Constructor for class com.couchbase.client.core.utils.InetAddresses
 
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.analytics.GenericAnalyticsResponse
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.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
 
initialize(ByteBuf, ResponseStatus, CouchbaseRequest) - Method in class com.couchbase.client.core.endpoint.query.parser.YasjlQueryResponseParser
Initialize this parser for a response parsing cycle.
initialize(ByteBuf) - Method in class com.couchbase.client.core.utils.yasjl.ByteBufJsonParser
(re)initializes this parser with new content.
inject(SpanContext, Format<C>, C) - Method in class com.couchbase.client.core.tracing.ThresholdLogTracer
 
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
 
insertDocument() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMutationRequest
Add document only if it does not exist
insertDocument(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationDocOptionsBuilder
 
insertDocument() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.SubMultiMutationDocOptionsBuilder
 
insertDocument() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
 
insertDocument(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
 
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.node.DefaultMemcachedHashingStrategy
 
INSTANCE - Static variable in class com.couchbase.client.core.node.LegacyMemcachedHashingStrategy
 
INSTANCE - Static variable in class com.couchbase.client.core.node.StandardMemcachedHashingStrategy
 
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.ServiceFactory
 
INSTANCE - Static variable in class com.couchbase.client.core.service.strategies.PartitionSelectionStrategy
 
instance() - Static method in class com.couchbase.client.core.tracing.RingBufferMonitor
 
instanceCounter() - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
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.
interval() - Method in class com.couchbase.client.core.endpoint.kv.ErrorMap.RetrySpecification
 
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, used as the default pool if not overridden for the individual services.
ioPool(EventLoopGroup) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Deprecated.
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
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
 
isActive() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
isActive() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
isActive() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
Checks if the request is unsubscribed on a timeout
isCompatible(EventLoop) - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
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.
isFree() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
 
isFree() - Method in interface com.couchbase.client.core.endpoint.Endpoint
If this endpoint is free to take a request.
isInetAddress(String) - Static method in class com.couchbase.client.core.utils.InetAddresses
 
isInfoEnabled() - Method in interface com.couchbase.client.core.logging.CouchbaseLogger
Is the logger instance enabled for the INFO level?
isInitialized() - Method in class com.couchbase.client.core.endpoint.query.parser.YasjlQueryResponseParser
True if this parser is currently initialized and ready to parse a response.
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.analytics.GenericAnalyticsRequest
 
isJsonFormat() - Method in class com.couchbase.client.core.message.query.GenericQueryRequest
 
isNumber(byte) - Static method in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
isOpen() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
isPipelined() - Method in class com.couchbase.client.core.env.AbstractServiceConfig
If this service is pipelined (more than one request at the same time on the same socket).
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
 
JSON_COLON - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JSON_COMMA - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JSON_ES - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JSON_F - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JSON_MINUS - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JSON_N - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JSON_PLUS - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JSON_ST - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JSON_T - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JSON_ZERO - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JsonArrayByteBufProcessor - Class in com.couchbase.client.core.utils.yasjl
Process JSON array
JsonArrayByteBufProcessor(JsonStringByteBufProcessor) - Constructor for class com.couchbase.client.core.utils.yasjl.JsonArrayByteBufProcessor
 
JsonBOMByteBufProcessor - Class in com.couchbase.client.core.utils.yasjl
Processes byte order mark.
JsonBOMByteBufProcessor() - Constructor for class com.couchbase.client.core.utils.yasjl.JsonBOMByteBufProcessor
 
JsonBooleanFalseByteBufProcessor - Class in com.couchbase.client.core.utils.yasjl
Processes JSON false value
JsonBooleanFalseByteBufProcessor() - Constructor for class com.couchbase.client.core.utils.yasjl.JsonBooleanFalseByteBufProcessor
 
JsonBooleanTrueByteBufProcessor - Class in com.couchbase.client.core.utils.yasjl
Processes JSON true value
JsonBooleanTrueByteBufProcessor() - Constructor for class com.couchbase.client.core.utils.yasjl.JsonBooleanTrueByteBufProcessor
 
JsonNullByteBufProcessor - Class in com.couchbase.client.core.utils.yasjl
Processes JSON null value
JsonNullByteBufProcessor() - Constructor for class com.couchbase.client.core.utils.yasjl.JsonNullByteBufProcessor
 
JsonNumberByteBufProcessor - Class in com.couchbase.client.core.utils.yasjl
Process JSON number
JsonNumberByteBufProcessor() - Constructor for class com.couchbase.client.core.utils.yasjl.JsonNumberByteBufProcessor
 
JsonObjectByteBufProcessor - Class in com.couchbase.client.core.utils.yasjl
Processes JSON object value
JsonObjectByteBufProcessor(JsonStringByteBufProcessor) - Constructor for class com.couchbase.client.core.utils.yasjl.JsonObjectByteBufProcessor
 
JsonParserUtils - Class in com.couchbase.client.core.utils.yasjl
 
JsonParserUtils() - Constructor for class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
JsonParserUtils.Mode - Enum in com.couchbase.client.core.utils.yasjl
 
JsonPointer - Class in com.couchbase.client.core.utils.yasjl
Represents a pointer in the JSON tree structure.
JsonPointer(String, JsonPointerCB) - Constructor for class com.couchbase.client.core.utils.yasjl.JsonPointer
Creates a new JsonPointer with a path and a callback.
JsonPointerCB - Interface in com.couchbase.client.core.utils.yasjl.Callbacks
 
JsonPointerCB1 - Interface in com.couchbase.client.core.utils.yasjl.Callbacks
 
JsonPointerCB2 - Interface in com.couchbase.client.core.utils.yasjl.Callbacks
 
JsonPointerTree - Class in com.couchbase.client.core.utils.yasjl
Represents a tree structure of stored JsonPointer.
jsonQuery(String, String, String, String) - Static method in class com.couchbase.client.core.message.analytics.GenericAnalyticsRequest
Create a GenericAnalyticsRequest and mark it as containing a full Analytics query in Json form (including additional query parameters).
jsonQuery(String, String, String, String, InetAddress) - Static method in class com.couchbase.client.core.message.analytics.GenericAnalyticsRequest
Create a GenericAnalyticsRequest and mark it as containing a full Analytics query in Json form (including additional query parameters).
jsonQuery(String, String, String) - Static method in class com.couchbase.client.core.message.analytics.RawAnalyticsRequest
Create a RawAnalyticsRequest containing a full Analytics query in Json form (including additional query parameters).
jsonQuery(String, String, String, String) - Static method in class com.couchbase.client.core.message.analytics.RawAnalyticsRequest
Create a RawAnalyticsRequest containing a full Analytics query in Json form (including additional query parameters).
jsonQuery(String, String, String, InetAddress) - Static method in class com.couchbase.client.core.message.analytics.RawAnalyticsRequest
Create a RawAnalyticsRequest containing a full Analytics query in Json form (including additional query parameters).
jsonQuery(String, String, String, String, InetAddress) - Static method in class com.couchbase.client.core.message.analytics.RawAnalyticsRequest
Create a RawAnalyticsRequest containing a full Analytics query in Json form (including additional query parameters).
jsonQuery(String, 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, 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, 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, String, InetAddress, 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, String) - Static method in class com.couchbase.client.core.message.query.RawQueryRequest
Create a RawQueryRequest containing a full N1QL query in Json form (including additional query parameters like named arguments, etc…).
jsonQuery(String, String, String, String, String) - Static method in class com.couchbase.client.core.message.query.RawQueryRequest
Create a RawQueryRequest containing a full N1QL query in Json form (including additional query parameters like named arguments, etc…).
jsonQuery(String, String, String, InetAddress, String) - Static method in class com.couchbase.client.core.message.query.RawQueryRequest
Create a RawQueryRequest containing a full N1QL query in Json form (including additional query parameters like named arguments, etc…).
jsonQuery(String, String, String, String, InetAddress, String) - Static method in class com.couchbase.client.core.message.query.RawQueryRequest
Create a RawQueryRequest containing a full N1QL query in Json form (including additional query parameters like named arguments, etc…).
jsonResponse() - Method in class com.couchbase.client.core.message.analytics.RawAnalyticsResponse
 
jsonResponse() - Method in class com.couchbase.client.core.message.query.RawQueryResponse
 
JsonStringByteBufProcessor - Class in com.couchbase.client.core.utils.yasjl
Processes JSON String value
JsonStringByteBufProcessor() - Constructor for class com.couchbase.client.core.utils.yasjl.JsonStringByteBufProcessor
 
JsonWhiteSpaceByteBufProcessor - Class in com.couchbase.client.core.utils.yasjl
Processes JSON ws
JsonWhiteSpaceByteBufProcessor() - Constructor for class com.couchbase.client.core.utils.yasjl.JsonWhiteSpaceByteBufProcessor
 

K

KeepAlive - Interface in com.couchbase.client.core.message
Marker interface to identify a request that handles a keepalive.
KEEPALIVE_ERROR_THRESHOLD - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
KEEPALIVE_TIMEOUT - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
keepAliveErrorThreshold() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Specifies the number of times a KeepAlive message on a socket can fail before the connection is recycled.
keepAliveErrorThreshold(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to customize the errors on keepalive messages threshold after which the connection will be recycled.
keepAliveErrorThreshold() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
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.analytics.AnalyticsHandler.KeepAliveRequest
 
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.query.QueryHandlerV2.KeepAliveRequest
 
KeepAliveRequest() - Constructor for class com.couchbase.client.core.endpoint.search.SearchHandler.KeepAliveRequest
 
KeepAliveRequest() - Constructor for class com.couchbase.client.core.endpoint.view.ViewHandler.KeepAliveRequest
 
KeepAliveResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler.KeepAliveResponse
 
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.query.QueryHandlerV2.KeepAliveResponse
 
KeepAliveResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.endpoint.search.SearchHandler.KeepAliveResponse
 
KeepAliveResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.endpoint.view.ViewHandler.KeepAliveResponse
 
keepAliveTimeout() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Specifies the timeout of a keepalive operation on the socket in milliseconds.
keepAliveTimeout(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to customize the timeout used for keepalive operations.
keepAliveTimeout() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
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.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_DECODE_MICROS - Static variable in class com.couchbase.client.core.tracing.ThresholdLogReporter
 
KEY_DISPATCH_MICROS - Static variable in class com.couchbase.client.core.tracing.ThresholdLogReporter
 
KEY_EEXISTS - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
 
KEY_ENCODE_MICROS - Static variable in class com.couchbase.client.core.tracing.ThresholdLogReporter
 
KEY_ENOENT - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheResponseStatus
 
KEY_SERVER_MICROS - Static variable in class com.couchbase.client.core.tracing.ThresholdLogReporter
 
KEY_TOTAL_MICROS - Static variable in class com.couchbase.client.core.tracing.ThresholdLogReporter
 
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, boolean) - 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, CoreContext) - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueEndpoint
Deprecated.
KeyValueEndpoint(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueEndpoint
Create a new KeyValueEndpoint.
KeyValueErrorMapHandler - Class in com.couchbase.client.core.endpoint.kv
This handler is added dynamically by the KeyValueFeatureHandler to load and store the extended error map from the server.
KeyValueErrorMapHandler() - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueErrorMapHandler
 
KeyValueFeatureHandler - Class in com.couchbase.client.core.endpoint.kv
This handler negotiates the enabled features through the HELLO command.
KeyValueFeatureHandler(CoreContext) - 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, 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
 
KeyValueSelectBucketHandler - Class in com.couchbase.client.core.endpoint.kv
A Select bucket handler required for Spock cluster
KeyValueSelectBucketHandler(String) - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
KeyValueService - Class in com.couchbase.client.core.service
 
KeyValueService(String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.KeyValueService
Deprecated.
KeyValueService(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.KeyValueService
Creates a new KeyValueService.
keyValueServiceConfig(KeyValueServiceConfig) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to set a custom configuration for the KV service.
KeyValueServiceConfig - Class in com.couchbase.client.core.env
 
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
kvEndpoints() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
kvIoPool() - Method in interface com.couchbase.client.core.env.CoreEnvironment
If set returns the IO Pool for the KV service, if not returns null.
kvIoPool(EventLoopGroup, ShutdownHook) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Sets the KV I/O Pool implementation for the underlying IO framework, along with the action to execute when this environment is shut down.
kvIoPool() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
kvServiceConfig() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Returns the current KeyValueService configuration.
kvServiceConfig() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
kvThreshold(long, TimeUnit) - Method in class com.couchbase.client.core.tracing.ThresholdLogReporter.Builder
Allows to customize the kvThreshold.

L

lastActivity() - Method in class com.couchbase.client.core.message.internal.EndpointHealth
 
lastLocalId() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
lastLocalId(String) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
lastLocalId() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
 
lastLocalId(String) - Method in interface com.couchbase.client.core.message.CouchbaseRequest
 
lastLocalSocket() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
lastLocalSocket(String) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
lastLocalSocket() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
 
lastLocalSocket(String) - Method in interface com.couchbase.client.core.message.CouchbaseRequest
 
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
 
lastRemoteSocket() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
lastRemoteSocket(String) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
lastRemoteSocket() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
 
lastRemoteSocket(String) - Method in interface com.couchbase.client.core.message.CouchbaseRequest
 
lastResponse() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
 
lastResponse() - Method in interface com.couchbase.client.core.endpoint.Endpoint
Returns the timestamp of the last response completed.
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.
latency() - Method in class com.couchbase.client.core.message.internal.PingServiceHealth
 
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.
LegacyMemcachedHashingStrategy - Class in com.couchbase.client.core.node
The legacy memcache bucket hashing strategy, compatible with Java SDK 1.x.
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(NetworkAddress, String, String) - Method in class com.couchbase.client.core.config.loader.AbstractLoader
Initiate the config loading process.
loadConfig(NetworkAddress, String, String, String) - Method in class com.couchbase.client.core.config.loader.AbstractLoader
Initiate the config loading process.
loadConfig(NetworkAddress, String, String) - Method in interface com.couchbase.client.core.config.loader.Loader
Deprecated.
loadConfig(NetworkAddress, String, 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
.
local() - Method in class com.couchbase.client.core.message.internal.EndpointHealth
 
local() - Method in class com.couchbase.client.core.message.internal.PingServiceHealth
 
localAddress0() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
localhost() - Static method in class com.couchbase.client.core.utils.NetworkAddress
Creates a new NetworkAddress for loopback.
localSocket() - Method in class com.couchbase.client.core.message.analytics.PingRequest
 
localSocket(SocketAddress) - Method in class com.couchbase.client.core.message.analytics.PingRequest
 
localSocket() - Method in interface com.couchbase.client.core.message.DiagnosticRequest
 
localSocket(SocketAddress) - Method in interface com.couchbase.client.core.message.DiagnosticRequest
 
localSocket() - Method in class com.couchbase.client.core.message.kv.NoopRequest
 
localSocket(SocketAddress) - Method in class com.couchbase.client.core.message.kv.NoopRequest
 
localSocket() - Method in class com.couchbase.client.core.message.query.PingRequest
 
localSocket(SocketAddress) - Method in class com.couchbase.client.core.message.query.PingRequest
 
localSocket() - Method in class com.couchbase.client.core.message.search.PingRequest
 
localSocket(SocketAddress) - Method in class com.couchbase.client.core.message.search.PingRequest
 
localSocket() - Method in class com.couchbase.client.core.message.view.PingRequest
 
localSocket(SocketAddress) - Method in class com.couchbase.client.core.message.view.PingRequest
 
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.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
 
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.
log(Map<String, ?>) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
 
log(String) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
 
log(long, Map<String, ?>) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
 
log(long, String) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
 
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(NetworkAddress) - 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.
logInterval(long, TimeUnit) - Method in class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter.Builder
Allows to customize the log interval.
logInterval(long, TimeUnit) - Method in class com.couchbase.client.core.tracing.ThresholdLogReporter.Builder
Allows to customize the log interval.
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
 
lookup() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommandBuilder
 
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
Deprecated.
LookupCommand(LookupCommandBuilder) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommand
 
LookupCommandBuilder - Class in com.couchbase.client.core.message.kv.subdoc.multi
Builder for LookupCommand
LookupCommandBuilder(Lookup, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommandBuilder
Create a multi-lookup command.

M

mapping() - Method in class com.couchbase.client.core.service.AbstractDynamicService
 
mapping() - Method in class com.couchbase.client.core.service.PooledService
 
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
 
MathUtils - Class in com.couchbase.client.core.utils
Various math utility methods, also backports from later JDK versions.
MathUtils() - Constructor for class com.couchbase.client.core.utils.MathUtils
 
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
 
maxAllowedInstances() - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
Returns the number of maximal allowed instances before warning log will be emitted.
maxAllowedInstances(int) - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
Allows to set the maximum allowed instances to higher than 1 to silence warning logs in environments where it can be disregarded.
maxDuration() - Method in class com.couchbase.client.core.endpoint.kv.ErrorMap.RetrySpecification
 
maxEndpoints() - Method in class com.couchbase.client.core.env.AbstractServiceConfig
The maximum endpoints per node which will be established.
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
 
maxRetryDuration(long) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
maxRetryDuration() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
maxRetryDuration(long) - Method in interface com.couchbase.client.core.message.CouchbaseRequest
Sets the maximum retry duration for the request.
maxRetryDuration() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
Returns the maximum retry duration for the request.
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.
MEMCACHED_HASHING_STRATEGY - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
MemcachedBucketConfig - Interface in com.couchbase.client.core.config
A configuration representing a memcached bucket.
memcachedHashingStrategy() - Method in interface com.couchbase.client.core.env.ConfigParserEnvironment
Allows to specify a custom strategy to hash memcached bucket documents.
memcachedHashingStrategy(MemcachedHashingStrategy) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Sets a custom memcached node hashing strategy, mainly used for compatibility with other clients.
memcachedHashingStrategy() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
MemcachedHashingStrategy - Interface in com.couchbase.client.core.node
This interface defines different hashing strategies used for ketama hashing in memcached buckets.
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.
message() - Method in class com.couchbase.client.core.logging.RedactableArgument
The message of this redactable argument.
message() - Method in class com.couchbase.client.core.message.config.UpsertUserResponse
 
meta(Object) - Static method in class com.couchbase.client.core.logging.RedactableArgument
A redactable argument of meta data.
metadata() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
method() - Method in class com.couchbase.client.core.message.config.RestApiRequest
 
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.
MIN_COMPRESSION_RATIO - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
MIN_COMPRESSION_SIZE - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
minEndpoints() - Method in class com.couchbase.client.core.env.AbstractServiceConfig
The minimum endpoints per node which will always be established.
MINIMUM_WINDOW_FOR_CLIENTID_TOKEN - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
This is a window of characters allowing to detect the clientContextID token (including room for JSON separators, etc…).
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
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() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
 
MUTATION_TOKENS_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
mutationCas() - Method in exception com.couchbase.client.core.DocumentConcurrentlyModifiedException
 
mutationCas() - Method in exception com.couchbase.client.core.DocumentMutationLostException
 
mutationCas() - Method in interface com.couchbase.client.core.OriginalMutationResult
If the originating operation used to be a mutation and was successful, this getter allows to retrieve the cas value returned.
mutationCas() - Method in exception com.couchbase.client.core.ReplicaNotAvailableException
 
mutationCas() - Method in exception com.couchbase.client.core.ReplicaNotConfiguredException
 
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
Deprecated.
MutationCommand(Mutation, String, ByteBuf) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
Deprecated.
MutationCommand(Mutation, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
Deprecated.
MutationCommand(MutationCommandBuilder) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
Create a multi-mutation command.
MutationCommandBuilder - Class in com.couchbase.client.core.message.kv.subdoc.multi
Builder for MutationCommand.
MutationCommandBuilder(Mutation, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
Create a multi-mutation command.
MutationCommandBuilder(Mutation, String, ByteBuf) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
Create a multi-mutation command.
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

n1qlThreshold(long, TimeUnit) - Method in class com.couchbase.client.core.tracing.ThresholdLogReporter.Builder
Allows to customize the n1qlThreshold.
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.endpoint.kv.ErrorMap.ErrorCode
 
name() - Method in class com.couchbase.client.core.env.NetworkResolution
Returns the wire representation of the network resolution setting.
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
 
nameAndAddress() - Method in class com.couchbase.client.core.utils.NetworkAddress
Prints a safe representation of the hostname (if available) and the IP address.
nameOrAddress() - Method in class com.couchbase.client.core.utils.NetworkAddress
Returns the hostname if available and if not returns the address.
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
 
NETWORK_RESOLUTION - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
NetworkAddress - Class in com.couchbase.client.core.utils
A convenient wrapper class around network primitives in Java.
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
 
networkResolution() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Allows to configure the network resolution, default being automatic.
networkResolution(NetworkResolution) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to tune the network resolution setting, pinning it to either internal or external instead of relying on the automatic mechanism.
networkResolution() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
NetworkResolution - Class in com.couchbase.client.core.env
Configuration options for CoreEnvironment.networkResolution().
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
 
newUnsafe() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
newVbucketUUID() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
 
newWaitStrategy() - Method in interface com.couchbase.client.core.env.WaitStrategyFactory
 
NO_IDLE_TIME - Static variable in class com.couchbase.client.core.env.AbstractServiceConfig
 
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(NetworkAddress) - 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(NetworkAddress) - 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(NetworkAddress) - 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
 
NoopRequest - Class in com.couchbase.client.core.message.kv
 
NoopRequest(String, NetworkAddress) - Constructor for class com.couchbase.client.core.message.kv.NoopRequest
 
NoopResponse - Class in com.couchbase.client.core.message.kv
 
NoopResponse(ResponseStatus, short, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.NoopResponse
 
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.
notifyResponseDecoded(boolean) - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
Called by the underlying channel to notify when the channel finished decoding the current response.
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
 
numEnvs() - Method in class com.couchbase.client.core.event.system.TooManyEnvironmentsEvent
The number of open environments at the time of the event.

O

O_CURLY - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
O_SQUARE - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
 
Objects - Class in com.couchbase.client.core.lang.backport.java.util
Backport of some utility methods from Java 1.7+
observable() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
 
observable() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
Get the underlying Observable.
Observables - Enum in com.couchbase.client.core.utils
Various utilities to help with Observables.
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, long) - 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
 
OldAnalyticsService - Class in com.couchbase.client.core.service
The Service is composed of and manages AnalyticsEndpoints.
OldAnalyticsService(String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldAnalyticsService
Deprecated.
OldAnalyticsService(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldAnalyticsService
Creates a new OldAnalyticsService.
OldKeyValueService - Class in com.couchbase.client.core.service
 
OldKeyValueService(String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldKeyValueService
Deprecated.
OldKeyValueService(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldKeyValueService
Creates a new KeyValueService.
OldQueryService - Class in com.couchbase.client.core.service
The QueryService is composed of and manages QueryEndpoints.
OldQueryService(String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldQueryService
Deprecated.
OldQueryService(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldQueryService
Creates a new QueryService.
OldSearchService - Class in com.couchbase.client.core.service
 
OldSearchService(String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldSearchService
Deprecated.
OldSearchService(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldSearchService
Creates a new ViewService.
oldVbucketUUID() - Method in class com.couchbase.client.core.message.kv.FailoverObserveSeqnoResponse
 
OldViewService - Class in com.couchbase.client.core.service
The ViewService is composed of and manages ViewEndpoints.
OldViewService(String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldViewService
Deprecated.
OldViewService(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.OldViewService
Creates a new ViewService.
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_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_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_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_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_PREPEND - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
 
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_STAT - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
 
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_GET_COUNT - 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 class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommandBuilder
 
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 class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
 
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.SubGetCountRequest
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, 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
 
openBucket(String, 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
 
OpenBucketRequest(String, 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.
operation() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MultiResult
 
OPERATION_TRACING_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
OPERATION_TRACING_SERVER_DUR_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
operationId() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
Default implementation, sub requests need to override this.
operationId() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
A unique operation id, used for tracing purposes.
operationId() - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
 
operationId() - Method in class com.couchbase.client.core.message.query.GenericQueryRequest
 
operationName() - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
Returns the operation name.
operationTracingEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment
True if tracing is enabled on the environment.
operationTracingEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to enable/disable the tracing support.
operationTracingEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
operationTracingServerDurationEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment
True if additional server duration tracing is enabled.
operationTracingServerDurationEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to enable/disable the negotiation of server duration-enabled tracing.
operationTracingServerDurationEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
origin() - Method in class com.couchbase.client.core.config.ProposedBucketConfigContext
Returns the origin, might be null.
OriginalMutationResult - Interface in com.couchbase.client.core
Represents mutation metadata which can be inspected after a mutation and during/after is respective observe poll cycles.
ORPHAN_REPORTING_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
orphanResponseReporter() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Returns the current orphan response reporter implementation.
orphanResponseReporter(OrphanResponseReporter) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
 
orphanResponseReporter() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
OrphanResponseReporter - Interface in com.couchbase.client.core.tracing
 
orphanResponseReportingEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Check if orphan response reporting is enabled.
orphanResponseReportingEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
 
orphanResponseReportingEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
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
 
paddedHex(long) - Static method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
Helper method to create a padded hex long value.
params() - Method in class com.couchbase.client.core.utils.ConnectionString
 
parse(String, ConfigParserEnvironment, NetworkAddress) - Static method in class com.couchbase.client.core.config.parser.BucketConfigParser
Parse a raw configuration into a BucketConfig.
parse() - Method in class com.couchbase.client.core.endpoint.query.parser.YasjlQueryResponseParser
Instruct the parser to run a new parsing cycle on the current response content.
parse() - Method in class com.couchbase.client.core.utils.yasjl.ByteBufJsonParser
Instructs the parser to start parsing the current buffer.
Partition - Interface in com.couchbase.client.core.config
 
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
 
PARTITION_NOT_EXISTENT - Static variable in class com.couchbase.client.core.config.DefaultCouchbaseBucketConfig
 
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/user.
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/user.
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/ user
path() - Method in class com.couchbase.client.core.endpoint.search.SearchHandler.KeepAliveRequest
 
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.GetUsersRequest
 
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.RemoveUserRequest
 
path() - Method in class com.couchbase.client.core.message.config.RestApiRequest
 
path() - Method in class com.couchbase.client.core.message.config.UpdateBucketRequest
 
path() - Method in class com.couchbase.client.core.message.config.UpsertUserRequest
 
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.LookupCommandBuilder
 
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.multi.MutationCommandBuilder
 
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.PingRequest
 
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
 
pathWithParameters() - Method in class com.couchbase.client.core.message.config.RestApiRequest
 
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.config.UpsertUserRequest
 
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.
ping(CoreEnvironment, String, String, ClusterFacade, String, long, TimeUnit, ServiceType...) - Static method in class com.couchbase.client.core.utils.HealthPinger
Performs a service ping against all or (if given) the services provided.
PingReport - Class in com.couchbase.client.core.message.internal
Contains a report for all the internal service health states.
PingReport(List<PingServiceHealth>, String, String, long) - Constructor for class com.couchbase.client.core.message.internal.PingReport
 
PingRequest - Class in com.couchbase.client.core.message.analytics
 
PingRequest(InetAddress, String, String) - Constructor for class com.couchbase.client.core.message.analytics.PingRequest
 
PingRequest - Class in com.couchbase.client.core.message.query
 
PingRequest(InetAddress, String, String) - Constructor for class com.couchbase.client.core.message.query.PingRequest
 
PingRequest - Class in com.couchbase.client.core.message.search
 
PingRequest(InetAddress, String, String) - Constructor for class com.couchbase.client.core.message.search.PingRequest
 
PingRequest - Class in com.couchbase.client.core.message.view
 
PingRequest(InetAddress, String, String) - Constructor for class com.couchbase.client.core.message.view.PingRequest
 
PingResponse - Class in com.couchbase.client.core.message.analytics
 
PingResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.analytics.PingResponse
 
PingResponse - Class in com.couchbase.client.core.message.query
 
PingResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.query.PingResponse
 
PingResponse - Class in com.couchbase.client.core.message.search
 
PingResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.search.PingResponse
 
PingResponse - Class in com.couchbase.client.core.message.view
 
PingResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.view.PingResponse
 
PingServiceHealth - Class in com.couchbase.client.core.message.internal
Represents health for a specific service on ping.
PingServiceHealth(ServiceType, PingServiceHealth.PingState, String, long, SocketAddress, SocketAddress, String) - Constructor for class com.couchbase.client.core.message.internal.PingServiceHealth
 
PingServiceHealth.PingState - Enum in com.couchbase.client.core.message.internal
 
PooledService - Class in com.couchbase.client.core.service
A generic implementation of a service pool.
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
 
pretty(boolean) - Method in class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter.Builder
Allows to set the JSON output to pretty, making it more readable but also more verbose.
pretty(boolean) - Method in class com.couchbase.client.core.tracing.ThresholdLogReporter.Builder
Allows to set the JSON output to pretty, making it more readable but also more verbose.
prettyWriter() - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
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
 
process(byte) - Method in class com.couchbase.client.core.utils.yasjl.JsonArrayByteBufProcessor
 
process(byte) - Method in class com.couchbase.client.core.utils.yasjl.JsonBOMByteBufProcessor
 
process(byte) - Method in class com.couchbase.client.core.utils.yasjl.JsonBooleanFalseByteBufProcessor
 
process(byte) - Method in class com.couchbase.client.core.utils.yasjl.JsonBooleanTrueByteBufProcessor
 
process(byte) - Method in class com.couchbase.client.core.utils.yasjl.JsonNullByteBufProcessor
 
process(byte) - Method in class com.couchbase.client.core.utils.yasjl.JsonNumberByteBufProcessor
 
process(byte) - Method in class com.couchbase.client.core.utils.yasjl.JsonObjectByteBufProcessor
 
process(byte) - Method in class com.couchbase.client.core.utils.yasjl.JsonStringByteBufProcessor
 
process(byte) - Method in class com.couchbase.client.core.utils.yasjl.JsonWhiteSpaceByteBufProcessor
 
profileInfo() - Method in class com.couchbase.client.core.message.query.GenericQueryResponse
Contains a single ByteBuf representing the JSON object of query profile information (or empty if profile haven’t been activated).
proposeBucketConfig(ProposedBucketConfigContext) - Method in interface com.couchbase.client.core.config.ConfigurationProvider
Propose a new bucket config with surrounding context.
proposeBucketConfig(ProposedBucketConfigContext) - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
 
ProposedBucketConfigContext - Class in com.couchbase.client.core.config
This context keeps together a bunch of related information needed to turn a raw config into a parsed one.
ProposedBucketConfigContext(String, String, NetworkAddress) - Constructor for class com.couchbase.client.core.config.ProposedBucketConfigContext
Creates a new proposed bucket config context.
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(ProposedBucketConfigContext) - 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.analytics.GenericAnalyticsRequest
 
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
 
QUERY_STATE_DONE - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_DONE - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_ERROR - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_ERROR - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_INFO - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_INFO - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_INITIAL - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_INITIAL - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_NO_INFO - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_NO_INFO - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_ROWS - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_ROWS - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_ROWS_DECIDE - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_ROWS_DECIDE - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_ROWS_RAW - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_ROWS_RAW - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_SIGNATURE - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_SIGNATURE - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_STATUS - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_STATUS - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
QUERY_STATE_WARNING - Static variable in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
 
QUERY_STATE_WARNING - Static variable in class com.couchbase.client.core.endpoint.query.QueryHandler
 
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, CoreContext) - Constructor for class com.couchbase.client.core.endpoint.query.QueryEndpoint
Deprecated.
QueryEndpoint(String, String, String, String, int, CoreContext) - 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
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, 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
 
QueryHandlerV2 - Class in com.couchbase.client.core.endpoint.query
The QueryHandlerV2 is responsible for encoding QueryRequests into lower level HttpRequests as well as decoding HttpObjects into CouchbaseResponses.
QueryHandlerV2(AbstractEndpoint, RingBuffer<ResponseEvent>, boolean, boolean) - Constructor for class com.couchbase.client.core.endpoint.query.QueryHandlerV2
Creates a new QueryHandlerV2 with the default queue for requests.
QueryHandlerV2.KeepAliveRequest - Class in com.couchbase.client.core.endpoint.query
 
QueryHandlerV2.KeepAliveResponse - Class in com.couchbase.client.core.endpoint.query
 
queryIoPool() - Method in interface com.couchbase.client.core.env.CoreEnvironment
If set returns the IO Pool for the query service, if not returns null.
queryIoPool(EventLoopGroup, ShutdownHook) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Sets the Query I/O Pool implementation for the underlying IO framework, along with the action to execute when this environment is shut down.
queryIoPool() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
QueryLocator - Class in com.couchbase.client.core.node.locate
 
QueryLocator() - Constructor for class com.couchbase.client.core.node.locate.QueryLocator
Generates the random initial value for the round robin counter used.
queryParameters() - Method in class com.couchbase.client.core.message.config.RestApiRequest
 
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, CoreContext) - Constructor for class com.couchbase.client.core.service.QueryService
Deprecated.
QueryService(String, String, String, String, int, CoreContext) - Constructor for class com.couchbase.client.core.service.QueryService
Creates a new QueryService.
queryServiceConfig() - Method in interface com.couchbase.client.core.env.CoreEnvironment
Returns the current QueryService configuration.
queryServiceConfig(QueryServiceConfig) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
Allows to set a custom configuration for the Query service.
queryServiceConfig() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
 
QueryServiceConfig - Class in com.couchbase.client.core.env
 
queryStatus() - Method in class com.couchbase.client.core.message.analytics.GenericAnalyticsResponse
Contains a single String denoting the status of the query (success, running, errors, completed, stopped, timeout, fatal).
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
 
raw() - Method in enum com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
 
RawAnalyticsRequest - Class in com.couchbase.client.core.message.analytics
A AnalyticsRequest that can also be prelocated, but expects a response with the uninterpreted JSON payload returned by the query service.
RawAnalyticsResponse - Class in com.couchbase.client.core.message.analytics
The response to a RawAnalyticsRequest, which only contains the raw JSON payload returned by the Analytics service, as a ByteBuf.
RawAnalyticsResponse(ResponseStatus, CouchbaseRequest, ByteBuf, int, String) - Constructor for class com.couchbase.client.core.message.analytics.RawAnalyticsResponse
 
rawHostname() - Method in interface com.couchbase.client.core.config.AlternateAddress
Contains the string representation from the hostname the same way it is represented in the config.
rawHostname() - Method in class com.couchbase.client.core.config.DefaultAlternateAddress
 
rawHostname() - Method in class com.couchbase.client.core.config.DefaultNodeInfo
 
rawHostname() - Method in interface com.couchbase.client.core.config.NodeInfo
Contains the string representation from the hostname the same way it is represented in the config.
RawQueryRequest - Class in com.couchbase.client.core.message.query
A QueryRequest that can also be prelocated, but expects a response with the uninterpreted JSON payload returned by the query service.
RawQueryResponse - Class in com.couchbase.client.core.message.query
The response to a RawQueryRequest, which only contains the raw JSON payload returned by the Query service, as a ByteBuf.
RawQueryResponse(ResponseStatus, CouchbaseRequest, ByteBuf, int, String) - Constructor for class com.couchbase.client.core.message.query.RawQueryResponse
 
read(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueAuthHandler
 
read(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueErrorMapHandler
 
read(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueFeatureHandler
 
read(ChannelHandlerContext) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueSelectBucketHandler
 
reader() - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readErrorCodeFromErrorMap(short) - Static method in class com.couchbase.client.core.endpoint.ResponseStatusConverter
Get the error code from Key Value error map
readResolve() - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
 
readTree(String) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readTree(byte[]) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readTree(Reader) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readTree(InputStream) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(String, Class<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(String, TypeReference<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(byte[], Class<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(byte[], int, int, Class<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(byte[], TypeReference<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(byte[], int, int, TypeReference<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(Reader, Class<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(Reader, TypeReference<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(InputStream, Class<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValue(InputStream, TypeReference<T>) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValueAsMap(String) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValueAsMap(byte[]) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValueAsMap(Reader) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
readValueAsMap(InputStream) - Static method in class com.couchbase.client.core.utils.DefaultObjectMapper
 
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.
RedactableArgument - Class in com.couchbase.client.core.logging
Represents a logging argument which is subject to redaction.
RedactableArgument.ArgumentType - Enum in com.couchbase.client.core.logging
The type of the redactable argument.
RedactionLevel - Enum in com.couchbase.client.core.logging
Allows to specify the level of log redaction.
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
 
reference() - Method in class com.couchbase.client.core.message.ResponseStatusDetails
 
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, 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, String) - Method in class com.couchbase.client.core.config.refresher.HttpRefresher
 
registerBucket(String, String) - Method in interface com.couchbase.client.core.config.refresher.Refresher
Deprecated.
registerBucket(String, 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
 
remote() - Method in class com.couchbase.client.core.message.internal.EndpointHealth
 
remote() - Method in class com.couchbase.client.core.message.internal.PingServiceHealth
 
remoteAddress() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
 
remoteAddress() - Method in interface com.couchbase.client.core.endpoint.Endpoint
Returns the remote address as String representation.
remoteAddress0() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
 
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.
remoteSocket() - Method in class com.couchbase.client.core.message.analytics.PingRequest
 
remoteSocket(SocketAddress) - Method in class com.couchbase.client.core.message.analytics.PingRequest
 
remoteSocket() - Method in interface com.couchbase.client.core.message.DiagnosticRequest
 
remoteSocket(SocketAddress) - Method in interface com.couchbase.client.core.message.DiagnosticRequest
 
remoteSocket() - Method in class com.couchbase.client.core.message.kv.NoopRequest
 
remoteSocket(SocketAddress) - Method