Package | Description |
---|---|
com.couchbase.client.core.dcp |
Modifier and Type | Method and Description |
---|---|
BucketStreamState |
BucketStreamAggregatorState.get(short partition)
Returns state for the vBucket
|
BucketStreamState |
BucketStreamStateUpdatedEvent.partitionState() |
BucketStreamState |
BucketStreamAggregatorState.remove(short partition) |
Modifier and Type | Method and Description |
---|---|
Iterator<BucketStreamState> |
BucketStreamAggregatorState.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
BucketStreamAggregatorState.put(BucketStreamState state)
Sets state for particular vBucket and notifies listener.
|
void |
BucketStreamAggregatorState.put(BucketStreamState state,
boolean notify)
Sets state for particular vBucket and optionally notifies listener.
|
Constructor and Description |
---|
BucketStreamStateUpdatedEvent(BucketStreamAggregatorState aggregatorState,
BucketStreamState partitionState)
Creates
BucketStreamStateUpdatedEvent which describes partial update. |
Copyright © 2015 Couchbase, Inc.. All rights reserved.