public class BucketConfigurationProvider extends net.spy.memcached.compat.SpyObject implements ConfigurationProvider, Reconfigurable
ConfigurationProvider
provides the current bucket configuration
in a best-effort way, mixing both http and binary fetching techniques
(depending on the supported mechanisms on the cluster side).Constructor and Description |
---|
BucketConfigurationProvider(java.util.List<java.net.URI> seedNodes,
java.lang.String bucket,
java.lang.String password,
CouchbaseConnectionFactory connectionFactory) |
Modifier and Type | Method and Description |
---|---|
Bucket |
bootstrap()
Initiate the config fetching process, eventually returning a valid
configuration.
|
java.lang.String |
getAnonymousAuthBucket()
Retrieves a default bucket name i.e.
|
Bucket |
getConfig()
Returns the current
Bucket configuration. |
void |
reconfigure(Bucket bucket)
Call on a configuration update.
|
void |
reloadConfig()
Method used to signal a new configuration should be loaded.
|
void |
setConfig(Bucket config)
Explictly set the current
Bucket configuration. |
void |
setConfig(java.lang.String config)
Replace the current config with a raw JSON string configuration.
|
void |
shutdown()
Shut down the
ConfigurationProvider . |
void |
signalOutdated()
Can be used as a hint for the
ConfigurationProvider to signal that
his current configuration may be outdated. |
void |
subscribe(Reconfigurable rec)
Subscribes for configuration updates.
|
void |
unsubscribe(Reconfigurable rec)
Unsubscribe from updates on the connected bucket.
|
public BucketConfigurationProvider(java.util.List<java.net.URI> seedNodes, java.lang.String bucket, java.lang.String password, CouchbaseConnectionFactory connectionFactory)
public Bucket bootstrap()
ConfigurationProvider
bootstrap
in interface ConfigurationProvider
public void reconfigure(Bucket bucket)
Reconfigurable
reconfigure
in interface Reconfigurable
bucket
- updated vbucket configurationpublic Bucket getConfig()
ConfigurationProvider
Bucket
configuration.getConfig
in interface ConfigurationProvider
public void setConfig(Bucket config)
ConfigurationProvider
Bucket
configuration.setConfig
in interface ConfigurationProvider
public void signalOutdated()
ConfigurationProvider
ConfigurationProvider
to signal that
his current configuration may be outdated.signalOutdated
in interface ConfigurationProvider
public void reloadConfig()
ConfigurationProvider
reloadConfig
in interface ConfigurationProvider
public void shutdown()
ConfigurationProvider
ConfigurationProvider
.shutdown
in interface ConfigurationProvider
public java.lang.String getAnonymousAuthBucket()
ConfigurationProvider
getAnonymousAuthBucket
in interface ConfigurationProvider
public void setConfig(java.lang.String config)
ConfigurationProvider
setConfig
in interface ConfigurationProvider
config
- the raw string configuration.public void subscribe(Reconfigurable rec)
ConfigurationProvider
subscribe
in interface ConfigurationProvider
rec
- reconfigurable that will receive updatespublic void unsubscribe(Reconfigurable rec)
ConfigurationProvider
unsubscribe
in interface ConfigurationProvider
rec
- reconfigurableCopyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.