Commit graph

367 commits

Author SHA1 Message Date
Viktor Klang
978c86339f #2721 - Adding implicit sender to Scheduler + tests 2012-12-18 10:25:48 +01:00
Björn Antonsson
a03460329d Change cluster MemberEvents to only be published on convergence. See #2692
Conflicts:
	akka-cluster/src/main/scala/akka/cluster/ClusterEvent.scala
	akka-cluster/src/main/scala/akka/cluster/ClusterJmx.scala
	akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala
	akka-cluster/src/main/scala/akka/cluster/ClusterReadView.scala
	akka-cluster/src/multi-jvm/scala/akka/cluster/MultiNodeClusterSpec.scala
	akka-docs/rst/cluster/cluster-usage-java.rst
	akka-docs/rst/cluster/cluster-usage-scala.rst
	akka-kernel/src/main/dist/bin/akka-cluster
2012-12-14 12:46:13 +01:00
Patrik Nordwall
44ab9f116f min-nr-of-members and registerOnMemberUp, see #2306
* Leader moves joining members to up when min-nr-of-members reached
* Tested by MinMembersBeforeUpSpec
* Used in factorial sample
* Docs
2012-12-12 14:00:06 +01:00
Patrik Nordwall
1673ccd51c Load Cluster extension from ClusterActorRefProvider, see #2704 2012-12-04 17:54:17 +01:00
Patrik Nordwall
4761feb071 Merge pull request #858 from akka/wip-2547-metrics-router-patriknw
AdaptiveLoadBalancingRouter and refactoring of metrics, see #2547
2012-11-30 23:37:30 -08:00
Patrik Nordwall
5ab0010a68 Hardening the tests in cluster sample, see #2654 2012-11-26 15:29:25 +01:00
Patrik Nordwall
6d13a72001 Hardening the tests in cluster sample, see #2654 2012-11-26 15:29:24 +01:00
Patrik Nordwall
5eec693fd0 Incorparate review feedback, see #2547
* case object and case class for MixMetricsSelector
* Rename decay-half-life-duration to moving-average-half-life
* Clarification of decay-half-life-duration and collect-interval
* Removed Fields, Java compatibility issue
* Adapt for-yield variables
* Comment metrics collector constructor that takes system param
* Don't copy EWMA if not needed
* LogOf2 constant 0.69315
* Don't use mapValues
* Remove RichInt conversion
* sigar version replace tag in docs
* createDeployer factory method to make it possible to override
  deployer in subclass
* Improve readability of MetricsListener (in sample)
* Better startup of factorial sample (no sleep)
* Many minor enhancements and cleanups
2012-11-16 11:03:20 +01:00
Patrik Nordwall
524bb65e0f Increase within timeouts in cluster sample tests, see #2699 2012-11-15 08:28:35 +01:00
Patrik Nordwall
dcde7d3594 AdaptiveLoadBalancingRouter and more refactoring of metrics, see #2547
* Refactoring of standard metrics extractors and data structures
* Removed optional value in Metric, simplified a lot
* Configuration of EWMA by using half-life duration
* Renamed DataStream to EWMA
* Incorporate review feedback
* Use binarySearch for selecting weighted routees
* More metrics selectors for the router
* Removed network metrics, since not supported on linux
* Configuration of router
* Rename to AdaptiveLoadBalancingRouter
* Remove total cores metrics, since it's the same as jmx getAvailableProcessors,
  tested on intel 24 core server and amd 48 core server, and MBP
* API cleanup
* Java API additions
* Documentation of metrics and AdaptiveLoadBalancingRouter
* New cluster sample to illustrate metrics in the documentation,
  and play around with (factorial)
2012-11-14 15:08:30 +01:00
Patrik Nordwall
2e2d367ae6 Missing variable assignment, see #2677
* Credit goes to Eric Pederson
2012-11-01 19:28:01 +01:00
Patrik Nordwall
dfb9280049 Eliminate glitch that caused job to be sent to deadletters, see #2630
* Cluster sample
* The problem was that the sent job was sometimes sent to deadLetters
* The reason was that statsService was not created when a facade
  at another node forwared the job to the statsService, i.e.
  deadLetters
* Solved by using ask and recover with JobFailed in case of
  timeout in the facade, so that the facade always sends back
  JobResult or JobFailed
2012-10-24 18:14:08 +02:00
Viktor Klang
f915d1335d #2628 - make HelloActor and WorldActor public static classes 2012-10-18 17:46:55 +02:00
Viktor Klang
6c89f640b6 Bumping the version of Akka master to 2.2-SNAPSHOT 2012-10-17 01:00:57 +02:00
Patrik Nordwall
94eaeca3a7 Mavenize java akka-sample-cluster 2012-10-16 11:03:43 +02:00
Roland
b96d77c15a actually build the samples
and fix the resulting breakage (of not compiling them for some time,
that is)

