public class ReplicationQueueFileBased extends java.lang.Object implements ReplicationQueue
Title: Dataspace Framework
Description: Replication queue based on file queue implementation.
Copyright: Copyright (c) 2018
Company: StreamScape Technologies
Modifier and Type | Class and Description |
---|---|
class |
ReplicationQueueFileBased.ReplicationProcessor |
static class |
ReplicationQueueFileBased.ReplicationQueueFilenameProvider |
static class |
ReplicationQueueFileBased.ReplicationQueueReplicationIdComparator |
static class |
ReplicationQueueFileBased.ReplicationQueueReplicationIdIndexes |
ReplicationQueue.QueueType, ReplicationQueue.ReplicationQueueSettings
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
REPLICATION_FILES_DIRECTORY |
QUEUE_PREFIX
Constructor and Description |
---|
ReplicationQueueFileBased(com.streamscape.ds.AbstractDataspace dataspace,
ReplicationManager replicationManager,
ReplicationSource source,
ReplicationQueue.ReplicationQueueSettings settings) |
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() |
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) |
void |
resetDeliveryMetrics() |
void |
rollback() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getQueueFullName, getQueueFullNameNoNodeName, getQueueName, getQueueName, removeDataspaceTypeFromName, startsWithDataspaceType
public static final java.lang.String REPLICATION_FILES_DIRECTORY
public ReplicationQueueFileBased(com.streamscape.ds.AbstractDataspace dataspace, ReplicationManager replicationManager, ReplicationSource source, ReplicationQueue.ReplicationQueueSettings settings)
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface ReplicationQueue
public void compileInternalStatements(com.streamscape.ds.session.Session session)
compileInternalStatements
in interface ReplicationQueue
public void open(com.streamscape.ds.session.Session session)
open
in interface ReplicationQueue
public void close()
close
in interface ReplicationQueue
public void destroy()
destroy
in interface ReplicationQueue
public void onRename(com.streamscape.ds.session.Session session)
onRename
in interface ReplicationQueue
public Table getReplicationQueueStorage()
getReplicationQueueStorage
in interface ReplicationQueue
public void enqueue(com.streamscape.ds.session.Session session, ReplicationDataTransaction replicationDataTransaction)
enqueue
in interface ReplicationQueue
public void commit()
commit
in interface ReplicationQueue
public void rollback()
rollback
in interface ReplicationQueue
public void onAfterCommit()
onAfterCommit
in interface ReplicationQueue
public java.util.List listAttachedReplicas()
listAttachedReplicas
in interface ReplicationQueue
public void attachOrUpdateReplica(ReplicationRequest request, RequestConsumerReference replicaRequestConsumer)
attachOrUpdateReplica
in interface ReplicationQueue
public void attachReplica(ReplicaInfo attachedReplica, RequestConsumerReference replicaRequestConsumer)
attachReplica
in interface ReplicationQueue
public boolean detachReplica(ReplicationEntityName entityName, long timestamp, boolean withRemove)
detachReplica
in interface ReplicationQueue
public int deleteAcknowledgedDataFromReplicationQueue(com.streamscape.ds.session.Session session, com.streamscape.ds.parser.statement.Statement statement)
deleteAcknowledgedDataFromReplicationQueue
in interface ReplicationQueue
public ReplicationSource.ReplicationError getReplicationErrors()
getReplicationErrors
in interface ReplicationQueue
public java.util.Map getMetricsReportMap()
getMetricsReportMap
in interface ReplicationQueue
public void resetDeliveryMetrics()
resetDeliveryMetrics
in interface ReplicationQueue
public void alterReplicationQueue(ReplicationQueue.ReplicationQueueSettings replicationQueueSettingsNew)
alterReplicationQueue
in interface ReplicationQueue
public long getLastTimeQueueCleaned()
getLastTimeQueueCleaned
in interface ReplicationQueue
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.