r2dbc-mini-client

Ultra-minimalistic client for R2DBC drivers.

License

License

Categories

Categories

CLI User Interface
GroupId

GroupId

com.astutebits
ArtifactId

ArtifactId

r2dbc-mini-client_2.13
Last Version

Last Version

0.3.0
Release Date

Release Date

Type

Type

jar
Description

Description

r2dbc-mini-client
Ultra-minimalistic client for R2DBC drivers.
Project URL

Project URL

https://github.com/chmodas/akka-persistence-r2dbc
Project Organization

Project Organization

AstuteBits
Source Code Management

Source Code Management

https://github.com/astutebits/akka-persistence-r2dbc

Download r2dbc-mini-client_2.13

How to add to project

<!-- https://jarcasting.com/artifacts/com.astutebits/r2dbc-mini-client_2.13/ -->
<dependency>
    <groupId>com.astutebits</groupId>
    <artifactId>r2dbc-mini-client_2.13</artifactId>
    <version>0.3.0</version>
</dependency>
// https://jarcasting.com/artifacts/com.astutebits/r2dbc-mini-client_2.13/
implementation 'com.astutebits:r2dbc-mini-client_2.13:0.3.0'
// https://jarcasting.com/artifacts/com.astutebits/r2dbc-mini-client_2.13/
implementation ("com.astutebits:r2dbc-mini-client_2.13:0.3.0")
'com.astutebits:r2dbc-mini-client_2.13:jar:0.3.0'
<dependency org="com.astutebits" name="r2dbc-mini-client_2.13" rev="0.3.0">
  <artifact name="r2dbc-mini-client_2.13" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.astutebits', module='r2dbc-mini-client_2.13', version='0.3.0')
)
libraryDependencies += "com.astutebits" % "r2dbc-mini-client_2.13" % "0.3.0"
[com.astutebits/r2dbc-mini-client_2.13 "0.3.0"]

Dependencies

compile (3)

Group / Artifact Type Version
org.scala-lang : scala-library jar 2.13.5
io.r2dbc : r2dbc-spi jar 0.8.3.RELEASE
io.projectreactor : reactor-core jar 3.3.10.RELEASE

test (3)

Group / Artifact Type Version
ch.qos.logback : logback-classic jar 1.2.3
org.scalatest : scalatest_2.13 jar 3.2.6
io.r2dbc : r2dbc-spi-test jar 0.8.3.RELEASE

Project Modules

There are no modules declared in this project.

Akka Persistence R2DBC

CircleCI

An implementation of the Akka Journal and Snapshot store persistence plugin APIs, and the full Persistence Query API with R2DBC. The plugin has a few additional extensions documented below.

Configuration

Unlike the other AsyncWriteJournal calls, the asyncReplayMessages one is not protected by a circuit-breaker, for a good reason:

This call is NOT protected with a circuit-breaker because it may take long time to replay all events. The plugin implementation itself must protect against an unresponsive backend store and make sure that the returned Future is completed with success or failure within reasonable time. It is not allowed to ignore completing the future.

The plugin guarantees that the Future is completed by imposing a time limit on the SQL stream's completion. You can configure the timeout with the replay-messages-timeout parameter, the default value is 10s (in line with the circuit breaker settings).

Extensions

  • akka.serialization.AsyncSerializer support
  • Atomic Projections gives you the ability to persist an event and run projections for a "local" read-side in an atomic transaction.

Atomic Projections

The goal of the extension is to allow you to enjoy the benefits of CQRS and Event Sourcing without incurring the costs of running a more complex infrastructure for those cases when you really don't have to.

Contributing

Contributions via GitHub pull requests are gladly accepted from their original author. Along with any pull requests, please state that the contribution is your original work and that you license the work to the project under the project’s open source license. Whether you state this explicitly, by submitting any copyrighted material via pull request, email, or other means you agree to license the material under the project’s open source license and warrant that you have the legal authority to do so.

License

This project is licensed under the Apache 2.0 license.

com.astutebits

AstuteBits

Versions

Version
0.3.0