Skip to content

feat(natsstore): serve refresh requests from the refresh queue - #26

Open
yordis wants to merge 1 commit into
yordis/feat-natsstore-refreshdispatchfrom
yordis/feat-natsstore-refreshworker
Open

yordis wants to merge 1 commit into
yordis/feat-natsstore-refreshdispatchfrom
yordis/feat-natsstore-refreshworker

Conversation

@yordis

@yordis yordis commented Nov 8, 2026 •

Copy link
Copy Markdown
Member

The queue only helps if something serves it. The worker runs each request through the existing journal-guarded refresh, so a redelivered request after a crash hits the unknown-outcome path rather than calling the provider twice.

The scheduler publishes a request instead of refreshing inline when the
store hosts a refresh queue. Wiring the NATS store to its work-queue
stream makes exactly one replica win each request and run it through the
existing journal-guarded refresh, while the others learn the result from
the credential bucket they already follow.

Signed-off-by: Yordis Prieto <yordis.prieto@gmail.com>
@coderabbitai

coderabbitai Bot commented Nov 8, 2026 •

Copy link
Copy Markdown

Warning

Review limit reached

You've used all free OSS reviews for now. Wait for the free limit to reset to keep reviewing this public repository.

Next included review available in 59 minutes.

Check out review usage here.

View limit details

Limit details: You’ve used the included review currently available.

Learn how review limits work.

Review configuration:

Run configuration

  • Source mode: Auto
  • Repository: Unavailable
  • Branch: Unavailable
  • File: No configuration file from this repository applied
  • Commit: Unavailable
  • Layers: Organization UI
  • Review profile: CHILL
  • Plan: Advanced
  • Run ID: 689152d4-705b-45de-bf36-33867a7fd374
Commits

Reviewing files that changed from the base of the PR and between 87e28d1 and 373449c.

Files selected for processing: 4

  • internal/store/natsstore/refresh_queue.go
  • internal/store/natsstore/refresh_worker.go
  • internal/store/natsstore/refresh_worker_test.go
  • internal/store/natsstore/store.go
  • Autofix · Keep fixing CodeRabbit findings and required CI, and resolving merge conflicts

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

Share

@yordis
yordis added this pull request to stack #9 November 8, 2026 03:32

This branch has not been deployed

No deployments
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant