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 classTimerTheTimeracts 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 CoreContextCoreContext. alternateAddress(Optional<String> alternateAddress)Sets the alternate address on this context.ClusterConfigCore. clusterConfig()This API provides access to the current config that is published throughout the core.ConfigurationProviderCore. 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.voidCore. initGlobalConfig()Instructs the client to, if possible, load and initialize the global config.voidCore. openBucket(String name)Attempts to open a bucket and fails theMonoif there is a persistent error as the reason.<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.cnc
Classes in com.couchbase.client.core.cnc with annotations of type Stability.Internal Modifier and Type Interface Description interfaceInternalSpanTheInternalSpantracks the nitty gritty details of the request/response cycle inside the SDK.static interfaceLoggingEventConsumer.LoggerGeneric logger interface.classOrphanReporterclassSimpleEventBusThis super simple event bus should be used in testing only to assert certain events got pushed through. -
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 interfaceConfigurationProviderTheConfigurationProvideris 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 voidClusterConfig. deleteBucketConfig(String bucketName)voidClusterConfig. deleteGlobalConfig()voidClusterConfig. setBucketConfig(BucketConfig config)voidClusterConfig. 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 classKeyValueBucketRefresherTheKeyValueBucketRefresherkeeps 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 classHealthPingerTheHealthPingerallows to "ping" individual services with real operations for their health.static classHealthPinger.PingTargetclassWaitUntilReadyHelperHelper class to perform the "wait until ready" logic.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 voidBaseEndpoint. decrementOutstandingRequests()Helper method to decrement outstanding requests, even if they haven't finished yet.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. -
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 classOwnedSupplier<T>A special supplier which allows the SDK to distinguish passed in suppliers vs.Methods in com.couchbase.client.core.env with annotations of type Stability.Internal Modifier and Type Method Description 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.IoEnvironmentIoEnvironment.Builder. build()LoggerConfig.BuilderLoggerConfig.Builder. customLogger(LoggingEventConsumer.Logger customLogger)Allows to specify a custom logger.default booleanAuthenticator. supportsNonTls()If this authenticator supports non-encrypted connections.default booleanAuthenticator. supportsTls()If this authenticator supports encrypted connections.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 classDefaultErrorUtilclassHttpStatusCodeExceptionclassIndexesNotReadyExceptionclassUnsupportedConfigMechanismExceptionMethods in com.couchbase.client.core.error with annotations of type Stability.Internal Modifier and Type Method Description byte[]AnalyticsException. content()static List<ErrorCodeAndMessage>ErrorCodeAndMessage. fromJsonArray(byte[] jsonArray)booleanPreparedStatementFailureException. retryable() -
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 classErrorMapLoadingHandlerThis handler tries to load the KV Error Map in a best effort manner.classFeatureNegotiatingHandlerTheFeatureNegotiatingHandleris responsible for sending the KV "hello" command and to handshake enabled features on both sides.classSaslListMechanismsHandlerTheSaslListMechanismsHandlerasks the server KV engine which SASL mechanism it supports.classSelectBucketHandlerTheSelectBucketHandleris responsible for, selecting the right bucket on this KV connection.classServerFeatureTheServerFeatureenum describes all the different negotiation modes between the server and the SDK. -
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 classMapperProvides utilities for encoding and decoding JSON data. -
Uses of Stability.Internal in com.couchbase.client.core.msg
Methods in com.couchbase.client.core.msg with annotations of type Stability.Internal Modifier and Type Method Description RequestContextRequestContext. clientContext(Map<String,Object> clientContext)Allows to set a custom payload for this request.RequestContextRequestContext. dispatchLatency(long dispatchLatency)Allows to set the dispatch duration of the request.RequestContextRequestContext. encodeLatency(long encodeLatency)RequestContextRequestContext. incrementRetryAttempts(Duration lastRetryDuration, RetryReason reason)RequestContextRequestContext. lastChannelId(String lastChannelId)RequestContextRequestContext. lastDispatchedFrom(HostAndPort lastDispatchedFrom)RequestContextRequestContext. lastDispatchedTo(HostAndPort lastDispatchedTo)RequestContextRequestContext. logicallyComplete()Signals that this request is completed fully, including streaming sections or logical sub-requests also being completed (i.e.RequestContextRequestContext. 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 classSubDocumentFieldMethods in com.couchbase.client.core.msg.kv with annotations of type Stability.Internal Modifier and Type Method Description byteDurabilityLevel. code() -
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 voidBucketConfigStreamingResponse. completeStream()voidBucketConfigStreamingResponse. failStream(Throwable e)voidBucketConfigStreamingResponse. pushConfig(String config) -
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 classFailFastRetryStrategyAn internal strategy to fail fast any request that goes through it.classRetryOrchestratorTheRetryOrchestratoris 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 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. -
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 classBucketConfigUtilDefines helpful routines for working with bucket configs.classCbAnnotationsclassCbCollectionsclassCbObjectsclassCbStringsclassCbThrowablesstatic classConnectionString.PortTypeclassConnectionStringUtilContains various helper methods when dealing with the connection string.classDnsSrvclassUrlQueryStringBuilder
-