Versions in this module Expand all Collapse all v1 v1.8.4 Aug 21, 2023 Changes in this version + func WithError(drainer Drainer, reader io.Reader, err error) error + type BehaviorSeedLimitedDrainer struct + DrainSize int + func (d *BehaviorSeedLimitedDrainer) AcknowledgeReceive(size int) + func (d *BehaviorSeedLimitedDrainer) Drain(reader io.Reader) error + type Drainer interface + AcknowledgeReceive func(size int) + Drain func(reader io.Reader) error + func NewBehaviorSeedLimitedDrainer(behaviorSeed int64, drainFoundation, maxBaseDrainSize, maxRandDrain int) (Drainer, error) + func NewNopDrainer() Drainer + type NopDrainer struct + func (n NopDrainer) AcknowledgeReceive(size int) + func (n NopDrainer) Drain(reader io.Reader) error
Go to main page