-
Notifications
You must be signed in to change notification settings - Fork 2.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Expose info for each TSDB #6329
Conversation
f855642
to
386d651
Compare
func (s *ProxyStore) TSDBInfos() []infopb.TSDBInfo { | ||
infos := make([]infopb.TSDBInfo, 0) | ||
for _, store := range s.stores() { | ||
infos = append(infos, store.TSDBInfos()...) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do we need to filter out nil
here if a store doesn't support this call?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
it seems that the spread operator can already handle nils. However, I added a test as a safeguard to make sure we don't have some weird regression in the future.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, just one comment
This commit exposes the label set alongside the min and max time for each TSDB covered by a Store. This information is used to scope the min time for a remote query so that we do not produce partial aggregates in distriuted mode. Signed-off-by: Filip Petkovski <[email protected]>
Signed-off-by: Filip Petkovski <[email protected]>
940612f
to
6fd6d2c
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM!
This commit exposes the label set alongside the min and max time for each TSDB covered by a Store.
This information is used to scope the min time for a remote query so that we do not produce partial aggregates in distriuted mode.
Changes
Verification