Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
36 commits
Select commit Hold shift + click to select a range
dcf3314
changes after review
marcomq Dec 16, 2025
3f5348a
add middleware
marcomq Dec 16, 2025
0f805cb
fixes & add middlewares as features
marcomq Dec 16, 2025
fd78502
make bulk_send more robust
marcomq Dec 16, 2025
6056fa5
stabilize errors & fmt
marcomq Dec 16, 2025
108a126
compile fix
marcomq Dec 16, 2025
058328b
add dlq retry
marcomq Dec 16, 2025
82b6465
switch from vec<u8> to bytes and fix some tests
marcomq Dec 16, 2025
2942e59
disable jetstream optionally
marcomq Dec 16, 2025
3691e5d
renam await_ack to skip_ack
marcomq Dec 16, 2025
ee84573
fix kafka sasl key
marcomq Dec 16, 2025
ea9d194
fmt
marcomq Dec 16, 2025
7175143
switch to prefer bulk
marcomq Dec 17, 2025
9762d1c
fmt
marcomq Dec 17, 2025
dbbce6c
clippy
marcomq Dec 17, 2025
fb2d88a
fix mqtt error messages
marcomq Dec 17, 2025
e98be87
rewrote read direct test for bulk
marcomq Dec 17, 2025
f93b669
rename bulk to batch
marcomq Dec 17, 2025
d8745c1
add receive_batch for kafka
marcomq Dec 18, 2025
2ed6caf
add tests for separate single and batch read / write performance
marcomq Dec 18, 2025
a117227
address some coderabbit issues
marcomq Dec 18, 2025
2bed90e
add batch read for mongodb
marcomq Dec 18, 2025
59bfe8d
try to optimize nats receive_batch (wip)
marcomq Dec 19, 2025
77c7ce5
add comment
marcomq Dec 19, 2025
00619c9
change warning log
marcomq Dec 19, 2025
05629ba
add computehandler as middleware
marcomq Dec 19, 2025
9d31696
Merge remote-tracking branch 'origin/main' into dev
marcomq Dec 19, 2025
ca67038
message_id to u128 and make app_name more generic
marcomq Dec 19, 2025
1e9171f
adding proper message_ids
marcomq Dec 19, 2025
f0ae729
adding cfg opts and retry and random_panic middelware
marcomq Dec 20, 2025
c5e9a76
raneming retry to attempt, bugfixings
marcomq Dec 20, 2025
a0dcc62
misc fixes, add performance bench
marcomq Dec 21, 2025
62eedd0
rename crate and repo
marcomq Dec 21, 2025
b4fd5d8
fix test
marcomq Dec 21, 2025
ec6288d
fix minor issues, add comments
marcomq Dec 21, 2025
553dc50
fix ci
marcomq Dec 21, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .github/workflows/ci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -44,4 +44,4 @@ jobs:
run: sudo apt-get update && sudo apt-get install -y libssl-dev pkg-config zlib1g-dev

- name: Run cargo test
run: cargo test --all-targets
run: cargo test --lib --bins
Loading