Wip event deletion

src/main/resources/reference.conf

@@ -2,4 +2,8 @@ sandbox.replication {
   ask-timeout = 10s
   retry-delay = 200ms
   batch-size = 10
+}
+
+sandbox.log {
+  delete.retry-delay = 200ms
 }

src/main/scala/com/rbmhtechnology/eventuate/sandbox/Event.scala

@@ -1,6 +1,6 @@
 package com.rbmhtechnology.eventuate.sandbox
 
-case class EventMetadata(emitterId: String, emitterLogId: String, localLogId: String, localSequenceNr: Long, vectorTimestamp: VectorTime)
+case class EventMetadata(emitterId: String, emitterLogId: String, localLogId: String, localSequenceNo: Long, vectorTimestamp: VectorTime)
 case class PayloadVersion(majorVersion: Int, minorVersion: Int)
 case class EventManifest(schema: String, isStringManifest: Boolean, payloadVersion: Option[PayloadVersion])
 case class EventBytes(bytes: Array[Byte], serializerId: Int, manifest: EventManifest)
@@ -20,17 +20,17 @@ object DecodedEvent {
 case class DecodedEvent(metadata: EventMetadata, payload: AnyRef) extends DurableEvent
 
 case class EncodedEvent(metadata: EventMetadata, payload: EventBytes) extends DurableEvent {
-  def emitted(localLogId: String, localSequenceNr: Long): EncodedEvent = {
+  def emitted(localLogId: String, localSequenceNo: Long): EncodedEvent = {
     copy(metadata.copy(
       emitterLogId = localLogId,
       localLogId = localLogId,
-      localSequenceNr = localSequenceNr,
-      vectorTimestamp = metadata.vectorTimestamp.setLocalTime(localLogId, localSequenceNr)))
+      localSequenceNo = localSequenceNo,
+      vectorTimestamp = metadata.vectorTimestamp.setLocalTime(localLogId, localSequenceNo)))
   }
 
-  def replicated(localLogId: String, localSequenceNr: Long): EncodedEvent = {
+  def replicated(localLogId: String, localSequenceNo: Long): EncodedEvent = {
     copy(metadata.copy(
       localLogId = localLogId,
-      localSequenceNr = localSequenceNr))
+      localSequenceNo = localSequenceNo))
   }
 }