static ReplicationResponse |
ReplicationUtil.addReplicaToSource(com.streamscape.ds.session.Session session,
ReplicationEntityName sourceEntityName,
ReplicationEntityName targetEntityName) |
boolean |
ReplicationQueueFileBased.detachReplica(ReplicationEntityName entityName,
long timestamp,
boolean withRemove) |
boolean |
ReplicationQueue.detachReplica(ReplicationEntityName entityName,
long timestamp,
boolean withRemove) |
void |
ReplicationSource.detachReplica(ReplicationEntityName replicaEntityName,
com.streamscape.ds.session.Session requestSession,
boolean withRemove,
long timestamp) |
void |
ReplicationSource.detachReplicaIfAttached(ReplicationEntityName replicaEntityName,
com.streamscape.ds.session.Session requestSession,
boolean withRemove,
long timestamp) |
boolean |
ReplicationEntityName.equalsNoCollection(ReplicationEntityName replica) |
void |
ReplicationSource.evictReplica(ReplicationEntityName replicaEntityName,
com.streamscape.ds.session.Session requestSession) |
static ReplicationResponse |
ReplicationUtil.getReplicaInfo(com.streamscape.ds.session.Session session,
ReplicationEntityName replicaEntityName,
boolean withMetrics) |
static ReplicationResponse |
ReplicationUtil.getSourceDefinition(com.streamscape.ds.session.Session session,
ReplicationEntityName sourceEntityName,
ReplicationEntityName replicaEntityName,
boolean global,
boolean withMetrics) |
static ReplicationResponse |
ReplicationUtil.getSourceReplicationId(com.streamscape.ds.session.Session session,
com.streamscape.ds.AbstractDataspace dataspace,
ReplicationEntityName sourceEntityName,
ReplicationEntityName targetEntityName) |
static ReplicationResponse |
ReplicationUtil.getSourceReplicationId(com.streamscape.ds.session.Session session,
ReplicationEntityName sourceEntityName,
ReplicationEntityName targetEntityName) |
void |
ReplicationSource.raiseReplicaStateChangeAdvisory(ReplicationEntityName replicaEntityName,
ReplicaState replicaState,
boolean isSuspended,
long replicationId) |
boolean |
ReplicationSource.raiseReplicationException(ReplicationEntityName replicaEntityName,
long replicationId,
java.lang.Throwable exception,
boolean withExpiration) |
void |
ReplicationSource.raiseTimeoutAdvisory(ReplicationEntityName replicaEntityName,
long timeout,
ReplicationDataBatch batch) |
ReplicationResponse |
ReplicationManager.sendReplicationManagementRequest(ReplicationRequest request,
ReplicationEntityName to) |
ReplicationResponse |
ReplicationManager.sendReplicationManagementRequest(ReplicationRequest request,
ReplicationEntityName to,
long timeout) |
static ReplicationResponse |
ReplicationManager.sendReplicationManagementRequestGlobal(ReplicationRequest request,
ReplicationEntityName to) |
static ReplicationResponse |
ReplicationManager.sendReplicationManagementRequestGlobal(ReplicationRequest request,
ReplicationEntityName to,
long timeout) |
void |
ReplicationSource.sendSourceUpdatedForReplica(com.streamscape.ds.session.Session session,
ReplicationEntityName replicaEntityName) |
static ReplicationResponse |
ReplicationUtil.sendSqlRequestTo(com.streamscape.ds.session.Session session,
ReplicationEntityName toEntityName,
java.lang.String sql) |
void |
ReplicationRequest.setReplicaEntityName(ReplicationEntityName replicaEntityName) |
void |
ReplicaInfo.setReplicaEntityName(ReplicationEntityName replicaEntityName) |
void |
ReplicationTarget.setSourceEntityName(ReplicationEntityName sourceEntityName) |
void |
ReplicaInfo.setSourceEntityName(ReplicationEntityName sourceEntityName) |