drain

Documentation

Index

• func WithError(drainer Drainer, reader io.Reader, err error) error
• type BehaviorSeedLimitedDrainer
  • func (d *BehaviorSeedLimitedDrainer) AcknowledgeReceive(size int)
  • func (d *BehaviorSeedLimitedDrainer) Drain(reader io.Reader) error
• type Drainer
  • func NewBehaviorSeedLimitedDrainer(behaviorSeed int64, drainFoundation, maxBaseDrainSize, maxRandDrain int) (Drainer, error)
  • func NewNopDrainer() Drainer
• type NopDrainer
  • func (n NopDrainer) AcknowledgeReceive(size int)
  • func (n NopDrainer) Drain(reader io.Reader) error

Functions

func WithError

func WithError(drainer Drainer, reader io.Reader, err error) error

Types

type BehaviorSeedLimitedDrainer

type BehaviorSeedLimitedDrainer struct {
	DrainSize int
}

func (*BehaviorSeedLimitedDrainer) AcknowledgeReceive

func (d *BehaviorSeedLimitedDrainer) AcknowledgeReceive(size int)

func (*BehaviorSeedLimitedDrainer) Drain

func (d *BehaviorSeedLimitedDrainer) Drain(reader io.Reader) error

type Drainer

type Drainer interface {
	AcknowledgeReceive(size int)
	Drain(reader io.Reader) error
}

func NewBehaviorSeedLimitedDrainer

func NewBehaviorSeedLimitedDrainer(behaviorSeed int64, drainFoundation, maxBaseDrainSize, maxRandDrain int) (Drainer, error)

func NewNopDrainer

func NewNopDrainer() Drainer

type NopDrainer

type NopDrainer struct{}

func (NopDrainer) AcknowledgeReceive

func (n NopDrainer) AcknowledgeReceive(size int)

func (NopDrainer) Drain

func (n NopDrainer) Drain(reader io.Reader) error