Commit graph

25891 commits

Author SHA1 Message Date
Scala Steward
3caa219dd5
Update sbt-reproducible-builds to 0.28 (#30380) 2021-07-09 15:18:10 +02:00
Scala Steward
aec7479665
Update sbt to 1.5.4 (#30382) 2021-07-09 15:12:04 +02:00
Patrik Nordwall
9abef504eb
Merge pull request #30376 from akka/wip-api-may-change-patrikw
sprinkle ApiMayChange over durable state
2021-07-09 13:49:45 +02:00
Patrik Nordwall
8468e6ae03
allow minor versions after Scala 3.0 (#30331) 2021-07-09 10:48:14 +02:00
Patrik Nordwall
942982a900 sprinkle ApiMayChange over durable state 2021-07-08 15:55:12 +02:00
Patrik Nordwall
6c74dd7b04
Merge pull request #30373 from akka/wip-state-merge-patriknw
merge master into dev-durable-state
2021-07-08 15:54:39 +02:00
Raymond Roestenburg
353d2ae6d6
Reading until last global offset at time of calling currentChanges, a… (#30372)
* Reading until last global offset at time of calling currentChanges, added test.
2021-07-08 15:20:36 +02:00
Patrik Nordwall
54261ceadd Merge branch 'master' into wip-state-merge-patriknw 2021-07-08 14:26:35 +02:00
Raymond Roestenburg
c4903ebe1e Moved inmem temporarily to query because of DurableStateStoreQuery.
* move to akka-persistence-testkit
* Delegating to scaladsl InMemDurableStateStore.
* InMemDurableStateStore -> PersistenceTestKitDurableStateStore
* implement changes query
2021-07-08 14:19:09 +02:00
economist
0bafbce327
stream: fix client-side mutual TLS bug (#29534)
Connected issues:
https://github.com/lightbend/ssl-config/issues/62
https://github.com/akka/akka-http/issues/1433

Co-authored-by: Renato Cavalcanti <renato@cavalcanti.be>
2021-07-08 09:51:53 +02:00
Johan Andrén
0559165b3d
doc: make it clear inputBuffer has no effect in sample #30332 (#30337) 2021-07-07 15:17:57 +02:00
Scala Steward
3594faf646
Update gson to 2.8.7 (#30296) 2021-07-07 13:07:57 +02:00
Johan Andrén
3a3e643e07
akka-stream compiling on Scala 3 (#30324)
Changes:
* Private constructor for case class means private apply in Scala 3
* Logger class with Any instead of wildcard where needed
* Explicit import of internal implicit conversion import SinkToCompletionStage
* Hopefully source and binary compatible Scala 3 signature for GraphApply.create methods
* ZipLatestWith leaking private type
* Auto apply-to-lambda made explicit
* Internal async callback event class covariant
* Hub leaking private type
* Remove cycles in stream Buffer classes
* Avoid cyclic import in ResizableMultiReaderRingBuffer
* Safe cast of Subscribers
* Explicit import of internal implicit conversion SourceToCompletionStage
* Ambigous field name and method
* recover delegates using PF from javadsl not inferred, made explicit
* TcpStage completing promise with wrong type
* Collect aggregator empty value cannot be underscore with type ascription
* Some type alias shenanigans in QueueSink removed
* Explicit type on effectiveMaximumBurst in Throttle
* Override method return type not inferred in GraphInterpreter
* MutableCollectorState.accumulated getter got wrong type somehow
* TLS actor fallback case only applicable to null
* Some internal unchecked pattern matching removed
* Ok that createGraph is not present in Java API
* Separate impl per language for implicit actor system apply
2021-07-06 18:01:41 +02:00
Patrik Nordwall
7f3bfb1a30
Merge pull request #30281 from Captain1653/unchecked-cast
Remove unchecked cast from SourceTest and FlowTest
2021-07-06 11:06:21 +02:00
marcoderama
75031c00cb
Update cluster.md (#30352) 2021-07-06 11:05:03 +02:00
Patrik Nordwall
edf68f32ba
Merge pull request #30351 from akka/johanandren-patch-1
Clarify sharding stop message being local
2021-07-05 15:12:21 +02:00
Patrik Nordwall
1c988a2bf9
Merge pull request #30364 from johanandren/wip-30342-prefer-bytestring-length
A few ByteString.size switched to ByteString.length
2021-07-05 15:09:20 +02:00
Johan Andrén
0dfa9e7675 A few ByteString.size switched to ByteString.length #30342 2021-07-02 15:53:52 +02:00
Johan Andrén
9657f8430a
Revert "Hide private members in documentation (#20185) (#30356)" (#30357)
This reverts commit 55be471ffa.
2021-07-02 12:56:22 +02:00
Andrei Arlou
55be471ffa
Hide private members in documentation (#20185) (#30356) 2021-07-02 10:45:45 +02:00
Johannes Rudolph
dd289e7e2e
stream: actually read coalesce-writes setting from config (#30353) 2021-07-01 13:58:36 +02:00
Patrik Nordwall
53727df35a
stream: smart batching of writes in TcpStages (#30334)
Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
2021-07-01 09:19:36 +02:00
Johan Andrén
e8e667c228
Clarify sharding stop message being local 2021-06-30 16:06:41 +02:00
Patrik Nordwall
8573c70883
Remove ApiMayChange for Replicated Event Sourcing, #30346 (#30347) 2021-06-28 17:11:55 +02:00
Debasish Ghosh
b1f5aa88e3
Changed seqNr to revision for all durable state APIs and implementations (#30344) 2021-06-28 18:58:35 +05:30
Arnout Engelen
bbae718ef7
Move more release instructions to the template (#30340)
* Move more release instructions to the template

Sparked by discussion in #17432

* use newer version in example

Co-authored-by: Renato Cavalcanti <renato@cavalcanti.be>

* point to sonatype for snapshots

Co-authored-by: Renato Cavalcanti <renato@cavalcanti.be>
2021-06-23 17:06:13 +02:00
Michael Rose
dd13277195
add missing thenUnstashAll call (#30305)
Add the missing `unstash` so that the next task would continue after a task successfully completed.
2021-06-21 14:49:31 +02:00
Levi Ramsey
99da637633
Fix word wrap in Stream Sink.combine docs (#30318) 2021-06-21 13:55:54 +02:00
Debasish Ghosh
26f8eba4c7
Fixed typo - replaced scaladsl with javadsl (#30316) 2021-06-11 19:03:55 +05:30
Arnout Engelen
4d6ff8106e
Amend release script to update milestones (#30314) 2021-06-11 09:22:14 +02:00
Scala Steward
fa23288bb3
Update sbt-jmh to 0.4.3 (#30304) 2021-06-10 21:22:49 +02:00
Arnout Engelen
ceac670501
set sonatype profile name for publishing (#30306) 2021-06-09 15:20:42 +02:00
Scala Steward
d83cda8f56
Update scala-library to 2.12.14 (#30301) 2021-06-09 12:12:46 +02:00
Arnout Engelen
c593e3a33c
Install graphviz for publishing (#30293)
Otherwise generating scaladoc fails
2021-06-09 10:32:01 +02:00
Arnout Engelen
ce008dd53f
Use whitesource credential when publishing from GH Actions (#30291) 2021-06-08 17:35:19 +02:00
Nicolas Vollmar
3a96f06e3f
Handles handover done message in state oldest #29215 (#29216) 2021-06-08 14:36:13 +02:00
Yury Gribkov
3da5c2bdd0
Fix mapConcat context propagation (#30289)
* Fix mapConcat context propagation

* Remove default ContextPropagation implementation to reduce possible overhead when no Telemetry is in use

* fix pullFirstSubElement onPull

* CR follow up
2021-06-08 12:09:47 +02:00
Scala Steward
d69d04957b
Update jctools-core to 3.3.0 (#30100) 2021-06-08 11:27:28 +02:00
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
Patrik Nordwall
4faa0c5828
Merge pull request #30286 from akka/wip-default-plugin-patriknw
fix default DurableStateStore pluginId and config, #30277
2021-06-07 08:02:10 +02:00
Patrik Nordwall
cbf717b6fc fix default DurableStateStore pluginId and config, #30277 2021-06-04 15:50:21 +02:00
Debasish Ghosh
6fffbe5a27
More tests on DurableStateBehavior (#30285)
* More tests on DurableStateBehavior

* ScalafmtCheck

* Removed unused variable

* Removed unused variable
2021-06-04 19:12:12 +05:30
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
Patrik Nordwall
f93a01cf32
Merge pull request #30280 from akka/wip-30277-spike-impl-patriknw
First implementation of DurableStateBehavior, #30277
2021-06-03 16:22:22 +02:00
Debasish Ghosh
78ff85d0fb Initial implementation of DurableStateStore and one test 2021-06-03 14:41:02 +02:00
Patrik Nordwall
2168cec497 First implementation of DurableStateBehavior, #30277
* implementation is based on a copy of the EventSourcedBehavior and then
  refactoring all things that are not needed or different such as:
  * remove replicated event sourcing
  * remove ReplayingEvents recovery phase
  * remove retention and snapshotting
  * remove SnapshotSelectionCriteria and snapshots
  * remove PersistAll
  * remove event handler, event types
  * rename EventSourced
  * single static tag
  * DurableStateAdapter
  * DurableStateSignal

* DurableStateStore plugin api with similar extension mechanism as query plugins
  * DurableStateStore, DurableStateUpdateStore
  * DurableStateStoreQuery

* note that the DurableStateStore can be pretty useful for other things also
2021-06-03 13:21:55 +02:00
Captain1653
e47af50f51 Remove unchecked cast from SourceTest and FlowTest 2021-06-03 00:03:26 +03:00