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
All Classes All Packages
All Classes All Packages
A
- AbstractBinaryMemcacheDecoder<M extends BinaryMemcacheMessage> - Class in com.couchbase.client.deps.io.netty.handler.codec.memcache.binary
-
Decoder for both
BinaryMemcacheRequest
andBinaryMemcacheResponse
. - 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>, String) - Constructor for class com.couchbase.client.core.config.AbstractBucketConfig
- AbstractCouchbaseLogger - Class in com.couchbase.client.core.logging
-
A skeletal implementation of
CouchbaseLogger
. - AbstractCouchbaseLogger(String) - Constructor for class com.couchbase.client.core.logging.AbstractCouchbaseLogger
-
Creates a new instance.
- AbstractCouchbaseRequest - Class in com.couchbase.client.core.message
-
Default implementation for a
CouchbaseRequest
, should be extended by child messages. - AbstractCouchbaseRequest(String, String) - Constructor for class com.couchbase.client.core.message.AbstractCouchbaseRequest
-
Create a new
AbstractCouchbaseRequest
. - AbstractCouchbaseRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.AbstractCouchbaseRequest
-
Create a new
AbstractCouchbaseRequest
. - AbstractCouchbaseRequest(String, String, String, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.AbstractCouchbaseRequest
-
Create a new
AbstractCouchbaseRequest
. - AbstractCouchbaseResponse - Class in com.couchbase.client.core.message
-
The default representation of a
CouchbaseResponse
. - AbstractCouchbaseResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.AbstractCouchbaseResponse
-
Sets the required properties for the response.
- 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
Endpoint
s. - 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
-
Creates a new
AbstractKeyValueRequest
. - AbstractKeyValueRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
-
Creates a new
AbstractKeyValueRequest
. - AbstractKeyValueRequest(String, String, String, String) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
-
Creates a new
AbstractKeyValueRequest
. - AbstractKeyValueRequest(String, String, String, String, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
-
Creates a new
AbstractKeyValueRequest
. - AbstractKeyValueResponse - Class in com.couchbase.client.core.message.kv
- AbstractKeyValueResponse(ResponseStatus, short, String, ByteBuf, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.kv.AbstractKeyValueResponse
- AbstractLatencyMetricsCollector<I extends LatencyMetricsIdentifier,E extends LatencyMetricsEvent> - Class in com.couchbase.client.core.metrics
-
The default abstract implementation for a latency metrics collector.
- AbstractLatencyMetricsCollector(EventBus, Scheduler, LatencyMetricsCollectorConfig) - Constructor for class com.couchbase.client.core.metrics.AbstractLatencyMetricsCollector
- AbstractLazyService - Class in com.couchbase.client.core.service
-
This service lazily creates an Endpoint if needed and reuses it.
- AbstractLazyService(String, String, String, 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 anMemcacheMessage
and its followingMemcacheContent
s into a singleMemcacheMessage
with no followingMemcacheContent
s. - 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 encodesMemcacheMessage
s. - 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
-
Creates a new service config.
- 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 theAbstractStringAwareBufProcessor.isEscaped(byte)
method. - AbstractStringAwareBufProcessor() - Constructor for class com.couchbase.client.core.endpoint.util.AbstractStringAwareBufProcessor
- AbstractSubdocMutationRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple
-
Base class for all
BinarySubdocMutationRequest
. - AbstractSubdocMutationRequest(String, String, ByteBuf, String, int, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
-
Creates a new
AbstractSubdocMutationRequest
. - AbstractSubdocMutationRequest(String, String, ByteBuf, String, int, long, Subject<CouchbaseResponse, CouchbaseResponse>) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
-
Creates a new
AbstractSubdocMutationRequest
. - AbstractSubdocRequest - Class in com.couchbase.client.core.message.kv.subdoc.simple
-
Base class for all
BinarySubdocRequest
. - AbstractSubdocRequest(String, String, String, ByteBuf...) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest
-
Creates a new
AbstractSubdocRequest
. - AbstractSubdocRequest(String, String, String, Subject<CouchbaseResponse, CouchbaseResponse>, ByteBuf...) - Constructor for class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocRequest
-
Creates a new
AbstractSubdocRequest
. - acceptOutboundMessage(Object) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectEncoder
- ACCESS_ERROR - com.couchbase.client.core.message.ResponseStatus
-
Access error.
- 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() - 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.multi.SubMultiLookupDocOptionsBuilder
- accessDeleted(boolean) - 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.SubGetCountRequest
- 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
- ACTIVE - com.couchbase.client.core.message.kv.GetAllMutationTokensRequest.PartitionState
-
Actively servicing a partition.
- 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
- ADD_UNIQUE - com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest.ArrayOperation
-
Add a value in an existing array unless the value already is present in the array.
- addHttpBasicAuth(ChannelHandlerContext, HttpRequest, String, String) - Static method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
-
Add basic authentication headers to a
HttpRequest
. - addNode(String, String) - 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(String) - Constructor for class com.couchbase.client.core.message.internal.AddNodeRequest
- AddNodeResponse - Class in com.couchbase.client.core.message.internal
- AddNodeResponse(ResponseStatus, String) - 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(AddServiceRequest) - Method in interface com.couchbase.client.core.node.Node
- addService(AddServiceRequest) - Method in class com.couchbase.client.core.RequestHandler
-
Add the service to the node.
- addService(Service, String) - Method in class com.couchbase.client.core.node.DefaultServiceRegistry
- addService(Service, String) - Method in interface com.couchbase.client.core.node.ServiceRegistry
- AddServiceRequest - Class in com.couchbase.client.core.message.internal
- AddServiceRequest(ServiceType, String, String, int, String) - Constructor for class com.couchbase.client.core.message.internal.AddServiceRequest
- AddServiceRequest(ServiceType, String, String, String, int, String) - Constructor for class com.couchbase.client.core.message.internal.AddServiceRequest
- AddServiceResponse - Class in com.couchbase.client.core.message.internal
- AddServiceResponse(ResponseStatus, String) - 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
-
Deprecated.
- 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 - com.couchbase.client.core.service.ServiceType
-
Analytics operations.
- 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 encodingAnalyticsRequest
s into lower levelHttpRequest
s as well as decodingHttpObject
s intoCouchbaseResponse
s. - 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
- AnalyticsHandlerV2 - Class in com.couchbase.client.core.endpoint.analytics
-
The
AnalyticsHandlerV2
is responsible for encodingAnalyticsRequest
s into lower levelHttpRequest
s as well as decodingHttpObject
s intoCouchbaseResponse
s. - AnalyticsHandlerV2(AbstractEndpoint, RingBuffer<ResponseEvent>, boolean, boolean) - Constructor for class com.couchbase.client.core.endpoint.analytics.AnalyticsHandlerV2
-
Creates a new
AnalyticsHandlerV2
with the default queue for requests. - AnalyticsHandlerV2.KeepAliveRequest - Class in com.couchbase.client.core.endpoint.analytics
- AnalyticsHandlerV2.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
- AnalyticsQueryResultRequest - Class in com.couchbase.client.core.message.analytics
-
Deferred analytics query result request
- AnalyticsQueryResultRequest(String, String, String, String) - Constructor for class com.couchbase.client.core.message.analytics.AnalyticsQueryResultRequest
- AnalyticsQueryResultRequest(String, String, String, String, String) - Constructor for class com.couchbase.client.core.message.analytics.AnalyticsQueryResultRequest
- AnalyticsQueryStatusRequest - Class in com.couchbase.client.core.message.analytics
-
Deferred analytics query status request
- AnalyticsQueryStatusRequest(String, String, String, String) - Constructor for class com.couchbase.client.core.message.analytics.AnalyticsQueryStatusRequest
- AnalyticsQueryStatusRequest(String, String, String, String, String) - Constructor for class com.couchbase.client.core.message.analytics.AnalyticsQueryStatusRequest
- 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 managesAnalyticsEndpoint
s. - 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() - Method in interface com.couchbase.client.core.env.CoreEnvironment
-
Returns the current service configuration for the Analytics service.
- 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.
- AnalyticsServiceConfig - Class in com.couchbase.client.core.env
-
Allows to configure a Analytics Service on a per-node basis.
- analyticsThreshold(long, TimeUnit) - Method in class com.couchbase.client.core.tracing.ThresholdLogReporter.Builder
-
Allows to customize the analyticsThreshold.
- ANY - com.couchbase.client.core.message.kv.GetAllMutationTokensRequest.PartitionState
-
Any live state (except DEAD).
- 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
- ARRAY_ADD_UNIQUE - com.couchbase.client.core.message.kv.subdoc.multi.Mutation
- ARRAY_INSERT - com.couchbase.client.core.message.kv.subdoc.multi.Mutation
- ARRAY_PUSH_FIRST - com.couchbase.client.core.message.kv.subdoc.multi.Mutation
- ARRAY_PUSH_LAST - com.couchbase.client.core.message.kv.subdoc.multi.Mutation
- arrayOperation() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest
- asChildOf(Span) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanBuilder
- asChildOf(SpanContext) - 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 - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
The operation failed because the client failed to authenticate or is not authorized to perform this operation.
- 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.
- AUTO_RETRY - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
Use retry specifications from the server
- 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) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanContext
-
Retrieve the baggage value by item.
- baggageItem(String, String) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpanContext
-
Stores the given baggage item/value.
- 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. - BINARY - com.couchbase.client.core.service.ServiceType
-
Key/Value type operations.
- 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
andBinaryMemcacheResponse
. - 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
BinaryRequest
s. - 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 anException
. - 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
- BOM - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- 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 11210).
- 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 true).
- 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 11207).
- 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 8091).
- 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 true).
- 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 18091).
- 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(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
- BucketConfig - Interface in com.couchbase.client.core.config
-
Represents a Couchbase Bucket Configuration.
- 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, String, String, String) - Constructor for class com.couchbase.client.core.message.config.BucketConfigRequest
- BucketConfigRequest(String, String, 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() - 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() - Static method in class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter
- builder() - Static method in class com.couchbase.client.core.tracing.ThresholdLogReporter
- Builder() - Constructor for class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
- Builder() - Constructor for class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig.Builder
- Builder() - Constructor for class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig.Builder
- Builder() - Constructor for class com.couchbase.client.core.tracing.DefaultOrphanResponseReporter.Builder
- 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-nullByteBuf
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
- 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) - Static method in class com.couchbase.client.core.message.stat.Stat
- 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, 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, 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) - 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, 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(JsonPointer, ByteBuf) - Method in interface com.couchbase.client.core.utils.yasjl.Callbacks.JsonPointerCB2
- call(ByteBuf) - Method in interface com.couchbase.client.core.utils.yasjl.Callbacks.JsonPointerCB1
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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. - capabilities() - Method in class com.couchbase.client.core.config.AbstractBucketConfig
- capabilities() - Method in interface com.couchbase.client.core.config.BucketConfig
-
Returns the bucket capabilities of this bucket config.
- Carrier - com.couchbase.client.core.config.LoaderType
- 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
- CBHELLO - com.couchbase.client.core.config.BucketCapabilities
- CCCP - com.couchbase.client.core.config.BucketCapabilities
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- certAuthEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Allows to enable X.509 client certificate authentication.
- 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. - checkIdleTime(int) - Method in class com.couchbase.client.core.env.AbstractServiceConfig
-
Helper method to check if the idle time is within proper range.
- 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() - Method in class com.couchbase.client.core.tracing.ThresholdLogScope
- 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
- 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.please use
ConfigUpdatedEvent.clusterNodesAsStrings()
instead. - clusterNodesAsStrings() - Method in class com.couchbase.client.core.event.system.ConfigUpdatedEvent
-
Returns the hostname 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.
- COLLECTIONS - com.couchbase.client.core.config.BucketCapabilities
- com.couchbase.client.core - package com.couchbase.client.core
-
Couchbase Core IO - Domain Model and Architecture ================================================= This documentation describes the domain model of the core package, covers important architecture and design decisions and provides a solid introduction on the inner workings.
- 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.analytics.parser - package com.couchbase.client.core.endpoint.analytics.parser
- 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.
- COMMAND_UNAVAILABLE - com.couchbase.client.core.message.ResponseStatus
-
Indicates that the request type was dispatched but not known by the server or it is not supported.
- 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.
- COMPRESSION_ENABLED - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
- compressionEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment
-
If true, compression is enabled and will be used if the min size and other thresholds match as well.
- compressionEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- compressionEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Allows to enable/disable compression completely, enabled by default.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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).
- 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 - com.couchbase.client.core.service.ServiceType
-
HTTP config operations.
- 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 encodingConfigRequest
s into lower levelHttpRequest
s as well as decodingHttpObject
s intoCouchbaseResponse
s. - 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- configPollFloorInterval(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Allows to set the minimum config polling interval.
- configPollInterval() - Method in interface com.couchbase.client.core.env.CoreEnvironment
-
Returns the proactive polling interval for cluster configurations.
- configPollInterval() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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.
- ConfigRequest - Interface in com.couchbase.client.core.message.config
-
Common marker interface for all
ConfigRequest
s. - 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 newClusterConfig
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
- CONN_STATE_INVALIDATED - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
The current connection is no longer valid.
- connect() - Method in class com.couchbase.client.core.endpoint.AbstractEndpoint
- connect() - Method in class com.couchbase.client.core.endpoint.BootstrapAdapter
-
Connect the underlying
Bootstrap
and return aChannelFuture
. - connect() - Method in interface com.couchbase.client.core.endpoint.Endpoint
-
Connect the
Endpoint
to the underlying channel. - connect() - Method in class com.couchbase.client.core.node.CouchbaseNode
- connect() - Method in interface com.couchbase.client.core.node.Node
-
Connects all currently enabled
Service
s. - 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
- 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(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
- CONNECTED - com.couchbase.client.core.state.LifecycleState
-
The component is connected without degradation.
- CONNECTING - com.couchbase.client.core.state.LifecycleState
-
The component is currently connecting or reconnecting.
- 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
- ConnectionString.UnresolvedSocket - Class in com.couchbase.client.core.utils
- CONSTANT - com.couchbase.client.core.endpoint.kv.ErrorMap.RetryStrategy
- 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 ofBinarySubdocMultiLookupRequest.commands()
. - content() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMultiMutationRequest
-
The
ByteBuf
representing the whole list ofBinarySubdocMultiMutationRequest.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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- continuousKeepAliveEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Allows to enable or disable the continous emitting of keepalive messages.
- 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
- COUCHAPI - com.couchbase.client.core.config.BucketCapabilities
- COUCHBASE - com.couchbase.client.core.config.BucketType
- COUCHBASE - com.couchbase.client.core.utils.ConnectionString.Scheme
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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 - Interface in com.couchbase.client.core.hooks
-
This hook allows to intercept and modify the
CouchbaseRequest
in the path of theCouchbaseCore.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(String, CoreContext) - Constructor for class com.couchbase.client.core.node.CouchbaseNode
- CouchbaseNode(String, CoreContext, String) - 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
CouchbaseRequest
s. - CouchbaseResponse - Interface in com.couchbase.client.core.message
- COUCHBASES - com.couchbase.client.core.utils.ConnectionString.Scheme
- count() - Method in class com.couchbase.client.core.event.metrics.LatencyMetric
-
The number of latency entries recorded in the interval.
- COUNTER - com.couchbase.client.core.message.kv.subdoc.multi.Mutation
- 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() - Static method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- create() - Static method in class com.couchbase.client.core.event.consumers.LoggingConsumer
- create() - Static method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
- create() - Static method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
- 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(int) - Static method in class com.couchbase.client.core.env.KeyValueServiceConfig
-
Creates a new configuration for the KV service.
- create(int, int) - Static method in class com.couchbase.client.core.env.AnalyticsServiceConfig
-
Creates a
AnalyticsServiceConfig
with the default idle time. - create(int, int) - Static method in class com.couchbase.client.core.env.QueryServiceConfig
-
Creates a
QueryServiceConfig
with the default idle time. - create(int, int) - Static method in class com.couchbase.client.core.env.SearchServiceConfig
-
Creates a
SearchServiceConfig
with the default idle time. - create(int, int) - Static method in class com.couchbase.client.core.env.ViewServiceConfig
-
Creates a
ViewServiceConfig
with the default idle time. - create(int, int, int) - Static method in class com.couchbase.client.core.env.AnalyticsServiceConfig
-
Creates a
AnalyticsServiceConfig
with a custom idle time. - create(int, int, int) - Static method in class com.couchbase.client.core.env.QueryServiceConfig
-
Creates a
QueryServiceConfig
with a custom idle time. - create(int, int, int) - Static method in class com.couchbase.client.core.env.SearchServiceConfig
-
Creates a
SearchServiceConfig
with a custom idle time. - create(int, int, int) - Static method in class com.couchbase.client.core.env.ViewServiceConfig
-
Creates a
ViewServiceConfig
with a custom idle time. - create(long, TimeUnit) - Static method in class com.couchbase.client.core.metrics.DefaultLatencyMetricsCollectorConfig
- create(long, TimeUnit) - Static method in class com.couchbase.client.core.metrics.DefaultMetricsCollectorConfig
- 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
- 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(CouchbaseLogLevel, LoggingConsumer.OutputFormat) - Static method in class com.couchbase.client.core.event.consumers.LoggingConsumer
- 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(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(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.
- 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() - 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.multi.SubMultiMutationDocOptionsBuilder
-
Deprecated.
- 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() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
- createIntermediaryPath(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
- 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.analytics.AnalyticsHandlerV2
- 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() - Static method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
-
Creates a new
UnicastAutoReleaseSubject
without a no subscription timeout. - createWithoutNoSubscriptionTimeout(Action0) - Static method in class com.couchbase.client.core.utils.UnicastAutoReleaseSubject
-
Creates a new
UnicastAutoReleaseSubject
without a no subscription timeout. - createWorker() - Method in class com.couchbase.client.core.env.CoreScheduler
- creationTime() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
- creationTime() - Method in class com.couchbase.client.core.message.AbstractCouchbaseResponse
- creationTime() - Method in interface com.couchbase.client.core.message.CouchbaseMessage
-
Returns the time in nanoseconds when the message was created.
- ctx - Variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.AbstractMemcacheObjectAggregator
-
Holds the current channel handler context if set.
- ctx() - Method in interface com.couchbase.client.core.ClusterFacade
-
Exposes the currently used environment.
- ctx() - Method in class com.couchbase.client.core.CouchbaseCore
- 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 - com.couchbase.client.core.endpoint.ServerFeatures
-
The custom datatype feature.
- DATATYPE_SNAPPY - Static variable in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
-
The datatype byte used to signal snappy.
- DCP - com.couchbase.client.core.config.BucketCapabilities
- DCP - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
The error is related to the DCP subsystem.
- DEAD - com.couchbase.client.core.message.kv.GetAllMutationTokensRequest.PartitionState
-
Not in use, pending deletion.
- 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...) - 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, 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 class com.couchbase.client.core.logging.AbstractCouchbaseLogger
- debug(Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger
-
Log an exception (throwable) at the DEBUG level.
- DEBUG - com.couchbase.client.core.logging.CouchbaseLogLevel
-
'DEBUG' log level.
- decode(ChannelHandlerContext, MemcacheObject, List<Object>) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheObjectAggregator
- decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheDecoder
- 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
- 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, FullBinaryMemcacheResponse) - Method in class com.couchbase.client.core.endpoint.kv.KeyValueHandler
- decodeResponse(ChannelHandlerContext, HttpObject) - Method in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
- decodeResponse(ChannelHandlerContext, HttpObject) - Method in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandlerV2
- decodeResponse(ChannelHandlerContext, HttpObject) - Method in class com.couchbase.client.core.endpoint.config.ConfigHandler
- 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
- decodeResponse(ChannelHandlerContext, RESPONSE) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
-
Decodes the incoming response and transforms it into a
CouchbaseResponse
. - 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
-
The default idle time for pooled services.
- 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(byte[], ByteBuf) - Constructor for class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.DefaultBinaryMemcacheRequest
-
Create a new
DefaultBinaryMemcacheRequest
with the header only. - 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. - 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(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. - 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. - DefaultClusterConfig - Class in com.couchbase.client.core.config
-
Default implementation of a
ClusterConfig
. - DefaultClusterConfig() - Constructor for class com.couchbase.client.core.config.DefaultClusterConfig
-
Creates a new
DefaultClusterConfig
. - DefaultConfigurationProvider - Class in com.couchbase.client.core.config
-
**The default implementation of a
ConfigurationProvider
.** - DefaultConfigurationProvider(ClusterFacade, CoreEnvironment) - Constructor for class com.couchbase.client.core.config.DefaultConfigurationProvider
-
Create a new
DefaultConfigurationProvider
. - DefaultConfigurationProvider(ClusterFacade, CoreEnvironment, List<Loader>, Map<LoaderType, Refresher>) - Constructor for class com.couchbase.client.core.config.DefaultConfigurationProvider
-
Create a new
DefaultConfigurationProvider
. - DefaultCoreEnvironment - Class in com.couchbase.client.core.env
- DefaultCoreEnvironment(DefaultCoreEnvironment.Builder) - Constructor for class com.couchbase.client.core.env.DefaultCoreEnvironment
- DefaultCoreEnvironment.Builder<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>, String) - 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>, String) - 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) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
- defaultMetricsLoggingConsumer(boolean, CouchbaseLogLevel, LoggingConsumer.OutputFormat) - 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(String, 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
-
Create a new
DefaultServiceRegistry
. - DEGRADED - com.couchbase.client.core.state.LifecycleState
-
The component is connected, but with service degradation.
- Delay - Class in com.couchbase.client.core.time
-
Parent class of
Delay
s and provides factory methods to create them. - DELETE - com.couchbase.client.core.message.kv.subdoc.multi.Mutation
- 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<String>) - 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() - 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 - 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() - 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.
- diagnostics() - Method in class com.couchbase.client.core.tracing.RingBufferMonitor
- 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(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 - 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
- diagnosticsReport() - Method in class com.couchbase.client.core.message.internal.DiagnosticsResponse
- DiagnosticsReport - Class in com.couchbase.client.core.message.internal
-
Aggregates the health of all
Endpoint
s. - DiagnosticsReport(List<EndpointHealth>, String, String, RingBufferDiagnostics) - Constructor for class com.couchbase.client.core.message.internal.DiagnosticsReport
- 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
- DICT_ADD - com.couchbase.client.core.message.kv.subdoc.multi.Mutation
- DICT_UPSERT - com.couchbase.client.core.message.kv.subdoc.multi.Mutation
- 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() - Method in class com.couchbase.client.core.node.CouchbaseNode
- disconnect() - Method in interface com.couchbase.client.core.node.Node
-
Disconnects all currently enabled
Service
s. - disconnect() - Method in class com.couchbase.client.core.service.AbstractDynamicService
- disconnect() - Method in class com.couchbase.client.core.service.AbstractOnDemandService
- disconnect() - Method in class com.couchbase.client.core.service.PooledService
- disconnect() - Method in interface com.couchbase.client.core.service.Service
- 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_TIMEOUT - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
- DISCONNECTED - com.couchbase.client.core.state.LifecycleState
-
The component is currently disconnected.
- DISCONNECTING - com.couchbase.client.core.state.LifecycleState
-
The component is disconnecting.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- disconnectTimeout(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Sets a custom disconnect timeout.
- discoverConfig(String, String, String, String) - Method in class com.couchbase.client.core.config.loader.AbstractLoader
-
Run the
BucketConfig
discovery process. - discoverConfig(String, String, String, String) - Method in class com.couchbase.client.core.config.loader.CarrierLoader
- discoverConfig(String, String, String, String) - 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() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
- dispatchHostname(String) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
- 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() - 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.
- 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.
- 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.
- 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.
- 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(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
- encode(ChannelHandlerContext, REQUEST, List<Object>) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
- 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
- encodeHeader(ByteBuf, M) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheEncoder
-
Encode the header.
- 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 writableByteBuf
. - encodeMessage(ChannelHandlerContext, M) - Method in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.AbstractBinaryMemcacheEncoder
- encodeRequest(ChannelHandlerContext, AnalyticsRequest) - Method in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler
- encodeRequest(ChannelHandlerContext, AnalyticsRequest) - Method in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandlerV2
- 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
- encodeRequest(ChannelHandlerContext, REQUEST) - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
-
Encode the outgoing request and return it in encoded format.
- 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() - 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.
- endpoints(ServiceType) - Method in class com.couchbase.client.core.message.internal.DiagnosticsReport
- 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.ConnectionString.UnresolvedSocket
- equals(Object) - Method in class com.couchbase.client.core.utils.NetworkAddress
- ERR_ACCESS - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_AUTH_CONTINUE - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_AUTH_ERROR - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_AUTH_STALE - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_BUSY - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_DELTA_BADVAL - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_EXISTS - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_INTERNAL - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_INVALID - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_NO_BUCKET - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_NO_MEM - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_NOT_FOUND - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_NOT_INITIALIZED - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_NOT_MY_VBUCKET - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_NOT_STORED - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_NOT_SUPPORTED - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_RANGE - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_ROLLBACK - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_DELTA_RANGE - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_DOC_NOT_JSON - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_DOC_TOO_DEEP - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_INVALID_COMBO - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_MULTI_PATH_FAILURE - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_NUM_RANGE - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_PATH_EXISTS - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_PATH_INVALID - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_PATH_MISMATCH - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_PATH_NOT_FOUND - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_PATH_TOO_BIG - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_VALUE_CANTINSERT - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_VALUE_TOO_DEEP - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_XATTR_INVALID_FLAG_COMBO - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_XATTR_INVALID_KEY_COMBO - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_SUBDOC_XATTR_UNKNOWN_MACRO - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_TEMP_FAIL - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_TOO_BIG - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- ERR_UNKNOWN_COMMAND - com.couchbase.client.core.endpoint.kv.KeyValueStatus
- error() - Method in class com.couchbase.client.core.message.view.ViewQueryResponse
- 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...) - 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, 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 class com.couchbase.client.core.logging.AbstractCouchbaseLogger
- error(Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger
-
Log an exception (throwable) at the ERROR level.
- ERROR - com.couchbase.client.core.logging.CouchbaseLogLevel
-
'ERROR' log level.
- ERROR - com.couchbase.client.core.message.internal.PingServiceHealth.PingState
-
The ping didn't time out but a different error happened.
- ErrorCode(String, String, Set<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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- eventBus(EventBus) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Sets the event bus to an alternative implementation.
- 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
- EXIST - com.couchbase.client.core.message.kv.subdoc.multi.Lookup
- EXISTS - com.couchbase.client.core.message.ResponseStatus
-
If the request expected the document to not exist, but it existed already.
- expandMacros() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMutationRequest
-
Sets whether macros such as ${Mutation.CAS} should be expanded
- expandMacros() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
- expandMacros() - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
- expandMacros() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
- expandMacros(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
- expandMacros(boolean) - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
- 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. - EXPONENTIAL - com.couchbase.client.core.endpoint.kv.ErrorMap.RetryStrategy
- 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() - 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.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.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).
- FAILURE - com.couchbase.client.core.message.ResponseStatus
-
Generic failure status.
- FETCH_CONFIG - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
The client's cluster map may be outdated and requires updating.
- 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
- FINISHED - com.couchbase.client.core.endpoint.DecodingState
-
Decoding is finished.
- finishedDecoding() - Method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
-
Notify that decoding is finished.
- finishedDecoding() - Method in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandlerV2
- 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.analytics.parser.YasjlAnalyticsDeferredResponseParser
-
Instruct the parser to finish the parsing and reset its internal state, turning it back to uninitialized as well.
- finishParsingAndReset() - Method in class com.couchbase.client.core.endpoint.analytics.parser.YasjlAnalyticsResponseParser
-
Instruct the parser to finish the parsing and reset its internal state, turning it back to uninitialized as well.
- 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_DNS_LOOKUP_ON_RECONNECT - Static variable in class com.couchbase.client.core.endpoint.AbstractEndpoint
-
A flag which controls whether the endpoint should force a DNS lookup request for the provided hostname in case the socket get disconnect.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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.
- 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
- FOUND_NOT_PERSISTED - com.couchbase.client.core.message.kv.ObserveResponse.ObserveStatus
-
Response indicating the key was found but not persisted.
- FOUND_PERSISTED - com.couchbase.client.core.message.kv.ObserveResponse.ObserveStatus
-
Response indicating the key was persisted.
- FOUR - com.couchbase.client.core.message.observe.Observe.PersistTo
-
Observe disk persistence of four nodes (one master and three replicas).
- fragment() - Method in interface com.couchbase.client.core.message.kv.subdoc.BinarySubdocMutationRequest
-
A
ByteBuf
containing the JSON fragment for the mutation. - fragment() - Method in class com.couchbase.client.core.message.kv.subdoc.simple.AbstractSubdocMutationRequest
- fragment(ByteBuf) - Method in class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommandBuilder
- 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.
- fromJson(String) - Static method in class com.couchbase.client.core.endpoint.kv.ErrorMap
- 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.
- FULL - com.couchbase.client.core.logging.RedactionLevel
-
User, System and Metadata are all redacted.
- 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
andLastMemcacheContent
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<NetworkLatencyMetricsIdentifier, LatencyStats>) - Method in class com.couchbase.client.core.metrics.NetworkLatencyMetricsCollector
- generateLatencyMetricsEvent(Map<I, LatencyStats>) - Method in class com.couchbase.client.core.metrics.AbstractLatencyMetricsCollector
- 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, String, int) - 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>, String, 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, String, String, 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
CouchbaseEvent
s. - GET - com.couchbase.client.core.message.kv.subdoc.multi.Lookup
- GET - Static variable in class com.couchbase.client.deps.io.netty.handler.codec.memcache.binary.BinaryMemcacheOpcodes
- GET_COUNT - com.couchbase.client.core.message.kv.subdoc.multi.Lookup
- 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(GetAllMutationTokensRequest.PartitionState, String, String) - Constructor for class com.couchbase.client.core.message.kv.GetAllMutationTokensRequest
- GetAllMutationTokensRequest(String, 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, String) - 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, String) - 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
- GETDOC - com.couchbase.client.core.message.kv.subdoc.multi.Lookup
- 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() - Method in class com.couchbase.client.core.RequestEvent
- 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
- 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.analytics.AnalyticsHandlerV2
- 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() - Method in class com.couchbase.client.core.message.analytics.GenericAnalyticsResponse
-
Contains the deferred handle url
- 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.analytics.AnalyticsHandlerV2
- 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.ConnectionString.UnresolvedSocket
- 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(String) - Method in interface com.couchbase.client.core.config.CouchbaseBucketConfig
-
Checks if the given hostname has active primary partitions assigned to it.
- hasPrimaryPartitionsOnNode(String) - 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 "raw" hostname 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.ConnectionString.UnresolvedSocket
- 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 - com.couchbase.client.core.config.LoaderType
- HTTP - com.couchbase.client.core.utils.ConnectionString.Scheme
- 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_TOO_MANY_REQUESTS - 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. - IDLE - com.couchbase.client.core.state.LifecycleState
-
The component is idle and has no associated connections to identify.
- 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() - 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
- 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...) - 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, 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 class com.couchbase.client.core.logging.AbstractCouchbaseLogger
- info(Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger
-
Log an exception (throwable) at the INFO level.
- INFO - com.couchbase.client.core.logging.CouchbaseLogLevel
-
'INFO' log level.
- initial() - Method in class com.couchbase.client.core.message.kv.CounterRequest
- INITIAL - com.couchbase.client.core.endpoint.DecodingState
-
Decoding is not currently taking place.
- initialize(ByteBuf) - Method in class com.couchbase.client.core.utils.yasjl.ByteBufJsonParser
-
(re)initializes this parser with new content.
- initialize(ByteBuf, ResponseStatus, CouchbaseRequest) - Method in class com.couchbase.client.core.endpoint.analytics.parser.YasjlAnalyticsDeferredResponseParser
-
Initialize this parser for a response parsing cycle.
- initialize(ByteBuf, ResponseStatus, CouchbaseRequest) - Method in class com.couchbase.client.core.endpoint.analytics.parser.YasjlAnalyticsResponseParser
-
Initialize this parser for a response parsing cycle.
- initialize(ByteBuf, ResponseStatus, CouchbaseRequest) - Method in class com.couchbase.client.core.endpoint.query.parser.YasjlQueryResponseParser
-
Initialize this parser for a response parsing cycle.
- inject(SpanContext, Format<C>, C) - Method in class com.couchbase.client.core.tracing.ThresholdLogTracer
- INSERT - com.couchbase.client.core.message.kv.subdoc.simple.SubArrayRequest.ArrayOperation
-
Insert a value at a specific index into an existing array, shifting values at and after the given index.
- 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() - 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.multi.SubMultiMutationDocOptionsBuilder
- 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, int, int, String) - 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, 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
- 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 method in class com.couchbase.client.core.tracing.RingBufferMonitor
- 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
- 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.
- INTERNAL - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
This is an internal error in the server.
- INTERNAL_ERROR - com.couchbase.client.core.message.ResponseStatus
-
The remote service failed for an internal reason.
- InternalRequest - Interface in com.couchbase.client.core.message.internal
-
Marker interface for all internal
CouchbaseRequest
s 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
- INVALID_ARGUMENTS - com.couchbase.client.core.message.ResponseStatus
-
The service reported that the request arguments are invalid.
- INVALID_INPUT - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
This attribute means that a user's input was invalid because it violates the semantics of the operation, or exceeds some predefined limit.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- ioPool(EventLoopGroup) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Deprecated.use
DefaultCoreEnvironment.Builder.ioPool(EventLoopGroup, ShutdownHook)
to also provide a shutdown hook. - ioPool(EventLoopGroup, ShutdownHook) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Sets the I/O Pool implementation for the underlying IO framework, along with the action to execute when this environment is shut down.
- IoPoolShutdownHook - Class in com.couchbase.client.core.env.resources
-
ShutdownHook
hook for anEventLoopGroup
. - 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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).
- 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() - 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.
- 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
? - 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.analytics.parser.YasjlAnalyticsDeferredResponseParser
-
True if this parser is currently initialized and ready to parse a response.
- isInitialized() - Method in class com.couchbase.client.core.endpoint.analytics.parser.YasjlAnalyticsResponseParser
-
True if this parser is currently initialized and ready to parse a response.
- 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?
- ITEM_DELETED - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
This attribute means that the error is related to operating on a soft-deleted document.
- ITEM_LOCKED - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
This attribute specifies that the requested item is currently locked.
- ITEM_ONLY - com.couchbase.client.core.endpoint.kv.ErrorMap.ErrorAttribute
-
This attribute means that the error is related to a constraint failure regarding the item itself, i.e.
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 - com.couchbase.client.core.event.consumers.LoggingConsumer.OutputFormat
-
Will log compact json.
- JSON_ARRAY - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- JSON_ARRAY_VALUE - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- JSON_BOOLEAN_FALSE_VALUE - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- JSON_BOOLEAN_TRUE_VALUE - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- 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_NULL_VALUE - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- JSON_NUMBER_VALUE - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- JSON_OBJECT - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- JSON_OBJECT_VALUE - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- JSON_PLUS - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
- JSON_PRETTY - com.couchbase.client.core.event.consumers.LoggingConsumer.OutputFormat
-
Will log pretty printed json.
- JSON_ST - Static variable in class com.couchbase.client.core.utils.yasjl.JsonParserUtils
- JSON_STRING_HASH_KEY - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- JSON_STRING_VALUE - com.couchbase.client.core.utils.yasjl.JsonParserUtils.Mode
- 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) - 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.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) - 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) - 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, int) - 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, 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, 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, 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.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, 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, 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, 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...). - 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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
- KeepAliveRequest() - Constructor for class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler.KeepAliveRequest
- KeepAliveRequest() - Constructor for class com.couchbase.client.core.endpoint.analytics.AnalyticsHandlerV2.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, short, CouchbaseRequest) - Constructor for class com.couchbase.client.core.endpoint.kv.KeyValueHandler.KeepAliveResponse
- KeepAliveResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler.KeepAliveResponse
- KeepAliveResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.endpoint.analytics.AnalyticsHandlerV2.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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- keepAliveTimeout(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Allows to customize the timeout used for keepalive operations.
- KETAMA - com.couchbase.client.core.config.BucketNodeLocator
-
The node locator based on the ketama location algorithm.
- 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 encodingBinaryRequest
s into lower levelBinaryMemcacheRequest
s as well as decodingFullBinaryMemcacheResponse
s intoCouchbaseResponse
s. - 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
- 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
-
Creates a new
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
-
Allows to configure a KV Service on a per-node basis.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- kvEndpoints(int) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Deprecated.Please use
DefaultCoreEnvironment.Builder.keyValueServiceConfig(KeyValueServiceConfig)
going forward. - 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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.
- kvServiceConfig() - Method in interface com.couchbase.client.core.env.CoreEnvironment
-
Returns the current service configuration for the KV service.
- 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() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
- lastLocalId(String) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
- lastLocalId(String) - Method in interface com.couchbase.client.core.message.CouchbaseRequest
- lastLocalSocket() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
- lastLocalSocket() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
- lastLocalSocket(String) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
- 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() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
- lastRemoteSocket(String) - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
- 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. - LINEAR - com.couchbase.client.core.endpoint.kv.ErrorMap.RetryStrategy
- LinearDelay - Class in com.couchbase.client.core.time
-
Delay which increases linearly for every attempt.
- loadConfig(String, String, String) - Method in class com.couchbase.client.core.config.loader.AbstractLoader
-
Initiate the config loading process.
- loadConfig(String, String, String) - Method in interface com.couchbase.client.core.config.loader.Loader
-
Deprecated.
- loadConfig(String, String, String, String) - Method in class com.couchbase.client.core.config.loader.AbstractLoader
-
Initiate the config loading process.
- loadConfig(String, 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() - Method in interface com.couchbase.client.core.message.DiagnosticRequest
- localSocket() - Method in class com.couchbase.client.core.message.kv.NoopRequest
- localSocket() - Method in class com.couchbase.client.core.message.query.PingRequest
- localSocket() - 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.analytics.PingRequest
- localSocket(SocketAddress) - Method in interface com.couchbase.client.core.message.DiagnosticRequest
- localSocket(SocketAddress) - Method in class com.couchbase.client.core.message.kv.NoopRequest
- localSocket(SocketAddress) - Method in class com.couchbase.client.core.message.query.PingRequest
- localSocket(SocketAddress) - Method in class com.couchbase.client.core.message.search.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(CouchbaseRequest) - Method in class com.couchbase.client.core.RequestHandler
-
Helper method to detect the correct locator for the given request type.
- Locator - Interface in com.couchbase.client.core.node.locate
- lock() - Method in class com.couchbase.client.core.message.kv.GetRequest
- LOCKED - com.couchbase.client.core.message.ResponseStatus
-
Indicates that the document is locked at the moment.
- log(long, String) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
- log(long, Map<String, ?>) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
- log(CouchbaseLogLevel, String) - 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 class com.couchbase.client.core.logging.AbstractCouchbaseLogger
- 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...) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
- 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, Object, Object) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
- 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, Throwable) - Method in class com.couchbase.client.core.logging.AbstractCouchbaseLogger
- 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 class com.couchbase.client.core.logging.AbstractCouchbaseLogger
- log(CouchbaseLogLevel, Throwable) - Method in interface com.couchbase.client.core.logging.CouchbaseLogger
-
Log an exception (throwable) at the specified
level
. - log(String) - Method in class com.couchbase.client.core.tracing.ThresholdLogSpan
- log(Map<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
CouchbaseEvent
s and logs them. - LoggingConsumer.OutputFormat - Enum in com.couchbase.client.core.event.consumers
-
The target output format to log.
- logIdent(ChannelHandlerContext, Endpoint) - Static method in class com.couchbase.client.core.endpoint.AbstractGenericHandler
-
Simple log helper to give logs a common prefix.
- logIdent(Channel, Endpoint) - Static method in class com.couchbase.client.core.endpoint.AbstractEndpoint
-
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() - 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
- Lookup - Enum in com.couchbase.client.core.message.kv.subdoc.multi
-
Enumeration of possible mutations inside a sub-document
LookupCommand
. - LookupCommand - Class in com.couchbase.client.core.message.kv.subdoc.multi
-
A single lookup description inside a TODO.
- LookupCommand(LookupCommandBuilder) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommand
- LookupCommand(Lookup, String) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.LookupCommand
-
Deprecated.
- 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
- MASTER - com.couchbase.client.core.message.observe.Observe.PersistTo
-
Observe disk persistence to the master node of the document only.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- maxRequestLifetime(long) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Sets the maximum time in milliseconds a request is allowed to live.
- maxRetryDuration() - Method in class com.couchbase.client.core.message.AbstractCouchbaseRequest
- maxRetryDuration() - Method in interface com.couchbase.client.core.message.CouchbaseRequest
-
Returns the maximum retry duration for the request.
- maxRetryDuration(long) - 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.
- 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 - com.couchbase.client.core.config.BucketType
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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 - 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.
- META - com.couchbase.client.core.logging.RedactableArgument.ArgumentType
-
Metadata is logical data needed by Couchbase to store and process user data.
- metadata() - Method in class com.couchbase.client.core.endpoint.util.FailedChannel
- method() - Method in class com.couchbase.client.core.message.config.RestApiRequest
- METRIC - com.couchbase.client.core.event.EventType
-
The event contains some kind of metric.
- 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...).
- MODIFIED - com.couchbase.client.core.message.kv.ObserveResponse.ObserveStatus
-
Response indicating the key was modified.
- MultiLookupResponse - Class in com.couchbase.client.core.message.kv.subdoc.multi
-
The response for a
BinarySubdocMultiLookupRequest
. - MultiLookupResponse(ResponseStatus, short, String, List<MultiResult<Lookup>>, BinarySubdocMultiLookupRequest, long) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MultiLookupResponse
- MultiMutationResponse - Class in com.couchbase.client.core.message.kv.subdoc.multi
-
The response for a
BinarySubdocMultiMutationRequest
. - MultiMutationResponse(ResponseStatus, short, String, int, short, BinarySubdocMultiMutationRequest, long, MutationToken) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse
-
Creates a
MultiMutationResponse
that failed at subdocument level. - MultiMutationResponse(ResponseStatus, short, String, BinarySubdocMultiMutationRequest, long, MutationToken) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse
-
Creates a unsuccessful
MultiMutationResponse
that failed at document level. - MultiMutationResponse(String, BinarySubdocMultiMutationRequest, long, MutationToken, List<MultiResult<Mutation>>) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MultiMutationResponse
-
Creates an successful
MultiMutationResponse
. - MultiResult<OPERATION> - Class in com.couchbase.client.core.message.kv.subdoc.multi
-
The result corresponding to an individual
LookupCommand
orMutationCommand
. - 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 - Enum in com.couchbase.client.core.message.kv.subdoc.multi
-
Enumeration of possible mutations inside a sub-document
MutationCommand
. - MUTATION_SEQNO - com.couchbase.client.core.endpoint.ServerFeatures
-
Return the sequence number on every mutation.
- 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(MutationCommandBuilder) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
-
Create a multi-mutation command.
- MutationCommand(Mutation, String) - 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, ByteBuf, boolean) - Constructor for class com.couchbase.client.core.message.kv.subdoc.multi.MutationCommand
-
Deprecated.
- 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() - 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
- 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
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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.
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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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 - Class in com.couchbase.client.core.env
-
Configuration options for
CoreEnvironment.networkResolution()
. - newInstance() - Method in class com.couchbase.client.core.RequestEventFactory
- newInstance() - Method in class com.couchbase.client.core.ResponseEventFactory
- 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
- 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
-
Constant to use if no idle time should be used.
- NO_PRIORITY - Static variable in class com.couchbase.client.core.message.analytics.GenericAnalyticsRequest
- 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(String) - 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(String) - 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(String) - 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.
- NODES_EXT - com.couchbase.client.core.config.BucketCapabilities
- 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
- NONE - com.couchbase.client.core.logging.RedactionLevel
-
No redaction is performed, this is the default
- NONE - com.couchbase.client.core.message.observe.Observe.PersistTo
-
Do not observe any disk persistence constraint.
- NONE - com.couchbase.client.core.message.observe.Observe.ReplicateTo
-
Do not observe any replication constraint.
- 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, String) - 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_EXISTS - com.couchbase.client.core.message.ResponseStatus
-
If the request expected the document to exit, but it didn't exist already.
- NOT_FOUND_NOT_PERSISTED - com.couchbase.client.core.message.kv.ObserveResponse.ObserveStatus
-
Response indicating the key was not found and not persisted, as in the case of deletes - a logical delete.
- NOT_FOUND_PERSISTED - com.couchbase.client.core.message.kv.ObserveResponse.ObserveStatus
-
Response indicating the key was not found and persisted, as in the case of deletes - a real delete.
- NOT_STORED - com.couchbase.client.core.message.ResponseStatus
-
The response indicates that a mutation try did not happen properly.
- 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_INTERVAL_DELAY - Static variable in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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.
- observeIntervalDelay() - Method in interface com.couchbase.client.core.env.CoreEnvironment
- observeIntervalDelay() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- observeIntervalDelay(Delay) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
- 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
- OK - com.couchbase.client.core.message.internal.PingServiceHealth.PingState
-
The ping went fine.
- OldAnalyticsService - Class in com.couchbase.client.core.service
-
The
Service
is composed of and managesAnalyticsEndpoint
s. - 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 managesQueryEndpoint
s. - 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 managesViewEndpoint
s. - 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
- ONE - com.couchbase.client.core.message.observe.Observe.PersistTo
-
Observe disk persistence of one node (master or replica).
- ONE - com.couchbase.client.core.message.observe.Observe.ReplicateTo
-
Observe replication to one replica.
- ONE_BY_ONE - com.couchbase.client.core.service.BucketServiceMapping
-
The service can only handle one bucket at a time.
- ONE_FOR_ALL - com.couchbase.client.core.service.BucketServiceMapping
-
The service is able to handle all buckets at the same time.
- 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
ResponseEvent
s 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 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
- 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
- openBucket(String, String) - Method in interface com.couchbase.client.core.config.ConfigurationProvider
-
Start to fetch a config for the given bucket and also watch for changes, depending on the mechanism used.
- openBucket(String, String) - Method in class com.couchbase.client.core.config.DefaultConfigurationProvider
- 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, 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- operationTracingEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Allows to enable/disable the tracing support.
- operationTracingServerDurationEnabled() - Method in interface com.couchbase.client.core.env.CoreEnvironment
-
True if additional server duration tracing is enabled.
- operationTracingServerDurationEnabled() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- operationTracingServerDurationEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
-
Allows to enable/disable the negotiation of server duration-enabled tracing.
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- orphanResponseReporter(OrphanResponseReporter) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
- 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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- orphanResponseReportingEnabled(boolean) - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment.Builder
- OS_BEAN - Static variable in class com.couchbase.client.core.env.Diagnostics
- OUT_OF_MEMORY - com.couchbase.client.core.message.ResponseStatus
-
The requested service is currently out of memory.
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() - Method in class com.couchbase.client.core.env.DefaultCoreEnvironment
- 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.
- 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() - Method in class com.couchbase.client.core.endpoint.analytics.parser.YasjlAnalyticsDeferredResponseParser
-
Instruct the parser to run a new parsing cycle on the current response content.
- parse() - Method in class com.couchbase.client.core.endpoint.analytics.parser.YasjlAnalyticsResponseParser
-
Instruct the parser to run a new parsing cycle on the current response content.
- 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.
- parse(String, ConfigParserEnvironment, String) - Static method in class com.couchbase.client.core.config.parser.BucketConfigParser
-
Parse a raw configuration into a
BucketConfig
. - PARTIAL - com.couchbase.client.core.logging.RedactionLevel
-
Only user data is redacted, system and metadata are not.
- partition() - 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() - 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(short) - Method in class com.couchbase.client.core.message.kv.AbstractKeyValueRequest
- partition(short) - Method in interface com.couchbase.client.core.message.kv.BinaryRequest
-
Set the partition ID.
- Partition - Interface in com.couchbase.client.core.config
- 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 theCouchbaseRequest
. - partitionState() - Method in class com.couchbase.client.core.message.kv.GetAllMutationTokensRequest
- password() - 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() - 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
- password(String) - Method in class com.couchbase.client.core.config.AbstractBucketConfig
- password(String) - Method in interface com.couchbase.client.core.config.BucketConfig
-
Setter to inject the password manually into the config.
- path() - Method in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandler.KeepAliveRequest
- path() - Method in class com.couchbase.client.core.endpoint.analytics.AnalyticsHandlerV2.KeepAliveRequest
- path() - Method in class com.couchbase.client.core.endpoint.search.SearchHandler.KeepAliveRequest
- path() - Method in class com.couchbase.client.core.message.analytics.AnalyticsQueryResultRequest
- path() - Method in class com.couchbase.client.core.message.analytics.AnalyticsQueryStatusRequest
- path() - Method in interface com.couchbase.client.core.message.analytics.AnalyticsRequest
-
Get path to construct the uri
- path() - Method in class com.couchbase.client.core.message.analytics.GenericAnalyticsRequest
- path() - Method in class com.couchbase.client.core.message.analytics.PingRequest
- 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
- PENDING - com.couchbase.client.core.message.kv.GetAllMutationTokensRequest.PartitionState
-
Pending active.
- 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 - Class in com.couchbase.client.core.message.query
- PingRequest - Class in com.couchbase.client.core.message.search
- PingRequest - Class in com.couchbase.client.core.message.view
- PingRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.analytics.PingRequest
- PingRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.query.PingRequest
- PingRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.search.PingRequest
- PingRequest(String, String, String) - Constructor for class com.couchbase.client.core.message.view.PingRequest
- PingResponse - Class in com.couchbase.client.core.message.analytics
- PingResponse - Class in com.couchbase.client.core.message.query
- PingResponse - Class in com.couchbase.client.core.message.search
- PingResponse - Class in com.couchbase.client.core.message.view
- PingResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.analytics.PingResponse
- PingResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.query.PingResponse
- PingResponse(ResponseStatus, CouchbaseRequest) - Constructor for class com.couchbase.client.core.message.search.PingResponse
- 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.message.internal.AddServiceRequest
- port() - Method in class com.couchbase.client.core.utils.ConnectionString.UnresolvedSocket
- port(String) - Method in class com.couchbase.client.core.config.loader.AbstractLoader
-
Port to use for the
ServiceType
. - port(String) - Method in class com.couchbase.client.core.config.loader.CarrierLoader
- port(String) - Method in class com.couchbase.client.core.config.loader.HttpLoader
- 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 hostname, shortcutting the dispatch usually performed by aLocator
.. - 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
- priority() - Method in class com.couchbase.client.core.message.analytics.GenericAnalyticsRequest
- process(byte) - Method in class com.couchbase.client.core.endpoint.util.ClosingPositionBufProcessor
- process(byte) - Method in class com.couchbase.client.core.endpoint.util.SplitPositionBufProcessor