tack/internal/ at b6e554047ffb806c77a7c7cc39be5760c485aece · mitchellh.com/tack · Tangled

mitchellh.com / tack

2

Stitch any CI into Tangled

2

tack / internal /

at b6e554047ffb806c77a7c7cc39be5760c485aece 2 folders

Mitchell Hashimoto jetstream: extract reusable consumer into internal/jetstream 7w ago

jetstream: extract reusable consumer into internal/jetstream The consumer code in jetstream.go mixed Tack-specific concerns (collections, applyCommit, store cursor) with generic firehose mechanics: configuring the upstream client, looping reconnects, rewinding time-based cursors, persisting cursor progress, and distinguishing permanent bad-record failures from transient handler failures. None of those are specific to Tack and they are the bits most likely to be reused for future jetstream consumers. Move the generic mechanics into a new internal/jetstream package.

1 month ago

jetstream: extract reusable consumer into internal/jetstream The consumer code in jetstream.go mixed Tack-specific concerns (collections, applyCommit, store cursor) with generic firehose mechanics: configuring the upstream client, looping reconnects, rewinding time-based cursors, persisting cursor progress, and distinguishing permanent bad-record failures from transient handler failures. None of those are specific to Tack and they are the bits most likely to be reused for future jetstream consumers. Move the generic mechanics into a new internal/jetstream package.

1 month ago