in internal/alloydb/instance.go [255:267]
func (i *RefreshAheadCache) ForceRefresh() {
i.resultGuard.Lock()
defer i.resultGuard.Unlock()
// If the next refresh hasn't started yet, we can cancel it and start an immediate one
if i.next.cancel() {
i.next = i.scheduleRefresh(0)
}
// block all sequential connection attempts on the next refresh operation
// if current is invalid
if !i.cur.isValid() {
i.cur = i.next
}
}