Constructor and Description |
---|
CouchbaseCore(CoreEnvironment environment)
Creates a new
CouchbaseCore . |
RequestHandler(CoreEnvironment environment,
Observable<ClusterConfig> configObservable,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
RequestHandler . |
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 |
---|
CarrierRefresher(CoreEnvironment environment,
ClusterFacade cluster)
Creates a new
CarrierRefresher . |
Modifier and Type | Method and Description |
---|---|
protected CoreEnvironment |
AbstractGenericHandler.env()
Returns environment.
|
CoreEnvironment |
AbstractEndpoint.environment()
The
CoreEnvironment reference. |
Constructor and Description |
---|
AbstractEndpoint(String bucket,
String password,
BootstrapAdapter adapter,
boolean isTransient,
CoreEnvironment env)
Constructor to which allows to pass in an artificial bootstrap adapter.
|
AbstractEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient)
Create a new
AbstractEndpoint . |
SSLEngineFactory(CoreEnvironment env)
Create a new engine factory.
|
Constructor and Description |
---|
ConfigEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Constructor and Description |
---|
DCPConnection(CoreEnvironment env,
ClusterFacade core,
String bucket,
String password) |
DCPConnection(CoreEnvironment env,
ClusterFacade core,
String bucket,
String password,
SerializedSubject<DCPRequest,DCPRequest> subject) |
DCPConnectionHandler(CoreEnvironment env)
Creates a new
DCPConnectionHandler . |
DCPEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Constructor and Description |
---|
KeyValueEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
KeyValueEndpoint . |
KeyValueFeatureHandler(CoreEnvironment environment) |
Constructor and Description |
---|
QueryEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Constructor and Description |
---|
SearchEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Constructor and Description |
---|
ViewEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
ViewEndpoint . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultCoreEnvironment |
Constructor and Description |
---|
CouchbaseNode(InetAddress hostname,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
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 |
DCPLocator.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 |
---|---|
Endpoint |
Service.EndpointFactory.create(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
Endpoint . |
static Service |
ServiceFactory.create(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
ServiceType type,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Constructor and Description |
---|
AbstractDynamicService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
int minEndpoints,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
Service.EndpointFactory endpointFactory) |
AbstractLazyService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
Service.EndpointFactory endpointFactory) |
AbstractOnDemandService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
Service.EndpointFactory endpointFactory) |
AbstractPoolingService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
int minEndpoints,
int maxEndpoints,
SelectionStrategy strategy,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
Service.EndpointFactory endpointFactory) |
ConfigService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
DCPService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
KeyValueService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Creates a new
KeyValueService . |
QueryService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Creates a new
ViewService . |
SearchService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Creates a new
ViewService . |
ViewService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Creates a new
ViewService . |
Copyright © 2016 Couchbase, Inc.. All rights reserved.