Uses of Class
com.couchbase.client.core.CoreContext
-
-
Uses of CoreContext in com.couchbase.client.core
Methods in com.couchbase.client.core that return CoreContext Modifier and Type Method Description CoreContext
CoreContext. alternateAddress(Optional<String> alternateAddress)
Sets the alternate address on this context.CoreContext
Core. context()
Returns theCoreContext
of this core instance. -
Uses of CoreContext in com.couchbase.client.core.cnc.events.config
Constructors in com.couchbase.client.core.cnc.events.config with parameters of type CoreContext Constructor Description IndividualGlobalConfigLoadFailedEvent(Duration duration, CoreContext context, Throwable cause, String host)
-
Uses of CoreContext in com.couchbase.client.core.cnc.events.core
Constructors in com.couchbase.client.core.cnc.events.core with parameters of type CoreContext Constructor Description CoreCreatedEvent(CoreContext context, CoreEnvironment environment, Set<SeedNode> seedNodes)
InitGlobalConfigFailedEvent(Event.Severity severity, Duration duration, CoreContext context, InitGlobalConfigFailedEvent.Reason reason, Throwable cause)
-
Uses of CoreContext in com.couchbase.client.core.cnc.events.node
Constructors in com.couchbase.client.core.cnc.events.node with parameters of type CoreContext Constructor Description NodePartitionLengthNotEqualEvent(CoreContext context, int actualSize, int configSize)
-
Uses of CoreContext in com.couchbase.client.core.endpoint
Subclasses of CoreContext in com.couchbase.client.core.endpoint Modifier and Type Class Description class
EndpointContext
Constructors in com.couchbase.client.core.endpoint with parameters of type CoreContext Constructor Description EndpointContext(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.io
Subclasses of CoreContext in com.couchbase.client.core.io Modifier and Type Class Description class
IoContext
TheIoContext
is used to extend the core context with IO related metadata that is useful during event generation.Constructors in com.couchbase.client.core.io with parameters of type CoreContext Constructor Description IoContext(CoreContext ctx, SocketAddress localSocket, SocketAddress remoteSocket, Optional<String> bucket)
Creates a new IO Context. -
Uses of CoreContext in com.couchbase.client.core.io.netty.kv
Methods in com.couchbase.client.core.io.netty.kv with parameters of type CoreContext Modifier and Type Method Description static com.couchbase.client.core.deps.io.netty.buffer.ByteBuf
MemcacheProtocol. flexibleSyncReplication(com.couchbase.client.core.deps.io.netty.buffer.ByteBufAllocator alloc, DurabilityLevel type, Duration timeout, CoreContext ctx)
Helper method to create the flexible extras for sync replication. -
Uses of CoreContext in com.couchbase.client.core.io.netty.manager
Constructors in com.couchbase.client.core.io.netty.manager with parameters of type CoreContext Constructor Description ManagerMessageHandler(BaseEndpoint endpoint, CoreContext coreContext)
-
Uses of CoreContext in com.couchbase.client.core.msg
Subclasses of CoreContext in com.couchbase.client.core.msg Modifier and Type Class Description class
RequestContext
Additional context which might be attached to an individualRequest
.Constructors in com.couchbase.client.core.msg with parameters of type CoreContext Constructor Description BaseRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy)
BaseRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, InternalSpan requestSpan)
Creates a basic request that has all the required properties to be executed in general.RequestContext(CoreContext ctx, Request<? extends Response> request)
Creates a newRequestContext
. -
Uses of CoreContext in com.couchbase.client.core.msg.analytics
Constructors in com.couchbase.client.core.msg.analytics with parameters of type CoreContext Constructor Description AnalyticsPingRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, NodeIdentifier target)
AnalyticsRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, byte[] query, int priority, boolean idempotent, String contextId, String statement, InternalSpan span)
GenericAnalyticsRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier, boolean idempotent)
-
Uses of CoreContext in com.couchbase.client.core.msg.kv
Constructors in com.couchbase.client.core.msg.kv with parameters of type CoreContext Constructor Description AppendRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte[] content, long cas, Optional<DurabilityLevel> syncReplicationType, InternalSpan span)
BaseKeyValueRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier)
BaseKeyValueRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier, InternalSpan span)
CarrierBucketConfigRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, NodeIdentifier target)
CarrierGlobalConfigRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, NodeIdentifier target)
DecrementRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long delta, Optional<Long> initial, long expiry, Optional<DurabilityLevel> syncReplicationType, InternalSpan span)
GetAndLockRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Duration lockFor, InternalSpan span)
GetAndTouchRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Duration expiration, InternalSpan 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, InternalSpan span)
GetRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, InternalSpan span)
IncrementRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long delta, Optional<Long> initial, long expiration, Optional<DurabilityLevel> syncReplicationType, InternalSpan span)
InsertRequest(String key, byte[] content, long expiration, int flags, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType, InternalSpan 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, InternalSpan span)
PrependRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte[] content, long cas, Optional<DurabilityLevel> syncReplicationType, InternalSpan span)
RemoveRequest(String key, long cas, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType, InternalSpan span)
ReplaceRequest(String key, byte[] content, long expiration, int flags, Duration timeout, long cas, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType, InternalSpan span)
ReplicaGetRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, short replica, InternalSpan span)
SubdocGetRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte flags, List<SubdocGetRequest.Command> commands, InternalSpan span)
SubdocMutateRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, BucketConfig bucketConfig, RetryStrategy retryStrategy, String key, boolean insertDocument, boolean upsertDocument, boolean accessDeleted, boolean createAsDeleted, List<SubdocMutateRequest.Command> commands, long expiration, long cas, Optional<DurabilityLevel> syncReplicationType, InternalSpan span)
TouchRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long expiry, InternalSpan span)
UnlockRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long cas, InternalSpan span)
UpsertRequest(String key, byte[] content, long expiration, int flags, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType, InternalSpan span)
-
Uses of CoreContext in com.couchbase.client.core.msg.manager
Constructors in com.couchbase.client.core.msg.manager with parameters of type CoreContext Constructor Description BucketConfigRequest(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)
GenericManagerRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier, boolean idempotent)
-
Uses of CoreContext in com.couchbase.client.core.msg.query
Constructors in com.couchbase.client.core.msg.query with parameters of type CoreContext Constructor Description QueryPingRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, NodeIdentifier target)
QueryRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String statement, byte[] query, boolean idempotent, String contextId, InternalSpan span, String queryContext)
-
Uses of CoreContext in com.couchbase.client.core.msg.search
Constructors in com.couchbase.client.core.msg.search with parameters of type CoreContext Constructor Description GenericSearchRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier, boolean idempotent)
SearchPingRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, NodeIdentifier target)
SearchRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String indexName, byte[] content, InternalSpan span)
-
Uses of CoreContext in com.couchbase.client.core.msg.view
Constructors in com.couchbase.client.core.msg.view with parameters of type CoreContext Constructor Description GenericViewRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier, boolean idempotent, String bucket)
ViewPingRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String bucket, NodeIdentifier target)
ViewRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String bucket, String design, String view, String query, Optional<byte[]> keysJson, boolean development, InternalSpan span)
-
Uses of CoreContext in com.couchbase.client.core.node
Subclasses of CoreContext in com.couchbase.client.core.node Modifier and Type Class Description class
NodeContext
Methods in com.couchbase.client.core.node with parameters of type CoreContext Modifier and Type Method Description static Node
Node. create(CoreContext ctx, NodeIdentifier identifier, Optional<String> alternateAddress)
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)
Constructors in com.couchbase.client.core.node with parameters of type CoreContext Constructor Description Node(CoreContext ctx, NodeIdentifier identifier, Optional<String> alternateAddress)
NodeContext(CoreContext ctx, NodeIdentifier nodeIdentifier, Optional<String> alternateAddress)
-
Uses of CoreContext in com.couchbase.client.core.retry
Methods in com.couchbase.client.core.retry with parameters of type CoreContext Modifier and Type Method Description static 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
Subclasses of CoreContext in com.couchbase.client.core.service Modifier and Type Class Description class
ServiceContext
Constructors in com.couchbase.client.core.service with parameters of type CoreContext Constructor Description AnalyticsService(AnalyticsServiceConfig config, CoreContext context, 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
Subclasses of CoreContext in com.couchbase.client.core.service.kv Modifier and Type Class Description class
ObserveContext
Constructors in com.couchbase.client.core.service.kv with parameters of type CoreContext Constructor Description ObserveContext(CoreContext ctx, Observe.ObservePersistTo persistTo, Observe.ObserveReplicateTo replicateTo, Optional<MutationToken> mutationToken, long cas, CollectionIdentifier collectionIdentifier, String key, boolean remove, Duration timeout, RequestSpan parentSpan)
-