code: func (v *priorityClientPool) subscribeTotalCapacity(sub *tcSubscription) {
  	v.lock.Lock()
  	defer v.lock.Unlock()
  
  	v.subs[sub] = struct{}{}
  }
docs: // subscribeTotalCapacity subscribes to changed total capacity events