Uses of Class
com.couchbase.client.core.topology.NodeIdentifier
Packages that use NodeIdentifier
Package
Description
-
Uses of NodeIdentifier in com.couchbase.client.core
Methods in com.couchbase.client.core with parameters of type NodeIdentifierModifier 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
Methods in com.couchbase.client.core.api.query that return NodeIdentifierModifier and TypeMethodDescriptionabstract 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 NodeIdentifierModifier 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.default CoreQueryMetaData
CoreQueryOps.queryBlockingStreaming
(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable, RuntimeException> errorConverter, Consumer<QueryChunkRow> callback) 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 NodeIdentifierModifier and TypeMethodDescriptionClassicCoreQueryResult.lastDispatchedTo()
ClassicCoreReactiveQueryResult.lastDispatchedTo()
Methods in com.couchbase.client.core.classic.query with parameters of type NodeIdentifierModifier 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) Constructors in com.couchbase.client.core.classic.query with parameters of type NodeIdentifierModifierConstructorDescriptionClassicCoreQueryResult
(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 NodeIdentifierMethods in com.couchbase.client.core.config with parameters of type NodeIdentifierModifier and TypeMethodDescriptionprotected 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 NodeIdentifierModifier 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
Methods in com.couchbase.client.core.endpoint.http that return NodeIdentifier -
Uses of NodeIdentifier in com.couchbase.client.core.msg
Methods in com.couchbase.client.core.msg that return NodeIdentifierModifier 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.Methods in com.couchbase.client.core.msg with parameters of type NodeIdentifierModifier and TypeMethodDescriptionRequestContext.lastDispatchedToNode
(NodeIdentifier lastDispatchedToNode) RequestTarget.withNodeIdentifier
(NodeIdentifier nodeIdentifier) Constructors in com.couchbase.client.core.msg with parameters of type NodeIdentifierModifierConstructorDescriptionRequestTarget
(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 NodeIdentifierModifier and TypeMethodDescriptionCarrierBucketConfigRequest.target()
CarrierGlobalConfigRequest.target()
KvPingRequest.target()
MultiObserveViaCasRequest.target()
Constructors in com.couchbase.client.core.msg.kv with parameters of type NodeIdentifierModifierConstructorDescriptionCarrierBucketConfigRequest
(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 NodeIdentifierConstructors in com.couchbase.client.core.msg.manager with parameters of type NodeIdentifierModifierConstructorDescriptionBucketConfigRequest
(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 NodeIdentifierConstructors in com.couchbase.client.core.msg.query with parameters of type NodeIdentifierModifierConstructorDescriptionQueryRequest
(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 NodeIdentifierModifier and TypeMethodDescriptionNodeIdentifier.asTopologyNodeIdentifier()
Deprecated.Node.identifier()
Returns the node identifier.Methods in com.couchbase.client.core.node with parameters of type NodeIdentifierModifier and TypeMethodDescriptionstatic Node
Node.create
(CoreContext ctx, NodeIdentifier identifier) Constructors in com.couchbase.client.core.node with parameters of type NodeIdentifierModifierConstructorDescriptionprotected
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 NodeIdentifierModifier and TypeMethodDescriptionProtostellarCoreQueryResult.lastDispatchedTo()
ProtostellarCoreReactiveQueryResult.lastDispatchedTo()
Methods in com.couchbase.client.core.protostellar.query with parameters of type NodeIdentifierModifier 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
Methods in com.couchbase.client.core.topology that return NodeIdentifierModifier and TypeMethodDescriptionstatic NodeIdentifier
NodeIdentifier.forBootstrap
(String bootstrapHost, int bootstrapPort) HostAndServicePorts.id()
Methods in com.couchbase.client.core.topology with parameters of type NodeIdentifierModifier and TypeMethodDescriptionboolean
CouchbaseBucketTopology.hasPrimaryPartitionsOnNode
(NodeIdentifier id) Constructors in com.couchbase.client.core.topology with parameters of type NodeIdentifierModifierConstructorDescriptionHostAndServicePorts
(String host, Map<ServiceType, Integer> ports, NodeIdentifier id, @Nullable HostAndPort ketamaAuthority, @Nullable String serverGroup, @Nullable String appTelemetryPath, @Nullable String nodeUuid)