public interface ReplicationQueue
Title: Dataspace Framework
Description: Replication queue interface.
Copyright: Copyright (c) 2018
Company: StreamScape Technologies
Modifier and Type | Interface and Description |
---|---|
static class |
ReplicationQueue.QueueType |
static class |
ReplicationQueue.ReplicationQueueSettings |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
QUEUE_PREFIX |
Modifier and Type | Method and Description |
---|---|
void |
alterReplicationQueue(ReplicationQueue.ReplicationQueueSettings replicationQueueSettingsNew) |
void |
attachOrUpdateReplica(ReplicationRequest request,
RequestConsumerReference replicaRequestConsumer) |
void |
attachReplica(ReplicaInfo attachedReplica,
RequestConsumerReference replicaRequestConsumer) |
void |
close() |
void |
commit() |
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
void |
compileInternalStatements(com.streamscape.ds.session.Session session) |
int |
deleteAcknowledgedDataFromReplicationQueue(com.streamscape.ds.session.Session session,
com.streamscape.ds.parser.statement.Statement statement) |
void |
destroy() |
boolean |
detachReplica(ReplicationEntityName entityName,
long timestamp,
boolean withRemove) |
void |
enqueue(com.streamscape.ds.session.Session session,
ReplicationDataTransaction replicationDataTransaction) |
long |
getLastTimeQueueCleaned() |
java.util.Map |
getMetricsReportMap() |
static java.lang.String |
getQueueFullName(java.lang.String nodeName,
java.lang.String dataspaceType,
java.lang.String dataspaceName,
java.lang.String sourceName) |
static java.lang.String |
getQueueFullNameNoNodeName(java.lang.String dataspaceName,
java.lang.String sourceName) |
static java.lang.String |
getQueueName(java.lang.String dataspaceName,
java.lang.String sourceName) |
static java.lang.String |
getQueueName(java.lang.String dataspaceType,
java.lang.String dataspaceName,
java.lang.String sourceName) |
ReplicationSource.ReplicationError |
getReplicationErrors() |
Table |
getReplicationQueueStorage() |
java.util.List |
listAttachedReplicas() |
void |
onAfterCommit() |
void |
onRename(com.streamscape.ds.session.Session session) |
void |
open(com.streamscape.ds.session.Session session) |
static java.lang.String |
removeDataspaceTypeFromName(java.lang.String name) |
void |
resetDeliveryMetrics() |
void |
rollback() |
static int |
startsWithDataspaceType(java.lang.String name) |
static final java.lang.String QUEUE_PREFIX
void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
void compileInternalStatements(com.streamscape.ds.session.Session session)
void open(com.streamscape.ds.session.Session session)
void close()
void destroy()
void onRename(com.streamscape.ds.session.Session session)
Table getReplicationQueueStorage()
void enqueue(com.streamscape.ds.session.Session session, ReplicationDataTransaction replicationDataTransaction)
void commit()
void rollback()
void onAfterCommit()
void attachOrUpdateReplica(ReplicationRequest request, RequestConsumerReference replicaRequestConsumer)
void attachReplica(ReplicaInfo attachedReplica, RequestConsumerReference replicaRequestConsumer)
boolean detachReplica(ReplicationEntityName entityName, long timestamp, boolean withRemove)
java.util.List listAttachedReplicas()
int deleteAcknowledgedDataFromReplicationQueue(com.streamscape.ds.session.Session session, com.streamscape.ds.parser.statement.Statement statement)
long getLastTimeQueueCleaned()
ReplicationSource.ReplicationError getReplicationErrors()
java.util.Map getMetricsReportMap()
void resetDeliveryMetrics()
void alterReplicationQueue(ReplicationQueue.ReplicationQueueSettings replicationQueueSettingsNew)
static java.lang.String getQueueName(java.lang.String dataspaceName, java.lang.String sourceName)
static java.lang.String getQueueName(java.lang.String dataspaceType, java.lang.String dataspaceName, java.lang.String sourceName)
static java.lang.String getQueueFullNameNoNodeName(java.lang.String dataspaceName, java.lang.String sourceName)
static java.lang.String getQueueFullName(java.lang.String nodeName, java.lang.String dataspaceType, java.lang.String dataspaceName, java.lang.String sourceName)
static java.lang.String removeDataspaceTypeFromName(java.lang.String name)
static int startsWithDataspaceType(java.lang.String name)
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.