Skip to content

v0.1.1

Choose a tag to compare

@AlexeyMatskevich AlexeyMatskevich released this 21 May 19:18
· 51 commits to master since this release

Fix

  • PostgresStorage is now Send + Sync under both tokio and ntex runtimes, so it can be used with apalis::WorkerBuilder::build(). The published 0.1.0 failed to compile inside a WorkerBuilder because ntex's BlockingResult is !Sync; PgSink::flush_future is now wrapped in Mutex<Option<…>> with Mutex::get_mut keeping the hot path lock-free. Compile-time assert_send_sync guards the invariant.

Notes

  • 0.1.0 has been yanked from crates.io — it does not work with apalis.
  • Added an integration test covering the full worker round-trip (handler-ok and handler-err branches).
  • Added examples/worker.rs (tokio) and examples/worker-ntex.rs (ntex / neon-polling) demonstrating end-to-end use with WorkerBuilder and in-handler push_with_conn.
  • README documents in-handler transactional fan-out.