Code

Cassandra snapshot store#532

Code

Draft

rtar wants to merge 65 commits intomasterevolution-gaming/kafka-journal:masterfrom snapshotevolution-gaming/kafka-journal:snapshotCopy head branch name to clipboard

+2,042-5

Commits

Commits on Jun 28, 2024

• WIP: Snapshot statements.

  Show description for 14176a4
  rtar

  committed
  14176a4

• Remove headers and tags.

  Show description for c14de14
  rtar

  committed
  c14de14

• Delete record instead of changing the status.

  Show description for 79330f2
  rtar

  committed
  79330f2

• Add snapshots into schema creation.

  Show description for e086b15
  rtar

  committed
  e086b15

• Experiment with API

  Show description for 8b2e1a2
  rtar

  committed
  8b2e1a2

• Placeholder for a store implementation.

  rtar

  committed
  f34c307

• Insert funnciton (without retries)

  Show description for 7e2f415
  rtar

  committed
  7e2f415

• Add unsafe update function.

  rtar

  committed
  5874e6e

• Add unit test for save and load.

  rtar

  committed
  f2d2be5

• Rename test to adhere to naming convention.

  rtar

  committed
  2906d24

• Some working tests are added.

  rtar

  committed
  495203f

• Reflect potential concurrency issue in the test.

  rtar

  committed
  a0723cd

• Add naive drop implementation.

  rtar

  committed
  587bbc6

• Add test for drop methods.

  rtar

  committed
  0b71740

• Start working on snapshot adapter.

  Show description for a909f1d
  rtar

  committed
  a909f1d

• Save should, probably, be idempotent.

  rtar

  committed
  4f12c01

• Avoid snapshot overwrite with IF/IF NOT EXISTS condition.

  Show description for a9191ea
  rtar

  committed
  a9191ea

• A bit more modern code style.

  rtar

  committed
  bcb6a69

• Trivial implementation of #save method.

  rtar

  committed
  c29df98

• Naive implementation of snapshot store adapter.

  rtar

  committed
  bb29464

• Add snapshot constructor.

  rtar

  committed
  5fa8754

• Add constructor for SnapshotStoreAdapter.

  rtar

  committed
  855b545

• Add adapter factories.

  rtar

  committed
  3304898

• Add adapter instance.

  rtar

  committed
  e5da5af

• Implement snapshot store API.

  rtar

  committed
  915f640

• Add integration test.

  rtar

  committed
  b73e848

• Minimal implementation (TCK not passing yet)

  rtar

  committed
  63ecca5

• Update the snapshot with the same SeqNr according to TCK

  rtar

  committed
  2518787

• Snapshot TCK is passing now.

  rtar

  committed
  a878be4

• Enable running Cassandra before test runs.

  rtar

  committed
  edc45a1

• Fix ordering issue found by performance tests.

  rtar

  committed
  87d940d

• Snapshot store performance test.

  rtar

  committed
  816c919

• Add a performance test for Akka Persistence Cassandra to compare.

  rtar

  committed
  a282309

• Reduce number of configuration files.

  rtar

  committed
  4f1838d

• Use LWT when deleting a row.

  rtar

  committed
  b35cd84

• Revert "Use LWT when deleting a row."

  Show description for 837a54c
  rtar

  committed
  837a54c

• Revert "Revert "Use LWT when deleting a row.""

  Show description for 5fdc2e9
  rtar

  committed
  5fdc2e9

• Fix broken test.

  rtar

  committed
  590b371

• Address review comments.

  rtar

  committed
  d9a4753

• Use a new table name to avoid conflict with Akka Persistence Cassandra.

  rtar

  committed
  6ebea73

• Remove segmentNr, because each set of snapshots per key is expected to

  Show description for 965f2e7
  rtar

  committed
  965f2e7

• Fixed broken test.

  rtar

  committed
  f10b5cc

• Remove question mark for segmentNr.

  rtar

  committed
  55a0493

• Use correct table name.

  Show description for c0b4f88
  rtar

  committed
  c0b4f88

• Use correct column index for bufferNr

  rtar

  committed
  d5a946b

• Separate CassandraSnapshotStoreConfig from KafkaJournalConfig.

  rtar

  committed
  9a6d994

• Fix compilation issues after rebase

  rtar

  committed
  5e05686

• Introduce "snapshot-cassandra" module.

  Show description for edd6aad
  rtar

  committed
  edd6aad

• Remove unnecessary changes.

  rtar

  committed
  db90f9e

• Minimize number of changes.

  rtar

  committed
  e9babc9

• Fixed file names.

  rtar

  committed
  37ecc8c

• Simplified method signatures.

  rtar

  committed
  74345c6

• Removed unnecessary copy-paste.

  rtar

  committed
  26fe488

• Fixed issues caused by merge conflicts.

  rtar

  committed
  8d2e676

• Simplify CreateSnapshotSchema.

  rtar

  committed
  d76d18e

• Remove obsolete test.

  rtar

  committed
  9cce3d5

• Minimize number of changes.

  rtar

  committed
  4eb4bf8

• Remove option wrapper around a payload.

  Show description for d9089a8
  rtar

  committed
  d9089a8

• Add scaladoc for SnapshotStoreFlat.

  rtar

  committed
  a99b355

• Replace drop with delete to adhere to Akka naming convention.

  rtar

  committed
  65697d9

• Rename SnapshotStoreFlat to SnapshotStore.

  Show description for 17807a6
  rtar

  committed
  17807a6

• Add scaladoc for SnapshotSerializer.

  rtar

  committed
  8fecd15

• Fix compliation issues after rebase.

  rtar

  committed
  1a425e7

• Disable LWTs by default.

  rtar

  committed
  adb39a9

• Print out fractional part of the duration.

  rtar

  committed
  c04b508