Package | Description |
---|---|
com.couchbase.client.core.dcp | |
com.couchbase.client.core.endpoint.dcp | |
com.couchbase.client.core.message.dcp |
Modifier and Type | Method and Description |
---|---|
Observable<DCPRequest> |
BucketStreamAggregator.feed()
Opens a DCP stream with default name and returns the feed of changes from beginning.
|
Observable<DCPRequest> |
BucketStreamAggregator.feed(BucketStreamAggregatorState aggregatorState)
Opens a DCP stream and returns the feed of changes.
|
Modifier and Type | Field and Description |
---|---|
PublishSubject<DCPRequest> |
DCPStream.subject |
Modifier and Type | Method and Description |
---|---|
PublishSubject<DCPRequest> |
DCPStream.subject() |
Modifier and Type | Method and Description |
---|---|
protected BinaryMemcacheRequest |
DCPHandler.encodeRequest(ChannelHandlerContext ctx,
DCPRequest msg) |
Constructor and Description |
---|
DCPHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
Queue<DCPRequest> queue,
boolean isTransient)
Creates a new
DCPHandler with a custom queue for requests (suitable for tests). |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDCPRequest
Default implementation of
DCPRequest . |
class |
MutationMessage
A message representing event that creates or updates a document.
|
class |
OpenConnectionRequest
Initiate logical DCP channel.
|
class |
RemoveMessage
A message representing event that removes or expires a document.
|
class |
SnapshotMarkerMessage
Snapshot marker.
|
class |
StreamRequestRequest
Stream request.
|
Modifier and Type | Method and Description |
---|---|
DCPRequest |
DCPRequest.partition(short id)
Set the partition ID.
|
DCPRequest |
AbstractDCPRequest.partition(short partition) |
Modifier and Type | Method and Description |
---|---|
Observable<DCPRequest> |
StreamRequestResponse.stream() |
Constructor and Description |
---|
StreamRequestResponse(ResponseStatus status,
Observable<DCPRequest> stream,
List<FailoverLogEntry> failoverLog,
CouchbaseRequest request,
long rollbackToSequenceNumber)
Sets the required properties for the response.
|
Copyright © 2015 Couchbase, Inc.. All rights reserved.