Versions in this module Expand all Collapse all v1 v1.0.1 Aug 12, 2022 Changes in this version + var AllPositions = Positions + var NoPositions = Positions + var VerboseLogging = flag.Int("v", -1, "log many verbose logs") + func ContextDone(ctx context.Context) bool + func PacketsToFile(in *PacketChan, out io.Writer, limit Limit) error + func PathDiskFreePercentage(path string) (int, error) + func V(level int, fmt string, args ...interface{}) + func Watchdog(d time.Duration, msg string) *time.Timer + type Context interface + Cancel func() + func NewContext(timeout time.Duration) Context + type Limit struct + Bytes int64 + Packets int64 + func LimitFromHeaders(h http.Header) (a Limit, err error) + func (a *Limit) ShouldStopAfter(b Limit) bool + type Packet struct + Data []byte + type PacketChan struct + C chan<- *Packet + func ConcatPacketChans(ctx context.Context, in <-chan *PacketChan) *PacketChan + func MergePacketChans(ctx context.Context, in []*PacketChan) *PacketChan + func NewPacketChan(buffer int) *PacketChan + func (p *PacketChan) Close(err error) + func (p *PacketChan) Discard() + func (p *PacketChan) Done() <-chan struct{} + func (p *PacketChan) Err() error + func (p *PacketChan) Receive() <-chan *Packet + func (p *PacketChan) Send(pkt *Packet) + type Positions []int64 + func (a Positions) Intersect(b Positions) (out Positions) + func (a Positions) Len() int + func (a Positions) Less(i, j int) bool + func (a Positions) Sort() + func (a Positions) Swap(i, j int) + func (a Positions) Union(b Positions) (out Positions) + func (p Positions) IsAllPositions() bool