also remove the last casts to FiniteDuration
2012-10-15 17:17:54 +02:00
Roland
0f04239f67 move Duration classes according to scala 2.10 nightly and remove casts to FiniteDuration, see #2504 2012-10-11 15:18:10 -07:00
Patrik Nordwall
c959d4a973 Incorporate feedback, see #2502 2012-10-05 08:17:54 +02:00
Patrik Nordwall
c5bdc636c9 Remove refactoring residue, see #2502 2012-10-04 18:09:08 +02:00
Patrik Nordwall
3e0e5f8473 Java version of Cluster usage documentation, see #2502
* Created separate java and scala rst chapters
* Converted the 3 cluster samples to java
* Everything tested manually, and with new multi-node tests
2012-10-04 14:16:11 +02:00
Björn Antonsson
08ef942242 Reformating configuration and examples for PDF (Scala, and leftovers). See #2413 2012-10-01 20:35:46 +02:00
Björn Antonsson
309bb53d98 Reformating configuration and examples for PDF (Java). See #2413 2012-10-01 20:35:46 +02:00
Roland
be877a6197 export supervision tools in Act trait, and other review fixes
- add more cross references to ActorDSL docs
- improve SBT command line for running the multi-node test
- correct small error in Restart Hooks section of actors.rst
2012-09-25 12:20:52 +02:00
Roland
3627b6cb4c replace/add READMEs for the samples (keep it simple) 2012-09-25 09:27:13 +02:00
Roland
ca75bbc2a0 say "IO support" in docs (avoid "module") 2012-09-24 11:51:21 +02:00
Patrik Nordwall
d2747df451 Merge branch 'master' into wip-2437-doc-cluster-test-patriknw
Conflicts:
	project/AkkaBuild.scala
2012-09-22 09:16:05 +02:00
Björn Antonsson
78597ed7c1 Merge branch 'master' into wip-2349-multi-node-and-multi-jvm-doc-ban
Conflicts:
	project/plugins.sbt
2012-09-21 17:00:34 +02:00
Patrik Nordwall
158f32e99b Merge branch 'master' into wip-2437-doc-cluster-test-patriknw 2012-09-21 16:50:18 +02:00
Björn Antonsson
3d83a25d64 Changed order of sections and additions based on review . See #2349 2012-09-21 12:30:05 +02:00
Viktor Klang (√)
a323161b2f Merge pull request #719 from akka/wip-2530-deprecate-tell1-∂π
remove all but one occurrence of single-arg tell()
2012-09-21 03:05:00 -07:00
Patrik Nordwall
7bb125385b Describe how to write cluster test, see #2437 2012-09-21 11:48:47 +02:00
Björn Antonsson
67f0de87b1 Multi Node Testing Docs and Sample. See #2349 2012-09-20 21:55:09 +02:00
Patrik Nordwall
c7b966b4e7 Switch to ConistentHashingRouter in cluster sample 2012-09-20 12:58:51 +02:00
Patrik Nordwall
9423d37da9 Merge branch 'master' into wip-cluster-docs-patriknw
Conflicts:
	project/AkkaBuild.scala
2012-09-20 10:40:08 +02:00
Roland
ce49ffe3c6 remove all but one occurrence of single-arg tell() 2012-09-19 23:55:53 +02:00
Roland
2502919c6e Merge branch 'wip-more-duration-∂π' 2012-09-19 14:45:37 +02:00
Patrik Nordwall
9ec7645617 Support load of extensions without specifying trailing $, see #2496
* Backwards compatible, i.e. still possible to use $
* DynamicAccess tries first with $ in getObjectFor, then falls back
  to fqcn as is
2012-09-18 15:51:26 +02:00
Patrik Nordwall
c0c6cc3931 Publish cluster LeaderChanged only when convergence, see #2518 2012-09-18 14:19:38 +02:00
Patrik Nordwall
175dd4c547 Minor cleanup 2012-09-18 10:49:41 +02:00
Roland
35b7a9e338 second round of FiniteDuration business, including cluster fixes
- make Scheduler only accept FiniteDuration, which has quite some
  knock-on effects
2012-09-18 09:58:30 +02:00
Patrik Nordwall
0524ba0a65 Cluster documentation
* 2 Sample applications with main programs to play with,
  and multi-node tests to illustrate testing, and
  code snippets for inclusion in rst docs
* TransformationSample illustratates subscription to
  cluster events
* StatsSample illustrates usage of cluster aware routers, both
  lookup and deploy
2012-09-13 11:35:04 +02:00
Patrik Nordwall
a237058b64 First part of usage doc for cluster, see #1916
* Sample app, akka-sample-cluster
* Preparing Your Project for Clustering
* A Simple Cluster Example
* Automatic vs. Manual Joining
* Automatic vs. Manual Downing
* Configuration
2012-08-27 17:15:11 +02:00
Patrik Nordwall
4a06719722 Merge branch 'master' into wip-2202-fine-grained-events-patriknw
Conflicts:
	akka-cluster/src/multi-jvm/scala/akka/cluster/TransitionSpec.scala
2012-08-27 16:52:06 +02:00
Patrik Nordwall
8fe8fc5512 Remove cluster-sample/README, was added prematurely 2012-08-21 18:16:04 +02:00
Patrik Nordwall
20a038fdfd Fine grained events, see #2202
* Defined the domain events in ClusterEvent.scala file
* Produce events from diff  and publish publish to event bus
  from separate actor, ClusterDomainEventPublisher
* Adjustments of tests
2012-08-21 15:35:38 +02:00
Patrik Nordwall
331cd7fca3 WIP cluster docs 2012-08-16 14:48:15 +02:00
RayRoestenburg
7071ac2b8d ticket #2322 updated camel to 2.10.0
ticket #1928  added camel samples to a proper sample project
2012-08-11 22:04:54 +02:00
Viktor Klang
54a3a44bf8 #2292 - Removing akka.util.Duration etc and replace it with scala.concurrent.util.Duration 2012-06-29 13:33:20 +02:00
Viktor Klang
4c2ac278a7 Getting akka-sample-fsm compiling and tests green 2012-06-25 19:15:57 +02:00
Viktor Klang
4ee2033761 Lots and lots of work to get things to compile without warnings 2012-06-13 15:44:24 +02:00