Commit graph

24876 commits

Author SHA1 Message Date
Scala Steward
2b8c3d98d3
Update jackson-databind to 2.10.4 2020-05-04 10:16:46 +02:00
Patrik Nordwall
8cfc23da37
fix publishRsync in release script (#29003) 2020-04-30 21:26:49 +02:00
Enno
d973f016cc
Docs: Javadoc links in project info (#28998) 2020-04-30 17:05:02 +02:00
Patrik Nordwall
bef03f8585
Merge pull request #28992 from akka/wip-24466-sharding-query-patriknw
Support GetClusterShardingStats query in Typed #24466
2020-04-30 12:26:39 +02:00
Patrik Nordwall
e01396843e Complete GetClusterShardingStats query, #24466 2020-04-30 11:27:25 +02:00
Ignasi Marimon-Clos
7702bce0d0
A few more apidoc directives (#28995) 2020-04-30 08:59:22 +02:00
Patrik Nordwall
ef79738373
Synchronous TestKit for EventSourcedBehavior, #23712 (#28952)
* using real EventSourcedBehaviorImpl
* using new inmem journal (PersistenceTestKit)
* advantages compared to a "fake" driver
  * no difference in implementation details from real thing
  * no limitations
  * less maintance
* added internal messsages to EventSourcedBehaviorImpl to be able to grab state
  and persistenceId
  * GetState as InternalProtocol instead of Signal so that it is stashed
* serialization checks, using SerializationTestKit
* better testKitGuardian naming to allow multiple PersistenceTestKit
* support testing of restart
* support failure testing by using PersistenceTestKit
* update doc sample
* apidoc, reference docs, and javadsl
2020-04-29 22:06:42 +02:00
Viktor Klang (√)
a910bee99f
Handling of onSpinWait and its absence in AffinityPool (#28946) 2020-04-29 20:08:05 +02:00
Ignasi Marimon-Clos
03411dd3cd
Merge pull request #28980 from ignasi35/unify-operator-signature-apidoc 2020-04-29 18:18:30 +02:00
Ignasi Marimon-Clos
a25c6091b8
Merge branch 'master' into unify-operator-signature-apidoc 2020-04-29 16:24:57 +02:00
Renato Cavalcanti
23535367a0
Merge pull request #28988 from renatocaval/artery-udp-three-lanes-spec 2020-04-29 13:55:15 +02:00
Renato Cavalcanti
379565e740
check that ActorIdentity is from the expected ActorPath 2020-04-29 10:38:49 +02:00
Ignasi Marimon-Clos
64cc32edbd
Examples for extrapolate (#28797)
* Adds example for Extrapolate

* Adds example for Extrapolate (Java)

* Adds example for Expand

* Remove code duplication. Improve docs signature sections

* Update akka-docs/src/main/paradox/stream/operators/Source-or-Flow/extrapolate.md

Co-Authored-By: Arnout Engelen <github@bzzt.net>

* PR comments

Co-authored-by: Arnout Engelen <github@bzzt.net>
2020-04-29 08:51:32 +02:00
Patrik Nordwall
21bab49ca0
Merge pull request #28844 from akka/wip-28720-delivery-request-interval-patriknw
Dynamically adjust the ConsumerController's resend interval for Request, #28720
2020-04-28 22:04:14 +02:00
Patrik Nordwall
8865ca44d6 Dynamically adjust the ConsumerController's resend interval for Request, #28720
* increase the interval when idle in active Behavior, no incoming messages
* still avoiding rescheduling the timer for each message
* when there is a steady flow of incoming messages it will only send the Request
  messages after half flow-control-window
* changed config property resend-interval to resend-interval-min and resend-interval-max
* the change of this setting is not backwards compatible but ApiMayChange and
  probably nobody using that setting yet
*

* fix ReliableDeliveryRandomSpec

* mima filter
2020-04-28 19:35:07 +02:00
Helena Edelson
c0e31978e6 Support GetClusterShardingStats query in Typed #24466 2020-04-28 19:27:43 +02:00
Ignasi Marimon-Clos
0e7bce7bae The automatic replacement produces Markdown that caused the paradox task in sbt to timeout or event fail. So
this commit removes some operators with outpu too complex:

- ignored operators:
          "ask.md",
          "alsoTo.md",
          "batchWeighted.md",
          "buffer.md",
          "actorRef.md",
          "collect.md",
          "collection.md",
          "combine.md",
          "completionTimeout.md",
          "concat.md",
          "from.md",
          "fromMaterializer.md",
          "map.md",
          "merge.md",
          "queue.md",
          "log.md", // too many overloads, breaks `paradox` task
          "throttle.md", // too many overloads, breaks `paradox` task
          "idleTimeout.md", // too many overloads, breaks `paradox` task
          "setup.md",
          "watch.md",
          "withBackoff.md",
          "zip.md",
          "zipWith.md",
          "actorRefWithBackpressure.md"

- Ignored class when FQCN contains: Implicits, FlowOpsMat, SubSource, FlowOps, SubFlow, WithContext, DelayStrategy

- some extra manual cleanup on the committed operators.
2020-04-28 19:21:04 +02:00
Ignasi Marimon-Clos
4f667de73d Some cleanup to prepare... 2020-04-28 17:34:40 +02:00
Enno
bb4940b027
Docs: sort all operators by method name in left-hand menu (#28900) 2020-04-28 16:58:00 +02:00
Ignasi Marimon-Clos
fcd960ad78
Merge pull request #28762 from ennru/stream-docs-ask 2020-04-28 16:37:29 +02:00
Arnout Engelen
ad2bd70213
Use sbt-publish-rsync rather than our own (#28868) 2020-04-28 11:49:42 +02:00
kerr
6b5d544deb
Add Source.fromJavaStream as convenient method alias (#28881) 2020-04-28 11:15:11 +02:00
Scala Steward
404d45ea82
Update sbt-paradox-akka to 0.33 (#28983) 2020-04-28 08:31:07 +02:00
Andreas Gabor
30e79c6231
Allow changing the recovery strategy in a typed persistence actor #25216 (#28932)
* Allow changing the recovery strategy in a typed persistence actor #25216

* scalafmt fix

* added mima exclusion

* added typed.Recovery allowing only default or disabled recovery strategy

* typed.Recovery takes SnapshotSelectionCriteria
deprecated withSnapshotSelectionCriteria

* updated docs
2020-04-28 07:18:50 +01:00
Scala Steward
dc9f907caa
Update sbt-header to 5.6.0 (#28944) 2020-04-27 19:31:02 +02:00
Johannes Rudolph
b8df0351cd
actor: use simple comparison in LightArrayRevolverScheduler (#28981) 2020-04-27 17:55:24 +02:00
Christopher Batey
0e3cfbf584
Docs: mergeLatest (#28586) 2020-04-27 17:45:04 +02:00
Renato Cavalcanti
8e0c8d07b9
Merge pull request #28974 from akka/wip-28939-protobuf-dep-patriknw 2020-04-27 17:35:49 +02:00
Christophe De Troyer
c28fd34b65
Minor typo in documentation. (#28687) 2020-04-27 17:16:48 +02:00
Christopher Batey
23ea1a4fed
Docs: flatMapConcat (#28584) 2020-04-27 16:46:16 +02:00
contrun
c2945a3e7f
Docs: API docs for asSourceWithContext (#28950) 2020-04-27 16:15:28 +02:00
Arnout Engelen
2db52a06ea
Check mima against 2.5.31 (#28857) 2020-04-27 16:11:32 +02:00
Renato Cavalcanti
f520ca7b7a
Merge pull request #28975 from ennru/update-persistence-plugins 2020-04-27 14:35:23 +02:00
kerr
0e4d41ad33
+build Add sort imports support. (#28780)
* Add scalafix plugin for jdk 9.
* Add command alias sortImports.
* Excludes some sources from SortImports.
* Update SortImports to 0.4.0
* Sort imports with `sortImports` command.
2020-04-27 14:32:18 +02:00
ohze.net
ea7205eaf7
dotty phase 2: scalafix ExplicitNonNullaryApply (#28949)
* scalafix ExplicitNonNullaryApply prepare

+ Temporarily use com.sandinh:sbt-scalafix because scalacenter/scalafix#1098
+ Add ExplicitNonNullaryApply rule to .scalafix.conf
+ Manually fix a NonNullaryApply case in DeathWatchSpec that cause
  `fixall` fail because ExplicitNonNullaryApply rule incorrectly rewrite
  `context unbecome` to `context unbecome()` instead of `context.unbecome()`

* scalafix ExplicitNonNullaryApply

fix by enabling only ExplicitNonNullaryApply rule in .scalafix.conf then:
```
% sbt -Dakka.build.scalaVersion=2.13.1
> fixall
```

* scalafmtAll

* Revert to ch.epfl.scala:sbt-scalafix

Co-authored-by: Bùi Việt Thành <thanhbv@sandinh.net>
2020-04-27 12:31:16 +02:00
Enno Runne
6f8be9a328 Docs: list persistence plugins 2020-04-27 11:23:37 +02:00
Patrik Nordwall
3784d03a2a remove visible protobuf-java dependency from akka-protobuf-v3, #28939 2020-04-27 11:15:10 +02:00
Patrik Nordwall
4ba835d328
Harden ShardCoordinator state replication, #28856 (#28895)
* Possibility to prefer oldest in ddata writes and reads
  * enabled for Cluster Sharding
* New ReadMajorityPlus and WriteMajorityPlus
  * used by Cluster Sharding, with configuration
  * also possible to define ReadAll in config
2020-04-24 14:19:53 +02:00
Domantas Petrauskas
d415211bf8
Update sbt-java-formatter to 0.5.1, disable javafmt on compile if discipline is disabled (#28962) 2020-04-24 14:12:01 +02:00
Arnout Engelen
305fa61a64
Fix typo in ClusterMetricsDisabledSpec (#28969)
Because of this typo this node did not follow the convention for multi-node
test class names from #28954, which caused its actor system to have an
unexpected name and fail to join the cluster.

Refs #28968
2020-04-24 14:10:50 +02:00
Patrik Nordwall
1dbc54b28a
fix wrong ActorSystem name when using MultiNodeClusterShardingSpec #28953 (#28954)
* fix wrong ActorSystem name when using MultiNodeClusterShardingSpec #28953

* use same testNameFromCallStack everywhere

* remove MultiJvm suffix from ActorSystem name
2020-04-23 15:54:38 +02:00
Hungai Amuhinda
9682a81b3f
Fix grammatical error (#28958) 2020-04-22 13:41:50 +02:00
Kirill Yankov
007aa0f710
#28908 - rename returnDefaultPolicy to resetPolicy (#28941) 2020-04-20 17:43:17 +02:00
Patrik Nordwall
1f448cae2c
Merge pull request #28920 from akka/wip-28918-cbor-patriknw
JacksonCborSerializer should use CBOR ofc, #28918
2020-04-20 16:06:04 +02:00
Patrik Nordwall
760efb7f71
Merge pull request #28947 from ohze/dotty/0
dotty phase 1
2020-04-20 16:03:01 +02:00
Patrik Nordwall
ef9a2c79c6 JacksonCborSerializer should use CBOR ofc, #28918
* When we updated to Jackson 2.10 (prior Akka 2.6.0) the new JsonFactoryBuilder
  was used. That doesn't preserve the formatParserFeatures and formatGeneratorFeatures
  from the base CBORFactory and therefore the format was plain JSON.

* rolling update compatibility
2020-04-20 15:09:43 +02:00
Bùi Việt Thành
666988ae57 scalafix Any2StringAdd
```
% sbt -Dakka.build.scalaVersion=2.13.1
> fixall
```
2020-04-20 17:59:50 +07:00
Bùi Việt Thành
8a40a0ceaa scalafix Any2StringAdd prepare
Remove an unused local variable that cause error when scalafix Any2StringAdd

```
scalafix.internal.v1.FileException: unexpected error processing file /Users/thanhbv/ohze/oss/akka/akka-bench-jmh/src/main/scala/akka/actor/TellOnlyBenchmark.scala
Caused by: org.scalameta.UnreachableError: this code path should've been unreachable
	at org.scalameta.UnreachableError$.raise(package.scala:40)
	at scala.meta.internal.prettyprinters.TreeSyntax$SyntaxInstances.isAmbiguousWithPatVarTerm$1(TreeSyntax.scala:251)
	at scala.meta.internal.prettyprinters.TreeSyntax$SyntaxInstances.guessIsBackquoted(TreeSyntax.scala:273)
  | => aat scala.meta.internal.prettyprinters.TreeSyntax$SyntaxInstances.$anonfun$syntaxTree$1(TreeSyntax.scala:331)
	at scala.meta.prettyprinters.Syntax$$anon$1.apply(Syntax.scala:9)
	at scala.meta.internal.prettyprinters.TreeSyntax$.$anonfun$apply$1(TreeSyntax.scala:1018)
	at scala.meta.prettyprinters.Syntax$$anon$1.apply(Syntax.scala:9)
	at scala.meta.prettyprinters.Api$XtensionSyntax.syntax(Api.scala:11)
	at scalafix.internal.v1.TreePos$.symbol(TreePos.scala:9)
	at scalafix.internal.v1.InternalSemanticDoc.fromTextDocument$1(InternalSemanticDoc.scala:53)
	at scalafix.internal.v1.InternalSemanticDoc.symbol(InternalSemanticDoc.scala:60)
	at scalafix.v1.package$XtensionTreeScalafix.symbol(package.scala:12)
	at scalafix.v1.SymbolMatcher.unapply(SymbolMatcher.scala:16)
	at scalafix.v1.SymbolMatcher.unapply$(SymbolMatcher.scala:15)
	at scalafix.v1.SymbolMatcher$$anon$2.unapply(SymbolMatcher.scala:29)
	at fix.Any2StringAdd$$anonfun$fix$1.applyOrElse(/Users/thanhbv/ohze/oss/scalafix-rules/scalafix/rules/src/main/scala/fix/Any2StringAdd.scala:41)
```
2020-04-20 17:59:50 +07:00
Bùi Việt Thành
fe0447d267 ExplicitResultTypes manually for implicit local val / def
ExplicitResultTypes scalafix rule can't fix those cases
2020-04-20 17:59:50 +07:00
Bùi Việt Thành
02b9b30354 scalafix ExplicitResultTypes - for implicit members 2020-04-20 17:59:50 +07:00