public class CarrierLoader extends AbstractLoader
Loads a raw bucket configuration through the carrier mechanism (also commonly referred to as CCCP).
Constructor and Description |
---|
CarrierLoader(ClusterFacade cluster,
CoreEnvironment environment)
Creates a new
CarrierLoader . |
Modifier and Type | Method and Description |
---|---|
protected Observable<String> |
discoverConfig(String bucket,
String password,
InetAddress hostname)
Run the
BucketConfig discovery process. |
protected int |
port()
Port to use for the
ServiceType . |
cluster, env, loadConfig, replaceHostWildcard
public CarrierLoader(ClusterFacade cluster, CoreEnvironment environment)
Creates a new CarrierLoader
.
cluster
- the cluster reference.environment
- the environment to use.protected int port()
AbstractLoader
Port to use for the ServiceType
.
This method needs to be implemented by the actual loader and defines the port which should be used to connect the service to. In practice, the actual port may depend on the environment (i.e. if SSL is used or not).
port
in class AbstractLoader
protected Observable<String> discoverConfig(String bucket, String password, InetAddress hostname)
AbstractLoader
Run the BucketConfig
discovery process.
discoverConfig
in class AbstractLoader
bucket
- the name of the bucket.password
- the password of the bucket.hostname
- the hostname of the seed node list.Copyright © 2016 Couchbase, Inc.. All rights reserved.