Compare commits

2 Commits

Author SHA1 Message Date
cuddle-please
35d579819c chore(release): 0.2.0
All checks were successful
continuous-integration/drone/push Build is passing
2025-09-25 08:49:47 +00:00
271823e278 feat: reset after failure
Some checks failed
continuous-integration/drone/push Build is failing
Signed-off-by: kjuulh <contact@kjuulh.io>
2025-09-25 10:49:29 +02:00
3 changed files with 36 additions and 10 deletions

View File

@@ -6,6 +6,24 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
## [Unreleased]
## [0.2.0] - 2025-09-25
### Added
- reset after failure
- print as well
- add publish
- add features for nats and postgres
- add postgres
- extract backend
- do publish
- allow readme
### Other
- *(release)* v0.1.3 (#3)
chore(release): 0.1.3
- Configure Renovate (#4)
Add renovate.json
## [0.1.3] - 2025-09-24
### Added

View File

@@ -3,7 +3,7 @@ members = ["crates/*"]
resolver = "2"
[workspace.package]
version = "0.1.3"
version = "0.2.0"
license = "MIT"
[workspace.dependencies]

View File

@@ -144,7 +144,10 @@ impl BackendEdge for PostgresBackend {
let res = match res {
Ok(res) => res,
Err(e) => match &e {
Err(e) => {
self.revision.store(0, Ordering::Relaxed);
match &e {
sqlx::Error::Database(database_error) => {
if database_error.is_unique_violation() {
anyhow::bail!("update conflict: another leader holds lock")
@@ -155,7 +158,8 @@ impl BackendEdge for PostgresBackend {
_ => {
anyhow::bail!(e);
}
},
}
}
};
match res {
@@ -170,6 +174,8 @@ impl BackendEdge for PostgresBackend {
// Only update our local revision if the update succeeded with our expected value
self.revision.store(rec.revision as u64, Ordering::Relaxed);
} else {
self.revision.store(0, Ordering::Relaxed);
anyhow::bail!(
"update conflict: expected value={}, revision={}, got value={}, revision={}",
val.0.to_string(),
@@ -207,6 +213,8 @@ impl BackendEdge for PostgresBackend {
.await
.context("failed to release lock, it will expire naturally")?;
self.revision.store(0, Ordering::Relaxed);
Ok(())
}
}