mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-03-05 20:59:13 -08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Merge b73c524ffa into 61aa82865d

Browse source
This commit is contained in:
Yandi Lee 2025-03-05 22:45:39 +01:00 committed by GitHub
parent 61aa82865d b73c524ffa
commit bfc516d2f8
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
discovery/manager.go
View file

@ -350,8 +350,10 @@ func (m *Manager) updater(ctx context.Context, p *Provider, updates chan []*targ
func (m *Manager) sender() { func (m *Manager) sender() {
ticker := time.NewTicker(m.updatert) ticker := time.NewTicker(m.updatert)
defer ticker.Stop() defer func() {
ticker.Stop()
close(m.syncCh)
}()
for { for {
select { select {
case <-m.ctx.Done(): case <-m.ctx.Done():

5
notifier/notifier.go
View file

@ -380,7 +380,10 @@ func (n *Manager) targetUpdateLoop(tsets <-chan map[string][]*targetgroup.Group)
select { select {
case <-n.stopRequested: case <-n.stopRequested:
return return
case ts := <-tsets: case ts, ok := <-tsets:
if !ok {
break
}
n.reload(ts) n.reload(ts)
} }
} }

5
scrape/manager.go
View file

@ -122,7 +122,10 @@ func (m *Manager) Run(tsets <-chan map[string][]*targetgroup.Group) error {
go m.reloader() go m.reloader()
for { for {
select { select {
case ts := <-tsets: case ts, ok := <-tsets:
if !ok {
break
}
m.updateTsets(ts) m.updateTsets(ts)
select { select {