public class Replicator extends Object
A replication is triggered by persisting a document, and cancelled by removing the document that triggered the replication.
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
CouchDbClientBase.replicator()
,
Replication
,
ReplicatorDocument
Constructor and Description |
---|
Replicator(CouchDbClientBase dbc) |
public Replicator(CouchDbClientBase dbc)
public ReplicatorDocument find()
ReplicatorDocument
public List<ReplicatorDocument> findAll()
public Replicator source(String source)
public Replicator target(String target)
public Replicator continuous(boolean continuous)
public Replicator filter(String filter)
public Replicator queryParams(String queryParams)
public Replicator queryParams(Map<String,Object> queryParams)
public Replicator docIds(String... docIds)
public Replicator proxy(String proxy)
public Replicator createTarget(Boolean createTarget)
public Replicator replicatorDB(String replicatorDB)
public Replicator replicatorDocId(String replicatorDocId)
public Replicator replicatorDocRev(String replicatorDocRev)
public Replicator workerProcesses(int workerProcesses)
public Replicator workerBatchSize(int workerBatchSize)
public Replicator httpConnections(int httpConnections)
public Replicator connectionTimeout(long connectionTimeout)
public Replicator retriesPerRequest(int retriesPerRequest)
public Replicator userCtxName(String userCtxName)
public Replicator userCtxRoles(String... userCtxRoles)
public Replicator sinceSeq(Integer sinceSeq)
Copyright © 2011–2016. All rights reserved.