Skip to content
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.

Sign up for GitHub

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

Jump to bottom

feat: GROW-1241-health-command-single-provider-arg #1475

Open
wants to merge 11 commits into
base: main
Choose a base branch
from
+368 −124
Open

feat: GROW-1241-health-command-single-provider-arg #1475

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
9d45fa5
GROW-1241-health-command-single-provider-arg
mikecot Jun 4, 2024
09d5ef7
final changes to optimize network/process time
mikecot Jun 19, 2024
d984bf4
lint
mikecot Jun 19, 2024
8871189
more debug prints
mikecot Jun 21, 2024
688e89e
waitgroup bug in wgspecs
mikecot Jun 25, 2024
656c7dd
Merge branch 'main' into GROW-1241-health-command-single-provider-arg
omerlavanet Jul 1, 2024
2a33633
merged with main
mikecot Aug 26, 2024
37da7b2
Merge branch 'main' into GROW-1241-health-command-single-provider-arg
mikecot Aug 26, 2024
20b8552
do no crash process
ranlavanet Sep 15, 2024
6f64d79
using the new pairingQuerier.Provider api to test if a provider is st…
mikecot Oct 9, 2024
4c89998
breaking changes - but faster health probes
mikecot Oct 9, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 11 additions & 2 deletions protocol/monitoring/alerting.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -354,10 +354,19 @@ func (al *Alerting) ProvidersAlerts(healthResults *HealthResults) {
for provider, data := range healthResults.ProviderData {
specId := provider.SpecId
if al.allowedTimeGapVsReference > 0 {
latestBlock := healthResults.LatestBlocks[specId]
latestBlock, ok := healthResults.LatestBlocks[specId]
if !ok {
utils.LavaFormatError("Invalid spec id - missing in healthResults", nil, utils.Attribute{Key: "specId", Value: specId})
return
}
if latestBlock > data.Block {
gap := latestBlock - data.Block
timeGap := time.Duration(gap*healthResults.Specs[specId].AverageBlockTime) * time.Millisecond
specHealthResult, ok := healthResults.Specs[specId]
if !ok {
utils.LavaFormatError("Invalid spec id - missing in healthResults", nil, utils.Attribute{Key: "specId", Value: specId})
return
}
timeGap := time.Duration(gap*specHealthResult.AverageBlockTime) * time.Millisecond
if timeGap > al.allowedTimeGapVsReference {
attrs = append(attrs, AlertAttribute{entity: provider, data: fmt.Sprintf("block gap: %s/%s", utils.StrValue(data.Block), utils.StrValue(latestBlock))})
}
Expand Down
Loading