Uses of Class
com.couchbase.client.core.annotation.Stability.Internal
-
-
Uses of Stability.Internal in com.couchbase.client.core
Classes in com.couchbase.client.core with annotations of type Stability.Internal Modifier and Type Class Description class
Timer
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.Methods in com.couchbase.client.core with annotations of type Stability.Internal Modifier and Type Method Description CoreContext
CoreContext. alternateAddress(Optional<String> alternateAddress)
Sets the alternate address on this context.ClusterConfig
Core. clusterConfig()
This API provides access to the current config that is published throughout the core.ConfigurationProvider
Core. configurationProvider()
Returns the attached configuration provider.Stream<EndpointDiagnostics>
Core. diagnostics()
Mono<Void>
Core. ensureServiceAt(NodeIdentifier identifier, ServiceType serviceType, int port, Optional<String> bucket, Optional<String> alternateAddress)
This method can be used by a caller to make sure a certain service is enabled at the given target node.CoreHttpClient
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.void
Core. openBucket(String name)
Attempts to open a bucket and fails theMono
if there is a persistent error as the reason.ValueRecorder
Core. responseMetric(Request<?> request)
<R extends Response>
voidCore. send(Request<R> request, boolean registerForTimeout)
Sends a command into the core layer and allows to avoid timeout registration.Optional<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.Mono<Void>
Core. shutdown()
Mono<Void>
Core. shutdown(Duration timeout)
Shuts down this core and all associated, owned resources. -
Uses of Stability.Internal in com.couchbase.client.core.callbacks
Classes in com.couchbase.client.core.callbacks with annotations of type Stability.Internal Modifier and Type Interface Description interface
BeforeSendRequestCallback
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.cnc
Classes in com.couchbase.client.core.cnc with annotations of type Stability.Internal Modifier and Type Class Description class
CbTracing
static interface
LoggingEventConsumer.Logger
Generic logger interface.class
OrphanReporter
class
SimpleEventBus
This super simple event bus should be used in testing only to assert certain events got pushed through.class
TracingIdentifiers
Holds static tracing identifiers throughout the SDK.Methods in com.couchbase.client.core.cnc with annotations of type Stability.Internal Modifier and Type Method Description void
RequestSpan. 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.Internal Constructor Description OrphanReporter(EventBus eventBus, OrphanReporterConfig config)
Creates a newOrphanReporter
. -
Uses of Stability.Internal in com.couchbase.client.core.cnc.metrics
Classes in com.couchbase.client.core.cnc.metrics with annotations of type Stability.Internal Modifier and Type Class Description class
NameAndTags
Helper class which consolidates names and tags for caching purposes. -
Uses of Stability.Internal in com.couchbase.client.core.config
Classes in com.couchbase.client.core.config with annotations of type Stability.Internal Modifier and Type Interface Description interface
ConfigurationProvider
TheConfigurationProvider
is responsible for grabbing, converting and managing bucket and cluster configurations.Methods in com.couchbase.client.core.config with annotations of type Stability.Internal Modifier and Type Method Description void
ClusterConfig. deleteBucketConfig(String bucketName)
void
ClusterConfig. deleteGlobalConfig()
void
ClusterConfig. setBucketConfig(BucketConfig config)
void
ClusterConfig. setGlobalConfig(GlobalConfig config)
-
Uses of Stability.Internal in com.couchbase.client.core.config.refresher
Classes in com.couchbase.client.core.config.refresher with annotations of type Stability.Internal Modifier and Type Class Description class
KeyValueBucketRefresher
TheKeyValueBucketRefresher
keeps 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.Internal Modifier and Type Class Description class
HealthPinger
TheHealthPinger
allows to "ping" individual services with real operations for their health.class
WaitUntilReadyHelper
Helper class to perform the "wait until ready" logic.static class
WaitUntilReadyHelper.WaitUntilReadyState
Encapsulates the state of where a wait until ready flow is in.Methods in com.couchbase.client.core.diagnostics with annotations of type Stability.Internal Modifier and Type Method Description static Mono<PingResult>
HealthPinger. ping(Core core, Optional<Duration> timeout, RetryStrategy retryStrategy, Set<ServiceType> serviceTypes, Optional<String> reportId, Optional<String> bucketName)
Performs a service ping against all or (if given) the services provided.static CompletableFuture<Void>
WaitUntilReadyHelper. waitUntilReady(Core core, Set<ServiceType> serviceTypes, Duration timeout, ClusterState desiredState, Optional<String> bucketName)
Constructors in com.couchbase.client.core.diagnostics with annotations of type Stability.Internal Constructor Description DiagnosticsResult(Map<ServiceType,List<EndpointDiagnostics>> endpoints, String sdk, String id)
Creates the new diagnostics report.EndpointDiagnostics(ServiceType type, EndpointState state, String local, String remote, Optional<String> namespace, Optional<Long> lastActivityUs, Optional<String> id)
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
Methods in com.couchbase.client.core.endpoint with annotations of type Stability.Internal Modifier and Type Method Description void
BaseEndpoint. decrementOutstandingRequests()
Helper method to decrement outstanding requests, even if they haven't finished yet.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. -
Uses of Stability.Internal in com.couchbase.client.core.endpoint.http
Classes in com.couchbase.client.core.endpoint.http with annotations of type Stability.Internal Modifier and Type Interface Description interface
CoreCommonOptions
class
CoreHttpClient
class
CoreHttpPath
The "path" component of a URI, with support for path parameters whose replacement values are automatically url-encoded.class
CoreHttpRequest
static class
CoreHttpRequest.Builder
Builder for dynamic HTTP requestsclass
CoreHttpResponse
-
Uses of Stability.Internal in com.couchbase.client.core.env
Classes in com.couchbase.client.core.env with annotations of type Stability.Internal Modifier and Type Class Description static class
LoggerConfig.Defaults
static class
LoggingMeterConfig.Defaults
static class
OrphanReporterConfig.Defaults
class
OwnedSupplier<T>
A special supplier which allows the SDK to distinguish passed in suppliers vs.interface
RequestCallback
Marker interface for different callbacks in the request lifecycle.static class
SecurityConfig.Defaults
static class
ThresholdLoggingTracerConfig.Defaults
static class
ThresholdRequestTracerConfig.Defaults
Deprecated.Fields in com.couchbase.client.core.env with annotations of type Stability.Internal Modifier and Type Field Description static int
IoEnvironment. DEFAULT_EVENT_LOOP_THREAD_COUNT
Methods in com.couchbase.client.core.env with annotations of type Stability.Internal Modifier and Type Method Description SELF
CoreEnvironment.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
IoEnvironment.Builder. build()
LoggerConfig.Builder
LoggerConfig.Builder. customLogger(LoggingEventConsumer.Logger customLogger)
Allows to specify a custom logger.LoggingEventConsumer.Logger
LoggerConfig. customLogger()
Returns a custom logger if configured for testing.static LoggerConfig.Builder
LoggerConfig. customLogger(LoggingEventConsumer.Logger customLogger)
Allows to specify a custom logger.static ThresholdRequestTracerConfig.Builder
ThresholdRequestTracerConfig.Builder. fromNewBuilder(ThresholdLoggingTracerConfig.Builder newBuilder)
Deprecated.List<RequestCallback>
CoreEnvironment. requestCallbacks()
default boolean
Authenticator. supportsNonTls()
If this authenticator supports non-encrypted connections.default boolean
Authenticator. supportsTls()
If this authenticator supports encrypted connections.ThresholdLoggingTracerConfig.Builder
ThresholdRequestTracerConfig.Builder. toNewBuillder()
Deprecated.Converts this deprecated builder into its non-deprecated version.Constructors in com.couchbase.client.core.env with annotations of type Stability.Internal Constructor Description OwnedSupplier(T value)
-
Uses of Stability.Internal in com.couchbase.client.core.error
Classes in com.couchbase.client.core.error with annotations of type Stability.Internal Modifier and Type Class Description class
BucketNotFoundDuringLoadException
Exception raised if during config load the bucket is not found (think: http 404).class
BucketNotReadyDuringLoadException
Exception raised if during config load the bucket is found, but not deemed ready yet.class
DefaultErrorUtil
class
HttpStatusCodeException
class
IndexesNotReadyException
class
UnsupportedConfigMechanismException
Methods in com.couchbase.client.core.error with annotations of type Stability.Internal Modifier and Type Method Description byte[]
AnalyticsException. content()
static List<ErrorCodeAndMessage>
ErrorCodeAndMessage. from(byte[] content)
static List<ErrorCodeAndMessage>
ErrorCodeAndMessage. fromJsonArray(byte[] jsonArray)
boolean
PreparedStatementFailureException. retryable()
-
Uses of Stability.Internal in com.couchbase.client.core.error.subdoc
Classes in com.couchbase.client.core.error.subdoc with annotations of type Stability.Internal Modifier and Type Class Description class
DocumentAlreadyAliveException
Sub-Document exception thrown when ReviveDocument has been used with a document that already exists -
Uses of Stability.Internal in com.couchbase.client.core.io.netty
Classes in com.couchbase.client.core.io.netty with annotations of type Stability.Internal Modifier and Type Class Description class
SslHandlerFactory
This factory createsSslHandler
based on a given configuration.class
TracingUtils
Contains various utils to set attributes for tracing spans.Methods in com.couchbase.client.core.io.netty with annotations of type Stability.Internal Modifier and Type Method Description static List<String>
SslHandlerFactory. 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
Classes in com.couchbase.client.core.io.netty.kv with annotations of type Stability.Internal Modifier and Type Class Description class
ErrorMapLoadingHandler
This handler tries to load the KV Error Map in a best effort manner.class
FeatureNegotiatingHandler
TheFeatureNegotiatingHandler
is responsible for sending the KV "hello" command and to handshake enabled features on both sides.class
SaslListMechanismsHandler
TheSaslListMechanismsHandler
asks the server KV engine which SASL mechanism it supports.class
SelectBucketHandler
TheSelectBucketHandler
is responsible for, selecting the right bucket on this KV connection.class
ServerFeature
TheServerFeature
enum describes 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.Internal Modifier and Type Method Description Set<SaslMechanism>
SaslAuthenticationHandler. allowedMechanisms()
Returns the allowed mechanisms for this handler, useful for testing assertions. -
Uses of Stability.Internal in com.couchbase.client.core.json
Classes in com.couchbase.client.core.json with annotations of type Stability.Internal Modifier and Type Class Description class
Mapper
Provides utilities for encoding and decoding JSON data. -
Uses of Stability.Internal in com.couchbase.client.core.manager
Classes in com.couchbase.client.core.manager with annotations of type Stability.Internal Modifier and Type Class Description class
CoreAnalyticsLinkManager
class
CoreBucketManager
class
CoreCollectionManager
class
CoreEventingFunctionManager
Encapsulates common functionality around the eventing management APIs.class
CoreViewIndexManager
-
Uses of Stability.Internal in com.couchbase.client.core.msg
Classes in com.couchbase.client.core.msg with annotations of type Stability.Internal Modifier and Type Class Description class
RequestTarget
Methods in com.couchbase.client.core.msg with annotations of type Stability.Internal Modifier and Type Method Description RequestContext
RequestContext. clientContext(Map<String,Object> clientContext)
Allows to set a custom payload for this request.RequestContext
RequestContext. dispatchLatency(long dispatchLatency)
Allows to set the dispatch duration of the request.RequestContext
RequestContext. encodeLatency(long encodeLatency)
RequestContext
RequestContext. incrementRetryAttempts(Duration lastRetryDuration, RetryReason reason)
RequestContext
RequestContext. lastChannelId(String lastChannelId)
RequestContext
RequestContext. lastDispatchedFrom(HostAndPort lastDispatchedFrom)
RequestContext
RequestContext. lastDispatchedTo(HostAndPort lastDispatchedTo)
NodeIdentifier
RequestContext. lastDispatchedToNode()
RequestContext
RequestContext. lastDispatchedToNode(NodeIdentifier lastDispatchedToNode)
RequestContext
RequestContext. logicallyComplete()
Signals that this request is completed fully, including streaming sections or logical sub-requests also being completed (i.e.RequestContext
RequestContext. serverLatency(long serverLatency)
Constructors in com.couchbase.client.core.msg with annotations of type Stability.Internal Constructor Description RequestContext(CoreContext ctx, Request<? extends Response> request)
Creates a newRequestContext
. -
Uses of Stability.Internal in com.couchbase.client.core.msg.kv
Classes in com.couchbase.client.core.msg.kv with annotations of type Stability.Internal Modifier and Type Class Description class
MutationTokenAggregator
Helper class that language-specific clients may use to implementMutationState
.class
SubDocumentField
Methods in com.couchbase.client.core.msg.kv with annotations of type Stability.Internal Modifier and Type Method Description byte
DurabilityLevel. code()
static DurabilityLevel
DurabilityLevel. decodeFromManagementApi(String input)
Decodes the string representation of the durability level from the management API into an enum.String
DurabilityLevel. encodeForManagementApi()
Encodes theDurabilityLevel
so that the management API understands it. -
Uses of Stability.Internal in com.couchbase.client.core.msg.manager
Methods in com.couchbase.client.core.msg.manager with annotations of type Stability.Internal Modifier and Type Method Description void
BucketConfigStreamingResponse. completeStream()
void
BucketConfigStreamingResponse. failStream(Throwable e)
void
BucketConfigStreamingResponse. 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.Internal Modifier and Type Class Description class
CoreQueryAccessor
class
EnhancedPreparedStatementStrategy
Server remembers query plan; client sends just the prepared statement name.class
LegacyPreparedStatementStrategy
Client remembers query plan and sends it on every request.class
PreparedStatement
Prepared statement cache entry.class
PreparedStatementStrategy
Methods in com.couchbase.client.core.msg.query with annotations of type Stability.Internal Modifier and Type Method Description QueryRequest
QueryRequest. toExecuteRequest(String preparedStatementName, String encodedPlan, RequestTracer requestTracer)
Returns a copy of this request tailored to execute a prepared statement.QueryRequest
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.Internal Modifier and Type Interface Description interface
MemcachedHashingStrategy
This interface defines different hashing strategies used for ketama hashing in memcached buckets. -
Uses of Stability.Internal in com.couchbase.client.core.retry
Classes in com.couchbase.client.core.retry with annotations of type Stability.Internal Modifier and Type Class Description class
FailFastRetryStrategy
An internal strategy to fail fast any request that goes through it.class
RetryOrchestrator
TheRetryOrchestrator
is responsible for checking if a request is eligible for retry and if so dispatch it properly and update state.Methods in com.couchbase.client.core.retry with annotations of type Stability.Internal Modifier and Type Method Description static 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. -
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 Modifier and Type Class Description class
ReplicaHelper
-
Uses of Stability.Internal in com.couchbase.client.core.util
Classes in com.couchbase.client.core.util with annotations of type Stability.Internal Modifier and Type Class Description class
BucketConfigUtil
Defines helpful routines for working with bucket configs.class
CbAnnotations
class
CbCollections
class
CbObjects
class
CbStrings
class
CbThrowables
static class
ConnectionString.PortType
class
ConnectionStringUtil
Contains various helper methods when dealing with the connection string.class
CouchbaseBlockHoundIntegration
Integrates the Couchbase infrastructure withBlockHound
.class
DnsSrv
class
EnumLookupTable<E extends Enum<E>>
Provides efficient lookup for enums whose values are associated with small integers.class
NetworkAddress
A convenient wrapper class around network primitives in Java.class
UrlQueryStringBuilder
Methods in com.couchbase.client.core.util with annotations of type Stability.Internal Modifier and Type Method Description static NetworkAddress
NetworkAddress. create(String input)
Creates a newNetworkAddress
from either a hostname or ip address literal.String
NetworkAddress. hostname()
Returns the hostname for this network address.
-