Uses of Class
com.couchbase.client.core.topology.NodeIdentifier

Packages that use NodeIdentifier

Package	Description
com.couchbase.client.core
com.couchbase.client.core.api.query
com.couchbase.client.core.classic.query
com.couchbase.client.core.config
com.couchbase.client.core.config.loader
com.couchbase.client.core.endpoint.http
com.couchbase.client.core.msg
com.couchbase.client.core.msg.kv
com.couchbase.client.core.msg.manager
com.couchbase.client.core.msg.query
com.couchbase.client.core.node
com.couchbase.client.core.protostellar.query
com.couchbase.client.core.topology

Uses of NodeIdentifier in com.couchbase.client.core

Methods in com.couchbase.client.core with parameters of type NodeIdentifier

Modifier and Type	Method	Description
protected Node	Core.createNode(NodeIdentifier identifier)	Create a Node from the given identifier.
reactor.core.publisher.Mono<Void>	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.
Optional<reactor.core.publisher.Flux<ServiceState>>	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

Methods in com.couchbase.client.core.api.query that return NodeIdentifier

Modifier and Type	Method	Description
abstract NodeIdentifier	CoreQueryResult.lastDispatchedTo()	The last node the request was dispatched to.
abstract NodeIdentifier	CoreReactiveQueryResult.lastDispatchedTo()

Methods in com.couchbase.client.core.api.query with parameters of type NodeIdentifier

Modifier and Type	Method	Description
CoreAsyncResponse<CoreQueryResult>	CoreQueryOps.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.
default CoreQueryMetaData	CoreQueryOps.queryBlockingStreaming(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter, Consumer<QueryChunkRow> callback)
reactor.core.publisher.Mono<CoreReactiveQueryResult>	CoreQueryOps.queryReactive(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter)

Uses of NodeIdentifier in com.couchbase.client.core.classic.query

Methods in com.couchbase.client.core.classic.query that return NodeIdentifier

Modifier and Type	Method	Description
NodeIdentifier	ClassicCoreQueryResult.lastDispatchedTo()
NodeIdentifier	ClassicCoreReactiveQueryResult.lastDispatchedTo()

Methods in com.couchbase.client.core.classic.query with parameters of type NodeIdentifier

Modifier and Type	Method	Description
CoreAsyncResponse<CoreQueryResult>	ClassicCoreQueryOps.queryAsync(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter)
reactor.core.publisher.Mono<CoreReactiveQueryResult>	ClassicCoreQueryOps.queryReactive(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter)

Constructors in com.couchbase.client.core.classic.query with parameters of type NodeIdentifier

Modifier	Constructor	Description
	ClassicCoreQueryResult(QueryChunkHeader header, List<QueryChunkRow> rows, QueryChunkTrailer trailer, NodeIdentifier lastDispatchedToNode)
	ClassicCoreReactiveQueryResult(QueryResponse response, NodeIdentifier lastDispatchedTo)

Uses of NodeIdentifier in com.couchbase.client.core.config

Methods in com.couchbase.client.core.config that return NodeIdentifier

Modifier and Type	Method	Description
NodeIdentifier	NodeInfo.id()	Deprecated.
NodeIdentifier	PortInfo.id()	Deprecated.

Methods in com.couchbase.client.core.config with parameters of type NodeIdentifier

Modifier and Type	Method	Description
protected reactor.core.publisher.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.

Uses of NodeIdentifier in com.couchbase.client.core.config.loader

Methods in com.couchbase.client.core.config.loader with parameters of type NodeIdentifier

Modifier and Type	Method	Description
protected abstract reactor.core.publisher.Mono<byte[]>	BaseBucketLoader.discoverConfig(NodeIdentifier seed, String bucket)	To be implemented by the actual child, performs the actual fetching of a config.
protected reactor.core.publisher.Mono<byte[]>	ClusterManagerBucketLoader.discoverConfig(NodeIdentifier seed, String bucket)
protected reactor.core.publisher.Mono<byte[]>	KeyValueBucketLoader.discoverConfig(NodeIdentifier seed, String bucket)
reactor.core.publisher.Mono<ProposedBucketConfigContext>	BaseBucketLoader.load(NodeIdentifier seed, int port, String bucket)	Performs the config loading through multiple steps.
reactor.core.publisher.Mono<ProposedBucketConfigContext>	BucketLoader.load(NodeIdentifier seed, int port, String bucket)	Attempts to load a config for the given seed node.
reactor.core.publisher.Mono<ProposedGlobalConfigContext>	GlobalLoader.load(NodeIdentifier seed, int port)	Tries to load the global configuration.

Uses of NodeIdentifier in com.couchbase.client.core.endpoint.http

Methods in com.couchbase.client.core.endpoint.http that return NodeIdentifier

Modifier and Type	Method	Description
NodeIdentifier	CoreHttpRequest.target()

