CRE-1601: Ring OCR plugin for shard orchestration#1742
Merged
Conversation
✅ API Diff Results - No breaking changes |
bolekk
requested changes
Dec 23, 2025
bolekk
reviewed
Dec 31, 2025
bolekk
approved these changes
Jan 2, 2026
chudilka1
reviewed
Jan 2, 2026
george-dorin
approved these changes
Jan 5, 2026
This was referenced Jan 5, 2026
cawthorne
pushed a commit
that referenced
this pull request
Jan 13, 2026
* cre-1601: shard orchestrator plugin for delegate * cre-1601: consistent hashing and plugin test * cre-1601: tidy * cre-1601: pb generate * cre-1601: review improvement * cre-1601: review improvement * cre-1601: review improvement * cre-1601: remove previous outcome, use outctx.SeqNr instead * cre-1601: transition state machine * cre-1601: removed TransmissionScheduleOverride * cre-1601: comments * cre-1601: rename plugin to ring * cre-1601: renames and cleanup * cre-1601: delegate integrations adjustments * cre-1601: proto comments; import fix * cre-1601: snake_case consistent for proto fields * cre-1601: remove unused field * cre-1601: more proto comments * cre-1601: proto cleanup, orphans removed * cre-1601: log overrides, log plugin config * cre-1601: better comment * cre-1601: deterministic time; f check for round; improved time median; improved workflows dedup; improved comments; * cre-1601: log improvement * cre-1601: shard count health refactor * cre-1601: hash ring pure function refactor for both storage and observation * cre-1601: Transmitter notifies Arbiter * cre-1601: store in two states, steady and transition; enque for allocation trigger post round; * cre-1601: comments improved * cre-1601: more comments improvements * cre-1601: test extension to validate workflows to shards eassignments * cre-1601: test improvement - distribution check by percents * cre-1601: using maps improvement * cre-1601: remove number of shards limits (ref. review) * cre-1601: initial state fix; intial transition state until OCR round; tests adjustments to simulate state confirmation; * cre-1601: more tests; boosting test coverage * cre-1601: better comments * cre-1601: better comments * cre-1601: improved test for plugin outcome * cre-1601: comments improved * cre-1601: comment improvement * cre-1601: more tests; more coverage * cre-1601: refactor of state; state verification tests; related changes; * cre-1601: bool wrapper ShardStatus to extend with weights later * cre-1601: ArbiterScaler.Status() wantShards being part of the observations in the consensus * cre-1601: improved comments; improved naming; simplified logic; observations validation; ring performance improvements * cre-1601: on 1st round make prior outcome wantShards equal to the current data from the arbiter * cre-1601: removed unnecessary check (code review suggestions) * Fail Observation() on Arbiter error --------- Co-authored-by: Bolek Kulbabinski <1416262+bolekk@users.noreply.github.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
CRE-1601