Uses of Annotation Type
com.couchbase.client.core.annotation.Stability.Internal
Package
Description
These classes came from https://github.com/dain/snappy/ at tag "snappy-0.4".
-
Uses of Stability.Internal in com.couchbase.client.core
Modifier and TypeClassDescriptionstatic class
final class
class
class
class
TheTimer
acts as the main timing facility for various operations, for example to track and time out requests if they run for too long or for rescheduling needs.Modifier and TypeMethodDescriptionCoreContext.alternateAddress
(Optional<String> alternateAddress) Deprecated.This method does not do anything.Core.bucketManager()
Core.clusterConfig()
This API provides access to the current config that is published throughout the core.Core.collectionManager
(String bucketName) Core.configurationProvider()
Returns the attached configuration provider.Core.diagnostics()
Core.ensureServiceAt
(NodeIdentifier identifier, ServiceType serviceType, int port, Optional<String> bucket) This method can be used by a caller to make sure a certain service is enabled at the given target node.Core.httpClient
(RequestTarget target) Returns a client for issuing HTTP requests to servers in the cluster.void
Core.initGlobalConfig()
Instructs the client to, if possible, load and initialize the global config.Core.internalDiagnostics()
Core.kvBinaryOps
(CoreKeyspace keyspace) Core.kvOps
(CoreKeyspace keyspace) void
Core.openBucket
(String name) Attempts to open a bucket and fails theMono
if there is a persistent error as the reason.Core.queryOps()
Core.responseMetric
(Request<?> request, Throwable err) CoreProtostellar.responseMetric
(Core.ResponseMetricIdentifier rmi) Core.searchOps
(CoreBucketAndScope scope) <R extends Response>
voidSends a command into the core layer and allows to avoid timeout registration.Core.serviceState
(NodeIdentifier nodeIdentifier, ServiceType type, Optional<String> bucket) If present, returns a flux that allows to monitor the state changes of a specific service.Core.shutdown()
Shuts down this core and all associated, owned resources.Core.transactionsCleanup()
Core.transactionsContext()
static <T> Mono
<T> Reactor.wrap
(CompletableFuture<T> response, Runnable cancellationTask) Converts the given future into a mono. -
Uses of Stability.Internal in com.couchbase.client.core.annotation
Modifier and TypeClassDescription@interface
Specifies the earliest version of Couchbase Server that supports the annotated feature.@interface
Indicates the target element is not intended for public use, but some other Couchbase project depends on it. -
Uses of Stability.Internal in com.couchbase.client.core.api
Modifier and TypeInterfaceDescriptioninterface
Provides access to the variousCore*Ops
instances. -
Uses of Stability.Internal in com.couchbase.client.core.api.kv
Modifier and TypeClassDescriptionfinal class
Associates aCompletableFuture
with a cancellation task.class
final class
Either a synchronousDurabilityLevel
, or "persist to and replicate to" for legacy durability.interface
class
final class
A relative or absolute expiry.final class
interface
interface
class
final class
class
class
Convenience macros to retrieve document metadata using a lookupIn Sub-Document call.class
enum
class
class
class
-
Uses of Stability.Internal in com.couchbase.client.core.api.manager
Modifier and TypeClassDescriptionclass
interface
Allows customizing how deferred indexes are built.interface
Allows customizing how a query primary index is created.interface
Allows customizing how a query index is created.interface
Allows customizing how a query primary index is created.interface
Allows customizing how primary indexes are dropped.interface
Allows customizing how query indexes are dropped.interface
Allows customizing how query indexes are loaded.class
Contains the properties of a Query Index.class
interface
Allows customizing how the query indexes are watched. -
Uses of Stability.Internal in com.couchbase.client.core.api.manager.search
Modifier and TypeClassDescriptionclass
class
class
class
interface
The same interface is used for ScopeSearchIndexManager and SearchIndexManager, as there is no API difference between them at this level.ModifierConstructorDescriptionClassicCoreScopeSearchIndexManager
(Core core, CoreBucketAndScope scope) -
Uses of Stability.Internal in com.couchbase.client.core.api.query
Modifier and TypeClassDescriptionclass
class
interface
interface
class
Transactions does some rather complex things with CoreQueryOptions.enum
Query profiling information received from the server query engine.class
The result of a N1QL query, including rows and associated metadata.enum
The possible values for scan consistency in a N1QL request.enum
class
Represents a single warning returned from the query engine.class
-
Uses of Stability.Internal in com.couchbase.client.core.api.search
Modifier and TypeClassDescriptionclass
enum
class
class
interface
interface
class
enum
Modifier and TypeMethodDescriptionstatic void
ClassicCoreSearchOps.injectOptions
(String indexName, com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode queryJson, Duration timeout, CoreSearchOptions opts, boolean disableShowRequest) -
Uses of Stability.Internal in com.couchbase.client.core.api.search.facet
Modifier and TypeClassDescriptionclass
class
class
class
class
class
-
Uses of Stability.Internal in com.couchbase.client.core.api.search.queries
Modifier and TypeClassDescriptionclass
class
class
class
class
class
class
class
class
class
To create a new instance:class
class
interface
class
class
class
enum
class
class
class
class
class
class
class
class
class
class
class
-
Uses of Stability.Internal in com.couchbase.client.core.api.search.result
Modifier and TypeClassDescriptionclass
class
class
class
class
A range (or bucket) for aCoreDateRangeSearchFacetResult
.interface
class
class
class
class
class
class
class
class
-
Uses of Stability.Internal in com.couchbase.client.core.api.search.sort
Modifier and TypeClassDescriptionenum
enum
enum
enum
class
class
class
class
class
class
A sort tier specified as a string. -
Uses of Stability.Internal in com.couchbase.client.core.api.search.util
-
Uses of Stability.Internal in com.couchbase.client.core.api.search.vector
Modifier and TypeClassDescriptionclass
class
enum
class
class
-
Uses of Stability.Internal in com.couchbase.client.core.callbacks
Modifier and TypeInterfaceDescriptioninterface
This callback is executed once an operation reaches the core and gets sent to a node. -
Uses of Stability.Internal in com.couchbase.client.core.classic
-
Uses of Stability.Internal in com.couchbase.client.core.classic.kv
Modifier and TypeClassDescriptionclass
class
final class
-
Uses of Stability.Internal in com.couchbase.client.core.classic.manager
Modifier and TypeClassDescriptionclass
final class
ModifierConstructorDescriptionCoreBucketSettingsJson
(String name, Map<String, String> controllers, Map<String, Long> quota, int numReplicas, boolean replicaIndex, int maxTTL, CoreCompressionMode compressionMode, BucketType bucketType, CoreConflictResolutionType conflictResolutionType, CoreEvictionPolicyType evictionPolicy, String durabilityMinLevel, CoreStorageBackend storageBackend, Boolean historyRetentionCollectionDefault, Long historyRetentionBytes, Long historyRetentionDurationSeconds) -
Uses of Stability.Internal in com.couchbase.client.core.classic.query
Modifier and TypeClassDescriptionclass
class
class
class
class
class
Server remembers query plan; client sends just the prepared statement name.class
Client remembers query plan and sends it on every request.class
Modifier and TypeMethodDescriptionstatic com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode
ClassicCoreQueryOps.convertOptions
(CoreQueryOptions opts) static ClassicCoreQueryMetaData
ClassicCoreQueryMetaData.from
(QueryChunkHeader header, QueryChunkTrailer trailer) ModifierConstructorDescriptionClassicCoreQueryMetaData
(QueryChunkHeader header, QueryChunkTrailer trailer) ClassicCoreReactiveQueryResult
(QueryResponse response, NodeIdentifier lastDispatchedTo) -
Uses of Stability.Internal in com.couchbase.client.core.cnc
Modifier and TypeClassDescriptionclass
class
class
This super simple event bus should be used in testing only to assert certain events got pushed through.class
Holds static tracing and metrics identifiers throughout the SDK.Modifier and TypeMethodDescriptiondefault void
RequestSpan.lowCardinalityAttribute
(String key, boolean value) Sets a low-cardinality attribute on the span, which is translated to the corresponding implementation specific tag.default void
RequestSpan.lowCardinalityAttribute
(String key, long value) Sets a low-cardinality attribute on the span, which is translated to the corresponding implementation specific tag.default void
RequestSpan.lowCardinalityAttribute
(String key, String value) Sets a low-cardinality attribute on the span, which is translated to the corresponding implementation specific tag.void
RequestSpan.requestContext
(RequestContext requestContext) Allows to set a request context to the request span.ModifierConstructorDescriptionOrphanReporter
(EventBus eventBus, OrphanReporterConfig config) Creates a newOrphanReporter
. -
Uses of Stability.Internal in com.couchbase.client.core.cnc.events.endpoint
Modifier and TypeClassDescriptionclass
This event is generated when an endpoint disconnect was delayed because it is still in useclass
This event is generated when an endpoint disconnect was delayed, but is now about to be disconnected -
Uses of Stability.Internal in com.couchbase.client.core.cnc.events.io
-
Uses of Stability.Internal in com.couchbase.client.core.cnc.events.transaction
ModifierConstructorDescriptionTransactionLogEvent
(long timestamp, long threadId, String threadName, String transactionId, String secondaryId, String fmt, Object[] values, Event.Severity level) -
Uses of Stability.Internal in com.couchbase.client.core.cnc.metrics
Modifier and TypeClassDescriptionclass
Helper class which consolidates names and tags for caching purposes. -
Uses of Stability.Internal in com.couchbase.client.core.compression.snappy
-
Uses of Stability.Internal in com.couchbase.client.core.compression.snappy.repackaged.org.iq80.snappy.v04
-
Uses of Stability.Internal in com.couchbase.client.core.config
Modifier and TypeClassDescriptionenum
interface
TheConfigurationProvider
is responsible for grabbing, converting and managing bucket and cluster configurations.class
Deprecated.In favor ofTopologyRevision
class
Modifier and TypeMethodDescriptionAbstractBucketConfig.asClusterTopology()
Deprecated.BucketConfig.asClusterTopology()
Deprecated.ClusterConfig.bucketNames()
ClusterConfig.bucketTopologies()
ClusterConfig.bucketTopology
(String bucketName) void
ClusterConfig.deleteBucketConfig
(String bucketName) void
ClusterConfig.deleteGlobalConfig()
ClusterConfig.globalTopology()
static BucketConfig
BucketConfigParser.parse
(String input, MemcachedHashingStrategy memcachedHashingStrategy, String origin) Deprecated.void
ClusterConfig.setBucketConfig
(BucketConfig config) void
ClusterConfig.setGlobalConfig
(GlobalConfig config) ModifierConstructorDescriptionDeprecated.NodeInfo
(String hostname, Map<ServiceType, Integer> direct, Map<ServiceType, Integer> ssl, HostAndPort ketamaAuthority, NodeIdentifier nodeIdentifier) Deprecated.Creates an instance from pre-parsed address info. -
Uses of Stability.Internal in com.couchbase.client.core.config.refresher
Modifier and TypeClassDescriptionclass
TheKeyValueBucketRefresher
keeps configs up-to-date through the KV service. -
Uses of Stability.Internal in com.couchbase.client.core.diagnostics
Modifier and TypeClassDescriptionclass
TheHealthPinger
allows to "ping" individual services with real operations for their health.class
class
Helper class to perform the "wait until ready" logic.static interface
static class
Encapsulates the state of where a wait until ready flow is in.Modifier and TypeMethodDescriptionstatic Mono
<PingResult> HealthPinger.ping
(Core core, Optional<Duration> timeout, RetryStrategy retryStrategy, Set<ServiceType> serviceTypes, Optional<String> reportId, Optional<String> bucketName) static Mono
<PingResult> HealthPinger.ping
(Core core, Optional<Duration> timeout, RetryStrategy retryStrategy, Set<ServiceType> serviceTypes, Optional<String> reportId, Optional<String> bucketName, WaitUntilReadyHelper.WaitUntilReadyLogger log) Performs a service ping against all or (if given) the services provided.ModifierConstructorDescriptionDiagnosticsResult
(Map<ServiceType, List<EndpointDiagnostics>> endpoints, String sdk, String id) Creates the new diagnostics report.EndpointDiagnostics
(ServiceType type, EndpointState state, CircuitBreaker.State circuitBreakerState, String local, String remote, Optional<String> namespace, Optional<Long> lastActivityUs, Optional<String> id, Optional<Throwable> lastConnectAttemptFailure) EndpointPingReport
(ServiceType type, String id, String local, String remote, PingState state, Optional<String> namespace, Duration latency, Optional<String> error) PingResult
(Map<ServiceType, List<EndpointPingReport>> endpoints, String sdk, String id) Creates the new ping report. -
Uses of Stability.Internal in com.couchbase.client.core.endpoint
Modifier and TypeClassDescriptionclass
class
Maintains a pool of ProtostellarEndpoints.Modifier and TypeMethodDescriptionEndpointContext.authenticationStatus()
void
EndpointContext.authenticationStatus
(AuthenticationStatus authenticationStatus) void
BaseEndpoint.decrementOutstandingRequests()
Helper method to decrement outstanding requests, even if they haven't finished yet.Endpoint.internalDiagnostics()
long
BaseEndpoint.lastConnectedAt()
void
BaseEndpoint.markRequestCompletion()
Called from the event loop handlers to mark a request as being completed.void
BaseEndpoint.notifyChannelInactive()
This method is called from inside the channel to tell the endpoint hat it got inactive.EndpointContext.tlsHandshakeFailure()
void
EndpointContext.tlsHandshakeFailure
(Throwable tlsHandshakeFailure) ProtostellarEndpoint.waitUntilReady
(Deadline deadline, boolean waitingForReady) Waits until the ManagedChannel is in READY state. -
Uses of Stability.Internal in com.couchbase.client.core.endpoint.http
Modifier and TypeInterfaceDescriptioninterface
class
class
The "path" component of a URI, with support for path parameters whose replacement values are automatically url-encoded.class
static class
Builder for dynamic HTTP requestsclass
-
Uses of Stability.Internal in com.couchbase.client.core.env
Modifier and TypeClassDescriptionclass
class
class
static class
static class
static class
class
A holder for a resource that is either "owned" (created and managed by the SDK) or "external" (created and managed outside the SDK).class
Deprecated.For internal Couchbase code, please useOwnedOrExternal.owned(Object)
instead.interface
Marker interface for different callbacks in the request lifecycle.static class
static class
static class
static class
Deprecated.class
Modifier and TypeMethodDescriptionCoreEnvironment.Builder.addRequestCallback
(RequestCallback requestCallback) Allows to configure callbacks across the lifetime of a request.default void
Authenticator.applyTlsProperties
(com.couchbase.client.core.deps.io.netty.handler.ssl.SslContextBuilder sslContextBuilder) The authenticator gets the chance to attach the client certificate to the ssl context if needed.default void
Authenticator.authHttpRequest
(ServiceType serviceType, com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpRequest request) Allows to add authentication credentials to the http request for the given service.default void
Authenticator.authKeyValueConnection
(EndpointContext endpointContext, com.couchbase.client.core.deps.io.netty.channel.ChannelPipeline pipeline) Allows the authenticator to add KV handlers during connection bootstrap to perform authentication.IoEnvironment.Builder.build()
CoreEnvironment.executor()
Returns the executor used to schedule non-reactive async tasks across the SDK.TimerConfig.exportAsMap()
ThresholdRequestTracerConfig.Builder.fromNewBuilder
(ThresholdLoggingTracerConfig.Builder newBuilder) Deprecated.CoreEnvironment.Builder.loadSystemProperties()
You might wonder why callers can't useCoreEnvironment.Builder.load(PropertyLoader)
to load system properties.com.couchbase.client.core.deps.io.grpc.CallCredentials
Authenticator.protostellarCallCredentials()
com.couchbase.client.core.deps.io.grpc.CallCredentials
CertificateAuthenticator.protostellarCallCredentials()
<T> Flux
<T> CoreEnvironment.publishOnUserScheduler
(Flux<T> flux) <T> Mono
<T> CoreEnvironment.publishOnUserScheduler
(Mono<T> mono) CoreEnvironment.requestCallbacks()
default boolean
Authenticator.supportsNonTls()
If this authenticator supports non-encrypted connections.default boolean
Authenticator.supportsTls()
If this authenticator supports encrypted connections.ThresholdRequestTracerConfig.Builder.toNewBuillder()
Deprecated.Converts this deprecated builder into its non-deprecated version.CoreEnvironment.Builder.transactionsConfig
(CoreTransactionsConfig transactionsConfig) Allows configuring the transactions config.CoreEnvironment.userScheduler()
Returns the supplier for the scheduler where Reactive API results should be published, or null if the user does not want to switch schedulers. -
Uses of Stability.Internal in com.couchbase.client.core.error
Modifier and TypeClassDescriptionclass
Exception raised if during config load the bucket is not found (think: http 404).class
Exception raised if during config load the bucket is found, but not deemed ready yet.class
This is an internal exception the user should never see; The SDK should translate it to some other exception before presenting it to the user.class
class
class
class
class
This is an internal exception used to signal exceptional states in the range scan orchestrator.class
Internal optimisation to avoid the cost of completableFuture.completeExceptionally() creating a CompletionException (including expensive stack creation).class
Modifier and TypeMethodDescriptionbyte[]
AnalyticsException.content()
static List
<ErrorCodeAndMessage> ErrorCodeAndMessage.from
(byte[] content) static List
<ErrorCodeAndMessage> ErrorCodeAndMessage.fromJsonArray
(byte[] jsonArray) boolean
PreparedStatementFailureException.retryable()
ModifierConstructorDescriptionBucketExistsException
(String bucketName, ErrorContext context) CollectionExistsException
(String collectionName, ErrorContext context) CouchbaseException
(String message, Throwable cause, boolean enableSuppression, boolean writableStacktrace, ErrorContext ctx) InternalServerFailureException
(Throwable cause, ErrorContext ctx) RequestCanceledException
(String message, CancellationReason reason, Throwable cause, CancellationErrorContext ctx) ScopeExistsException
(String scopeName, ErrorContext context) ScopeNotFoundException
(String scopeName, ErrorContext context) -
Uses of Stability.Internal in com.couchbase.client.core.error.context
-
Uses of Stability.Internal in com.couchbase.client.core.error.subdoc
Modifier and TypeClassDescriptionclass
Sub-Document exception thrown when ReviveDocument has been used with a document that already exists -
Uses of Stability.Internal in com.couchbase.client.core.error.transaction
Modifier and TypeClassDescriptionclass
Indicates that this transaction should be retried.class
This operation (such as a replace, get or insert) either failed or ambiguously succeeded.static enum
Modifier and TypeMethodDescriptionboolean
TransactionOperationFailedException.autoRollbackAttempt()
boolean
TransactionOperationFailedException.retryTransaction()
TransactionOperationFailedException.toRaise()
-
Uses of Stability.Internal in com.couchbase.client.core.error.transaction.internal
Modifier and TypeClassDescriptionclass
The transaction expired at the point of trying to commit it.class
The transaction could not be fully completed in the configured timeout.class
The transaction failed to reach the Committed point.class
class
Indicates that committing the ATR entry should be retried.class
Indicates that this operation should be retried.class
Used only in testing: injects an error that will be handled as FAIL_AMBIGUOUS.class
Used only in testing: injects an error that will be handled as FAIL_HARD.class
Used only in testing: injects an error that will be handled as FAIL_OTHER.class
Used only in testing: injects a FAIL_TRANSIENT error.class
interface
TransactionOperationFailedException is raised as an opaque signal that something went wrong with a transaction operation. -
Uses of Stability.Internal in com.couchbase.client.core.io
Modifier and TypeClassDescriptionclass
TheCollectionIdentifier
uniquely identifies the position of a collection. -
Uses of Stability.Internal in com.couchbase.client.core.io.netty
Modifier and TypeClassDescriptionclass
This factory createsSslHandler
based on a given configuration.class
Contains various utils to set attributes for tracing spans.Modifier and TypeMethodDescriptionSslHandlerFactory.defaultCiphers
(boolean nativeTlsEnabled) Lists the default ciphers used for this platform.static boolean
SslHandlerFactory.opensslAvailable()
True if the native ssl transport is available, false otherwise. -
Uses of Stability.Internal in com.couchbase.client.core.io.netty.kv
Modifier and TypeClassDescriptionclass
This handler tries to load the KV Error Map in a best effort manner.class
TheFeatureNegotiatingHandler
is responsible for sending the KV "hello" command and to handshake enabled features on both sides.class
TheSaslListMechanismsHandler
asks the server KV engine which SASL mechanism it supports.class
TheSelectBucketHandler
is responsible for, selecting the right bucket on this KV connection.enum
Describes all the different negotiation modes between the server and the SDK.Modifier and TypeMethodDescriptionSaslAuthenticationHandler.allowedMechanisms()
Returns the allowed mechanisms for this handler, useful for testing assertions.ModifierConstructorDescriptionKeyValueChannelContext
(CompressionConfig compression, Optional<String> bucket, CollectionMap collectionMap, com.couchbase.client.core.deps.io.netty.channel.ChannelId channelId, Set<ServerFeature> features) -
Uses of Stability.Internal in com.couchbase.client.core.json
Modifier and TypeClassDescriptionclass
Provides utilities for encoding and decoding JSON data. -
Uses of Stability.Internal in com.couchbase.client.core.kv
Modifier and TypeInterfaceDescriptioninterface
Performs a KV range scan to scan between twoCoreScanTerms
.interface
Performs a KV range scan using random sampling.interface
Allows to customize the various range and sampling scan options.class
A singleCoreScanTerm
identifying either the point to scan from or to scan to.interface
Either RangeScan or SampleScanclass
Main entry point from higher level languages to perform KV range scans. -
Uses of Stability.Internal in com.couchbase.client.core.manager
Modifier and TypeClassDescriptionclass
class
Deprecated.interface
interface
class
class
Encapsulates common functionality around the eventing management APIs.class
enum
class
-
Uses of Stability.Internal in com.couchbase.client.core.manager.bucket
Modifier and TypeInterfaceDescriptioninterface
enum
enum
interface
enum
class
-
Uses of Stability.Internal in com.couchbase.client.core.manager.collection
-
Uses of Stability.Internal in com.couchbase.client.core.msg
Modifier and TypeMethodDescriptionRequestContext.clientContext
(Map<String, Object> clientContext) Allows to set a custom payload for this request.RequestContext.dispatchLatency
(long dispatchLatency) Allows to set the dispatch duration of the request.RequestContext.encodeLatency
(long encodeLatency) RequestContext.incrementRetryAttempts
(Duration lastRetryDuration, RetryReason reason) RequestContext.lastChannelId
(String lastChannelId) RequestContext.lastDispatchedFrom
(HostAndPort lastDispatchedFrom) RequestContext.lastDispatchedTo
(HostAndPort lastDispatchedTo) RequestContext.lastDispatchedToNode()
RequestContext.lastDispatchedToNode
(NodeIdentifier lastDispatchedToNode) RequestContext.logicallyComplete()
RequestContext.logicallyComplete
(Throwable err) Signals that this request is completed fully, including streaming sections or logical sub-requests also being completed (i.e.RequestContext.serverLatency
(long serverLatency) ModifierConstructorDescriptionRequestContext
(CoreContext ctx, Request<? extends Response> request) RequestContext
(Core core, long contextId, CoreEnvironment environment, Authenticator authenticator, Request<? extends Response> request) -
Uses of Stability.Internal in com.couchbase.client.core.msg.kv
Modifier and TypeClassDescriptionfinal class
Represents the response of aGetRequest
.class
Helper class that language-specific clients may use to implementMutationState
.class
class
class
Modifier and TypeMethodDescriptionbyte
DurabilityLevel.code()
static List
<CoreSubdocGetCommand> SubdocGetRequest.convertCommandsToCore
(List<SubdocGetRequest.Command> commands) static DurabilityLevel
DurabilityLevel.decodeFromManagementApi
(String input) Decodes the string representation of the durability level from the management API into an enum.DurabilityLevel.encodeForManagementApi()
Encodes theDurabilityLevel
so that the management API understands it.SubdocGetResponse.toCore
(CoreKeyspace keyspace, String key) -
Uses of Stability.Internal in com.couchbase.client.core.msg.manager
Modifier and TypeMethodDescriptionvoid
BucketConfigStreamingResponse.completeStream()
void
BucketConfigStreamingResponse.failStream
(Throwable e) void
BucketConfigStreamingResponse.pushConfig
(String config) -
Uses of Stability.Internal in com.couchbase.client.core.msg.query
Modifier and TypeMethodDescriptionQueryRequest.toExecuteRequest
(String preparedStatementName, String encodedPlan, RequestTracer requestTracer) Returns a copy of this request tailored to execute a prepared statement.QueryRequest.toPrepareRequest
(boolean autoExecute, RequestTracer requestTracer) Returns a new request that creates a prepared statement using this request as a template. -
Uses of Stability.Internal in com.couchbase.client.core.node
Modifier and TypeInterfaceDescriptioninterface
This interface defines different hashing strategies used for ketama hashing in memcached buckets.Modifier and TypeMethodDescriptionNodeIdentifier.asTopologyNodeIdentifier()
Deprecated.Node.internalDiagnostics()
-
Uses of Stability.Internal in com.couchbase.client.core.protostellar
Modifier and TypeClassDescriptionclass
class
interface
class
ProtostellarCollectionManagerRequest<TGrpcRequest>
final class
class
ProtostellarKeyValueRequest<TGrpcRequest>
class
ProtostellarRequest<TGrpcRequest>
Holds onto a GRPC request, along with pertaining mutable and immutable state bound to the request's lifetime.class
ModifierConstructorDescriptionProtostellarBaseRequest
(CoreProtostellar core, ProtostellarRequest<?> request) -
Uses of Stability.Internal in com.couchbase.client.core.protostellar.kv
Modifier and TypeClassDescriptionclass
For creating Protostellar GRPC KV requests.class
For converting Protostellar GRPC KV responses.class
class
For converting Protostellar GRPC KV responses.class
class
final class
-
Uses of Stability.Internal in com.couchbase.client.core.protostellar.manager
Modifier and TypeClassDescriptionclass
For creating Protostellar GRPC requests.class
For converting Protostellar GRPC responses.class
class
final class
-
Uses of Stability.Internal in com.couchbase.client.core.protostellar.query
Modifier and TypeClassDescriptionclass
class
class
class
-
Uses of Stability.Internal in com.couchbase.client.core.protostellar.search
-
Uses of Stability.Internal in com.couchbase.client.core.retry
Modifier and TypeClassDescriptionclass
class
An internal strategy to fail fast any request that goes through it.class
Determines what to do with a request.class
TheRetryOrchestrator
is responsible for checking if a request is eligible for retry and if so dispatch it properly and update state.class
Modifier and TypeMethodDescriptionstatic Duration
RetryOrchestrator.capDuration
(Duration uncappedDuration, Request<? extends Response> request) Calculates the potentially capped retry duration so we do not schedule a longer retry than the actual total timeout.static Duration
RetryOrchestratorProtostellar.capDuration
(Duration uncappedDuration, ProtostellarRequest<?> request) static Duration
RetryOrchestrator.controlledBackoff
(int retryAttempt) Helper method for a simple, bounded controlled backoff for the "always retry" handler so that it doesn't spam quickly all the time. -
Uses of Stability.Internal in com.couchbase.client.core.service
-
Uses of Stability.Internal in com.couchbase.client.core.service.kv
-
Uses of Stability.Internal in com.couchbase.client.core.topology
Modifier and TypeClassDescriptionenum
interface
enum
class
class
A cluster topology that also has topology info for one bucket.class
class
Used for locating the services running on a node.final class
KetamaRing<E>
A Ketama ring (or "continuum", if you prefer) with Couchbase-specific parameters defined by Couchbase SDK RFC 26 (Ketama Hashing)interface
class
interface
Helps the config parser select the correct alternate addresses.class
class
A map from partition index to info about the partition.class
Knows which nodes host the active and replicas for one partition.enum
Helps the config parser select only the service ports relevant to the client's transport security mode (TLS or non-TLS).class
class
class
Modifier and TypeMethodDescriptionMemcachedBucketTopology.hashingStrategy()
BucketTopology.nodes()
Returns the subset of cluster nodes that are ready to service requests for this bucket.static BucketTopology
BucketTopology.parse
(com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode json, List<HostAndServicePorts> nodes, MemcachedHashingStrategy memcachedHashingStrategy) HostAndServicePorts.withKetamaAuthority
(HostAndPort ketamaAuthority) HostAndServicePorts.without
(ServiceType service, ServiceType... moreServices) -
Uses of Stability.Internal in com.couchbase.client.core.transaction
Modifier and TypeClassDescriptionclass
class
Provides methods to allow an application's transaction logic to read, mutate, insert and delete documents, as well as commit or rollback the transaction.class
Stores some context related to a transaction.class
Represents a value fetched from Couchbase, along with additional transactional metadata.class
class
Modifier and TypeMethodDescriptionstatic CoreTransactionGetResult
CoreTransactionGetResult.createFrom
(CollectionIdentifier collection, String documentId, CoreSubdocGetResult doc) static CoreTransactionGetResult
CoreTransactionGetResult.createFrom
(CoreTransactionGetResult doc, byte[] content) ModifierConstructorDescriptionCoreTransactionGetResult
(String id, byte[] content, int userFlags, long cas, CollectionIdentifier collection, TransactionLinks links, Optional<DocumentMetadata> documentMetadata, Optional<com.couchbase.client.core.deps.com.fasterxml.jackson.databind.JsonNode> txnMeta, Optional<String> crc32OfGet) Note that it's intentionally obfuscated here as to whether both content and userFlags come from the document's current body, or staged in the transactional metadata. -
Uses of Stability.Internal in com.couchbase.client.core.transaction.atr
-
Uses of Stability.Internal in com.couchbase.client.core.transaction.cleanup
Modifier and TypeClassDescriptionclass
Simple data class, so all fields are public.class
Used for testing/mocking.class
class
Used for testing/mocking.class
class
Represents the ClientRecord doc, a single document that contains an entry for every client (app) current participating in the cleanup of 'lost' transactions.class
Utility class to store the result of a client checking/updating the Client Record doc.class
Used for testing/mocking.class
Used for testing/mocking.class
Owns cleanup threads.class
Runs the algorithm to find 'lost' transactions, distributing the work between clients.class
Handles cleaning up expired/lost transactions. -
Uses of Stability.Internal in com.couchbase.client.core.transaction.components
Modifier and TypeClassDescriptionclass
static class
class
class
class
enum
Metadata related to the CAS.class
class
Responsible for doing transaction-aware get()s.class
Stores some $document metadata from when the document is fetchedclass
class
class
Stores the transaction links stored on each document in a transactionModifier and TypeMethodDescriptionOptional
<byte[]> TransactionLinks.stagedContentBinary()
Optional
<byte[]> TransactionLinks.stagedContentJson()
Optional
<byte[]> TransactionLinks.stagedContentJsonOrBinary()
-
Uses of Stability.Internal in com.couchbase.client.core.transaction.config
Modifier and TypeClassDescriptionclass
MergesCoreTransactionOptions
andCoreTransactionsConfig
.class
class
Tunables for an individual transaction.class
class
Modifier and TypeMethodDescriptionCoreTransactionsCleanupConfig.createDefault()
static CoreTransactionsConfig
CoreTransactionsConfig.createDefault
(CoreTransactionsSupportedExtensions supported) -
Uses of Stability.Internal in com.couchbase.client.core.transaction.context
Modifier and TypeClassDescriptionclass
Holds transactions state that has the same lifetime as a Core.class
-
Uses of Stability.Internal in com.couchbase.client.core.transaction.error.internal
-
Uses of Stability.Internal in com.couchbase.client.core.transaction.forwards
Modifier and TypeClassDescriptionenum
All known protocol extensions.class
Defines what is support by this implementation (extensions and protocol version).class
A mechanism to help ensure that older clients can be prevented from interacting with transactions created by future clients that they do not know how to process.enum
Points in the protocol where forward compatibility can be checked. -
Uses of Stability.Internal in com.couchbase.client.core.transaction.log
Modifier and TypeClassDescriptionclass
A logger optimized for logging transactions-specific info. -
Uses of Stability.Internal in com.couchbase.client.core.transaction.support
Modifier and TypeClassDescriptionenum
The possible states for a transaction attempt.class
class
Wraps a RequestSpan, with the value-add that it automatically records how long the operation took for transaction logging.class
class
enum
class
class
-
Uses of Stability.Internal in com.couchbase.client.core.transaction.threadlocal
Modifier and TypeClassDescriptionclass
Used to indicate that we are inside a transaction, and placed in ThreadLocalStorage (or reactive context).class
Used to manage ThreadLocalStorage (or reactive context) of TransactionMarker. -
Uses of Stability.Internal in com.couchbase.client.core.transaction.util
Modifier and TypeClassDescriptionclass
Can be used for testing transactions, but is for internal use only.class
Mainly to aid debugging, transactions use their own pool of schedulers.class
class
class
class
class
Tracks read and write units used.static class
class
MonoBridge<T>
Protects against concurrent op cancellation.class
class
A mutex pessimistic lock, compatible with reactive.class
Provides locking functionality in line with Go's WaitGroups, in a reactive compatible way.class
Can be used for testing transactions, but is for internal use only.class
Transactions does a lot of KV work from core-io.interface
TriFunction<T,
U, V, R> -
Uses of Stability.Internal in com.couchbase.client.core.util
Modifier and TypeClassDescriptionclass
Defines helpful routines for working with bucket configs.class
class
class
class
class
class
class
Defines helpful routines for working with cluster capabilities.class
static enum
class
Contains various helper methods when dealing with the connection string.class
Helper routines for tests to wait for all nodes to have a consistent view of a resource.class
class
final class
Integrates the Couchbase infrastructure withBlockHound
.class
class
The default implementation for performing DNS SRV lookups.class
class
Either<L,
R> class
EnumLookupTable<E extends Enum<E>>
Provides efficient lookup for enums whose values are associated with small integers.interface
IntMap<E>
A read-only map where the keys are non-negative integers.class
Approximates Java 9's java.lang.ref.Cleanerclass
Useful when only the latest value of a Flux is interesting, and processing values is relatively expensive.class
class
A convenient wrapper class around network primitives in Java.@interface
Indicates that at least one purpose of the annotated field is to prevent the value from being garbage collected.class
interface
class
Modifier and TypeMethodDescriptionstatic NetworkAddress
Creates a newNetworkAddress
from either a hostname or ip address literal.ConnectionStringUtil.fromDnsSrvOrThrowIfTlsRequired
(String serviceName, boolean secure) NetworkAddress.hostname()
Returns the hostname for this network address.static <T> T
ReactorOps.proxyToPublishOnSuppliedScheduler
(T obj, Class<T> interfaceToProxy, Supplier<Scheduler> scheduler) Returns a dynamic proxy for the given object (unless the given supplier is null, in which case the same object is returned).ConnectionString.withParams
(Map<String, String> params) ConnectionString.withScheme
(ConnectionString.Scheme scheme)