com.couchbase.client.java.bucket

Class ReplicaReader

java.lang.Object

com.couchbase.client.java.bucket.ReplicaReader

@InterfaceStability.Uncommitted
 @InterfaceAudience.Private
public class ReplicaReader
extends Object

Helper class to deal with reading from zero to N replicas and returning results.

Since:

2.1.4

Author:

Michael Nitschinger

Constructor Summary

Constructors

Constructor and Description
ReplicaReader()

Method Summary

Modifier and Type	Method and Description
static Observable<GetResponse>	read(ClusterFacade core, String id, ReplicaMode type, String bucket) Perform replica reads to as many nodes a possible based on the given ReplicaMode.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReplicaReader

public ReplicaReader()

Method Detail

read

public static Observable<GetResponse> read(ClusterFacade core,
                                           String id,
                                           ReplicaMode type,
                                           String bucket)

Perform replica reads to as many nodes a possible based on the given ReplicaMode.

Individual errors are swallowed, but logged.

Parameters:

core - the core reference.

id - the id of the document to load from the replicas.

type - the replica mode type.

bucket - the name of the bucket to load it from.

Returns:

a potentially empty observable with the returned raw responses.