public class Replicator
extends java.lang.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) |
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.String 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) |
public Replicator(CouchDbClientBase dbc)
public ReplicatorDocument find()
ReplicatorDocument
public java.util.List<ReplicatorDocument> findAll()
ReplicatorDocument
public Replicator source(java.lang.String source)
public Replicator target(java.lang.String target)
public Replicator continuous(boolean continuous)
public Replicator filter(java.lang.String filter)
public Replicator queryParams(java.lang.String queryParams)
public Replicator queryParams(java.util.Map<java.lang.String,java.lang.Object> queryParams)
public Replicator docIds(java.lang.String... docIds)
public Replicator proxy(java.lang.String proxy)
public Replicator createTarget(java.lang.Boolean createTarget)
public Replicator replicatorDB(java.lang.String replicatorDB)
public Replicator replicatorDocId(java.lang.String replicatorDocId)
public Replicator replicatorDocRev(java.lang.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(java.lang.String userCtxName)
public Replicator userCtxRoles(java.lang.String... userCtxRoles)
public Replicator sinceSeq(java.lang.String sinceSeq)
Copyright © 2011-2017. All Rights Reserved.