Searched refs:writeQuota (Results 1 – 3 of 3) sorted by relevance
54 type writeQuota struct { struct67 func newWriteQuota(sz int32, done <-chan struct{}) *writeQuota {68 w := &writeQuota{77 func (w *writeQuota) get(sz int32) error { argument92 func (w *writeQuota) realReplenish(n int) { argument
90 wq *writeQuota100 wq *writeQuota // write quota for the stream created.176 wq *writeQuota
180 wq *writeQuota