public class KeyValueBucketLoader extends BaseBucketLoader
The main and primary mechanism to bootstrap a good configuration is through the kv protocol with a special command, since those connections need to be open anyways and it is more efficient at large scale than the cluster manager (who is the authority).
Note that this loader can fail (hence the ClusterManagerBucketLoader
as a backup), either because
the current seed node does not have the data service enabled or it is a memcached bucket which
does not support the special command.
In 1.x this loader used to be called Carrier BucketLoader (from CCCP "couchbase carrier config publication"), but the new name more accurately reflects from which service it is loading it rather than how.
Constructor and Description |
---|
KeyValueBucketLoader(Core core) |
Modifier and Type | Method and Description |
---|---|
protected Mono<byte[]> |
discoverConfig(NodeIdentifier seed,
String bucket)
To be implemented by the actual child, performs the actual fetching of a config.
|
core, load
public KeyValueBucketLoader(Core core)
protected Mono<byte[]> discoverConfig(NodeIdentifier seed, String bucket)
BaseBucketLoader
discoverConfig
in class BaseBucketLoader
seed
- the node from where to fetch it.bucket
- the name of the bucket to fetch from.Copyright © 2020 Couchbase, Inc.. All rights reserved.