Commit graph

25696 commits

Author SHA1 Message Date
Arnout Engelen
39b4a5c57a
Publish from GitHub Actions (#30288)
* Publish from GitHub Actions

* Break out instructions into release train issue template
2021-06-08 09:05:16 +02:00
Scala Steward
2c524f110f
Update sbt-pgp to 2.1.2 (#30097) 2021-06-04 15:25:08 +02:00
Wayne Wang
dfd6ae20ea
support ipv6 in artery (#30190) 2021-06-04 08:32:37 +02:00
Yury Gribkov
390e9f675b
Fix context propagation (#30221)
* Introduce ContextPropagation for explicit intent
* Preserve upstream context in ZipWith, ZipLatest, ZipWithN, ZipLatestWith, Filter, Batch, Expand, GroupedWeightedWithin, IdleInject and Detacher
* Mark instrumented apply method as InternalStableApi
2021-06-03 17:31:26 +02:00
Jens Neumaier
7d1b412b22
Resolve snapshot check skipped for some events (#30225) (#30226) 2021-06-03 17:04:57 +02:00
Johan Andrén
e43f2be6cd
Byte array allocation/copy hunt (#30266)
* Loads of byte array copy/allocations squashed
* Use a central place for the proto unsafe instead of ad hoc
* Extra docs on serializer toBinary about not mutating bytes after returned
* Found some more toArray:s that can potentially benefit from being unsafe
* Array handed to user callback so extra docs needed
* Unsafe reading of underlying bytes of strings fixed
2021-06-02 17:28:37 +02:00
Johan Andrén
b5cbf383d6
Move typed persistence tests away from LevelDB (#30224) 2021-06-02 17:15:18 +02:00
Arman Bilge
ab98618a25
Fix specificity of inherited attributes for {Source,Flow,Sink}.fromMaterializer (#30171) #30142 2021-06-02 16:17:31 +02:00
Lukas Rytz
41d5f1571b
Compile typed actors with Scala 3 (#30258) 2021-06-02 16:10:10 +02:00
Patrik Nordwall
3cafeb2639
Merge pull request #30177 from johanandren/wip-restart-source-incorrect-api-doc
Incorrect API:doc on RestartSource.onFailuresWithBackoff
2021-06-02 13:47:00 +02:00
Johan Andrén
5c7ff2188c
Don't put temporary actor refs in the heavy hitters table (#30214)
* Don't put temporary actor refs in the heavy hitters table #30212

* Formatting
2021-06-02 13:39:54 +02:00
Johan Andrén
d4fdf5639e
Deprecate LevelDB (#30213)
* Deprecate LevelDB

In preparation of moving into the testing infra (or deleting it completely) at some distant future point in time

* Remove leveldb tests where there also is an inmem one

* More details in deprecation text, recommend inmem + journal proxy for testing etc.
2021-06-02 13:37:52 +02:00
Patrik Nordwall
1c6f184127
Merge pull request #30237 from akka/rgc/fix-java-docs-on-tagging
fix(docs): java snippet showing how to tag events
2021-06-02 12:52:25 +02:00
Arman Bilge
e714f7bdbc
Inner stages of lazy/future stages should inherit attributes (#30161)
* Add tests for attributes inheritance
* Fix inheritance bugs revealed by tests
2021-06-02 12:48:14 +02:00
Johan Andrén
fe1459fcbc
Small clarification of recovery strategy in config (#30167) 2021-06-02 11:57:51 +02:00
Johan Andrén
55840374f4
ByteString.toArrayUnsafe method for zero copy transformation of bytestrings (#30262) 2021-06-02 11:22:24 +02:00
Renato Cavalcanti
3dd0c4c86b
Artery test transport blackhole only let HandshakeReq pass (#30219)
* only let HandshakeReq is blackholed
2021-06-02 08:41:39 +02:00
Scala Steward
5abc119577
Update metrics-core, metrics-jvm to 4.1.21 (#30232) 2021-06-02 08:27:48 +02:00
Yury Gribkov
c31c114e7b
Introduce onDeadLetterMailboxEnqueue hook for telemetry (#30279)
It's needed for better instrumentation stability in future versions.
2021-06-01 14:05:21 +02:00
Andrei Arlou
258bac491b
Remove unused imports in tests (#30265) 2021-06-01 13:34:43 +02:00
Seeta Ramayya
a887c63f8a
Source.fromPublisher does not pick up attributes fix #30076 (#30195) 2021-06-01 10:44:40 +02:00
Viktor Klang (√)
364cb06905
Wip optimize allocations optionval #30264
* Optimizes retrieval of mandatoryAttributes by removing potential allocation of OptionVal
* Optimizes ActorContextImpl by avoiding allocations inserted by Scala 2.13
* Optimizes Artery Codecs to avoid allocations associated with Scala 2.13 pattern-matching
* Avoid pattern-matching on OptionVal since Scala 2.13 allocates when checking the pattern
2021-06-01 08:55:36 +02:00
Patrik Nordwall
e09de4fc84
Possibility to make snapshot load failures non-fatal, #30234 (#30238)
Co-authored-by: Renato Cavalcanti <renato@cavalcanti.be>
2021-05-31 21:50:28 +02:00
Andrei Arlou
206dafa01d
Unnecessary boxing was removed from tests (#30250) 2021-05-31 15:46:14 +02:00
Nicolas Vollmar
622d8af0ef
Extends supervision strategy to define custom log levels #30267 (#30268)
* Adds logLevel in Directive
* Extends supervision logging documentation
* Adds sealed and marks as internal
2021-05-31 13:56:42 +02:00
Johan Andrén
3986b1c3bb
Fix LineNumberSpec failing since Scala 3 update in #30248 (#30261) 2021-05-28 08:53:15 +02:00
Johan Andrén
4ade8ef2d1
Lazy and fast concat and prepend (#30252) 2021-05-27 17:18:47 +02:00
Yury Gribkov
cbb12e6ef3
Call BoundaryEvent cancellation hook for telemetry when ActorGraphInterpreter stops (#30259)
* Call BoundaryEvent cancellation hook for telemetry when ActorGraphInterpreter stops
* Add missing annotation to ActorCell.sendMessage
2021-05-27 17:13:17 +02:00
Alex
3ae85e8cd0
Change tests to use new Source.queue api, #29801 (#30070) 2021-05-27 08:53:18 +02:00
Andrei Arlou
48e4f11dfd
Change parameter order in assertEquals (#30247) 2021-05-25 17:46:07 +02:00
Justin Pihony
b989c4cf3e
Add more explicit docs of top level coexistence (#29921) 2021-05-25 15:12:49 +02:00
Renato Cavalcanti
678dea73d8
use old school Set construction 2021-05-25 14:21:29 +02:00
Lukas Rytz
aa03e8b089
Update Scala to 3.0.0 final, sbt to 1.5.2 (#30248)
Also: Migrate to sbt slash syntax
2021-05-25 12:50:51 +02:00
Yury Gribkov
49759617ab
Add BoundaryEvent cancellation hook for telemetry (#30246) 2021-05-20 18:10:44 +02:00
Andrei Arlou
657386488d
Fix test ActorCreationTest.testWrongAnonymousInPlaceCreator (#30236)
* Fix test ActorCreationTest.testWrongAnonymousInPlaceCreator - added non-static check for Creator (#30220)

* fix spec test
2021-05-19 21:06:56 +02:00
Arnout Engelen
79b48ca354
Remove SourceModule/SinkModule newInstance (#30244)
* Remove SourceModule/SinkModule newInstance

AFAICS it's not public API and not called anywhere
Extracted from #30223

* mima excludes
2021-05-19 20:51:30 +02:00
Xiaoguang Zhang
a19e73a253
lease settings support for typed cluster singleton (#30209) 2021-05-19 11:05:40 +02:00
Johannes Rudolph
18e78816c3
stream: reuse maxBytesPerChunk buffer for inflate / gunzip (#30239)
Before, for every round of `parse` a new buffer was allocated that was then
copied again by `ByteString.fromArray`. This effectively more than doubled
the allocation rate while inflating. For bulk data like expected for
compressed data this can make a big difference in throughput.

The slight downside of keeping the buffer is that the stage now uses more memory
by default even while idle. deflate/gzip's window is 64kb which happens to be also the
default `maxBytesPerChunk` setting. It is therefore expected that the additional buffer will
less than double the existing memory footprint while dividing the allocation rate
by more than two which seems like a good trade-off.
2021-05-17 16:08:26 +02:00
Patrik Nordwall
2dde4b6b51
Merge pull request #30211 from johanandren/wip-remove-leveldbjournalnative-perf-spec
Delete CI-sensitive LevelDB perf spec
2021-05-14 16:18:00 +02:00
Patrik Nordwall
877c4ee29d
Merge pull request #30216 from nivox/fix-hubspec-test
Fixed race condition in MergeHub draining test: 30207
2021-05-14 16:15:02 +02:00
Muskan Gupta
dd8b514e89
Add Sink.asPublisher example and update doc (#30105)
Co-authored-by: Renato Cavalcanti <renato@cavalcanti.be>
2021-05-12 21:16:41 +02:00
Patrik Nordwall
240378f062
Merge pull request #30233 from Captain1653/use-standart-charsets
Use StandardCharsets.UTF-8 in SerializationDocTest
2021-05-12 13:10:51 +02:00
Patrik Nordwall
245527cacb
Merge pull request #30235 from toshetah/patch-1
Fix Broadcast examples, as they currently fail.
2021-05-12 13:09:14 +02:00
Tomer Shetah
82fc6c0e68
Fix Broadcast examples, as they currently fail.
Use different outputs for broadcast
2021-05-11 15:29:28 +03:00
Captain1653
0ee9532306 Use StandardCharsets.UTF-8 in SerializationDocTest 2021-05-10 18:00:53 +03:00
Andrei Arlou
f568d4d4f9
Remove usage of Java assert in tests (#30220) (#30227) 2021-05-07 21:27:39 +02:00
Seeta Ramayya
174c725ef8
fixed typo (#30218) 2021-05-05 13:20:10 +02:00
Andrei Arlou
1a36631dbb
Use assertThrows in classes ActorCreationTest and OutputStreamSinkTest (#30165) 2021-05-05 10:45:37 +02:00
Jens Neumaier
73d74dfc69
Resolve missing internal state update in EventSourcedRememberEntities… (#30217) 2021-05-04 14:59:24 +02:00
Andrea Zito
9fbc796515 Fixed race condition in MergeHub draining test: 30207 2021-05-03 17:08:52 +02:00