Permalink
Browse files

M[_[_]] (#26)

  • Loading branch information...
notxcain committed Feb 20, 2018
1 parent 13f991a commit 050b05071653525d628ad01681a3edfdfa35e69b
Showing with 3,628 additions and 2,891 deletions.
  1. +2 −2 .travis.yml
  2. +0 −58 aecor-akka-generic/src/main/scala/aecor/runtime/akkageneric/GenericAkkaRuntime.scala
  3. +0 −84 aecor-akka-generic/src/main/scala/aecor/runtime/akkageneric/GenericAkkaRuntimeActor.scala
  4. +0 −101 aecor-akka-persistence/src/main/scala/aecor/runtime/akkapersistence/AkkaPersistenceRuntime.scala
  5. +0 −72 aecor-akka-persistence/src/main/scala/aecor/runtime/akkapersistence/CassandraEventJournalQuery.scala
  6. +0 −52 ...-akka-persistence/src/main/scala/aecor/runtime/akkapersistence/CommittableEventJournalQuery.scala
  7. +0 −21 aecor-akka-persistence/src/main/scala/aecor/runtime/akkapersistence/EventJournalQuery.scala
  8. +0 −36 aecor-fs2/src/main/scala/aecor/effect/fs2/Fs2TaskInstances.scala
  9. +0 −3 aecor-fs2/src/main/scala/aecor/effect/fs2/package.scala
  10. +0 −35 aecor-monix/src/main/scala/aecor/effect/monix/MonixTaskInstances.scala
  11. +0 −3 aecor-monix/src/main/scala/aecor/effect/monix/package.scala
  12. +0 −108 aecor-test-kit/src/main/scala/aecor/testkit/Eventsourced.scala
  13. +0 −112 aecor-test-kit/src/main/scala/aecor/testkit/StateEventJournal.scala
  14. +0 −62 aecor-test-kit/src/main/scala/aecor/testkit/StateRuntime.scala
  15. +83 −109 build.sbt
  16. +0 −43 core/src/main/scala/aecor/data/Behavior.scala
  17. +0 −16 core/src/main/scala/aecor/data/Correlation.scala
  18. +0 −8 core/src/main/scala/aecor/data/EventsourcedBehavior.scala
  19. +0 −29 core/src/main/scala/aecor/data/Folder.scala
  20. +0 −20 core/src/main/scala/aecor/data/Handler.scala
  21. +0 −6 core/src/main/scala/aecor/data/Reducer.scala
  22. +0 −39 core/src/main/scala/aecor/data/Tagging.scala
  23. +0 −70 core/src/main/scala/aecor/effect/Async.scala
  24. +0 −23 core/src/main/scala/aecor/effect/Capture.scala
  25. +0 −28 core/src/main/scala/aecor/effect/CaptureFuture.scala
  26. +0 −15 core/src/main/scala/aecor/util/JavaTimeClock.scala
  27. +0 −28 distributed-processing/src/main/scala/aecor/distributedprocessing/AkkaStreamProcess.scala
  28. +0 −44 example/src/main/scala/aecor/example/AccountEndpoint.scala
  29. +0 −34 example/src/main/scala/aecor/example/domain/account/AccountEvent.scala
  30. +0 −107 example/src/main/scala/aecor/example/domain/account/EventsourcedAccountAggregate.scala
  31. +0 −153 example/src/main/scala/aecor/example/domain/transaction/EventsourcedTransactionAggregate.scala
  32. +0 −30 example/src/main/scala/aecor/example/domain/transaction/TransactionAggregate.scala
  33. +0 −36 example/src/main/scala/aecor/example/domain/transaction/TransactionEvent.scala
  34. +8 −0 modules/akka-cluster-runtime/src/main/resources/reference.conf
  35. +79 −0 modules/akka-cluster-runtime/src/main/scala/aecor/runtime/akkageneric/GenericAkkaRuntime.scala
  36. +126 −0 modules/akka-cluster-runtime/src/main/scala/aecor/runtime/akkageneric/GenericAkkaRuntimeActor.scala
  37. +1 −1 ...s/akka-cluster-runtime}/src/main/scala/aecor/runtime/akkageneric/GenericAkkaRuntimeSettings.scala
  38. +13 −19 {core → modules/akka-persistence-runtime}/src/main/resources/reference.conf
  39. +97 −0 ...kka-persistence-runtime/src/main/scala/aecor/runtime/akkapersistence/AkkaPersistenceRuntime.scala
  40. +82 −70 ...rsistence-runtime}/src/main/scala/aecor/runtime/akkapersistence/AkkaPersistenceRuntimeActor.scala
  41. 0 ...stence-runtime}/src/main/scala/aecor/runtime/akkapersistence/AkkaPersistenceRuntimeSettings.scala
  42. +34 −0 ...ka-persistence-runtime/src/main/scala/aecor/runtime/akkapersistence/CassandraJournalAdapter.scala
  43. +15 −0 modules/akka-persistence-runtime/src/main/scala/aecor/runtime/akkapersistence/JournalAdapter.scala
  44. +35 −0 modules/akka-persistence-runtime/src/main/scala/aecor/runtime/akkapersistence/SnapshotPolicy.scala
  45. +86 −0 ...time/src/main/scala/aecor/runtime/akkapersistence/readside/AkkaPersistenceEventJournalQuery.scala
  46. +11 −9 ...istence-runtime/src/main/scala/aecor/runtime/akkapersistence/readside}/CassandraOffsetStore.scala
  47. +45 −0 ...-runtime/src/main/scala/aecor/runtime/akkapersistence/readside/CommittableEventJournalQuery.scala
  48. +24 −0 ...akka-persistence-runtime/src/main/scala/aecor/runtime/akkapersistence/readside/JournalQuery.scala
  49. +43 −0 ...s/akka-persistence-runtime/src/main/scala/aecor/runtime/akkapersistence/readside/Projection.scala
  50. 0 .../akka-persistence-runtime}/src/main/scala/aecor/runtime/akkapersistence/serialization/Codec.scala
  51. +6 −0 ...akka-persistence-runtime/src/main/scala/aecor/runtime/akkapersistence/serialization/Message.scala
  52. +39 −0 ...stence-runtime/src/main/scala/aecor/runtime/akkapersistence/serialization/MessageSerializer.scala
  53. +6 −1 ...tence-runtime}/src/main/scala/aecor/runtime/akkapersistence/serialization/PersistentDecoder.scala
  54. +5 −0 ...tence-runtime}/src/main/scala/aecor/runtime/akkapersistence/serialization/PersistentEncoder.scala
  55. 0 ...sistence-runtime}/src/main/scala/aecor/runtime/akkapersistence/serialization/PersistentRepr.scala
  56. 0 ...stence-runtime}/src/main/scala/akka/persistence/cassandra/CassandraSessionInitSerialization.scala
  57. +52 −0 modules/benchmarks/src/main/scala/io/aecor/benchmarks/ComposerBenchmarks.scala
  58. +10 −0 modules/core/src/main/scala/aecor/ReifiedInvocation.scala
  59. +5 −0 modules/core/src/main/scala/aecor/arrow/Invocation.scala
  60. +44 −0 modules/core/src/main/scala/aecor/data/ActionT.scala
  61. +56 −0 modules/core/src/main/scala/aecor/data/Behavior.scala
  62. +1 −2 { → modules}/core/src/main/scala/aecor/data/Committable.scala
  63. +92 −0 modules/core/src/main/scala/aecor/data/Composer.scala
  64. 0 { → modules}/core/src/main/scala/aecor/data/ConsumerId.scala
  65. +5 −0 modules/core/src/main/scala/aecor/data/EntityEvent.scala
  66. 0 { → modules}/core/src/main/scala/aecor/data/EventTag.scala
  67. +41 −0 modules/core/src/main/scala/aecor/data/EventsourcedBehaviorT.scala
  68. +23 −50 { → modules}/core/src/main/scala/aecor/data/Folded.scala
  69. +18 −0 modules/core/src/main/scala/aecor/data/PairE.scala
  70. +24 −0 modules/core/src/main/scala/aecor/data/Tagging.scala
  71. +3 −2 { → modules}/core/src/main/scala/aecor/data/package.scala
  72. +13 −0 modules/core/src/main/scala/aecor/encoding/AnyValKeyDecoder.scala
  73. +12 −0 modules/core/src/main/scala/aecor/encoding/AnyValKeyEncoder.scala
  74. +121 −0 modules/core/src/main/scala/aecor/encoding/KeyDecoder.scala
  75. +52 −0 modules/core/src/main/scala/aecor/encoding/KeyEncoder.scala
  76. +58 −0 modules/core/src/main/scala/aecor/encoding/WireProtocol.scala
  77. +101 −0 modules/core/src/main/scala/aecor/macros/reifyInvocations.scala
  78. +189 −0 modules/core/src/main/scala/aecor/macros/wireProtocol.scala
  79. 0 { → modules}/core/src/main/scala/aecor/util/Clock.scala
  80. 0 { → modules}/core/src/main/scala/aecor/util/FunctionBuilder.scala
  81. +15 −0 modules/core/src/main/scala/aecor/util/JavaTimeClock.scala
  82. 0 { → modules}/core/src/main/scala/aecor/util/KeyValueStore.scala
  83. 0 { → modules}/core/src/main/scala/aecor/util/NoopKeyValueStore.scala
  84. +26 −0 modules/core/src/main/scala/aecor/util/effect.scala
  85. 0 { → modules}/distributed-processing/src/main/protobuf/DistributedProcessing.proto
  86. 0 { → modules}/distributed-processing/src/main/resources/reference.conf
  87. +27 −0 modules/distributed-processing/src/main/scala/aecor/distributedprocessing/AkkaStreamProcess.scala
  88. +36 −28 ...es}/distributed-processing/src/main/scala/aecor/distributedprocessing/DistributedProcessing.scala
  89. 0 ...buted-processing/src/main/scala/aecor/distributedprocessing/DistributedProcessingSupervisor.scala
  90. +12 −10 ...stributed-processing/src/main/scala/aecor/distributedprocessing/DistributedProcessingWorker.scala
  91. 0 ...es}/distributed-processing/src/main/scala/aecor/distributedprocessing/serialization/Message.scala
  92. 0 ...buted-processing/src/main/scala/aecor/distributedprocessing/serialization/MessageSerializer.scala
  93. +4 −25 { → modules}/example/src/main/resources/application.conf
  94. 0 { → modules}/example/src/main/resources/logback.xml
  95. +38 −0 modules/example/src/main/scala/aecor/example/AccountEndpoint.scala
  96. 0 { → modules}/example/src/main/scala/aecor/example/AnyValCirceEncoding.scala
  97. +48 −47 { → modules}/example/src/main/scala/aecor/example/App.scala
  98. +1 −0 { → modules}/example/src/main/scala/aecor/example/MonixSupport.scala
  99. +14 −17 { → modules}/example/src/main/scala/aecor/example/ScheduleApp.scala
  100. +41 −43 { → modules}/example/src/main/scala/aecor/example/TransactionEndpoint.scala
  101. 0 { → modules}/example/src/main/scala/aecor/example/domain/Amount.scala
  102. +5 −0 modules/example/src/main/scala/aecor/example/domain/EventMeta.scala
  103. +23 −25 { → modules}/example/src/main/scala/aecor/example/domain/TransactionProcess.scala
  104. +26 −26 ...ccountAggregate.scala → modules/example/src/main/scala/aecor/example/domain/account/Account.scala
  105. +25 −0 modules/example/src/main/scala/aecor/example/domain/account/AccountEvent.scala
  106. 0 { → modules}/example/src/main/scala/aecor/example/domain/account/AccountId.scala
  107. +91 −0 modules/example/src/main/scala/aecor/example/domain/account/EventsourcedAccount.scala
  108. +132 −0 ...es/example/src/main/scala/aecor/example/domain/transaction/EventsourcedTransactionAggregate.scala
  109. +26 −0 modules/example/src/main/scala/aecor/example/domain/transaction/TransactionAggregate.scala
  110. +28 −0 modules/example/src/main/scala/aecor/example/domain/transaction/TransactionEvent.scala
  111. 0 { → modules}/example/src/main/scala/aecor/example/persistentEncoderUtil.scala
  112. +0 −4 { → modules}/schedule/src/main/protobuf/ScheduleEvents.proto
  113. 0 { → modules}/schedule/src/main/resources/reference.conf
  114. +17 −22 { → modules}/schedule/src/main/scala/aecor/schedule/CassandraScheduleEntryRepository.scala
  115. +16 −20 { → modules}/schedule/src/main/scala/aecor/schedule/DefaultSchedule.scala
  116. +111 −0 modules/schedule/src/main/scala/aecor/schedule/DefaultScheduleBucket.scala
  117. +22 −26 { → modules}/schedule/src/main/scala/aecor/schedule/Schedule.scala
  118. +19 −0 modules/schedule/src/main/scala/aecor/schedule/ScheduleBucket.scala
  119. +21 −0 modules/schedule/src/main/scala/aecor/schedule/ScheduleBucketId.scala
  120. +4 −8 { → modules}/schedule/src/main/scala/aecor/schedule/ScheduleEntryRepository.scala
  121. +15 −15 { → modules}/schedule/src/main/scala/aecor/schedule/process/DefaultScheduleEventJournal.scala
  122. +12 −18 { → modules}/schedule/src/main/scala/aecor/schedule/process/PeriodicProcessRuntime.scala
  123. +8 −0 modules/schedule/src/main/scala/aecor/schedule/process/ScheduleEventJournal.scala
  124. +13 −13 { → modules}/schedule/src/main/scala/aecor/schedule/process/ScheduleProcess.scala
  125. +7 −42 { → modules}/schedule/src/main/scala/aecor/schedule/protobuf/ScheduleEventCodec.scala
  126. 0 { → modules}/schedule/src/main/scala/aecor/schedule/protobuf/ScheduleEventSerializer.scala
  127. +44 −36 {aecor-test-kit → modules/test-kit}/src/main/scala/aecor/testkit/E2eSupport.scala
  128. +2 −3 {aecor-test-kit → modules/test-kit}/src/main/scala/aecor/testkit/EventJournal.scala
  129. +134 −0 modules/test-kit/src/main/scala/aecor/testkit/Eventsourced.scala
  130. 0 {aecor-test-kit → modules/test-kit}/src/main/scala/aecor/testkit/StateClock.scala
  131. +118 −0 modules/test-kit/src/main/scala/aecor/testkit/StateEventJournal.scala
  132. 0 {aecor-test-kit → modules/test-kit}/src/main/scala/aecor/testkit/StateKeyValueStore.scala
  133. +63 −0 modules/test-kit/src/main/scala/aecor/testkit/StateRuntime.scala
  134. 0 {tests/src/test → modules/tests/src/main}/scala/aecor/tests/PersistentEncoderCirce.scala
  135. +57 −0 modules/tests/src/main/scala/aecor/tests/e2e/Counter.scala
  136. +7 −5 {tests/src/test → modules/tests/src/main}/scala/aecor/tests/e2e/CounterViewProcess.scala
  137. +5 −5 {tests/src/test → modules/tests/src/main}/scala/aecor/tests/e2e/CounterViewRepository.scala
  138. +39 −0 modules/tests/src/main/scala/aecor/tests/e2e/NotificationProcess.scala
  139. +5 −8 {tests/src/test → modules/tests/src/main}/scala/aecor/tests/e2e/TestScheduleEntryRepository.scala
  140. +47 −0 modules/tests/src/main/scala/aecor/tests/e2e/notification.scala
  141. +2 −0 modules/tests/src/test/resources/cassandra-topology.properties
  142. +4 −0 modules/tests/src/test/resources/log4j.properties
  143. +18 −0 modules/tests/src/test/resources/logback-test.xml
  144. +81 −0 modules/tests/src/test/scala/aecor/tests/AkkaPersistenceRuntimeSpec.scala
  145. 0 { → modules}/tests/src/test/scala/aecor/tests/AkkaSpec.scala
  146. +103 −0 modules/tests/src/test/scala/aecor/tests/CassandraLifecycle.scala
  147. +16 −0 modules/tests/src/test/scala/aecor/tests/ComposerSpec.scala
  148. +50 −46 { → modules}/tests/src/test/scala/aecor/tests/EndToEndTest.scala
  149. +5 −13 { → modules}/tests/src/test/scala/aecor/tests/FoldedTests.scala
  150. +43 −0 modules/tests/src/test/scala/aecor/tests/GadtTest.scala
  151. +73 −0 modules/tests/src/test/scala/aecor/tests/GenericRuntimeSpec.scala
  152. 0 { → modules}/tests/src/test/scala/aecor/tests/LawSuite.scala
  153. +8 −19 ...s/ScheduleAggregateSpec.scala → modules/tests/src/test/scala/aecor/tests/ScheduleBucketSpec.scala
  154. 0 { → modules}/tests/src/test/scala/aecor/tests/ScheduleEventCodecSpec.scala
  155. +51 −0 modules/tests/src/test/scala/aecor/tests/StateRuntimeSpec.scala
  156. +1 −1 project/build.properties
  157. +9 −7 project/plugins.sbt
  158. +0 −150 schedule/src/main/scala/aecor/schedule/DefaultScheduleAggregate.scala
  159. +0 −59 schedule/src/main/scala/aecor/schedule/ScheduleAggregate.scala
  160. +0 −7 schedule/src/main/scala/aecor/schedule/process/ScheduleEventJournal.scala
  161. +0 −66 tests/src/test/scala/aecor/tests/AkkaPersistenceRuntimeSpec.scala
  162. +0 −10 tests/src/test/scala/aecor/tests/CompositeCorrelationIdSpec.scala
  163. +0 −37 tests/src/test/scala/aecor/tests/DistributedSourceWorkerSpec.scala
  164. +0 −67 tests/src/test/scala/aecor/tests/ShardedRuntimeSpec.scala
  165. +0 −56 tests/src/test/scala/aecor/tests/StateRuntimeSpec.scala
  166. +0 −69 tests/src/test/scala/aecor/tests/e2e/CounterOp.scala
  167. +0 −39 tests/src/test/scala/aecor/tests/e2e/NotificationProcess.scala
  168. +0 −58 tests/src/test/scala/aecor/tests/e2e/notification.scala
@@ -1,7 +1,7 @@
language: scala
scala:
- 2.11.11-bin-typelevel-4
- 2.12.2-bin-typelevel-4
- 2.11.12
- 2.12.4
jdk:
- oraclejdk8

This file was deleted.

Oops, something went wrong.

This file was deleted.

Oops, something went wrong.

This file was deleted.

Oops, something went wrong.

This file was deleted.

Oops, something went wrong.

This file was deleted.

Oops, something went wrong.
Oops, something went wrong.

0 comments on commit 050b050

Please sign in to comment.