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 rx.Observable<String> |
discoverConfig(String bucket,
String username,
String password,
NetworkAddress hostname)
Run the
BucketConfig discovery process. |
protected int |
port()
Port to use for the
ServiceType . |
cluster, env, loadConfig, 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 rx.Observable<String> discoverConfig(String bucket, String username, String password, NetworkAddress hostname)
AbstractLoader
Run the BucketConfig
discovery process.
discoverConfig
in class AbstractLoader
bucket
- the name of the bucket.username
- user authorized for bucket access.password
- the password of the user.hostname
- the hostname of the seed node list.Copyright © 2017 Couchbase, Inc.. All rights reserved.