-
-
-
-
-
-
-
-
-
-
-
Constructors in com.couchbase.client.core.msg.analytics with parameters of type CoreContext
Constructor |
Description |
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) |
|
-
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,
RequestSpan span) |
|
BaseKeyValueRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String key,
CollectionIdentifier collectionIdentifier) |
|
BaseKeyValueRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String key,
CollectionIdentifier collectionIdentifier,
RequestSpan 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,
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) |
|
PrependRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
byte[] content,
long cas,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
|
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 accessDeleted,
boolean createAsDeleted,
List<SubdocMutateRequest.Command> 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) |
|
-
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,
RequestSpan span) |
|
GenericManagerRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier,
boolean idempotent,
RequestSpan span) |
|
-
Constructors in com.couchbase.client.core.msg.query with parameters of type CoreContext
Constructor |
Description |
QueryRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
String statement,
byte[] query,
boolean idempotent,
String contextId,
RequestSpan span,
String bucket,
String scope) |
|
TargetedQueryRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
String statement,
byte[] query,
boolean idempotent,
String contextId,
RequestSpan parentSpan,
String bucket,
String scope,
NodeIdentifier target) |
|
-
-
Constructors in com.couchbase.client.core.msg.view with parameters of type CoreContext
Constructor |
Description |
ViewRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
String bucket,
String design,
String view,
String query,
Optional<byte[]> keysJson,
boolean development,
RequestSpan span) |
|
-
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.service with parameters of type CoreContext
Constructor |
Description |
AnalyticsService(AnalyticsServiceConfig config,
CoreContext context,
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) |
|
-