Uses of Class
com.couchbase.client.core.node.NodeIdentifier
Package
Description
-
Uses of NodeIdentifier in com.couchbase.client.core
Modifier and TypeMethodDescriptionprotected Node
Core.createNode
(NodeIdentifier identifier) Create aNode
from the given identifier.Core.ensureServiceAt
(NodeIdentifier identifier, ServiceType serviceType, int port, Optional<String> bucket) This method can be used by a caller to make sure a certain service is enabled at the given target node.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. -
Uses of NodeIdentifier in com.couchbase.client.core.api.query
Modifier and TypeMethodDescriptionabstract NodeIdentifier
CoreQueryResult.lastDispatchedTo()
The last node the request was dispatched to.abstract NodeIdentifier
CoreReactiveQueryResult.lastDispatchedTo()
Modifier and TypeMethodDescriptionCoreQueryOps.queryAsync
(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable, RuntimeException> errorConverter) default CoreQueryResult
CoreQueryOps.queryBlocking
(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable, RuntimeException> errorConverter) Performs a query.CoreQueryOps.queryReactive
(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable, RuntimeException> errorConverter) -
Uses of NodeIdentifier in com.couchbase.client.core.classic.query
Modifier and TypeMethodDescriptionClassicCoreQueryResult.lastDispatchedTo()
ClassicCoreReactiveQueryResult.lastDispatchedTo()
Modifier and TypeMethodDescriptionClassicCoreQueryOps.queryAsync
(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable, RuntimeException> errorConverter) ClassicCoreQueryOps.queryReactive
(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable, RuntimeException> errorConverter) ModifierConstructorDescriptionClassicCoreQueryResult
(QueryChunkHeader header, List<QueryChunkRow> rows, QueryChunkTrailer trailer, NodeIdentifier lastDispatchedToNode) ClassicCoreReactiveQueryResult
(QueryResponse response, NodeIdentifier lastDispatchedTo) -
Uses of NodeIdentifier in com.couchbase.client.core.config
Modifier and TypeMethodDescriptionNodeInfo.identifier()
Deprecated.PortInfo.identifier()
Deprecated.MemcachedBucketConfig.nodeForId
(byte[] id) Deprecated.Modifier and TypeMethodDescriptionboolean
CouchbaseBucketConfig.hasPrimaryPartitionsOnNode
(NodeIdentifier nodeId) Deprecated.protected Mono<ProposedBucketConfigContext>
DefaultConfigurationProvider.loadBucketConfigForSeed
(NodeIdentifier identifier, int mappedKvPort, int mappedManagerPort, String name) Encapsulates the logic to load the bucket config from kv and then fall back to manager.ModifierConstructorDescriptionNodeInfo
(String hostname, Map<ServiceType, Integer> direct, Map<ServiceType, Integer> ssl, HostAndPort ketamaAuthority, NodeIdentifier nodeIdentifier) Deprecated.Creates an instance from pre-parsed address info. -
Uses of NodeIdentifier in com.couchbase.client.core.config.loader
Modifier and TypeMethodDescriptionprotected abstract Mono<byte[]>
BaseBucketLoader.discoverConfig
(NodeIdentifier seed, String bucket) To be implemented by the actual child, performs the actual fetching of a config.protected Mono<byte[]>
ClusterManagerBucketLoader.discoverConfig
(NodeIdentifier seed, String bucket) protected Mono<byte[]>
KeyValueBucketLoader.discoverConfig
(NodeIdentifier seed, String bucket) BaseBucketLoader.load
(NodeIdentifier seed, int port, String bucket) Performs the config loading through multiple steps.BucketLoader.load
(NodeIdentifier seed, int port, String bucket) Attempts to load a config for the given seed node.GlobalLoader.load
(NodeIdentifier seed, int port) Tries to load the global configuration. -
Uses of NodeIdentifier in com.couchbase.client.core.endpoint.http
-
Uses of NodeIdentifier in com.couchbase.client.core.msg
Modifier and TypeMethodDescriptionRequestContext.lastDispatchedToNode()
RequestTarget.nodeIdentifier()
default NodeIdentifier
Request.target()
Returns the node that should service this request, or null to let the service locator decide.Modifier and TypeMethodDescriptionRequestContext.lastDispatchedToNode
(NodeIdentifier lastDispatchedToNode) RequestTarget.withNodeIdentifier
(NodeIdentifier nodeIdentifier) ModifierConstructorDescriptionRequestTarget
(ServiceType serviceType, NodeIdentifier nodeIdentifier, String bucketName) -
Uses of NodeIdentifier in com.couchbase.client.core.msg.kv
Modifier and TypeMethodDescriptionCarrierBucketConfigRequest.target()
CarrierGlobalConfigRequest.target()
KvPingRequest.target()
MultiObserveViaCasRequest.target()
ModifierConstructorDescriptionCarrierBucketConfigRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, NodeIdentifier target, ConfigVersion ifNewerThan) CarrierGlobalConfigRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, NodeIdentifier target, ConfigVersion ifNewerThan) 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) -
Uses of NodeIdentifier in com.couchbase.client.core.msg.manager
ModifierConstructorDescriptionBucketConfigRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String bucketName, Authenticator authenticator, NodeIdentifier target) -
Uses of NodeIdentifier 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 NodeIdentifier in com.couchbase.client.core.node
Modifier and TypeMethodDescriptionstatic NodeIdentifier
NodeIdentifier.forBootstrap
(String bootstrapHost, int bootstrapPort) Node.identifier()
Returns the node identifier.Modifier and TypeMethodDescriptionstatic Node
Node.create
(CoreContext ctx, NodeIdentifier identifier) ModifierConstructorDescriptionprotected
Node
(CoreContext ctx, NodeIdentifier identifier) NodeContext
(CoreContext ctx, NodeIdentifier nodeIdentifier) -
Uses of NodeIdentifier in com.couchbase.client.core.protostellar.query
Modifier and TypeMethodDescriptionProtostellarCoreQueryResult.lastDispatchedTo()
ProtostellarCoreReactiveQueryResult.lastDispatchedTo()
Modifier and TypeMethodDescriptionProtostellarCoreQueryOps.queryAsync
(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable, RuntimeException> errorConverter) ProtostellarCoreQueryOps.queryBlocking
(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable, RuntimeException> errorConverter) ProtostellarCoreQueryOps.queryReactive
(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable, RuntimeException> errorConverter) -
Uses of NodeIdentifier in com.couchbase.client.core.topology
MemcachedBucketConfig.nodeForKey(byte[])
.identifier() instead.