Package | Description |
---|---|
com.couchbase.client.core.dcp |
Modifier and Type | Method and Description |
---|---|
BucketStreamAggregatorState |
BucketStreamStateUpdatedEvent.aggregatorState() |
Modifier and Type | Method and Description |
---|---|
Observable<BucketStreamAggregatorState> |
BucketStreamAggregator.getCurrentState()
Retrieve current state of the partitions.
|
Modifier and Type | Method and Description |
---|---|
Observable<DCPRequest> |
BucketStreamAggregator.feed(BucketStreamAggregatorState aggregatorState)
Opens a DCP stream and returns the feed of changes.
|
Constructor and Description |
---|
BucketStreamStateUpdatedEvent(BucketStreamAggregatorState aggregatorState)
Creates
BucketStreamStateUpdatedEvent which describes full update. |
BucketStreamStateUpdatedEvent(BucketStreamAggregatorState aggregatorState,
BucketStreamState partitionState)
Creates
BucketStreamStateUpdatedEvent which describes partial update. |
Copyright © 2016 Couchbase, Inc.. All rights reserved.