org.lightcouch

Class Replicator

java.lang.Object

org.lightcouch.Replicator

public class Replicator
extends java.lang.Object

This class allows construction and sending of replication requests targeting a replicator database.

The Replicator database, by default is called _replicator was introduced in CouchDB version 1.1.0

The API supports triggering replication requests by adding a document to the replicator database, and cancelling a replication by removing the document that triggered the replication.

Usage Example:

 Response response = dbClient.replicator()
        .source("source-db")
        .target("target-db")
        .continuous(true)
        .createTarget(true)
        .replicatorDB("replicator-db-name") // optionally specify database name, defaults to _replicator
        .replicatorDocId("doc-id")          // optionally specify document id, defaults to a new UUID being assigned
        .save(); 
 
 ReplicatorDocument document = dbClient.replicator()
        .replicatorDocId("doc-id")
        .replicatorDocRev("doc-rev") // optional
        .find();
 
 List<ReplicatorDocument> docs = dbClient.replicator().findAll();
 
 
 Response response = dbClient.replicator()
        .replicatorDocId("doc-id")
        .replicatorDocRev("doc-rev")
        .remove();
 

See Also:

Replication

Constructor Summary

Constructors

Constructor and Description
Replicator(CouchDbClient dbc)

Method Summary

Methods

Modifier and Type	Method and Description
Replicator	connectionTimeout(long connectionTimeout)
Replicator	continuous(boolean continuous)
Replicator	createTarget(java.lang.Boolean createTarget)
Replicator	docIds(java.lang.String... docIds)
Replicator	filter(java.lang.String filter)
ReplicatorDocument	find() Finds a document in the replicator database.
java.util.List<ReplicatorDocument>	findAll() Finds all documents in the replicator database.
Replicator	httpConnections(int httpConnections)
Replicator	proxy(java.lang.String proxy)
Replicator	queryParams(java.util.Map<java.lang.String,java.lang.Object> queryParams)
Replicator	queryParams(java.lang.String queryParams)
Response	remove() Removes a document from the replicator database.
Replicator	replicatorDB(java.lang.String replicatorDB)
Replicator	replicatorDocId(java.lang.String replicatorDocId)
Replicator	replicatorDocRev(java.lang.String replicatorDocRev)
Replicator	retriesPerRequest(int retriesPerRequest)
Response	save() Adds a new document to the replicator database.
Replicator	sinceSeq(java.lang.Integer sinceSeq)
Replicator	source(java.lang.String source)
Replicator	target(java.lang.String target)
Replicator	userCtxName(java.lang.String userCtxName)
Replicator	userCtxRoles(java.lang.String... userCtxRoles)
Replicator	workerBatchSize(int workerBatchSize)
Replicator	workerProcesses(int workerProcesses)

Methods inherited from class java.lang.Object

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

Constructor Detail

Replicator

public Replicator(CouchDbClient dbc)

Method Detail

save

public Response save()

Adds a new document to the replicator database.

Returns:

Response

find

public ReplicatorDocument find()

Finds a document in the replicator database.

Returns:

ReplicatorDocument

findAll

public java.util.List<ReplicatorDocument> findAll()

Finds all documents in the replicator database.

remove

public Response remove()

Removes a document from the replicator database.

Returns:

Response

source

public Replicator source(java.lang.String source)

target

public Replicator target(java.lang.String target)

continuous

public Replicator continuous(boolean continuous)

filter

public Replicator filter(java.lang.String filter)

queryParams

public Replicator queryParams(java.lang.String queryParams)

queryParams

public Replicator queryParams(java.util.Map<java.lang.String,java.lang.Object> queryParams)

docIds

public Replicator docIds(java.lang.String... docIds)

proxy

public Replicator proxy(java.lang.String proxy)

createTarget

public Replicator createTarget(java.lang.Boolean createTarget)

replicatorDB

public Replicator replicatorDB(java.lang.String replicatorDB)

replicatorDocId

public Replicator replicatorDocId(java.lang.String replicatorDocId)

replicatorDocRev

public Replicator replicatorDocRev(java.lang.String replicatorDocRev)

workerProcesses

public Replicator workerProcesses(int workerProcesses)

workerBatchSize

public Replicator workerBatchSize(int workerBatchSize)

httpConnections

public Replicator httpConnections(int httpConnections)

connectionTimeout

public Replicator connectionTimeout(long connectionTimeout)

retriesPerRequest

public Replicator retriesPerRequest(int retriesPerRequest)

userCtxName

public Replicator userCtxName(java.lang.String userCtxName)

userCtxRoles

public Replicator userCtxRoles(java.lang.String... userCtxRoles)

sinceSeq

public Replicator sinceSeq(java.lang.Integer sinceSeq)