This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch port/d1e577a8ba-app-version-deploy-doc
in repository https://gitbox.apache.org/repos/asf/pekko.git
omit 7bd6b04cb7 docs: point pekko-management extref to snapshot docs
omit 67a26f4eb3 docs: link to app-version from Deployment for rolling
updates
add 5d1b67dedf docs: document preMaterialize error-propagation caveat
(#3272)
add b9bd7d0f5a feat: add FilteredPayload placeholder for filtered journal
events (#3275)
add 05b300dafb Port scalable fan-out persistence query abstraction from
Akka (#3277)
add 26c5086c7c docs: how to write a custom Durable State store plugin
(#3274)
add 21ed4f3683 docs: link to app-version from Deployment for rolling
updates
add c0e7a0fdce docs: point pekko-management extref to snapshot docs
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (7bd6b04cb7)
\
N -- N -- N refs/heads/port/d1e577a8ba-app-version-deploy-doc
(c0e7a0fdce)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../docs/persistence/state/MyJavaStateStore.java | 77 ++
.../state/MyJavaStateStoreProvider.java | 45 ++
.../paradox/durable-state/state-store-plugin.md | 45 ++
docs/src/main/paradox/persistence-query.md | 4 +-
.../stream/operators/Sink/preMaterialize.md | 3 +
.../operators/Source-or-Flow/preMaterialize.md | 4 +
.../typed/index-persistence-durable-state.md | 1 +
.../docs/persistence/state/MyStateStore.scala | 71 ++
.../state/PersistenceStatePluginDocSpec.scala | 83 ++
.../src/main/resources/reference.conf | 53 ++
.../persistence/query/typed/EventEnvelope.scala | 18 +-
.../EventsBySliceFirehoseReadJournalProvider.scala | 33 +
.../typed/internal/EventsBySliceFirehose.scala | 839 +++++++++++++++++++++
...ByPersistenceIdStartingFromSnapshotQuery.scala} | 16 +-
...tEventsBySliceStartingFromSnapshotsQuery.scala} | 20 +-
...ByPersistenceIdStartingFromSnapshotQuery.scala} | 16 +-
.../typed/javadsl/EventsBySliceFirehoseQuery.scala | 95 +++
.../query/typed/javadsl/EventsBySliceQuery.scala | 2 +
... EventsBySliceStartingFromSnapshotsQuery.scala} | 22 +-
...ByPersistenceIdStartingFromSnapshotQuery.scala} | 16 +-
...tEventsBySliceStartingFromSnapshotsQuery.scala} | 20 +-
...ByPersistenceIdStartingFromSnapshotQuery.scala} | 16 +-
.../scaladsl/EventsBySliceFirehoseQuery.scala | 119 +++
.../query/typed/scaladsl/EventsBySliceQuery.scala | 2 +
... EventsBySliceStartingFromSnapshotsQuery.scala} | 22 +-
.../apache/pekko/persistence/query/TestClock.scala | 59 ++
.../query/typed/EventEnvelopeSpec.scala | 53 ++
.../typed/internal/EventsBySliceFirehoseSpec.scala | 440 +++++++++++
persistence/src/main/resources/reference.conf | 3 +
.../apache/pekko/persistence/FilteredPayload.scala | 26 +
.../serialization/FilteredPayloadSerializer.scala | 45 ++
.../state/DurableStateStoreProvider.scala | 2 +-
.../FilteredPayloadSerializerSpec.scala | 35 +
.../org/apache/pekko/stream/javadsl/Flow.scala | 8 +
.../org/apache/pekko/stream/javadsl/Sink.scala | 6 +
.../org/apache/pekko/stream/javadsl/Source.scala | 6 +
.../org/apache/pekko/stream/scaladsl/Flow.scala | 4 +
.../org/apache/pekko/stream/scaladsl/Sink.scala | 3 +
.../org/apache/pekko/stream/scaladsl/Source.scala | 3 +
39 files changed, 2261 insertions(+), 74 deletions(-)
create mode 100644
docs/src/main/java/docs/persistence/state/MyJavaStateStore.java
create mode 100644
docs/src/main/java/docs/persistence/state/MyJavaStateStoreProvider.java
create mode 100644 docs/src/main/paradox/durable-state/state-store-plugin.md
create mode 100644
docs/src/main/scala/docs/persistence/state/MyStateStore.scala
create mode 100644
docs/src/test/scala/docs/persistence/state/PersistenceStatePluginDocSpec.scala
create mode 100644
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/EventsBySliceFirehoseReadJournalProvider.scala
create mode 100644
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/internal/EventsBySliceFirehose.scala
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/{CurrentEventsByPersistenceIdTypedQuery.scala
=> CurrentEventsByPersistenceIdStartingFromSnapshotQuery.scala} (58%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/{CurrentEventsBySliceQuery.scala
=> CurrentEventsBySliceStartingFromSnapshotsQuery.scala} (51%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/{CurrentEventsByPersistenceIdTypedQuery.scala
=> EventsByPersistenceIdStartingFromSnapshotQuery.scala} (58%)
create mode 100644
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/EventsBySliceFirehoseQuery.scala
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/{CurrentEventsBySliceQuery.scala
=> EventsBySliceStartingFromSnapshotsQuery.scala} (53%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/{CurrentEventsByPersistenceIdTypedQuery.scala
=> CurrentEventsByPersistenceIdStartingFromSnapshotQuery.scala} (58%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/{CurrentEventsBySliceQuery.scala
=> CurrentEventsBySliceStartingFromSnapshotsQuery.scala} (52%)
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/{CurrentEventsByPersistenceIdTypedQuery.scala
=> EventsByPersistenceIdStartingFromSnapshotQuery.scala} (58%)
create mode 100644
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/EventsBySliceFirehoseQuery.scala
copy
persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/{CurrentEventsBySliceQuery.scala
=> EventsBySliceStartingFromSnapshotsQuery.scala} (53%)
create mode 100644
persistence-query/src/test/scala/org/apache/pekko/persistence/query/TestClock.scala
create mode 100644
persistence-query/src/test/scala/org/apache/pekko/persistence/query/typed/EventEnvelopeSpec.scala
create mode 100644
persistence-query/src/test/scala/org/apache/pekko/persistence/query/typed/internal/EventsBySliceFirehoseSpec.scala
create mode 100644
persistence/src/main/scala/org/apache/pekko/persistence/FilteredPayload.scala
create mode 100644
persistence/src/main/scala/org/apache/pekko/persistence/serialization/FilteredPayloadSerializer.scala
create mode 100644
persistence/src/test/scala/org/apache/pekko/persistence/serialization/FilteredPayloadSerializerSpec.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
