org.lightcouch

Class Replicator

java.lang.Object

org.lightcouch.Replicator

public class Replicator
extends java.lang.Object

This class provides access to the _replicator database introduced in CouchDB version 1.1.0

A replication is triggered by persisting a document, and cancelled 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") // optional, defaults to _replicator
        .replicatorDocId("doc-id")          // optional, defaults to UUID 
        .save(); // trigger replication
 
 ReplicatorDocument replicatorDoc = dbClient.replicator()
        .replicatorDocId("doc-id")
        .replicatorDocRev("doc-rev") // optional
        .find();
 
  
 List<ReplicatorDocument> replicatorDocs = dbClient.replicator().findAll();
 
 
 Response response = dbClient.replicator()
        .replicatorDocId("doc-id")
        .replicatorDocRev("doc-rev")
        .remove(); // cancels a replication
 

Since:

0.0.2

See Also:

CouchDbClientBase.replicator(), Replication, ReplicatorDocument

Field Summary

Fields

Modifier and Type	Field and Description
private CouchDbClientBase	dbc
private java.net.URI	dbURI
private java.lang.String	replicatorDB
private ReplicatorDocument	replicatorDoc
private java.lang.String	userCtxName
private java.lang.String[]	userCtxRoles

Constructor Summary

Constructors

Constructor and Description
Replicator(CouchDbClientBase dbc)

Method Summary

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

Field Detail

replicatorDB

private java.lang.String replicatorDB

userCtxName

private java.lang.String userCtxName

userCtxRoles

private java.lang.String[] userCtxRoles

dbc

private CouchDbClientBase dbc

replicatorDoc

private ReplicatorDocument replicatorDoc

dbURI

private java.net.URI dbURI

Constructor Detail

Replicator

public Replicator(CouchDbClientBase 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)