Package | Description |
---|---|
com.couchbase.client.core |
Couchbase Core IO - Domain Model and Architecture
|
com.couchbase.client.core.config | |
com.couchbase.client.core.config.loader | |
com.couchbase.client.core.config.refresher | |
com.couchbase.client.core.message.observe | |
com.couchbase.client.core.message.stat | |
com.couchbase.client.core.utils |
Modifier and Type | Class and Description |
---|---|
class |
CouchbaseCore
The general implementation of a
ClusterFacade . |
Constructor and Description |
---|
ResponseHandler(CoreEnvironment environment,
ClusterFacade cluster,
ConfigurationProvider provider)
Creates a new
ResponseHandler . |
Constructor and Description |
---|
DefaultConfigurationProvider(ClusterFacade cluster,
CoreEnvironment environment)
Create a new
DefaultConfigurationProvider . |
DefaultConfigurationProvider(ClusterFacade cluster,
CoreEnvironment environment,
List<Loader> loaderChain,
Map<LoaderType,Refresher> refreshers)
Create a new
DefaultConfigurationProvider . |
Modifier and Type | Method and Description |
---|---|
protected ClusterFacade |
AbstractLoader.cluster()
Returns the
ClusterFacade for child implementations. |
Constructor and Description |
---|
AbstractLoader(LoaderType loaderType,
ServiceType serviceType,
ClusterFacade cluster,
CoreEnvironment environment)
Create a new
AbstractLoader . |
CarrierLoader(ClusterFacade cluster,
CoreEnvironment environment)
Creates a new
CarrierLoader . |
HttpLoader(ClusterFacade cluster,
CoreEnvironment environment)
Creates a new
HttpLoader . |
Modifier and Type | Method and Description |
---|---|
protected ClusterFacade |
AbstractRefresher.cluster()
Returns the cluster reference.
|
Constructor and Description |
---|
AbstractRefresher(CoreEnvironment env,
ClusterFacade cluster)
Creates a new
AbstractRefresher . |
CarrierRefresher(CoreEnvironment environment,
ClusterFacade cluster)
Creates a new
CarrierRefresher . |
HttpRefresher(CoreEnvironment env,
ClusterFacade cluster) |
Modifier and Type | Method and Description |
---|---|
static rx.Observable<Boolean> |
Observe.call(ClusterFacade core,
String bucket,
String id,
long cas,
boolean remove,
MutationToken token,
Observe.PersistTo persistTo,
Observe.ReplicateTo replicateTo,
Delay delay,
RetryStrategy retryStrategy) |
static rx.Observable<Boolean> |
ObserveViaCAS.call(ClusterFacade core,
String bucket,
String id,
long cas,
boolean remove,
Observe.PersistTo persistTo,
Observe.ReplicateTo replicateTo,
Delay delay,
RetryStrategy retryStrategy) |
static rx.Observable<Boolean> |
Observe.call(ClusterFacade core,
String bucket,
String id,
long cas,
boolean remove,
Observe.PersistTo persistTo,
Observe.ReplicateTo replicateTo,
Delay delay,
RetryStrategy retryStrategy) |
static rx.Observable<Boolean> |
Observe.call(ClusterFacade core,
String bucket,
String id,
long cas,
boolean remove,
Observe.PersistTo persistTo,
Observe.ReplicateTo replicateTo,
RetryStrategy retryStrategy) |
static rx.Observable<Boolean> |
ObserveViaMutationToken.call(ClusterFacade core,
String bucket,
String id,
MutationToken token,
Observe.PersistTo persistTo,
Observe.ReplicateTo replicateTo,
Delay delay,
RetryStrategy retryStrategy,
long cas) |
Modifier and Type | Method and Description |
---|---|
static rx.Observable<StatResponse> |
Stat.call(ClusterFacade core,
String bucket,
String key) |
Modifier and Type | Method and Description |
---|---|
static rx.Single<PingReport> |
HealthPinger.ping(CoreEnvironment env,
String bucket,
String password,
ClusterFacade core,
String id,
long timeout,
TimeUnit timeUnit,
ServiceType... types)
Performs a service ping against all or (if given) the services provided.
|
Copyright © 2018 Couchbase, Inc.. All rights reserved.