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()
Deprecated.
|
rx.subjects.Subject<DCPRequest,DCPRequest> |
DCPConnection.subject()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected BinaryMemcacheRequest |
DCPHandler.encodeRequest(ChannelHandlerContext ctx,
DCPRequest msg)
Deprecated.
|
Constructor and Description |
---|
DCPConnection(CoreEnvironment env,
ClusterFacade core,
String bucket,
String password,
rx.subjects.SerializedSubject<DCPRequest,DCPRequest> subject)
Deprecated.
|
DCPConnection(CoreEnvironment env,
ClusterFacade core,
String bucket,
String password,
rx.subjects.SerializedSubject<DCPRequest,DCPRequest> subject)
Deprecated.
|
DCPHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
Queue<DCPRequest> queue,
boolean isTransient,
boolean pipeline)
Deprecated.
Creates a new
DCPHandler with a custom queue for requests (suitable for tests). |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDCPMessage
Deprecated.
|
class |
AbstractDCPRequest
Deprecated.
|
class |
ExpirationMessage
Deprecated.
|
class |
GetFailoverLogRequest
Deprecated.
|
class |
GetLastCheckpointRequest
Deprecated.
|
class |
MutationMessage
Deprecated.
|
class |
RemoveMessage
Deprecated.
|
class |
SnapshotMarkerMessage
Deprecated.
|
class |
StreamCloseRequest
Deprecated.
|
class |
StreamEndMessage
Deprecated.
|
class |
StreamRequestRequest
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
DCPRequest |
DCPRequest.partition(short id)
Deprecated.
Set the partition ID.
|
DCPRequest |
AbstractDCPRequest.partition(short partition)
Deprecated.
|
Copyright © 2017 Couchbase, Inc.. All rights reserved.