public class CarrierLoader extends AbstractLoader
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,
String hostname)
Run the
BucketConfig discovery process. |
protected int |
port(String hostname)
Port to use for the
ServiceType . |
cluster, env, loadConfig, loadConfig, replaceHostWildcard, tryLoadingPortFromConfig
public CarrierLoader(ClusterFacade cluster, CoreEnvironment environment)
CarrierLoader
.cluster
- the cluster reference.environment
- the environment to use.protected int port(String hostname)
AbstractLoader
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, String hostname)
AbstractLoader
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 © 2021 Couchbase, Inc.. All rights reserved.