Uses of NodeIdentifier in com.couchbase.client.core.msg

Methods in com.couchbase.client.core.msg that return NodeIdentifier

Modifier and Type	Method	Description
NodeIdentifier	RequestContext.lastDispatchedToNode()
NodeIdentifier	RequestTarget.nodeIdentifier()
default NodeIdentifier	Request.target()	Returns the node that should service this request, or null to let the service locator decide.

Methods in com.couchbase.client.core.msg with parameters of type NodeIdentifier

Modifier and Type	Method	Description
RequestContext	RequestContext.lastDispatchedToNode(NodeIdentifier lastDispatchedToNode)
RequestTarget	RequestTarget.withNodeIdentifier(NodeIdentifier nodeIdentifier)

Constructors in com.couchbase.client.core.msg with parameters of type NodeIdentifier

Modifier	Constructor	Description
	RequestTarget(ServiceType serviceType, NodeIdentifier nodeIdentifier, String bucketName)

Uses of NodeIdentifier in com.couchbase.client.core.msg.kv

Methods in com.couchbase.client.core.msg.kv that return NodeIdentifier

Modifier and Type	Method	Description
NodeIdentifier	CarrierBucketConfigRequest.target()
NodeIdentifier	CarrierGlobalConfigRequest.target()
NodeIdentifier	KvPingRequest.target()
NodeIdentifier	MultiObserveViaCasRequest.target()

Constructors in com.couchbase.client.core.msg.kv with parameters of type NodeIdentifier

Modifier	Constructor	Description
	CarrierBucketConfigRequest(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

Methods in com.couchbase.client.core.msg.manager that return NodeIdentifier

Modifier and Type	Method	Description
NodeIdentifier	BucketConfigRequest.target()

Constructors in com.couchbase.client.core.msg.manager with parameters of type NodeIdentifier

Modifier	Constructor	Description
	BucketConfigRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String bucketName, Authenticator authenticator, NodeIdentifier target)

Uses of NodeIdentifier in com.couchbase.client.core.msg.query

Methods in com.couchbase.client.core.msg.query that return NodeIdentifier

Modifier and Type	Method	Description
NodeIdentifier	QueryRequest.target()

Constructors in com.couchbase.client.core.msg.query with parameters of type NodeIdentifier

Modifier	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, NodeIdentifier target)

Uses of NodeIdentifier in com.couchbase.client.core.node

Methods in com.couchbase.client.core.node that return NodeIdentifier

Modifier and Type	Method	Description
NodeIdentifier	NodeIdentifier.asTopologyNodeIdentifier()	Deprecated.
NodeIdentifier	Node.identifier()	Returns the node identifier.

Methods in com.couchbase.client.core.node with parameters of type NodeIdentifier

Modifier and Type	Method	Description
static Node	Node.create(CoreContext ctx, NodeIdentifier identifier)

Constructors in com.couchbase.client.core.node with parameters of type NodeIdentifier

Modifier	Constructor	Description
protected	Node(CoreContext ctx, NodeIdentifier identifier)
	NodeContext(CoreContext ctx, NodeIdentifier nodeIdentifier)

Uses of NodeIdentifier in com.couchbase.client.core.protostellar.query

Methods in com.couchbase.client.core.protostellar.query that return NodeIdentifier

Modifier and Type	Method	Description
NodeIdentifier	ProtostellarCoreQueryResult.lastDispatchedTo()
NodeIdentifier	ProtostellarCoreReactiveQueryResult.lastDispatchedTo()

Methods in com.couchbase.client.core.protostellar.query with parameters of type NodeIdentifier

Modifier and Type	Method	Description
CoreAsyncResponse<CoreQueryResult>	ProtostellarCoreQueryOps.queryAsync(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter)
CoreQueryResult	ProtostellarCoreQueryOps.queryBlocking(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter)
reactor.core.publisher.Mono<CoreReactiveQueryResult>	ProtostellarCoreQueryOps.queryReactive(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter)

Uses of NodeIdentifier in com.couchbase.client.core.topology

Methods in com.couchbase.client.core.topology that return NodeIdentifier

Modifier and Type	Method	Description
static NodeIdentifier	NodeIdentifier.forBootstrap(String bootstrapHost, int bootstrapPort)
NodeIdentifier	HostAndServicePorts.id()

Methods in com.couchbase.client.core.topology with parameters of type NodeIdentifier

Modifier and Type	Method	Description
boolean	CouchbaseBucketTopology.hasPrimaryPartitionsOnNode(NodeIdentifier id)

Constructors in com.couchbase.client.core.topology with parameters of type NodeIdentifier

Modifier	Constructor	Description
	HostAndServicePorts(String host, Map<ServiceType,Integer> ports, NodeIdentifier id, @Nullable HostAndPort ketamaAuthority, @Nullable String serverGroup, @Nullable String appTelemetryPath, @Nullable String nodeUuid)