Uses of Class
com.couchbase.client.core.CoreContext
Package
Description
-
Uses of CoreContext in com.couchbase.client.core
Modifier and TypeMethodDescriptionCoreContext.alternateAddress
(Optional<String> alternateAddress) Deprecated.This method does not do anything.Core.context()
Returns theCoreContext
of this core instance. -
Uses of CoreContext in com.couchbase.client.core.cnc
Modifier and TypeMethodDescriptionstatic RequestSpan
CbTracing.newSpan
(CoreContext coreContext, String spanName, RequestSpan parent) Returns a new span with the `db.system` attribute set to `couchbase`. -
Uses of CoreContext in com.couchbase.client.core.cnc.events.config
ModifierConstructorDescriptionIndividualGlobalConfigLoadFailedEvent
(Duration duration, CoreContext context, Throwable cause, String host) IndividualGlobalConfigRefreshFailedEvent
(Duration duration, CoreContext context, Throwable cause, String host, CarrierGlobalConfigResponse response) -
Uses of CoreContext in com.couchbase.client.core.cnc.events.core
ModifierConstructorDescriptionCoreCreatedEvent
(CoreContext context, CoreEnvironment environment, Set<SeedNode> seedNodes, int numCoreInstances, ConnectionString connectionString) InitGlobalConfigFailedEvent
(Event.Severity severity, Duration duration, CoreContext context, InitGlobalConfigFailedEvent.Reason reason, Throwable cause) -
Uses of CoreContext in com.couchbase.client.core.cnc.events.node
ModifierConstructorDescriptionNodePartitionLengthNotEqualEvent
(CoreContext context, int actualSize, int configSize) -
Uses of CoreContext in com.couchbase.client.core.endpoint
ModifierConstructorDescriptionEndpointContext
(CoreContext ctx, HostAndPort remoteSocket, CircuitBreaker circuitBreaker, ServiceType serviceType, Optional<HostAndPort> localSocket, Optional<String> bucket, Optional<String> channelId) Creates a newEndpointContext
. -
Uses of CoreContext in com.couchbase.client.core.endpoint.http
Modifier and TypeMethodDescriptionstatic CoreHttpRequest.Builder
CoreHttpRequest.builder
(CoreCommonOptions options, CoreContext coreContext, com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpMethod method, CoreHttpPath path, RequestTarget target) ModifierConstructorDescriptionBuilder
(CoreCommonOptions options, CoreContext coreContext, RequestTarget target, com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpMethod method, CoreHttpPath path) -
Uses of CoreContext in com.couchbase.client.core.io
Modifier and TypeClassDescriptionclass
TheIoContext
is used to extend the core context with IO related metadata that is useful during event generation.ModifierConstructorDescriptionIoContext
(CoreContext ctx, SocketAddress localSocket, SocketAddress remoteSocket, Optional<String> bucket) Creates a new IO Context. -
Uses of CoreContext in com.couchbase.client.core.io.netty.manager
ModifierConstructorDescriptionManagerMessageHandler
(BaseEndpoint endpoint, CoreContext coreContext) -
Uses of CoreContext in com.couchbase.client.core.msg
Modifier and TypeClassDescriptionclass
Additional context which might be attached to an individualRequest
.ModifierConstructorDescriptionBaseRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy) BaseRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, RequestSpan requestSpan) Creates a basic request that has all the required properties to be executed in general.RequestContext
(CoreContext ctx, Request<? extends Response> request) -
Uses of CoreContext in com.couchbase.client.core.msg.analytics
ModifierConstructorDescriptionAnalyticsRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, byte[] query, int priority, boolean idempotent, String contextId, String statement, RequestSpan span, String bucket, String scope) AnalyticsRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, byte[] query, int priority, boolean idempotent, String contextId, String statement, RequestSpan span, String bucket, String scope, boolean translateExceptions, int apiVersion) -
Uses of CoreContext in com.couchbase.client.core.msg.kv
Modifier and TypeMethodDescriptionstatic ReplicaSubdocGetRequest
ReplicaSubdocGetRequest.create
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte flags, List<CoreSubdocGetCommand> commands, short replica, RequestSpan span) static SubdocGetRequest
SubdocGetRequest.create
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte flags, List<CoreSubdocGetCommand> commands, RequestSpan span) static RangeScanCreateRequest
RangeScanCreateRequest.forRangeScan
(byte[] startTerm, CoreRangeScan rangeScan, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier, Map<Short, MutationToken> consistencyMap) static RangeScanCreateRequest
RangeScanCreateRequest.forSamplingScan
(CoreSamplingScan samplingScan, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier, Map<Short, MutationToken> consistencyMap) ModifierConstructorDescriptionAppendRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte[] content, long cas, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) protected
BaseKeyValueRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier) protected
BaseKeyValueRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier, RequestSpan span) CarrierBucketConfigRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, NodeIdentifier target, ConfigVersion ifNewerThan) CarrierGlobalConfigRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, NodeIdentifier target, ConfigVersion ifNewerThan) DecrementRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long delta, Optional<Long> initial, long expiry, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) GetAndLockRequest
(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Duration lockFor, RequestSpan span) GetAndTouchRequest
(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, long expiration, RequestSpan span) GetCollectionIdRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier) GetCollectionManifestRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier) GetMetaRequest
(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, RequestSpan span) GetRequest
(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, RequestSpan span) IncrementRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long delta, Optional<Long> initial, long expiration, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) InsertRequest
(String key, byte[] content, long expiration, int flags, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) KvPingRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier identifier, NodeIdentifier target) MultiObserveViaCasRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier, NodeIdentifier target, Map<byte[], Short> keys, Predicate<ObserveViaCasResponse.ObserveStatus> responsePredicate) NoopRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier) ObserveViaCasRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, boolean active, int replica) ObserveViaSeqnoRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, int replica, boolean active, long vbucketUUID, String key, RequestSpan span) PredeterminedPartitionRequest
(short partition, Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier, RequestSpan span) PrependRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte[] content, long cas, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) RangeScanCancelRequest
(CoreRangeScanId id, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier) RangeScanContinueRequest
(CoreRangeScanId id, Sinks.Many<CoreRangeScanItem> sink, String key, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier) RemoveRequest
(String key, long cas, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) ReplaceRequest
(String key, byte[] content, long expiration, boolean preserveExpiry, int flags, Duration timeout, long cas, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) ReplicaGetRequest
(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, short replica, RequestSpan span) SubdocGetRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte flags, List<SubdocGetRequest.Command> commands, RequestSpan span) SubdocMutateRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, BucketConfig bucketConfig, RetryStrategy retryStrategy, String key, boolean insertDocument, boolean upsertDocument, boolean reviveDocument, boolean accessDeleted, boolean createAsDeleted, List<SubdocMutateRequest.Command> commands, long expiration, boolean preserveExpiry, long cas, int userFlags, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) Deprecated.Please use the other constructor instead.SubdocMutateRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, BucketConfig bucketConfig, RetryStrategy retryStrategy, String key, CoreStoreSemantics storeSemantics, boolean accessDeleted, boolean createAsDeleted, List<CoreSubdocMutateCommand> commands, long expiration, boolean preserveExpiry, long cas, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) TouchRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long expiry, RequestSpan span) UnlockRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long cas, RequestSpan span) UpsertRequest
(String key, byte[] content, long expiration, boolean preserveExpiry, int flags, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) -
Uses of CoreContext in com.couchbase.client.core.msg.manager
ModifierConstructorDescriptionBucketConfigRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String bucketName, Authenticator authenticator, NodeIdentifier target) BucketConfigStreamingRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String bucketName, Authenticator authenticator) GenericManagerRequest
(CoreContext ctx, Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier, boolean idempotent, RequestSpan span) Deprecated.GenericManagerRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier, boolean idempotent, RequestSpan span) Deprecated. -
Uses of CoreContext in com.couchbase.client.core.msg.query
ModifierConstructorDescriptionQueryRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String statement, byte[] query, boolean idempotent, String contextId, RequestSpan span, String bucket, String scope, NodeIdentifier target) -
Uses of CoreContext in com.couchbase.client.core.msg.search
ModifierConstructorDescriptionServerSearchRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String indexName, byte[] content, RequestSpan span, CoreBucketAndScope scope) -
Uses of CoreContext in com.couchbase.client.core.msg.view
ModifierConstructorDescriptionViewRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String bucket, String design, String view, String query, Optional<byte[]> keysJson, boolean development, RequestSpan span) -
Uses of CoreContext in com.couchbase.client.core.node
Modifier and TypeMethodDescriptionstatic Node
Node.create
(CoreContext ctx, NodeIdentifier identifier) void
KeyValueLocator.dispatch
(Request<? extends Response> request, List<Node> nodes, ClusterConfig config, CoreContext ctx) void
Locator.dispatch
(Request<? extends Response> request, List<Node> nodes, ClusterConfig config, CoreContext ctx) Given the environment and node information, the implementation locates the right set of nodes and dispatches the request into them.void
RoundRobinLocator.dispatch
(Request<? extends Response> request, List<Node> nodes, ClusterConfig config, CoreContext ctx) ModifierConstructorDescriptionprotected
Node
(CoreContext ctx, NodeIdentifier identifier) NodeContext
(CoreContext ctx, NodeIdentifier nodeIdentifier) -
Uses of CoreContext in com.couchbase.client.core.retry
Modifier and TypeMethodDescriptionstatic void
RetryOrchestrator.maybeRetry
(CoreContext ctx, Request<? extends Response> request, RetryReason reason) Retry or cancel the given request, depending on its state and the configuredRetryStrategy
. -
Uses of CoreContext in com.couchbase.client.core.service
ModifierConstructorDescriptionAnalyticsService
(AnalyticsServiceConfig config, CoreContext context, String hostname, int port) BackupService
(CoreContext coreContext, String hostname, int port) EventingService
(CoreContext coreContext, String hostname, int port) KeyValueService
(ServiceConfig serviceConfig, CoreContext coreContext, String hostname, int port, Optional<String> bucketName, Authenticator authenticator) ManagerService
(CoreContext coreContext, String hostname, int port) QueryService
(QueryServiceConfig config, CoreContext context, String hostname, int port) SearchService
(SearchServiceConfig config, CoreContext context, String hostname, int port) ServiceContext
(CoreContext ctx, String remoteHostname, int remotePort, ServiceType serviceType, Optional<String> bucket) ViewService
(ViewServiceConfig config, CoreContext context, String hostname, int port) -
Uses of CoreContext in com.couchbase.client.core.service.kv
ModifierConstructorDescriptionNodeIndexCalculator
(CoreReadPreference readPreference, CouchbaseBucketConfig topology, CoreContext coreContext) ObserveContext
(CoreContext ctx, Observe.ObservePersistTo persistTo, Observe.ObserveReplicateTo replicateTo, Optional<MutationToken> mutationToken, long cas, CollectionIdentifier collectionIdentifier, String key, boolean remove, Duration timeout, RequestSpan parentSpan) -
Uses of CoreContext in com.couchbase.client.core.transaction
ModifierConstructorDescriptionCoreTransactionContext
(CoreContext coreContext, String transactionId, CoreMergedTransactionConfig config, CoreTransactionsCleanup cleanup) -
Uses of CoreContext in com.couchbase.client.core.transaction.components
ModifierConstructorDescriptionCoreTransactionRequest
(Duration timeout, CoreContext ctx, RequestSpan span)