Rename SnapshotStoreFlat to SnapshotStore.

The reason behind this is that there won't be a flat counterpart of the store. It will be the only one.
evolution-gaming · Feb 15, 2024 · 3dcd233 · 3dcd233
1 parent cfe3861
commit 3dcd233
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 64 deletions.
diff --git a/persistence/src/main/scala/akka/persistence/kafka/journal/SnapshotStoreAdapter.scala b/persistence/src/main/scala/akka/persistence/kafka/journal/SnapshotStoreAdapter.scala
@@ -38,7 +38,7 @@ object SnapshotStoreAdapter {
   ): Resource[F, SnapshotStoreAdapter[F]] = {
 
     def adapter(
-      store: SnapshotStoreFlat[F]
+      store: SnapshotStore[F]
     )(implicit snapshotSerializer: SnapshotSerializer[F, A], snapshotReadWrite: SnapshotReadWrite[F, A]) =
       SnapshotStoreAdapter(store, toKey, origin)
 
@@ -47,7 +47,7 @@ object SnapshotStoreAdapter {
     } yield adapter(store)(snapshotSerializer, snapshotReadWrite)
   }
 
-  def apply[F[_]: Monad: Fail, A](store: SnapshotStoreFlat[F], toKey: ToKey[F], origin: Option[Origin])(implicit
+  def apply[F[_]: Monad: Fail, A](store: SnapshotStore[F], toKey: ToKey[F], origin: Option[Origin])(implicit
     snapshotSerializer: SnapshotSerializer[F, A],
     snapshotReadWrite: SnapshotReadWrite[F, A]
   ): SnapshotStoreAdapter[F] =

diff --git a/...c/main/scala/com/evolutiongaming/kafka/journal/snapshot/cassandra/SnapshotCassandra.scala b/...c/main/scala/com/evolutiongaming/kafka/journal/snapshot/cassandra/SnapshotCassandra.scala
@@ -18,7 +18,7 @@ object SnapshotCassandra {
     config: SnapshotCassandraConfig,
     origin: Option[Origin],
     cassandraClusterOf: CassandraClusterOf[F]
-  ): Resource[F, SnapshotStoreFlat[F]] = {
+  ): Resource[F, SnapshotStore[F]] = {
 
     def store(implicit cassandraCluster: CassandraCluster[F], cassandraSession: CassandraSession[F]) =
       of(config.schema, origin, config.consistencyConfig, config.numberOfSnapshots)
@@ -36,16 +36,16 @@ object SnapshotCassandra {
     origin: Option[Origin],
     consistencyConfig: CassandraConsistencyConfig,
     numberOfSnapshots: Int
-  ): F[SnapshotStoreFlat[F]] =
+  ): F[SnapshotStore[F]] =
     for {
       schema <- SetupSnapshotSchema[F](schemaConfig, origin, consistencyConfig)
       statements <- Statements.of[F](schema, consistencyConfig)
     } yield SnapshotCassandra(statements, numberOfSnapshots)
 
   private sealed abstract class Main
 
-  def apply[F[_]: MonadThrow](statements: Statements[F], numberOfSnapshots: Int): SnapshotStoreFlat[F] = {
-    new Main with SnapshotStoreFlat[F] {
+  def apply[F[_]: MonadThrow](statements: Statements[F], numberOfSnapshots: Int): SnapshotStore[F] = {
+    new Main with SnapshotStore[F] {
 
       def save(key: Key, snapshot: SnapshotRecord[EventualPayloadAndType]): F[Unit] = {
         statements.selectMetadata(key).flatMap {

diff --git a/snapshot/src/main/scala/com/evolutiongaming/kafka/journal/SnapshotStoreFlat.scala b/snapshot/src/main/scala/com/evolutiongaming/kafka/journal/SnapshotStoreFlat.scala