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
Core. context()
Returns theCoreContext
of this core instance. -
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, String remoteHostname, int remotePort, CircuitBreaker circuitBreaker, ServiceType serviceType, Optional<SocketAddress> 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.config
Constructors in com.couchbase.client.core.io.netty.config 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)
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 AnalyticsRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Credentials credentials, byte[] query, int priority)
-
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)
CarrierBucketConfigRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, NodeIdentifier target)
DecrementRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long cas, long delta, Optional<Long> initial, int expiry, Optional<DurabilityLevel> syncReplicationType)
GetAndLockRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Duration lockFor)
GetAndTouchRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Duration expiration)
GetCollectionIdRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier)
GetCollectionManifestRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier)
GetRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy)
IncrementRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long cas, long delta, Optional<Long> initial, int expiration, Optional<DurabilityLevel> syncReplicationType)
InsertRequest(String key, byte[] content, long expiration, int flags, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType)
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)
PrependRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte[] content, long cas, Optional<DurabilityLevel> syncReplicationType)
RemoveRequest(String key, long cas, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType)
ReplaceRequest(String key, byte[] content, long expiration, int flags, Duration timeout, long cas, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType)
ReplicaGetRequest(String key, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, short replica)
SubdocGetRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte flags, List<SubdocGetRequest.Command> commands)
SubdocMutateRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, boolean insertDocument, boolean upsertDocument, List<SubdocMutateRequest.Command> commands, long expiration, long cas, Optional<DurabilityLevel> syncReplicationType)
TouchRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long expiry, Optional<DurabilityLevel> syncReplicationType)
UnlockRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, long cas)
UpsertRequest(String key, byte[] content, long expiration, int flags, Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, Optional<DurabilityLevel> syncReplicationType)
-
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 BaseManagerRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy)
TerseBucketConfigRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String bucketName, Credentials credentials, NodeIdentifier target)
-
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 QueryRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Credentials credentials, String statement, byte[] query)
-
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 GetSearchIndexRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Credentials credentials, String name)
RemoveSearchIndexRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Credentials credentials, String name)
SearchRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Credentials credentials, String indexName, byte[] content)
UpsertSearchIndexRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Credentials credentials, String name, byte[] payload)
-
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 ViewRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Credentials credentials, String bucket, String design, String view, String query, Optional<byte[]> keysJson, boolean development)
-
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)
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
ManagerLocator. dispatch(Request<? extends Response> request, List<Node> nodes, ClusterConfig config, CoreContext ctx)
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)
NodeContext(CoreContext ctx, NodeIdentifier nodeIdentifier)
-
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)
Retry or cancel the given request, depending on its state and the configuredRetryStrategy
.static void
RetryOrchestrator. retryImmediately(CoreContext ctx, Request<? extends Response> request)
Retries the given request immediatly, unless it is already completed. -
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, String bucketname, Credentials credentials)
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)
-