public interface CassandraReplicatedStatements
extends akka.persistence.cassandra.journal.CassandraStatements
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
createNotificationKeyspace(java.lang.String keyspaceName,
java.lang.String replicationStrategy) |
java.lang.String |
createNotificationTable() |
scala.concurrent.Future<akka.Done> |
executeAsyncCreateNotificationKeyspace(com.datastax.driver.core.Session session,
scala.concurrent.ExecutionContext ec) |
scala.concurrent.Future<akka.Done> |
executeCreateKeyspaceAndTables(com.datastax.driver.core.Session session,
akka.persistence.cassandra.journal.CassandraJournalConfig config,
scala.concurrent.ExecutionContext ec) |
MultiDcConfig |
multiDcConfig() |
java.lang.String |
notificationTableName() |
java.lang.String |
readNotification() |
scala.concurrent.Future<akka.Done> |
super$executeCreateKeyspaceAndTables(com.datastax.driver.core.Session session,
akka.persistence.cassandra.journal.CassandraJournalConfig config,
scala.concurrent.ExecutionContext ec) |
java.lang.String |
writeNotification() |
addTagsToMessagesTable, config, createKeyspace, createMetadataTable, createTable, createTagScanningTable, createTagsProgressTable, createTagsTable, deleteDeletedTo, deleteMessage, deleteMessages, insertDeletedTo, selectDeletedTo, selectHighestSequenceNr, selectMessages, selectTagPidSequenceNr, selectTagProgress, selectTagProgressForPersistenceId, selectTagScanningForPersistenceId, tableName, updateMessagePayloadAndTags, updateMessagePayloadInTagView, writeInUse, writeMessage, writeTagProgress, writeTags, writeTagScanningjava.lang.String createNotificationKeyspace(java.lang.String keyspaceName,
java.lang.String replicationStrategy)
java.lang.String createNotificationTable()
scala.concurrent.Future<akka.Done> executeAsyncCreateNotificationKeyspace(com.datastax.driver.core.Session session,
scala.concurrent.ExecutionContext ec)
scala.concurrent.Future<akka.Done> executeCreateKeyspaceAndTables(com.datastax.driver.core.Session session,
akka.persistence.cassandra.journal.CassandraJournalConfig config,
scala.concurrent.ExecutionContext ec)
executeCreateKeyspaceAndTables in interface akka.persistence.cassandra.journal.CassandraStatementsMultiDcConfig multiDcConfig()
java.lang.String notificationTableName()
java.lang.String readNotification()
scala.concurrent.Future<akka.Done> super$executeCreateKeyspaceAndTables(com.datastax.driver.core.Session session,
akka.persistence.cassandra.journal.CassandraJournalConfig config,
scala.concurrent.ExecutionContext ec)
java.lang.String writeNotification()