raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10
23776 commits 1 branch 31 tags 268 MiB
Commit graph

23776 commits

This branch
This branch
All branches
Author SHA1 Message Date
Helena Edelson
737fedcb91
Review suggestions tested and added, stepped on the merge gas with two approvals but suggestions lingering #27424 (#27433) 2019-07-30 06:30:57 -07:00
Helena Edelson
5f35c2326e
Cleaned up ShardsQueryResult and added region shards query timeout for failure context in logging. (#27427) 2019-07-30 05:33:37 -07:00
Christopher Batey
89e269d5d8 Remove catchall silents from prod code (#27432) 
* WIP

* Remove catch all silent annocations from prod code
 2019-07-30 11:12:23 +02:00
Arnout Engelen
e898197bdd Add 'core' and 'dumps' to gitignore (#27423) 
'core' is sometimes left behind by graphviz, and a 'dumps' directory
is sometimes left behind when running with jdk11 and graal.
 2019-07-30 08:11:05 +01:00
Arnout Engelen
80a920da52 Fix warnings in akka-actor-typed-tests (#27424) 2019-07-29 13:52:07 -07:00
Dale Wijnand
c4417d1c59 Reword the "private messages" typed style docs (#27392) 
Use Message/Command/Event as a better example, as the
PrivateCommand/Command example seemed to go out of its way to look
like an unattractive implementation strategy.

Oh, and touch up the "Partial versus total Function" section below too.
 2019-07-29 12:00:27 +02:00
Mohamed Ali Bannour
56f3a6b126 Update example documentation of retry. (#27403) 2019-07-26 13:56:51 -07:00
Christopher Batey
e188b1f653 Migration guide for Persistent FSM to typed persistence (#27336) 2019-07-26 10:01:11 +02:00
Helena Edelson
3534a0b977
Productionize: GetShardRegionStats returns empty shard set on ask timeout (#27395) 2019-07-25 08:00:34 -07:00
Johannes Rudolph
051ff07ca2 Provide more helpful message when synchronous testing ActorRef is used for asking (#27414) 2019-07-25 16:42:24 +02:00
Christopher Batey
4f6cccc4d8 Fix stashing of commands when snapshot is in progress (#27389) 
* Fix stashing of commands when snapshot is in progress

Fixes #27381

* Naming
 2019-07-25 16:32:57 +02:00
Arnout Engelen
e5e2922b0f
OutputStreamGraphStage follow-up fixes (#27412) 
To https://github.com/akka/akka/pull/26827
 2019-07-25 14:58:43 +02:00
Johannes Rudolph
e39bbb34b8
Deemphasize CallingThreadDispatcher in the docs (#27401) 
Deemphasize CallingThreadDispatcher in the docs
 2019-07-25 14:26:38 +02:00
Helena Edelson
96abaf2168 Add clarification to doc on cluster cross boundary use of DeathWatch (#27385) 
* Add clarification to doc on cluster cross boundary use of DeathWatch #27376

* Clarrified reasoning and behavior update, and updated warning config name to same convention.
 2019-07-25 14:12:57 +02:00
Christopher Batey
625eb7b913 Re-write output stream subscriber as graph stage (#26827) 2019-07-25 13:51:47 +02:00
Christopher Batey
09838a71e5 Remove source/sink fromPublisher/fromSubscriber (#27288) 
* Remove source/sink fromPublisher/fromSubscriber

Refs #26187

* mima
 2019-07-25 13:16:30 +02:00
Helena Edelson
ba2384893f Expand on rolling update recommendations, best practices (#27382) 2019-07-25 11:53:16 +02:00
Yury Gribkov
a53f1a8101 Change the onWriteRejected and onWriteFailed signature to pass PersistentRepr for context propagation. (#27408) 2019-07-25 10:26:24 +01:00
kenji yoshida
94857fd4e1 update mima url (#27407) 2019-07-24 14:22:10 +02:00
Dale Wijnand
5997f516de Reword the "Where to define messages" style docs (#27393) 2019-07-24 13:26:43 +02:00
Kun Song
38be540467 Use min of numberOfMessages and buffer size when unstash. (#27398) 2019-07-24 12:32:22 +02:00
Christopher Batey
7cc7d86971
Instructions for generating protobuf (#27402) 
* Instructions for generating protobuf

* Update CONTRIBUTING.md

Co-Authored-By: Arnout Engelen <github@bzzt.net>
 2019-07-24 10:25:53 +01:00
Arnout Engelen
6d4fbfc43d Loosen expectation of TlsTcpWithHostnameVerificationSpec (#27394) (#27396) 2019-07-24 08:34:25 +01:00
Arnout Engelen
ccd2c9aff6 Include version error in the docs (#27365) 
So the relevant section will show up in google
 2019-07-24 07:47:37 +01:00
Arnout Engelen
c4d4dd3875 Persistence typed context (#27404) 
* Add context parameters to persistence typed
* Add hooks to capture event-written
 2019-07-23 18:47:25 -07:00
Johannes Rudolph
743c542e18 streams: clarify how to complete a Source.actorRef in Scaladocs and docs (#27325) 
* streams: clarify how to complete a Source.actorRef in Scaladocs and docs
 2019-07-23 19:17:11 +02:00
Christopher Batey
6c416c2818 User serializer for protobuf3 (#27362) 
* User serializer for protobuf3
 2019-07-23 16:22:07 +02:00
kerr
d4dcbee4c9 Use a dedicated mismatching indicator instead of null for WidenInterceptor. (#27292) 2019-07-23 15:58:03 +02:00
Arnout Engelen
df57d42782
Deemphasize CallingThreadDispatcher in the docs (#27387) 2019-07-23 10:09:59 +02:00
Kun Song
5e68cd0297 Fix a typo in Stash document (#27399) 2019-07-23 09:35:31 +02:00
Dale Wijnand
f2eec1106d Reword the "ask versus ?" typed style docs (#27390) 2019-07-23 09:25:34 +02:00
Dale Wijnand
fb653cc336 Fix some grammar in the typed style guide (#27388) 
Also, use English ("for example") rather than Latin ("e.g.") in docs.
 2019-07-22 15:25:01 +02:00
Christopher Batey
69fd98a39d Fix SurviveNetworkInstabilitySpec (#27383) 2019-07-19 07:27:08 -07:00
jeremie-seguin
950ec71294 fix typo in stream doc (#27379) 2019-07-19 09:18:08 +02:00
Johan Andrén
03b8c543fc Serialization support for wrapped stream refs (#27353) 2019-07-16 10:11:33 -07:00
kerr
cdd7976c26 Don't use pattern matching to generate less bytecode. (#27293) 2019-07-16 08:30:54 -07:00
Arnout Engelen
c3e8a968d9
Test hostname verification (#27355) 2019-07-16 15:32:50 +02:00
Patrik Nordwall
10c2b0714a reduce message sizes for Gossip and DeltaPropagation in ddata, #27175 (#27176) 2019-07-16 14:22:16 +02:00
Johan Andrén
2626f17747
Select mailbox in Akka typed actors #27124 2019-07-16 13:52:23 +02:00
Johan Andrén
d03294d359
Align SpawnProtocol with style guide #27318 2019-07-16 11:36:12 +02:00
James Roper
511356177d Added actor termination coordinated shutdown task #27089 
A convenience method that allows creating a
shutdown task by sending a message to an actor, and watching for its
termination.
 2019-07-16 10:56:48 +02:00
Arnout Engelen
d3170a56ea Add fluent API for 2-stream merging (#27020) 
* fluent API for 2-stream mergeLatest, mergePreferred and mergePrioritized
* Add javadocs and 'eagerClose' paramter to 'mergeLatest'
* fluent API's for
 2019-07-16 10:54:18 +02:00
Philippus Baalman
0f7dbf6fcb Replace link to scalariform with link to scalafmt (#27239) 2019-07-15 15:51:32 +02:00
Johan Andrén
f0e42d2b9c
Cluster aware routers for typed #26355 2019-07-15 15:25:00 +02:00
Christopher Batey
d2f5d2daa3 Allow java serialization for TypedActorRemoteDeploySpec (#27354) 
* Allow java serialization for TypedActorRemoteDeploySpec

* Also delete ignore for 2.12 annotation
 2019-07-15 14:00:34 +02:00
rohitkumbhar
50b63464fa Hostname verification should be done by the client only (#26906) 
Setting the endpoint identification algorithm to HTTPS on the server engine
forces the client to preset a certificate that contains the server name. This
is rather unlikely and it fails TLS handshake today

This change will allow hostname verification to be done by the client only
 2019-07-15 13:43:50 +02:00
Helena Edelson
a110be8f69
Fix intercept of Watch in use of safe remote features #27333 (#27334) 
And added one more case for cluster watcher, watching remote no cluster watchee, and the reverse.
 2019-07-12 12:18:37 -07:00
Patrik Nordwall
d27be3fa48
Merge pull request #27337 from akka/wip-22805-style4-patriknw 
Style Guide: enum msg, ask, tot fun, naming, meth ref, intro, #22805
 2019-07-12 19:21:02 +02:00
Patrik Nordwall
6f94707cfd Style Guide: Additional sections, #22805 
* Behavior factory method
  * AbstractBehavior via Behaviors.setup
* Where to define messages
* Public vs. private messages
* Singleton messages, enum
* ask vs ?
* Partial vs. total Function
* Additional naming conventions
* Lamdas vs. method references
* intro

Co-Authored-By: Helena Edelson <helena@users.noreply.github.com>
 2019-07-12 17:13:58 +02:00
Patrik Nordwall
0f01df713f
Merge pull request #27302 from akka/wip-27301-copyUSAsciiStrToBytes-patriknw 
Harden copyUSAciiBytesToStr, so that it works on Raspberry Pi, #27301
 2019-07-12 16:48:24 +02:00