-
Notifications
You must be signed in to change notification settings - Fork 78
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
4f11260
commit ce5a996
Showing
18 changed files
with
448 additions
and
60 deletions.
There are no files selected for viewing
This file contains 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
This file contains 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
This file contains 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
This file contains 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
55 changes: 55 additions & 0 deletions
55
staging/src/slime.io/slime/modules/meshregistry/pkg/monitoring/monitoring.go
This file contains 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,55 @@ | ||
| package monitoring | ||
|
|
||
| import ( | ||
| "time" | ||
|
|
||
| "slime.io/slime/framework/monitoring" | ||
| "slime.io/slime/modules/meshregistry/model" | ||
| ) | ||
|
|
||
| var ( | ||
| // souceLabel is the label for the source of the service entry. | ||
| souceLabel = monitoring.MustCreateLabel("source") | ||
| // statusLabel is the label for the status of the event. | ||
| statusLabel = monitoring.MustCreateLabel("status") | ||
| ) | ||
|
|
||
| var ( | ||
|
|
||
| // enabledSource is the number of enabled sources. | ||
| enabledSource = monitoring.NewGauge( | ||
| model.ModuleName, | ||
| "enabled_source", | ||
| "Number of enabled sources.", | ||
| ) | ||
|
|
||
| // readyTime is the time spent on ready in seconds. | ||
| readyTime = monitoring.NewGauge( | ||
| model.ModuleName, | ||
| "ready_time", | ||
| "Time spent on ready in seconds", | ||
| monitoring.WithLabels(souceLabel), | ||
| ) | ||
|
|
||
| // mcpPushCount is the number of mcp push. | ||
| mcpPushCount = monitoring.NewSum( | ||
| model.ModuleName, | ||
| "mcp_push_count", | ||
| "Number of mcp push.", | ||
| ) | ||
| ) | ||
|
|
||
| // RecordEnabledSource records the number of enabled sources. | ||
| func RecordEnabledSource(count int) { | ||
| enabledSource.Record(float64(count)) | ||
| } | ||
|
|
||
| // RecordReady records the time spent on ready. | ||
| func RecordReady(source string, t0, t1 time.Time) { | ||
| readyTime.With(souceLabel.Value(source)).Record(float64(t1.Sub(t0).Seconds())) | ||
| } | ||
|
|
||
| // RecordMcpPush records the number of mcp push. | ||
| func RecordMcpPush() { | ||
| mcpPushCount.Increment() | ||
| } |
Oops, something went wrong.