Uses of Annotation Type
com.couchbase.client.core.annotation.Stability.Internal
Packages that use 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
Classes in com.couchbase.client.core with annotations of type Stability.InternalModifier and TypeClassDescriptionfinal classclassclassinterfaceResources that are owned by aCoreCouchbaseOps.classTheTimeracts 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.Methods in com.couchbase.client.core with annotations of type Stability.InternalModifier and TypeMethodDescriptionCoreContext.alternateAddress(Optional<String> alternateAddress) Deprecated.This method does not do anything.Core.appTelemetryCollector()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.coreResources()CoreContext.coreResources()Core.diagnostics()reactor.core.publisher.Mono<Void> 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.voidCore.initGlobalConfig()Instructs the client to, if possible, load and initialize the global config.Core.internalDiagnostics()Core.kvBinaryOps(CoreKeyspace keyspace) Core.kvOps(CoreKeyspace keyspace) voidCore.openBucket(String name) Attempts to open a bucket and fails theMonoif there is a persistent error as the reason.Core.queryOps()Core.responseMetric(Request<?> request, Throwable err) CoreProtostellar.responseMetric(ResponseMetricIdentifier rmi) Core.searchOps(CoreBucketAndScope scope) <R extends Response>
voidSends a command into the core layer and allows to avoid timeout registration.Optional<reactor.core.publisher.Flux<ServiceState>> 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.reactor.core.publisher.Mono<Void> Core.shutdown()reactor.core.publisher.Mono<Void> Shuts down this core and all associated, owned resources.Core.transactionsCleanup()Core.transactionsContext()reactor.core.publisher.Mono<ClusterTopology> Core.waitForClusterTopology(Duration timeout) static <T> reactor.core.publisher.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
Classes in com.couchbase.client.core.annotation with annotations of type Stability.InternalModifier and TypeClassDescription@interfaceSpecifies the earliest version of Couchbase Server that supports the annotated feature.@interfaceIndicates 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
Classes in com.couchbase.client.core.api with annotations of type Stability.InternalModifier and TypeInterfaceDescriptioninterfaceProvides access to the variousCore*Opsinstances. -
Uses of Stability.Internal in com.couchbase.client.core.api.kv
Classes in com.couchbase.client.core.api.kv with annotations of type Stability.InternalModifier and TypeClassDescriptionfinal classAssociates aCompletableFuturewith a cancellation task.classfinal classEither a synchronousDurabilityLevel, or "persist to and replicate to" for legacy durability.interfaceclassfinal classA relative or absolute expiry.final classinterfaceinterfaceclassfinal classclassclassConvenience macros to retrieve document metadata using a lookupIn Sub-Document call.classenumclassclassclass -
Uses of Stability.Internal in com.couchbase.client.core.api.manager
Classes in com.couchbase.client.core.api.manager with annotations of type Stability.InternalModifier and TypeClassDescriptionclassinterfaceAllows customizing how deferred indexes are built.interfaceAllows customizing how a query primary index is created.interfaceAllows customizing how a query index is created.interfaceAllows customizing how a query primary index is created.interfaceAllows customizing how primary indexes are dropped.interfaceAllows customizing how query indexes are dropped.interfaceAllows customizing how query indexes are loaded.classContains the properties of a Query Index.classinterfaceAllows customizing how the query indexes are watched. -
Uses of Stability.Internal in com.couchbase.client.core.api.manager.search
Classes in com.couchbase.client.core.api.manager.search with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassclassclassinterfaceThe same interface is used for ScopeSearchIndexManager and SearchIndexManager, as there is no API difference between them at this level.Constructors in com.couchbase.client.core.api.manager.search with annotations of type Stability.InternalModifierConstructorDescriptionClassicCoreScopeSearchIndexManager(Core core, CoreBucketAndScope scope) -
Uses of Stability.Internal in com.couchbase.client.core.api.query
Classes in com.couchbase.client.core.api.query with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassinterfaceinterfaceclassTransactions does some rather complex things with CoreQueryOptions.enumQuery profiling information received from the server query engine.classThe result of a N1QL query, including rows and associated metadata.enumThe possible values for scan consistency in a N1QL request.enumclassRepresents a single warning returned from the query engine.class -
Uses of Stability.Internal in com.couchbase.client.core.api.search
Classes in com.couchbase.client.core.api.search with annotations of type Stability.InternalModifier and TypeClassDescriptionclassenumclassclassinterfaceinterfaceclassenumMethods in com.couchbase.client.core.api.search with annotations of type Stability.InternalModifier and TypeMethodDescriptionstatic voidClassicCoreSearchOps.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
Classes in com.couchbase.client.core.api.search.facet with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassclassclassclassclass -
Uses of Stability.Internal in com.couchbase.client.core.api.search.queries
Classes in com.couchbase.client.core.api.search.queries with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassclassclassclassclassclassclassclassclassTo create a new instance:classclassinterfaceclassclassclassenumclassclassclassclassclassclassclassclassclassclassclass -
Uses of Stability.Internal in com.couchbase.client.core.api.search.result
Classes in com.couchbase.client.core.api.search.result with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassclassclassclassA range (or bucket) for aCoreDateRangeSearchFacetResult.interfaceclassclassclassclassclassclassclassclass -
Uses of Stability.Internal in com.couchbase.client.core.api.search.sort
Classes in com.couchbase.client.core.api.search.sort with annotations of type Stability.InternalModifier and TypeClassDescriptionenumenumenumenumclassclassclassclassclassclassA sort tier specified as a string. -
Uses of Stability.Internal in com.couchbase.client.core.api.search.util
Classes in com.couchbase.client.core.api.search.util with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.api.search.vector
Classes in com.couchbase.client.core.api.search.vector with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassenumclassclass -
Uses of Stability.Internal in com.couchbase.client.core.callbacks
Classes in com.couchbase.client.core.callbacks with annotations of type Stability.InternalModifier and TypeInterfaceDescriptioninterfaceThis 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
Classes in com.couchbase.client.core.classic with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.classic.analytics
Classes in com.couchbase.client.core.classic.analytics with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.classic.kv
Classes in com.couchbase.client.core.classic.kv with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassfinal class -
Uses of Stability.Internal in com.couchbase.client.core.classic.manager
Classes in com.couchbase.client.core.classic.manager with annotations of type Stability.InternalModifier and TypeClassDescriptionclassfinal classConstructors in com.couchbase.client.core.classic.manager with annotations of type Stability.InternalModifierConstructorDescriptionCoreBucketSettingsJson(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, Integer numVBuckets, Boolean historyRetentionCollectionDefault, Long historyRetentionBytes, Long historyRetentionDurationSeconds) -
Uses of Stability.Internal in com.couchbase.client.core.classic.query
Classes in com.couchbase.client.core.classic.query with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassclassclassclassclassServer remembers query plan; client sends just the prepared statement name.classClient remembers query plan and sends it on every request.classMethods in com.couchbase.client.core.classic.query with annotations of type Stability.InternalModifier and TypeMethodDescriptionstatic com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNodeClassicCoreQueryOps.convertOptions(CoreQueryOptions opts) static ClassicCoreQueryMetaDataClassicCoreQueryMetaData.from(QueryChunkHeader header, QueryChunkTrailer trailer) Constructors in com.couchbase.client.core.classic.query with annotations of type Stability.InternalModifierConstructorDescriptionClassicCoreQueryMetaData(QueryChunkHeader header, QueryChunkTrailer trailer) ClassicCoreReactiveQueryResult(QueryResponse response, NodeIdentifier lastDispatchedTo) -
Uses of Stability.Internal in com.couchbase.client.core.cnc
Classes in com.couchbase.client.core.cnc with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassclassThis super simple event bus should be used in testing only to assert certain events got pushed through.classHolds static tracing and metrics identifiers throughout the SDK.Methods in com.couchbase.client.core.cnc with annotations of type Stability.InternalModifier and TypeMethodDescriptiondefault voidRequestSpan.lowCardinalityAttribute(String key, boolean value) Sets a low-cardinality attribute on the span, which is translated to the corresponding implementation specific tag.default voidRequestSpan.lowCardinalityAttribute(String key, long value) Sets a low-cardinality attribute on the span, which is translated to the corresponding implementation specific tag.default voidRequestSpan.lowCardinalityAttribute(String key, String value) Sets a low-cardinality attribute on the span, which is translated to the corresponding implementation specific tag.voidRequestSpan.requestContext(RequestContext requestContext) Allows to set a request context to the request span.Constructors in com.couchbase.client.core.cnc with annotations of type Stability.InternalModifierConstructorDescriptionOrphanReporter(EventBus eventBus, OrphanReporterConfig config) Creates a newOrphanReporter. -
Uses of Stability.Internal in com.couchbase.client.core.cnc.apptelemetry
Classes in com.couchbase.client.core.cnc.apptelemetry with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.cnc.apptelemetry.collector
Classes in com.couchbase.client.core.cnc.apptelemetry.collector with annotations of type Stability.InternalModifier and TypeInterfaceDescriptioninterfacefinal classenum -
Uses of Stability.Internal in com.couchbase.client.core.cnc.apptelemetry.reporter
Classes in com.couchbase.client.core.cnc.apptelemetry.reporter with annotations of type Stability.InternalModifier and TypeInterfaceDescriptioninterfaceclass -
Uses of Stability.Internal in com.couchbase.client.core.cnc.events.endpoint
Classes in com.couchbase.client.core.cnc.events.endpoint with annotations of type Stability.InternalModifier and TypeClassDescriptionclassThis event is generated when an endpoint disconnect was delayed because it is still in useclassThis 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
Classes in com.couchbase.client.core.cnc.events.io with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.cnc.events.transaction
Constructors in com.couchbase.client.core.cnc.events.transaction with annotations of type Stability.InternalModifierConstructorDescriptionTransactionLogEvent(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
Classes in com.couchbase.client.core.cnc.metrics with annotations of type Stability.InternalModifier and TypeClassDescriptionclassHelper class which consolidates names and tags for caching purposes.class -
Uses of Stability.Internal in com.couchbase.client.core.compression.snappy
Classes in com.couchbase.client.core.compression.snappy with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.compression.snappy.repackaged.org.iq80.snappy.v04
Classes in com.couchbase.client.core.compression.snappy.repackaged.org.iq80.snappy.v04 with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.config
Classes in com.couchbase.client.core.config with annotations of type Stability.InternalModifier and TypeClassDescriptionenuminterfaceTheConfigurationProvideris responsible for grabbing, converting and managing bucket and cluster configurations.classDeprecated.In favor ofTopologyRevisionclassMethods in com.couchbase.client.core.config with annotations of type Stability.InternalModifier and TypeMethodDescriptionAbstractBucketConfig.asClusterTopology()Deprecated.BucketConfig.asClusterTopology()Deprecated.ClusterConfig.bucketNames()ClusterConfig.bucketTopologies()ClusterConfig.bucketTopology(String bucketName) voidClusterConfig.deleteBucketConfig(String bucketName) voidClusterConfig.deleteGlobalConfig()ClusterConfig.globalTopology()static BucketConfigBucketConfigParser.parse(String input, MemcachedHashingStrategy memcachedHashingStrategy, String origin) Deprecated.voidClusterConfig.setBucketConfig(ClusterTopologyWithBucket topology) voidClusterConfig.setGlobalConfig(ClusterTopology config) Constructors in com.couchbase.client.core.config with annotations of type Stability.InternalModifierConstructorDescriptionDeprecated.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
Classes in com.couchbase.client.core.config.refresher with annotations of type Stability.InternalModifier and TypeClassDescriptionclassTheKeyValueBucketRefresherkeeps configs up-to-date through the KV service. -
Uses of Stability.Internal in com.couchbase.client.core.diagnostics
Classes in com.couchbase.client.core.diagnostics with annotations of type Stability.InternalModifier and TypeClassDescriptionclassTheHealthPingerallows to "ping" individual services with real operations for their health.classclassHelper class to perform the "wait until ready" logic.static interfacestatic classEncapsulates the state of where a wait until ready flow is in.Methods in com.couchbase.client.core.diagnostics with annotations of type Stability.InternalModifier and TypeMethodDescriptionstatic reactor.core.publisher.Mono<PingResult> HealthPinger.ping(Core core, Optional<Duration> timeout, RetryStrategy retryStrategy, Set<ServiceType> serviceTypes, Optional<String> reportId, Optional<String> bucketName) static reactor.core.publisher.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.Constructors in com.couchbase.client.core.diagnostics with annotations of type Stability.InternalModifierConstructorDescriptionDiagnosticsResult(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
Classes in com.couchbase.client.core.endpoint with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassMaintains a pool of ProtostellarEndpoints.Methods in com.couchbase.client.core.endpoint with annotations of type Stability.InternalModifier and TypeMethodDescriptionEndpointContext.authenticationStatus()voidEndpointContext.authenticationStatus(AuthenticationStatus authenticationStatus) static Class<? extends com.couchbase.client.core.deps.io.netty.channel.Channel> BaseEndpoint.channelFrom(com.couchbase.client.core.deps.io.netty.channel.EventLoopGroup eventLoopGroup) Helper method to locate the right socket channel class based on the injected event loop group.voidBaseEndpoint.decrementOutstandingRequests()Helper method to decrement outstanding requests, even if they haven't finished yet.Endpoint.internalDiagnostics()longBaseEndpoint.lastConnectedAt()voidBaseEndpoint.markRequestCompletion()Called from the event loop handlers to mark a request as being completed.voidBaseEndpoint.notifyChannelInactive()This method is called from inside the channel to tell the endpoint hat it got inactive.EndpointContext.tlsHandshakeFailure()voidEndpointContext.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
Classes in com.couchbase.client.core.endpoint.http with annotations of type Stability.InternalModifier and TypeInterfaceDescriptioninterfaceclassclassThe "path" component of a URI, with support for path parameters whose replacement values are automatically url-encoded.classstatic classBuilder for dynamic HTTP requestsclass -
Uses of Stability.Internal in com.couchbase.client.core.env
Classes in com.couchbase.client.core.env with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassclassstatic classstatic classstatic classclassA holder for a resource that is either "owned" (created and managed by the SDK) or "external" (created and managed outside the SDK).classDeprecated.For internal Couchbase code, please useOwnedOrExternal.owned(Object)instead.interfaceMarker interface for different callbacks in the request lifecycle.classWraps aRequestTracerto provide new attributes.static classstatic classstatic classstatic classDeprecated.classFields in com.couchbase.client.core.env with annotations of type Stability.InternalMethods in com.couchbase.client.core.env with annotations of type Stability.InternalModifier and TypeMethodDescriptionCoreEnvironment.Builder.addRequestCallback(RequestCallback requestCallback) Allows to configure callbacks across the lifetime of a request.default voidAuthenticator.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 voidAuthenticator.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 voidAuthenticator.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.CallCredentialsAuthenticator.protostellarCallCredentials()com.couchbase.client.core.deps.io.grpc.CallCredentialsCertificateAuthenticator.protostellarCallCredentials()<T> reactor.core.publisher.Flux<T> CoreEnvironment.publishOnUserScheduler(reactor.core.publisher.Flux<T> flux) <T> reactor.core.publisher.Mono<T> CoreEnvironment.publishOnUserScheduler(reactor.core.publisher.Mono<T> mono) CoreEnvironment.requestCallbacks()default booleanAuthenticator.supportsNonTls()If this authenticator supports non-encrypted connections.default booleanAuthenticator.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.SecurityConfig.trustCertificatesToString()Supplier<reactor.core.scheduler.Scheduler> 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.Constructors in com.couchbase.client.core.env with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.error
Classes in com.couchbase.client.core.error with annotations of type Stability.InternalModifier and TypeClassDescriptionclassException raised if during config load the bucket is not found (think: http 404).classException raised if during config load the bucket is found, but not deemed ready yet.classThis is an internal exception the user should never see; The SDK should translate it to some other exception before presenting it to the user.classclassclassclassclassThis is an internal exception used to signal exceptional states in the range scan orchestrator.classInternal optimisation to avoid the cost of completableFuture.completeExceptionally() creating a CompletionException (including expensive stack creation).classMethods in com.couchbase.client.core.error with annotations of type Stability.InternalModifier and TypeMethodDescriptionbyte[]AnalyticsException.content()static List<ErrorCodeAndMessage> ErrorCodeAndMessage.from(byte[] content) static List<ErrorCodeAndMessage> ErrorCodeAndMessage.fromJsonArray(byte[] jsonArray) booleanPreparedStatementFailureException.retryable()Constructors in com.couchbase.client.core.error with annotations of type Stability.InternalModifierConstructorDescriptionBucketExistsException(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
Methods in com.couchbase.client.core.error.context with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.error.subdoc
Classes in com.couchbase.client.core.error.subdoc with annotations of type Stability.InternalModifier and TypeClassDescriptionclassSub-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
Classes in com.couchbase.client.core.error.transaction with annotations of type Stability.InternalModifier and TypeClassDescriptionclassIndicates that this transaction should be retried.classThis operation (such as a replace, get or insert) either failed or ambiguously succeeded.static enumMethods in com.couchbase.client.core.error.transaction with annotations of type Stability.InternalModifier and TypeMethodDescriptionbooleanTransactionOperationFailedException.autoRollbackAttempt()booleanTransactionOperationFailedException.retryTransaction()TransactionOperationFailedException.toRaise() -
Uses of Stability.Internal in com.couchbase.client.core.error.transaction.internal
Classes in com.couchbase.client.core.error.transaction.internal with annotations of type Stability.InternalModifier and TypeClassDescriptionclassThe transaction expired at the point of trying to commit it.classThe transaction could not be fully completed in the configured timeout.classThe transaction failed to reach the Committed point.classclassIndicates that committing the ATR entry should be retried.classIndicates that this operation should be retried.classUsed only in testing: injects an error that will be handled as FAIL_AMBIGUOUS.classUsed only in testing: injects an error that will be handled as FAIL_HARD.classUsed only in testing: injects an error that will be handled as FAIL_OTHER.classUsed only in testing: injects a FAIL_TRANSIENT error.classinterfaceTransactionOperationFailedException is raised as an opaque signal that something went wrong with a transaction operation. -
Uses of Stability.Internal in com.couchbase.client.core.io
Classes in com.couchbase.client.core.io with annotations of type Stability.InternalModifier and TypeClassDescriptionclassTheCollectionIdentifieruniquely identifies the position of a collection. -
Uses of Stability.Internal in com.couchbase.client.core.io.netty
Classes in com.couchbase.client.core.io.netty with annotations of type Stability.InternalModifier and TypeClassDescriptionclassThis factory createsSslHandlerbased on a given configuration.classContains various utils to set attributes for tracing spans.Methods in com.couchbase.client.core.io.netty with annotations of type Stability.InternalModifier and TypeMethodDescriptionSslHandlerFactory.defaultCiphers(boolean nativeTlsEnabled) Lists the default ciphers used for this platform.static booleanSslHandlerFactory.opensslAvailable()True if the native ssl transport is available, false otherwise. -
Uses of Stability.Internal in com.couchbase.client.core.io.netty.kv
Classes in com.couchbase.client.core.io.netty.kv with annotations of type Stability.InternalModifier and TypeClassDescriptionclassThis handler tries to load the KV Error Map in a best effort manner.classTheFeatureNegotiatingHandleris responsible for sending the KV "hello" command and to handshake enabled features on both sides.classTheSaslListMechanismsHandlerasks the server KV engine which SASL mechanism it supports.classTheSelectBucketHandleris responsible for, selecting the right bucket on this KV connection.enumDescribes all the different negotiation modes between the server and the SDK.Methods in com.couchbase.client.core.io.netty.kv with annotations of type Stability.InternalModifier and TypeMethodDescriptionSaslAuthenticationHandler.allowedMechanisms()Returns the allowed mechanisms for this handler, useful for testing assertions.Constructors in com.couchbase.client.core.io.netty.kv with annotations of type Stability.InternalModifierConstructorDescriptionKeyValueChannelContext(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
Classes in com.couchbase.client.core.json with annotations of type Stability.InternalModifier and TypeClassDescriptionclassProvides utilities for encoding and decoding JSON data. -
Uses of Stability.Internal in com.couchbase.client.core.kv
Classes in com.couchbase.client.core.kv with annotations of type Stability.InternalModifier and TypeInterfaceDescriptioninterfacePerforms a KV range scan to scan between twoCoreScanTerms.interfacePerforms a KV range scan using random sampling.interfaceAllows to customize the various range and sampling scan options.classA singleCoreScanTermidentifying either the point to scan from or to scan to.interfaceEither RangeScan or SampleScanclassMain entry point from higher level languages to perform KV range scans. -
Uses of Stability.Internal in com.couchbase.client.core.manager
Classes in com.couchbase.client.core.manager with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassDeprecated.interfaceinterfaceclassclassEncapsulates common functionality around the eventing management APIs.classenumclass -
Uses of Stability.Internal in com.couchbase.client.core.manager.bucket
Classes in com.couchbase.client.core.manager.bucket with annotations of type Stability.InternalModifier and TypeInterfaceDescriptioninterfaceenumenuminterfaceenumclassMethods in com.couchbase.client.core.manager.bucket with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.manager.collection
Classes in com.couchbase.client.core.manager.collection with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.msg
Classes in com.couchbase.client.core.msg with annotations of type Stability.InternalMethods in com.couchbase.client.core.msg with annotations of type Stability.InternalModifier 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. observe polling).RequestContext.serverLatency(long serverLatency) Constructors in com.couchbase.client.core.msg with annotations of type Stability.InternalModifierConstructorDescriptionRequestContext(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
Classes in com.couchbase.client.core.msg.kv with annotations of type Stability.InternalModifier and TypeClassDescriptionfinal classRepresents the response of aGetRequest.classHelper class that language-specific clients may use to implementMutationState.classclassclassMethods in com.couchbase.client.core.msg.kv with annotations of type Stability.InternalModifier and TypeMethodDescriptionbyteDurabilityLevel.code()static List<CoreSubdocGetCommand> SubdocGetRequest.convertCommandsToCore(List<SubdocGetRequest.Command> commands) static DurabilityLevelDurabilityLevel.decodeFromManagementApi(String input) Decodes the string representation of the durability level from the management API into an enum.DurabilityLevel.encodeForManagementApi()Encodes theDurabilityLevelso that the management API understands it.SubdocGetResponse.toCore(CoreKeyspace keyspace, String key) -
Uses of Stability.Internal in com.couchbase.client.core.msg.manager
Methods in com.couchbase.client.core.msg.manager with annotations of type Stability.InternalModifier and TypeMethodDescriptionvoidBucketConfigStreamingResponse.completeStream()voidBucketConfigStreamingResponse.failStream(Throwable e) voidBucketConfigStreamingResponse.pushConfig(String config) -
Uses of Stability.Internal in com.couchbase.client.core.msg.query
Classes in com.couchbase.client.core.msg.query with annotations of type Stability.InternalMethods in com.couchbase.client.core.msg.query with annotations of type Stability.InternalModifier 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
Classes in com.couchbase.client.core.node with annotations of type Stability.InternalModifier and TypeInterfaceDescriptioninterfaceThis interface defines different hashing strategies used for ketama hashing in memcached buckets.Methods in com.couchbase.client.core.node with annotations of type Stability.InternalModifier and TypeMethodDescriptionNodeIdentifier.asTopologyNodeIdentifier()Deprecated.Node.internalDiagnostics() -
Uses of Stability.Internal in com.couchbase.client.core.protostellar
Classes in com.couchbase.client.core.protostellar with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassinterfaceclassProtostellarCollectionManagerRequest<TGrpcRequest>final classclassProtostellarKeyValueRequest<TGrpcRequest>classProtostellarRequest<TGrpcRequest>Holds onto a GRPC request, along with pertaining mutable and immutable state bound to the request's lifetime.classConstructors in com.couchbase.client.core.protostellar with annotations of type Stability.InternalModifierConstructorDescriptionProtostellarBaseRequest(CoreProtostellar core, ProtostellarRequest<?> request) -
Uses of Stability.Internal in com.couchbase.client.core.protostellar.kv
Classes in com.couchbase.client.core.protostellar.kv with annotations of type Stability.InternalModifier and TypeClassDescriptionclassFor creating Protostellar GRPC KV requests.classFor converting Protostellar GRPC KV responses.classclassFor converting Protostellar GRPC KV responses.classclassfinal class -
Uses of Stability.Internal in com.couchbase.client.core.protostellar.manager
Classes in com.couchbase.client.core.protostellar.manager with annotations of type Stability.InternalModifier and TypeClassDescriptionclassFor creating Protostellar GRPC requests.classFor converting Protostellar GRPC responses.classclassfinal class -
Uses of Stability.Internal in com.couchbase.client.core.protostellar.query
Classes in com.couchbase.client.core.protostellar.query with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassclassclass -
Uses of Stability.Internal in com.couchbase.client.core.protostellar.search
Classes in com.couchbase.client.core.protostellar.search with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.retry
Classes in com.couchbase.client.core.retry with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassAn internal strategy to fail fast any request that goes through it.classDetermines what to do with a request.classTheRetryOrchestratoris responsible for checking if a request is eligible for retry and if so dispatch it properly and update state.classMethods in com.couchbase.client.core.retry with annotations of type Stability.InternalModifier and TypeMethodDescriptionstatic DurationRetryOrchestrator.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 DurationRetryOrchestratorProtostellar.capDuration(Duration uncappedDuration, ProtostellarRequest<?> request) static DurationRetryOrchestrator.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
Methods in com.couchbase.client.core.service with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.service.kv
Classes in com.couchbase.client.core.service.kv with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.topology
Classes in com.couchbase.client.core.topology with annotations of type Stability.InternalModifier and TypeClassDescriptionenuminterfaceenumclassclassfinal classFor building synthetic topologies in unit tests.classstatic classclassA cluster topology that also has topology info for one bucket.classclassUsed for locating the services running on a node.final classKetamaRing<E>A Ketama ring (or "continuum", if you prefer) with Couchbase-specific parameters defined by Couchbase SDK RFC 26 (Ketama Hashing)interfaceclassinterfaceHelps the config parser select the correct alternate addresses.classclassA map from partition index to info about the partition.classKnows which nodes host the active and replicas for one partition.enumHelps the config parser select only the service ports relevant to the client's transport security mode (TLS or non-TLS).classclassclassMethods in com.couchbase.client.core.topology with annotations of type Stability.InternalModifier and TypeMethodDescriptionMemcachedBucketTopology.hashingStrategy()BucketTopology.nodes()Returns the subset of cluster nodes that are ready to service requests for this bucket.static @Nullable BucketTopologyBucketTopology.parse(com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode json, List<HostAndServicePorts> nodes, MemcachedHashingStrategy memcachedHashingStrategy) HostAndServicePorts.withKetamaAuthority(@Nullable HostAndPort ketamaAuthority) HostAndServicePorts.without(ServiceType service, ServiceType... moreServices) -
Uses of Stability.Internal in com.couchbase.client.core.transaction
Classes in com.couchbase.client.core.transaction with annotations of type Stability.InternalModifier and TypeClassDescriptionclassclassProvides methods to allow an application's transaction logic to read, mutate, insert and delete documents, as well as commit or rollback the transaction.classStores some context related to a transaction.classWraps a CoreTransactionGetResult with the CoreTransactionGetMultiSpec it's for, to make it easier to sort the results just once at the end.classRepresents a value fetched from Couchbase, along with additional transactional metadata.classWraps a CoreTransactionGetResult with the CoreTransactionGetMultiSpec it's for, to make it easier to sort the results just once at the end.classclassMethods in com.couchbase.client.core.transaction with annotations of type Stability.InternalModifier and TypeMethodDescriptionstatic CoreTransactionGetResultCoreTransactionGetResult.createFrom(CollectionIdentifier collection, String documentId, CoreSubdocGetResult doc) static CoreTransactionGetResultCoreTransactionGetResult.createFrom(CoreTransactionGetResult doc, byte[] content) Constructors in com.couchbase.client.core.transaction with annotations of type Stability.InternalModifierConstructorDescriptionCoreTransactionGetResult(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
Classes in com.couchbase.client.core.transaction.atr with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.transaction.cleanup
Classes in com.couchbase.client.core.transaction.cleanup with annotations of type Stability.InternalModifier and TypeClassDescriptionclassSimple data class, so all fields are public.classUsed for testing/mocking.classclassUsed for testing/mocking.classclassRepresents the ClientRecord doc, a single document that contains an entry for every client (app) current participating in the cleanup of 'lost' transactions.classUtility class to store the result of a client checking/updating the Client Record doc.classUsed for testing/mocking.classUsed for testing/mocking.classOwns cleanup threads.classRuns the algorithm to find 'lost' transactions, distributing the work between clients.classHandles cleaning up expired/lost transactions. -
Uses of Stability.Internal in com.couchbase.client.core.transaction.components
Classes in com.couchbase.client.core.transaction.components with annotations of type Stability.InternalModifier and TypeClassDescriptionclassstatic classclassclassclassenumMetadata related to the CAS.classclassclassResponsible for doing transaction-aware get()s.classStores some $document metadata from when the document is fetchedclassclassclassStores the transaction links stored on each document in a transactionMethods in com.couchbase.client.core.transaction.components with annotations of type Stability.InternalModifier and TypeMethodDescriptionOptional<byte[]> TransactionLinks.stagedContentBinary()Optional<byte[]> TransactionLinks.stagedContentJson()Optional<byte[]> TransactionLinks.stagedContentJsonOrBinary() -
Uses of Stability.Internal in com.couchbase.client.core.transaction.config
Classes in com.couchbase.client.core.transaction.config with annotations of type Stability.InternalModifier and TypeClassDescriptionclassMergesCoreTransactionOptionsandCoreTransactionsConfig.classclassTunables for an individual transaction.classclassMethods in com.couchbase.client.core.transaction.config with annotations of type Stability.InternalModifier and TypeMethodDescriptionCoreTransactionsCleanupConfig.createDefault()static CoreTransactionsConfigCoreTransactionsConfig.createDefault(CoreTransactionsSupportedExtensions supported) -
Uses of Stability.Internal in com.couchbase.client.core.transaction.context
Classes in com.couchbase.client.core.transaction.context with annotations of type Stability.InternalModifier and TypeClassDescriptionclassHolds transactions state that has the same lifetime as a Core.class -
Uses of Stability.Internal in com.couchbase.client.core.transaction.error.internal
Classes in com.couchbase.client.core.transaction.error.internal with annotations of type Stability.Internal -
Uses of Stability.Internal in com.couchbase.client.core.transaction.forwards
Classes in com.couchbase.client.core.transaction.forwards with annotations of type Stability.InternalModifier and TypeClassDescriptionenumAll known protocol extensions.classDefines what is support by this implementation (extensions and protocol version).classA 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.enumPoints in the protocol where forward compatibility can be checked. -
Uses of Stability.Internal in com.couchbase.client.core.transaction.getmulti
Classes in com.couchbase.client.core.transaction.getmulti with annotations of type Stability.InternalModifier and TypeClassDescriptionclassenumenumclassclassclassenum -
Uses of Stability.Internal in com.couchbase.client.core.transaction.log
Classes in com.couchbase.client.core.transaction.log with annotations of type Stability.InternalModifier and TypeClassDescriptionclassA logger optimized for logging transactions-specific info. -
Uses of Stability.Internal in com.couchbase.client.core.transaction.support
Classes in com.couchbase.client.core.transaction.support with annotations of type Stability.InternalModifier and TypeClassDescriptionenumThe possible states for a transaction attempt.classclassWraps a RequestSpan, with the value-add that it automatically records how long the operation took for transaction logging.classclassenumclassclass -
Uses of Stability.Internal in com.couchbase.client.core.transaction.threadlocal
Classes in com.couchbase.client.core.transaction.threadlocal with annotations of type Stability.InternalModifier and TypeClassDescriptionclassUsed to indicate that we are inside a transaction, and placed in ThreadLocalStorage (or reactive context).classUsed to manage ThreadLocalStorage (or reactive context) of TransactionMarker. -
Uses of Stability.Internal in com.couchbase.client.core.transaction.util
Classes in com.couchbase.client.core.transaction.util with annotations of type Stability.InternalModifier and TypeClassDescriptionclassCan be used for testing transactions, but is for internal use only.classMainly to aid debugging, transactions use their own pool of schedulers.classclassclassclassclassTracks read and write units used.static classclassMonoBridge<T>Protects against concurrent op cancellation.classclassA mutex pessimistic lock, compatible with reactive.classProvides locking functionality in line with Go's WaitGroups, in a reactive compatible way.classCan be used for testing transactions, but is for internal use only.classTransactions does a lot of KV work from core-io.interfaceTriFunction<T,U, V, R> -
Uses of Stability.Internal in com.couchbase.client.core.util
Classes in com.couchbase.client.core.util with annotations of type Stability.InternalModifier and TypeClassDescriptionclassAtomicEnumSet<E extends Enum<E>>A thread-safe cousin ofEnumSetthat performs well in use cases dominated by reads.classclassclassclassfinal classclassclassclassclassclassstatic enumclassContains various helper methods when dealing with the connection string.classHelper routines for tests to wait for all nodes to have a consistent view of a resource.classclassfinal classIntegrates the Couchbase infrastructure withBlockHound.classclassThe default implementation for performing DNS SRV lookups.classclassEither<L,R> classEnumLookupTable<E extends Enum<E>>Provides efficient lookup for enums whose values are associated with small integers.interfaceIntMap<E>A read-only map where the keys are non-negative integers.classApproximates Java 9's java.lang.ref.CleanerclassUseful when only the latest value of a Flux is interesting, and processing values is relatively expensive.classclassclassA convenient wrapper class around network primitives in Java.@interfaceIndicates that at least one purpose of the annotated field is to prevent the value from being garbage collected.classinterfaceclassMethods in com.couchbase.client.core.util with annotations of type Stability.InternalModifier and TypeMethodDescriptionstatic NetworkAddressCreates a newNetworkAddressfrom either a hostname or ip address literal.ConnectionStringUtil.fromDnsSrvOrThrowIfTlsRequired(String serviceName, boolean secure) NetworkAddress.hostname()Returns the hostname for this network address.static <T> TReactorOps.proxyToPublishOnSuppliedScheduler(T obj, Class<T> interfaceToProxy, @Nullable Supplier<reactor.core.scheduler.Scheduler> scheduler) Returns a dynamic proxy for the given object (unless the given supplier is null, in which case the same object is returned).StorageSize.requireInt()ConnectionString.withParams(Map<String, String> params) ConnectionString.withScheme(ConnectionString.Scheme scheme)