Package | Description |
---|---|
com.couchbase.client.core.endpoint.dcp | |
com.couchbase.client.core.message.dcp |
Modifier and Type | Method and Description |
---|---|
rx.subjects.Subject<DCPRequest,DCPRequest> |
DCPConnection.subject() |
rx.subjects.Subject<DCPRequest,DCPRequest> |
DCPConnection.subject() |
Modifier and Type | Method and Description |
---|---|
protected BinaryMemcacheRequest |
DCPHandler.encodeRequest(ChannelHandlerContext ctx,
DCPRequest msg) |
Constructor and Description |
---|
DCPConnection(CoreEnvironment env,
ClusterFacade core,
String bucket,
String password,
rx.subjects.SerializedSubject<DCPRequest,DCPRequest> subject) |
DCPConnection(CoreEnvironment env,
ClusterFacade core,
String bucket,
String password,
rx.subjects.SerializedSubject<DCPRequest,DCPRequest> subject) |
DCPHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
Queue<DCPRequest> queue,
boolean isTransient,
boolean pipeline)
Creates a new
DCPHandler with a custom queue for requests (suitable for tests). |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDCPMessage
Default implementation of
DCPRequest . |
class |
AbstractDCPRequest
Default implementation of
DCPRequest . |
class |
ExpirationMessage
A message representing event that removes or expires a document.
|
class |
GetFailoverLogRequest
Get the current failover logs for partition.
|
class |
GetLastCheckpointRequest
Returns the last checkpoint for a particular VBucket.
|
class |
MutationMessage
A message representing event that creates or updates a document.
|
class |
RemoveMessage
A message representing event that removes or expires a document.
|
class |
SnapshotMarkerMessage
Snapshot marker.
|
class |
StreamCloseRequest |
class |
StreamEndMessage |
class |
StreamRequestRequest
Stream request.
|
Modifier and Type | Method and Description |
---|---|
DCPRequest |
DCPRequest.partition(short id)
Set the partition ID.
|
DCPRequest |
AbstractDCPRequest.partition(short partition) |
Copyright © 2017 Couchbase, Inc.. All rights reserved.