- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for shuttingDown (0.19 sec)
-
pilot/pkg/xds/pushqueue_test.go
Name: fmt.Sprintf("%d", eds), }), }) } } }() done := make(chan struct{}) mu := sync.RWMutex{} go func() { for { con, info, shuttingdown := p.Dequeue() if shuttingdown { return } for eds := range model.ConfigNamesOfKind(info.ConfigsUpdated, kind.ServiceEntry) { mu.Lock() delete(expected, key(con, eds)) mu.Unlock() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0)