gazette / core

Build platforms that flexibly mix SQL, batch, and stream processing paradigms
https://gazette.dev
MIT License
718 stars 52 forks source link

consumer: add Shard.PrimaryLoop() client.OpFuture #339

Closed jgraettinger closed 1 year ago

jgraettinger commented 1 year ago

Expose the status of the shard's primary processing loop to those who might care.

This allows applications to reliably detect when a shard has failed, and is a more reliable mechanism than the BeginFinisher interface because that interface is only called in the context of a current consumer transaction.


This change is Reviewable