This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch refactor/pekko-style-imports
in repository https://gitbox.apache.org/repos/asf/pekko.git
discard 2bd356ea29 fix: repair broken Paradox snippet markers in
MultiNodeSample.scala
discard b0b0c180fa fix: move `import org.apache.pekko` before `import pekko.X`
in 9 files
discard 489b06797d fix: remove redundant inner `import org.apache.pekko`
causing unused-import errors
discard 5d90de2b1c fix: add bare `import org.apache.pekko` where pekko.*
imports are used at file scope
discard 3b0664a15a refactor: convert org.apache.pekko.X imports to pekko.X
style
add b3c7c24fcc fix(stream): notify PartitionHub consumers on materializer
shutdown (#3347)
add f042c7aa3b fix: abort TLS transport on session verification failure
(#3323)
add 4b35bfb0c3 fix: bound Artery stream shutdown (#3317)
add 872034db3f add stub doc describing migrating to pekko 2 (#3355)
add 39682c8ca7 Delete DurableStateExceptionsSpec.scala (#3352)
add dfdd3eb55c Rework stack walking code to avoid Class.forName (#3354)
add c5132df18f fix: bound persistence event replay batches (#3325)
add 4fab32d5c8 stream: deprecate Source.queue overloads that materialize
SourceQueueWithComplete (#3095)
add 6c360f64c7 Update sbt-license-report to 1.10.0 (#3356)
add 4d821bbce9 fix: include sourceThread in typed actor MDC (#3239) (#3357)
add 3832509592 fix: invoke lifecycle handlers during snapshot recovery
(#3358)
add 1fa250d450 Stop PersistentActor by default on RecoveryCompleted
failure (#3359)
add 54c6002aee refactor: convert org.apache.pekko.X imports to pekko.X
style
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 (2bd356ea29)
\
N -- N -- N refs/heads/refactor/pekko-style-imports (54c6002aee)
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:
.../typed/scaladsl/LoggingEventFilterSpec.scala | 1 -
.../scala/org/apache/pekko/actor/AddressSpec.scala | 1 -
.../org/apache/pekko/actor/FSMTimingSpec.scala | 1 -
.../scala/org/apache/pekko/actor/HotSwapSpec.scala | 1 -
.../org/apache/pekko/io/dns/IdGeneratorSpec.scala | 1 -
.../pekko/serialization/NoVerification.scala | 1 -
.../org/apache/pekko/util/ManifestInfoSpec.scala | 1 -
.../org/apache/pekko/util/MessageBufferSpec.scala | 1 -
.../org/apache/pekko/typed/myapp/package.scala | 3 +-
.../org/apache/pekko/actor/typed/PropsSpec.scala | 1 -
.../typed/eventstream/EventStreamDocSpec.scala | 1 -
.../actor/typed/scaladsl/ActorLoggingSpec.scala | 18 +-
.../pekko/actor/typed/TypedActorContext.scala | 1 -
.../delivery/internal/DeliverySerializable.scala | 1 -
.../pekko/actor/typed/internal/ActorMdc.scala | 7 +-
.../pekko/actor/typed/internal/CachedProps.scala | 1 -
.../main/scala/org/apache/pekko/PekkoVersion.scala | 1 -
.../scala/org/apache/pekko/io/dns/RecordType.scala | 1 -
.../scala/org/apache/pekko/util/JavaVersion.scala | 1 -
.../scala/org/apache/pekko/util/OptionVal.scala | 1 -
.../main/scala/org/apache/pekko/util/Version.scala | 1 -
.../org/apache/pekko/persistence/Common.scala | 1 -
.../pekko/stream/InvokeWithFeedbackBenchmark.scala | 2 +
.../cluster/metrics/sample/StatsMessages.scala | 1 -
.../pekko/cluster/metrics/sample/StatsWorker.scala | 1 -
.../ClusterShardingTypedSerializable.scala | 1 -
.../docs/delivery/PointToPointDocExample.scala | 1 -
.../sharding/typed/AccountExampleSpec.scala | 1 -
.../internal/ShardedDaemonProcessIdSpec.scala | 1 -
.../internal/jfr/JFRShardingFlightRecorder.scala | 1 -
.../ClusterShardingIncorrectSetupSpec.scala | 1 -
.../sharding/MultiNodeClusterShardingConfig.scala | 29 +-
.../sharding/ShardRegionDataTypesSpec.scala | 1 -
.../HillClimbingAdmissionOptimizerSpec.scala | 1 -
.../typed/ClusterDispatcherSelectorSpec.scala | 1 -
.../org/apache/pekko/cluster/ClusterLogClass.scala | 1 -
.../pekko/cluster/HeartbeatNodeRingPerfSpec.scala | 1 -
.../pekko/cluster/HeartbeatNodeRingSpec.scala | 1 -
.../apache/pekko/cluster/ReachabilitySpec.scala | 1 -
.../pekko/cluster/sbr/LeaseMajoritySpec.scala | 1 -
.../apache/pekko/cluster/ddata/EstimatedSize.scala | 1 -
.../org/apache/pekko/cluster/ddata/FastMerge.scala | 1 -
.../scala/org/apache/pekko/cluster/ddata/Key.scala | 1 -
.../pekko/cluster/ddata/STMultiNodeSpec.scala | 1 -
.../org/apache/pekko/cluster/ddata/FlagSpec.scala | 1 -
.../org/apache/pekko/cluster/ddata/GSetSpec.scala | 1 -
.../cluster/ddata/ReplicatorSettingsSpec.scala | 1 -
docs/src/main/paradox/migration/index.md | 1 +
.../paradox/migration/migration-guide-1.x-2.x.md | 35 ++
docs/src/main/paradox/persistence.md | 15 +
docs/src/main/paradox/remoting-artery.md | 8 +
docs/src/main/paradox/stream/actor-interop.md | 8 +
.../operators/Source/actorRefWithBackpressure.md | 2 +-
.../main/paradox/stream/operators/Source/queue.md | 26 ++
docs/src/main/paradox/typed/persistence.md | 11 +
docs/src/test/scala/docs/actor/FSMDocSpec.scala | 1 -
.../scala/docs/actor/InitializationDocSpec.scala | 1 -
.../test/scala/docs/actor/PropsEdgeCaseSpec.scala | 1 -
.../test/scala/docs/actor/UnnestedReceives.scala | 1 -
.../actor/typed/BlockingDispatcherSample.scala | 1 -
.../actor/typed/CoordinatedActorShutdownSpec.scala | 1 -
.../scala/docs/actor/typed/DispatcherDocSpec.scala | 1 -
.../test/scala/docs/actor/typed/PrintActor.scala | 1 -
.../actor/typed/SharedMutableStateDocSpec.scala | 1 -
.../docs/cluster/SimpleClusterListener2.scala | 1 -
.../src/test/scala/docs/config/ConfigDocSpec.scala | 1 -
docs/src/test/scala/docs/ddata/TwoPhaseSet.scala | 1 -
.../scala/docs/extension/ExtensionDocSpec.scala | 1 -
docs/src/test/scala/docs/faq/Faq.scala | 1 -
docs/src/test/scala/docs/io/ReadBackPressure.scala | 1 -
docs/src/test/scala/docs/io/UdpDocSpec.scala | 1 -
.../docs/pattern/BackoffSupervisorDocSpec.scala | 1 -
.../PersistenceEventAdapterDocSpec.scala | 1 -
.../persistence/query/MyEventsByTagSource.scala | 1 -
.../docs/persistence/testkit/Configuration.scala | 1 -
.../docs/persistence/testkit/TestKitExamples.scala | 1 -
.../docs/remoting/RemoteDeploymentDocSpec.scala | 1 -
.../test/scala/docs/stream/BidiFlowDocSpec.scala | 1 -
.../scala/docs/stream/CompositionDocSpec.scala | 1 -
docs/src/test/scala/docs/stream/FlowDocSpec.scala | 1 -
.../scala/docs/stream/FlowParallelismDocSpec.scala | 1 -
.../test/scala/docs/stream/GraphCyclesSpec.scala | 1 -
.../test/scala/docs/stream/GraphDSLDocSpec.scala | 1 -
docs/src/test/scala/docs/stream/HubsDocSpec.scala | 1 -
.../scala/docs/stream/IntegrationDocSpec.scala | 10 +-
.../test/scala/docs/stream/KillSwitchDocSpec.scala | 1 -
.../test/scala/docs/stream/MigrationsScala.scala | 1 -
.../docs/stream/RateTransformationDocSpec.scala | 1 -
.../scala/docs/stream/ReactiveStreamsDocSpec.scala | 1 -
.../test/scala/docs/stream/RestartDocSpec.scala | 1 -
.../test/scala/docs/stream/SinkRecipeDocSpec.scala | 1 -
.../scala/docs/stream/StreamBuffersRateSpec.scala | 1 -
.../docs/stream/StreamPartialGraphDSLDocSpec.scala | 1 -
.../test/scala/docs/stream/SubstreamDocSpec.scala | 1 -
.../docs/stream/cookbook/RecipeByteStrings.scala | 1 -
.../docs/stream/cookbook/RecipeDecompress.scala | 1 -
.../stream/cookbook/RecipeDroppyBroadcast.scala | 1 -
.../docs/stream/cookbook/RecipeFlattenSeq.scala | 1 -
.../docs/stream/cookbook/RecipeKeepAlive.scala | 1 -
.../stream/cookbook/RecipeLoggingElements.scala | 1 -
.../docs/stream/cookbook/RecipeManualTrigger.scala | 1 -
.../docs/stream/cookbook/RecipeMissedTicks.scala | 1 -
.../docs/stream/cookbook/RecipeMultiGroupBy.scala | 1 -
.../docs/stream/cookbook/RecipeParseLines.scala | 1 -
.../docs/stream/cookbook/RecipeReduceByKey.scala | 1 -
.../scala/docs/stream/cookbook/RecipeSeq.scala | 1 -
.../docs/stream/cookbook/RecipeSimpleDrop.scala | 1 -
.../scala/docs/stream/cookbook/RecipeSpec.scala | 1 -
.../docs/stream/cookbook/RecipeSplitter.scala | 1 -
.../docs/stream/cookbook/RecipeWorkerPool.scala | 1 -
.../stream/operators/flow/FromSinkAndSource.scala | 1 -
.../docs/stream/operators/flow/FutureFlow.scala | 1 -
.../docs/stream/operators/flow/StatefulMap.scala | 1 -
.../stream/operators/flow/StatefulMapConcat.scala | 1 -
.../docs/stream/operators/sink/AsPublisher.scala | 1 -
.../docs/stream/operators/sink/Cancelled.scala | 1 -
.../docs/stream/operators/sink/Collection.scala | 1 -
.../scala/docs/stream/operators/sink/Fold.scala | 1 -
.../docs/stream/operators/sink/FoldWhile.scala | 1 -
.../scala/docs/stream/operators/sink/ForAll.scala | 1 -
.../docs/stream/operators/sink/HeadOption.scala | 1 -
.../scala/docs/stream/operators/sink/Lazy.scala | 1 -
.../docs/stream/operators/sink/NoneMatch.scala | 1 -
.../docs/stream/operators/source/Combine.scala | 1 -
.../scala/docs/stream/operators/source/Lazy.scala | 1 -
.../docs/stream/operators/source/Restart.scala | 1 -
.../scala/docs/stream/operators/source/Tick.scala | 1 -
.../docs/stream/operators/source/Unfold.scala | 1 -
.../docs/stream/operators/source/UnfoldAsync.scala | 1 -
.../stream/operators/source/UnfoldResource.scala | 1 -
.../operators/source/UnfoldResourceAsync.scala | 1 -
.../scala/docs/stream/operators/source/Zip.scala | 1 -
.../stream/operators/sourceorflow/Collect.scala | 1 -
.../operators/sourceorflow/CompletionTimeout.scala | 1 -
.../docs/stream/operators/sourceorflow/Drop.scala | 1 -
.../sourceorflow/ExtrapolateAndExpand.scala | 1 -
.../stream/operators/sourceorflow/Filter.scala | 1 -
.../operators/sourceorflow/FlatMapConcat.scala | 1 -
.../operators/sourceorflow/FlatMapMerge.scala | 1 -
.../stream/operators/sourceorflow/GroupBy.scala | 1 -
.../stream/operators/sourceorflow/Grouped.scala | 1 -
.../operators/sourceorflow/GroupedAdjacentBy.scala | 1 -
.../operators/sourceorflow/GroupedWeighted.scala | 1 -
.../operators/sourceorflow/Intersperse.scala | 1 -
.../docs/stream/operators/sourceorflow/Limit.scala | 1 -
.../operators/sourceorflow/LimitWeighted.scala | 1 -
.../docs/stream/operators/sourceorflow/Log.scala | 1 -
.../operators/sourceorflow/LogWithMarker.scala | 1 -
.../stream/operators/sourceorflow/MapConcat.scala | 1 -
.../stream/operators/sourceorflow/MapError.scala | 1 -
.../operators/sourceorflow/MapWithResource.scala | 1 -
.../operators/sourceorflow/MergeLatest.scala | 1 -
.../stream/operators/sourceorflow/Monitor.scala | 1 -
.../stream/operators/sourceorflow/Reduce.scala | 1 -
.../docs/stream/operators/sourceorflow/Scan.scala | 1 -
.../stream/operators/sourceorflow/ScanAsync.scala | 1 -
.../stream/operators/sourceorflow/Sliding.scala | 1 -
.../stream/operators/sourceorflow/Throttle.scala | 1 -
.../docs/stream/operators/sourceorflow/Watch.scala | 1 -
.../operators/sourceorflow/WatchTermination.scala | 1 -
.../tutorial_1/ActorHierarchyExperiments.scala | 1 -
.../scala/typed/tutorial_4/DeviceManager.scala | 1 -
.../scala/typed/tutorial_4/DeviceManagerSpec.scala | 1 -
.../test/scala/typed/tutorial_4/DeviceSpec.scala | 1 -
.../scala/typed/tutorial_5/DeviceManagerSpec.scala | 1 -
.../test/scala/typed/tutorial_5/DeviceSpec.scala | 1 -
.../org/apache/pekko/osgi/test/PingPong.scala | 1 -
.../persistence/query/DurableStateChange.scala | 1 -
.../leveldb/PersistencePluginProxySpec.scala | 14 +-
.../persistence/scalatest/OptionalTests.scala | 1 -
.../persistence/japi/JavaJournalSpecSpec.scala | 1 -
.../EventSourcedBehaviorRecoverySignalSpec.scala | 169 +++++++++
.../EventSourcedBehaviorReplayBatchingSpec.scala | 243 +++++++++++++
.../pekko/persistence/typed/crdt/LwwTime.scala | 1 -
.../pekko/persistence/typed/crdt/OpCrdt.scala | 1 -
.../typed/internal/ExternalInteractions.scala | 3 +
.../typed/internal/ReplayingEvents.scala | 10 +
.../typed/internal/ReplayingSnapshot.scala | 14 +-
.../persistence/typed/PersistenceIdSpec.scala | 1 -
persistence/src/main/resources/reference.conf | 5 +
.../org/apache/pekko/persistence/TraitOrder.scala | 1 -
.../org/apache/pekko/persistence/TraitOrder.scala | 1 -
.../apache/pekko/persistence/Eventsourced.scala | 27 +-
.../apache/pekko/persistence/JournalProtocol.scala | 35 ++
.../org/apache/pekko/persistence/Protocol.scala | 1 -
.../persistence/journal/AsyncWriteJournal.scala | 316 ++++++++++++++---
.../journal/PersistencePluginProxy.scala | 4 +-
.../pekko/persistence/journal/ReplayFilter.scala | 10 +-
.../journal/leveldb/LeveldbCompaction.scala | 1 -
.../PersistentActorJournalProtocolSpec.scala | 9 +-
.../PersistentActorReplayBatchingSpec.scala | 387 +++++++++++++++++++++
.../pekko/persistence/RecoveryPermitterSpec.scala | 57 ++-
.../persistence/journal/ReplayFilterSpec.scala | 27 ++
.../exception/DurableStateExceptionsSpec.scala | 57 ---
project/plugins.sbt | 2 +-
remote/src/main/resources/reference.conf | 5 +
.../org/apache/pekko/remote/UniqueAddress.scala | 1 -
.../pekko/remote/artery/ArterySettings.scala | 4 +
.../pekko/remote/artery/ArteryTransport.scala | 34 +-
.../pekko/remote/artery/QuarantinedEvent.scala | 1 -
.../pekko/remote/RemoteActorMailboxSpec.scala | 1 -
.../artery/ArteryTransportShutdownSpec.scala | 98 ++++++
.../SerializationTransportInformationSpec.scala | 1 -
.../artery/TransientSerializationErrorSpec.scala | 1 -
.../artery/compress/CompressionTableSpec.scala | 1 -
.../artery/compress/CompressionTestUtils.scala | 1 -
.../jackson/v2a/OrderPlacedMigration.scala | 1 -
.../jackson3/v2a/OrderPlacedMigration.scala | 1 -
.../pekko/stream/tck/EmptyPublisherTest.scala | 1 -
.../pekko/stream/tck/FlatMapPrefixTest.scala | 1 -
.../pekko/stream/tck/FoldSinkSubscriberTest.scala | 1 -
.../stream/tck/ForeachSinkSubscriberTest.scala | 1 -
.../org/apache/pekko/stream/tck/MapTest.scala | 1 -
.../apache/pekko/stream/tck/MaybeSourceTest.scala | 1 -
.../scala/org/apache/pekko/stream/io/TlsSpec.scala | 30 +-
.../stream/scaladsl/FlowCollectTypeSpec.scala | 1 -
.../pekko/stream/scaladsl/FlowPrependSpec.scala | 1 -
.../org/apache/pekko/stream/scaladsl/HubSpec.scala | 23 ++
.../pekko/stream/scaladsl/QueueSourceSpec.scala | 1 +
.../pekko/stream/scaladsl/SinkFoldSpec.scala | 1 -
.../pekko/stream/scaladsl/SubscriberSinkSpec.scala | 1 -
.../stream/scaladsl/TlsEngineSelectionSpec.scala | 1 -
.../apache/pekko/stream/CompletionStrategy.scala | 1 -
.../org/apache/pekko/stream/FlowMonitor.scala | 1 -
.../org/apache/pekko/stream/QueueOfferResult.scala | 1 -
.../org/apache/pekko/stream/Supervision.scala | 1 -
.../stream/WatchedActorTerminatedException.scala | 1 -
.../pekko/stream/impl/CompletedPublishers.scala | 1 -
.../pekko/stream/impl/ContextPropagation.scala | 1 -
.../pekko/stream/impl/io/TlsGraphStage.scala | 43 ++-
.../org/apache/pekko/stream/javadsl/Source.scala | 12 +
.../apache/pekko/stream/javadsl/StreamRefs.scala | 1 -
.../org/apache/pekko/stream/scaladsl/Hub.scala | 32 +-
.../pekko/stream/scaladsl/Materialization.scala | 1 -
.../org/apache/pekko/stream/scaladsl/Source.scala | 13 +-
.../org/apache/pekko/testkit/TestActors.scala | 1 -
.../org/apache/pekko/testkit/TestKitUtils.scala | 29 +-
.../apache/pekko/testkit/DefaultTimeoutSpec.scala | 1 -
.../apache/pekko/testkit/ImplicitSenderSpec.scala | 1 -
239 files changed, 1688 insertions(+), 395 deletions(-)
create mode 100644 docs/src/main/paradox/migration/migration-guide-1.x-2.x.md
create mode 100644
persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRecoverySignalSpec.scala
create mode 100644
persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorReplayBatchingSpec.scala
create mode 100644
persistence/src/test/scala/org/apache/pekko/persistence/PersistentActorReplayBatchingSpec.scala
delete mode 100644
persistence/src/test/scala/org/apache/pekko/persistence/state/exception/DurableStateExceptionsSpec.scala
create mode 100644
remote/src/test/scala/org/apache/pekko/remote/artery/ArteryTransportShutdownSpec.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
