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.endpoint | |
com.couchbase.client.core.endpoint.query.parser | |
com.couchbase.client.core.env | |
com.couchbase.client.core.message | |
com.couchbase.client.core.node.locate | |
com.couchbase.client.core.retry | |
com.couchbase.client.core.utils |
Modifier and Type | Method and Description |
---|---|
CoreEnvironment |
CoreContext.environment()
Returns the current environment.
|
Constructor and Description |
---|
CoreContext(CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseRingBuffer)
Creates a new
CoreContext with no core id. |
CoreContext(CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseRingBuffer,
long coreId)
Creates a new
CoreContext with no a core id. |
CouchbaseCore(CoreEnvironment environment)
Creates a new
CouchbaseCore . |
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 CoreEnvironment |
AbstractLoader.env()
Returns the
CoreEnvironment 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 . |
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 |
---|---|
protected CoreEnvironment |
AbstractGenericHandler.env()
Returns environment.
|
CoreEnvironment |
AbstractEndpoint.environment()
The
CoreEnvironment reference. |
Constructor and Description |
---|
YasjlQueryResponseParser(rx.Scheduler scheduler,
long ttl,
CoreEnvironment env)
Create a new
YasjlQueryResponseParser . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultCoreEnvironment |
Modifier and Type | Method and Description |
---|---|
void |
CouchbaseRequest.span(io.opentracing.Span span,
CoreEnvironment env)
Allows to set a custom span that should be used.
|
void |
AbstractCouchbaseRequest.span(io.opentracing.Span span,
CoreEnvironment env) |
Modifier and Type | Method and Description |
---|---|
void |
ViewLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
void |
QueryLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
void |
Locator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Given with the environment and node information, the implementation locates the right set of nodes and dispatches the request into them.
|
void |
KeyValueLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig cluster,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
void |
ConfigLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Modifier and Type | Method and Description |
---|---|
static void |
RetryHelper.retryOrCancel(CoreEnvironment environment,
CouchbaseRequest request,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer)
Either retry or cancel a request, based on the strategy used.
|
boolean |
RetryStrategy.shouldRetry(CouchbaseRequest request,
CoreEnvironment environment)
Decides whether the given
CouchbaseRequest should be retried or cancelled. |
boolean |
FailFastRetryStrategy.shouldRetry(CouchbaseRequest request,
CoreEnvironment env) |
boolean |
BestEffortRetryStrategy.shouldRetry(CouchbaseRequest request,
CoreEnvironment env) |
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.