You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2022/10/31 09:12:15 UTC
[incubator-pekko-persistence-r2dbc] branch main created (now d47856c)
This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-persistence-r2dbc.git
at d47856c sbt 1.7.1 (was 1.6.2) (#266)
This branch includes the following new commits:
new dddb44f Initial main
new bc217ef Initial build infra
new 7149cd8 Merge pull request #1 from patriknw/wip-initial-build-patriknw
new 4778e99 First journal implementation
new 1a06782 Merge pull request #2 from patriknw/wip-journal-patriknw
new a9ec9cd Query events by slice
new ac00a77 Merge pull request #3 from patriknw/wip-slice-query-patriknw
new b2c265d Connection pool workaround
new f6cba2a Merge pull request #4 from patriknw/wip-pool-patriknw
new 5923ba9 Read in chunks
new 2ef5a02 Merge pull request #5 from patriknw/wip-read-buffer-patriknw
new 181325c EventSourcedProvider2 for eventsBySlices projection
new 62c11d5 Serializer for TimestampOffset
new 29bed1f deleted = false in eventsBySlicesRangeSql
new 9ba9822 Merge pull request #6 from patriknw/wip-projection-patriknw
new 3e08146 Test with Yugabyte
new a4c328a Merge pull request #7 from patriknw/wip-yugabyte-patriknw
new cffc12d Read behind current timestamp
new 7d16d66 Merge pull request #8 from patriknw/wip-tail-patriknw
new 9abcc52 Remove duplicate schema definitions
new f246236 Don't try to publish just yet
new 4d173aa Merge pull request #9 from patriknw/wip-less-schema-patriknw
new 294574e R2dbcProjection
new 88babd6 Disable Yugabyte in CI for now
new 72795aa Merge pull request #10 from patriknw/wip-projection2-patriknw
new 0544eb0 One OffsetStore per projectionId
new d681f96 Merge pull request #11 from patriknw/wip-projectionId-patriknw
new 3a3d239 OffsetStore for TimestampOffset
new 5ec3c95 Merge pull request #12 from patriknw/wip-timestamp-offset-store-patriknw
new cb2be54 Deduplicate already seen offsets
new 5c06562 More state in ContinuousQuery
new 8e0d7b8 Merge pull request #13 from patriknw/wip-projection-timestamp-offset-patriknw
new 972a66a Backtracking to find missing events
new d847154 Only accept known expected sequence numbers
new 96d01ce Merge pull request #14 from patriknw/wip-backtrack-patriknw
new 7abfe82 End-to-end test of eventsBySlices projection
new b5698d5 Merge pull request #15 from patriknw/wip-accept-seqNr-patriknw
new b81d353 Don't run tests in parallel
new ec57a41 Merge pull request #16 from patriknw/wip-e2e-test-patriknw
new ac0949c Randomized chaos test
new 3c545b0 sliceRanges in projection api
new 566bdae Merge pull request #17 from patriknw/wip-chaos-patriknw
new bc7cee8 fork tests
new 1ade913 remove verbose logging setting
new cf6bf30 Merge pull request #18 from patriknw/wip-slice-api-patriknw
new 115a2e6 Merge pull request #19 from patriknw/wip-fork-test-patriknw
new 2533f02 Merge pull request #20 from patriknw/wip-verbose-patriknw
new b61aac4 bind with index instead of named param
new 59783b3 Fix problem with connection pool
new 1f78b54 Merge pull request #21 from patriknw/wip-sql-params-patriknw
new a7fc9dc Merge pull request #22 from patriknw/wip-con-pool-patriknw
new a29413a Better performance with auto commit for single update
new d7744ab forceBinary and preferAttachedBuffers
new d208bb3 Merge pull request #23 from patriknw/wip-auto-patriknw
new 75c28a1 schema setting
new c0c4489 Merge pull request #24 from patriknw/wip-schema-patriknw
new 1674f9d Fix use-connection-factory setting
new 213fabf Merge pull request #25 from patriknw/wip-settings-patriknw
new 9f7dd69 No need to rollback when auto-commit
new 4c1c0a2 Simplify exc handling in R2dbcExecutor
new 0c8606b Merge pull request #26 from patriknw/wip-auto-rollback-patriknw
new 4d7105f Query params in same order as param index
new 3dc507f Test for grouped projection - filter out unknown sequence numbers
new 34f51de Merge pull request #38 from akka/wip-grouped-test-patriknw
new f2c4e81 fix publisher completion
new f178a29 delayNextQuery is S => Opt[Duration]
new 62aebc8 Merge pull request #42 from akka/rgc/fix-publisher-completion
new 5a958af Merge pull request #43 from akka/rgc/clean-up-unused-code
new 5d7b17b Increase buffer-size in ChaosSpec
new 1f5853a Merge pull request #37 from akka/wip-query-params-patriknw
new 8a5785b Merge pull request #45 from akka/wip-buffer-size-patriknw
new 86470e4 Transactions are wrong with the connection pool, #46 (#47)
new 3b83479 Filter duplicates for async and flow projections, #35 (#39)
new aeb098f enable tests with yugabyte (#51)
new c96e73c Fix connection pool problem, #48 (#52)
new 8d9cc45 Design notes
new 3fd546b Merge pull request #56 from akka/wip-design-patriknw
new 426fe4a Close connection pool before terminating actor system (#55)
new 4d5a954 clear seen when loading, #54
new db2731d R2dbcExecutor RS-utilities (internal) public (#50)
new 00ef575 Merge pull request #60 from akka/wip-54-clear-seen-patriknw
new fc19102 Make deserializeAndAddOffset a Flow
new d40885e Merge pull request #58 from akka/wip-feedback-patriknw
new 05ef321 Guard against transaction_timestamp() moving backwards #49 (#59)
new 4d6e5a3 temporarily disable query cache (#61)
new bfb84b8 Yugabyte tables (#63)
new 932361d update sbt (#68)
new bd0bc57 run statements in order when using the same connection (#69)
new a7426c0 exec time from pg_stat_statements (#66)
new 12a218a Include slice and entity type in journal queries (#62)
new d2fcb67 SSL settings (#67)
new 470822b Yugabyte 2.9 in CI (#70)
new 1f9dd5a Limit cache size to force usage of BoundedStatementCache (#71)
new a0aa31a Clarify not supported (#91)
new 79c4275 consume Flux directly into a IndexedSeq (#93)
new 5011501 DurableStateStore implementation (#92)
new 41436ff fix continuous query outlet name (#94)
new 8cc2c42 DurableState by slices query, #79 (#97)
new 2f92339 inflight cache accept event after retry (#99)
new 46827d9 Extract common by slice query logic (#98)
new 8cd8982 Make inflight more robust, #31 (#101)
new a7df450 Create the test table from the tests
new 6e43673 currentPersistenceIds query, #81 (#105)
new 836de16 Metadata for replicated event sourcing, #85
new 8a695b6 Merge pull request #110 from akka/wip-85-meta-patriknw
new a8d615b Merge pull request #108 from akka/wip-testtable-patriknw
new 37418d8 eventsByPersistenceId query, #80
new ddd4cd9 DurableState Projection, #79 (#102)
new 8c2d2f1 Fix wrong logic in isAccepted
new c869960 Include slice in offset table, #57
new ff708b4 Merge pull request #104 from akka/wip-isAccepted-patriknw
new 24db8e2 Better error reporting in EndToEndSpec
new e8b4c90 Merge pull request #111 from akka/wip-80-eventsByPersistenceId-patriknw
new d895c6d Merge pull request #107 from akka/wip-57-slice-offset-patriknw
new 6dfa085 Merge pull request #114 from akka/wip-EndToEndSpec-patriknw
new 06028c6 Reduce EventsBySlicePerfSpec
new 41bf20c Merge pull request #117 from akka/wip-EventsBySlicePerfSpec-patriknw
new dfea53b feat: Snapshot store added (#112)
new ca88e98 Clean up deprecated sbt syntax to get rid of warnings on sbt start
new 7ca74a9 Merge pull request #119 from akka/wip-sbt-warnings-cleanup
new 6e75910 Adjust live query refresh rate based on previous result, #28 (#116)
new 51c441a Latest sbt-ci-release (#121)
new 7a4d4d8 Lookup timestamp of previous sequence number, #74 (#120)
new c6053d4 Disable doc publish since it fails
new 9b83e08 Remove hint from entity_type_hint, #95
new cfb02b9 Merge pull request #123 from akka/wip-95-entity-type-hint-patriknw
new 73e3bbd Move deserialization of journal row out from connection block
new 53c6780 Merge pull request #122 from akka/wip-disable-doc-publis-patriknw
new 368679d DRY snapshot upsert sql by using bindNull for metadata
new a8c3cd4 Merge pull request #124 from akka/wip-ser-patriknw
new 3796677 Remove linebreaks in sql
new b284901 Merge pull request #125 from akka/wip-stripMargin-patriknw
new ded1e84 Merge pull request #126 from akka/wip-bindNull-patriknw
new 161257b Remove unecessary write_timestamp column
new fedb055 addInflight of several envelopes, one CAS
new 2bbbd81 Merge pull request #128 from akka/wip-rm-unused-patriknw
new 21db69f Merge pull request #129 from akka/wip-addInflight-patriknw
new dca0ed8 Remove tags, since not implemented (#130)
new 7d3be36 Remove R2dbcSerializer (#127)
new 165db33 javadsl for the queries, #83 (#131)
new 2e77f70 Yugabyte 2.9.1.0-b140 (#134)
new 468ebc7 Possibility to preserve event timestamp when writing from MigrationTool (#133)
new bd11ed6 Migration of events and snapshots from any Akka Persistence plugin (#132)
new 903f4c0 Rename sequence_number column to seq_nr (#136)
new 7b03306 Lazy loading of events/state for backtracking queries, #76
new 47ab250 Use batch statements (#137)
new cb9d93f withConnection clean ups
new 802cc54 Merge pull request #138 from akka/wip-lazy-backtrack-patriknw
new f22374e Merge pull request #143 from akka/octonato/with-connection-methods
new 2cef40e pause/resume projection management (#142)
new 68510e2 Add new EventBySliceEnvelope (#144)
new fa7efb3 Harden EventsBySliceSpec, #118 (#145)
new dd1de1a Backtrack to the ordinary timestamp, #109 (#146)
new b7dfac0 Rewrite test for grouped async, #147 (#148)
new 4def81d Tuning parameters (#150)
new fe86953 Reference documentation, #89 (#149)
new b6b577e Update to latest Akka and Akka Projections snapshot (#151)
new e9d00e2 Publish docs (#153)
new bfc7b2a More hardening of ProjectionSpec, #147 (#152)
new fb0cc9b Reference documentation for Projections, #89 (#154)
new f123449 Don't copy .jvmopts-ci (#155)
new 97c886f Projection javadsl, #83 (#156)
new ee3e8f4 A few more connection pool settings (#158)
new 9702946 Error when event from backtracking is rejected (#160)
new 3229ff0 Debug log if getConnection takes more than 10 ms (#161)
new 45c121f remove order by in snapshot sql (#162)
new 7577430 config setting for logging of (slow) db calls (#163)
new 8bd80c7 Insert offset instead of upsert, #106 (#164)
new c6c8a26 Make primitive offset table optional (#165)
new e03bf46 Remove SliceUtil, included in Akka (#166)
new 48337d6 Adjust config to reduce connection errors, #157 (#167)
new a843a77 Remove TimestampOffset, included in Akka (#169)
new 8db8fd8 Utility to replace numbered sql parameters, #135 (#170)
new 70526c2 Yugabyte 2.8.0.0-b37 (#172)
new 1baf02e Upgrade to sbt 1.5.6 (#176)
new 030907e Remove slice from primary key, #175 (#177)
new 4cd344e Adjust log-db-calls-exceeding config (#180)
new 6fb32e0 Avoid repeatly trying to delete offsets when idle (#179)
new 0e44406 Update to Akka 2.6.18
new 21e334d Split slice index, #174 (#183)
new 227848a Option to use application timestamp (#185)
new 53cbb48 Use default-dispatcher (#186)
new 915de54 fix table names with schema (#188)
new 4f4f4ab Send events over pub-sub, #77 (#168)
new 1dc98fa Split projection_timestamp_offset table (#190)
new f6812ad Use Mono for Publisher to Future conversion (#191)
new 443b415 Update to R2DBC 0.9.0 (#192)
new 536a12b fix highest seqNr in seen of latestOffset, #173 (#194)
new febb34a URLEncoder.encode for jdk 8 (#195)
new aba7bb3 add Scala Steward (#193)
new 528fc00 disable replay-filter (#196)
new 70ea8bf cleanup some more slice and entity_type columns (#202)
new bea7cac scala-library 2.13.8 (was 2.13.6) (#200)
new ef15936 sbt 1.5.8 (was 1.5.6) (#201)
new ce18294 sbt-header 5.6.0 (was 5.2.0) (#199)
new 72ccd1d sbt-java-formatter 0.7.0 (was 0.4.4) (#198)
new 658f6ca paradox-theme-akka, ... 0.42 (was 0.39) (#197)
new 4d753c5 Projection magement clear/set offset (#203)
new ece4439 Adjust log level for 'Rejecting unexpected sequence number' (#205)
new b645a5d Store tags, but no query yet (#206)
new 3faec10 make it possible to configure a connection from url (#207)
new ab9270b Upper bound on db_timestamp in eventsBySlices query, #178 (#210)
new 75f65c2 add executeDdls for several ddl statements in same tx (#209)
new 3dbd9f6 Update to Yugabyte 2.12.1 (#213)
new 9c6d8bd Update to Yugabyte 2.12.1, both servers (#215)
new 7d27108 sbt 1.6.2 (was 1.5.8) (#219)
new e23f1ab sbt-header 5.6.5 (was 5.6.0) (#216)
new 97e1c1b postgresql 42.3.3 (was 42.3.1) (#218)
new 1f59c8e Update documentation of config for durable state store (#221)
new 0676989 Support ssl-mode values, in addition to enum names (#220)
new 6d9f4c4 Separate getConnection and db call measurement (logging) (#223)
new 65a4ccd logback-classic 1.2.11 (was 1.2.10) (#224)
new c19f5fb Update to r2dbc-postgresql 0.9.1 (#227)
new a028c9e Update to Yugabyte 2.12.2.0-b58 (#228)
new 72560ee Upper bound on db_timestamp in changesBySlices query, #212 (#226)
new e91b64d paradox-theme-akka, ... 0.43 (was 0.42) (#229)
new 14057a2 Background eviction interval must be set (#235)
new 92b7a0f Set max-life-time to shrink pool (#237)
new 9cb97de postgresql 42.3.4 (was 42.3.3) (#233)
new 146ec2a Fix connection leak caused by create-timeout, #182 (#238)
new 0ccb325 Store offset for failed skipped envelope (#204)
new fddbad3 Use same instance of the ReadJournal (#240)
new 659752e A way to skip envelopes but still store offset (#241)
new 0709d01 Less aggressive eviction (#246)
new dd1eaca No delay when switching from backtracking (#247)
new d12db6f Deduplicate when using publish-events (#248)
new 7be15c8 Use IN for Postgres in slice query, #249 (#250)
new 51fc328 Change log level of Rejecting unknown sequence number (#251)
new f777dab Disable deduplication for publish-events by default (#256)
new 8cc6579 Allow envelope from backtracking as duplicate when in-flight, #245 (#257)
new 8a720fa Tagged pubsub (#258)
new 2ea4121 Save offsets in Batch without bind parameters, #253 (#255)
new 039e400 Revert "Save offsets in Batch without bind parameters, #253 (#255)" (#259)
new ac1c881 Remove Postgres jdbc dependency (#264)
new 50cc95a scala-library 2.12.16 (was 2.12.15) (#263)
new 6757252 r2dbc-pool 0.9.1.RELEASE (was 0.9.0.RELEASE) (#261)
new 026ee33 paradox-theme-akka, ... 0.44 (was 0.43) (#260)
new 715b5e0 Update to Yugabyte 2.14.1.0-b36 (#267)
new d47856c sbt 1.7.1 (was 1.6.2) (#266)
The 239 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org