kubernetes/vendor/google.golang.org/grpc/internal/transport/flowcontrol.go

type writeQuota …

func newWriteQuota(sz int32, done <-chan struct{ … }

func (w *writeQuota) get(sz int32) error { … }

func (w *writeQuota) realReplenish(n int) { … }

type trInFlow …

func (f *trInFlow) newLimit(n uint32) uint32 { … }

func (f *trInFlow) onData(n uint32) uint32 { … }

func (f *trInFlow) reset() uint32 { … }

func (f *trInFlow) updateEffectiveWindowSize() { … }

func (f *trInFlow) getSize() uint32 { … }

type inFlow …

// newLimit updates the inflow window to a new value n.
// It assumes that n is always greater than the old limit.
func (f *inFlow) newLimit(n uint32) { … }

func (f *inFlow) maybeAdjust(n uint32) uint32 { … }

// onData is invoked when some data frame is received. It updates pendingData.
func (f *inFlow) onData(n uint32) error { … }

// onRead is invoked when the application reads the data. It returns the window size
// to be sent to the peer.
func (f *inFlow) onRead(n uint32) uint32 { … }