feat: Start projection from custom offset #934
Conversation
* support a way for the user to define the offset that is used when starting the Projection * optionally load the existing stored offset and pass that to the user function * some rather messy jugling of SourceProvider adapters
akka-projection-core/src/main/scala/akka/projection/scaladsl/SourceProvider.scala
Outdated
Show resolved
Hide resolved
...-eventsourced/src/main/scala/akka/projection/eventsourced/javadsl/EventSourcedProvider.scala
Outdated
Show resolved
Hide resolved
akka-projection-core/src/main/scala/akka/projection/scaladsl/SourceProvider.scala
Outdated
Show resolved
Hide resolved
akka-projection-core/src/main/scala/akka/projection/scaladsl/SourceProvider.scala
Outdated
Show resolved
Hide resolved
akka-projection-core/src/main/scala/akka/projection/scaladsl/SourceProvider.scala
Outdated
Show resolved
Hide resolved
|
I think I have a better idea for how to do this, closing until updated. |
| */ | ||
| final class CustomStartOffsetSourceProvider[Offset, Envelope]( | ||
| loadFromOffsetStore: Boolean, | ||
| adjustStartOffset: Option[Offset] => Future[Option[Offset]], |
There was a problem hiding this comment.
The idea is that the user would decorate the ordinary SourceProvider by wrapping it with this
| @InternalApi private[projection] object BySliceSourceProviderAdapter { | ||
| def apply[Offset, Envelope]( | ||
| sourceProvider: javadsl.SourceProvider[Offset, Envelope]): scaladsl.SourceProvider[Offset, Envelope] = | ||
| sourceProvider match { |
There was a problem hiding this comment.
this javadsl -> scaladsl adapter is still rather messy, but need to unwrap the CustomStartOffsetSourceProvider decoration and implement it here instead to keep the BySlicesSourceProvider type
There was a problem hiding this comment.
Actually, it will be a problem also for the normal scaladsl case. I'll have to take another look at that.
|
This will not fly because of the optional traits that we look for: BySlicesSourceProvider, EventTimestampQuery, LoadEventQuery I'll open a new PR with a different approach. |
On top of #933