tiennm99 30c8efc504 fix(poller): checkpoint each event independently after fan-out ...

A single retryable delivery failure aborted checkpoints for the whole poll batch, so fully-delivered events were re-collected and re-sent on the next poll, and an unrelated failure froze all change detection. Attach post-delivery checkpoints to each event and run them as soon as that event fully delivers; a failed event defers only its own checkpoints for retry. A subscriber skipped after an earlier retryable failure now counts as the event's failure so the event is not marked delivered to a subscriber that never received it.

2026-06-26 15:48:34 +07:00

..

delivery.go

fix(poller): checkpoint each event independently after fan-out

2026-06-26 15:48:34 +07:00

event_collection.go

fix(poller): checkpoint each event independently after fan-out

2026-06-26 15:48:34 +07:00

format_test.go

fix: align status bot delivery behavior

2026-06-19 15:56:59 +07:00

format.go

refactor(poller): batch delivery checks and dedupe component helpers

2026-06-26 09:19:29 +07:00

poller_test.go

fix(poller): checkpoint each event independently after fan-out

2026-06-26 15:48:34 +07:00

poller.go

fix(poller): checkpoint each event independently after fan-out

2026-06-26 15:48:34 +07:00