Modifier and Type | Class and Description |
---|---|
class |
AbstractEndpoint
The common parent implementation for all
Endpoint s. |
Modifier and Type | Method and Description |
---|---|
protected static String |
AbstractEndpoint.logIdent(Channel chan,
Endpoint endpoint)
Simple log helper to give logs a common prefix.
|
protected static String |
AbstractGenericHandler.logIdent(ChannelHandlerContext ctx,
Endpoint endpoint)
Simple log helper to give logs a common prefix.
|
Modifier and Type | Class and Description |
---|---|
class |
ConfigEndpoint |
Modifier and Type | Class and Description |
---|---|
class |
DCPEndpoint
This endpoint defines the pipeline for DCP requests and responses.
|
Modifier and Type | Class and Description |
---|---|
class |
KeyValueEndpoint
This endpoint defines the pipeline for binary requests and responses.
|
Modifier and Type | Class and Description |
---|---|
class |
QueryEndpoint
This endpoint defines the pipeline for query requests and responses (N1QL).
|
Modifier and Type | Class and Description |
---|---|
class |
ViewEndpoint
This endpoint defines the pipeline for binary requests and responses.
|
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 . |
protected Endpoint |
AbstractDynamicService.createEndpoint()
Helper method to create a new endpoint.
|
protected Endpoint[] |
AbstractDynamicService.endpoints()
Returns the current list of endpoints.
|
Modifier and Type | Method and Description |
---|---|
protected static void |
AbstractDynamicService.whenState(Endpoint endpoint,
LifecycleState wanted,
Action1<LifecycleState> then)
Waits until the endpoint goes into the given state, calls the action and then unsubscribes.
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
SelectionStrategy.select(CouchbaseRequest request,
Endpoint[] endpoints)
Selects an
Endpoint for the given CouchbaseRequest . |
Endpoint |
RandomSelectionStrategy.select(CouchbaseRequest request,
Endpoint[] endpoints) |
Endpoint |
PartitionSelectionStrategy.select(CouchbaseRequest request,
Endpoint[] endpoints) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
SelectionStrategy.select(CouchbaseRequest request,
Endpoint[] endpoints)
Selects an
Endpoint for the given CouchbaseRequest . |
Endpoint |
RandomSelectionStrategy.select(CouchbaseRequest request,
Endpoint[] endpoints) |
Endpoint |
PartitionSelectionStrategy.select(CouchbaseRequest request,
Endpoint[] endpoints) |
Copyright © 2015 Couchbase, Inc.. All rights reserved.