Versions in this module Expand all Collapse all v0 v0.9.2 Apr 26, 2024 Changes in this version + func CheckExec(cmd string) error + type Exec struct + func NewExec(cmd string) *Exec + func (e *Exec) Yield(ctx context.Context, ch chan<- string, count chan<- int) (err error) type Multiplexer + ShowValues []bool v0.8.0 Jul 12, 2023 Changes in this version + type File struct + func NewFile(rd io.ReadSeeker, seekable bool) *File + func (f *File) Yield(ctx context.Context, ch chan<- string, count chan<- int) (err error) type FilterLimit + CancelProducer func() + type Multiplexer struct + Names []string + Sources []Source + func (m *Multiplexer) AddSource(name string, src Source) + func (m *Multiplexer) Run(ctx context.Context, ch chan<- []string, count chan<- int) error type Range + func NewRange(s string) (r Range, err error) type Ranges + func NewRanges(ranges []Range, format string) *Ranges + func (r *Ranges) Yield(ctx context.Context, ch chan<- string, count chan<- int) (err error) + type Source interface + Yield func(ctx context.Context, ch chan<- string, count chan<- int) error + type Value struct + func NewValue(value string) *Value + func (f *Value) Yield(ctx context.Context, ch chan<- string, count chan<- int) (err error) v0.7.0 Jun 28, 2022 v0.6.0 Oct 28, 2020 v0.5.0 Sep 16, 2020 v0.4.0 Aug 27, 2020 Changes in this version + func Limit(ctx context.Context, perSecond float64, in <-chan string) <-chan string + func Ranges(ctx context.Context, ranges []Range, format string, ch chan<- string, ...) error + func Reader(ctx context.Context, rd io.ReadCloser, ch chan<- string, count chan<- int) (err error) + type Filter interface + Count func(ctx context.Context, in <-chan int) <-chan int + Select func(ctx context.Context, in <-chan string) <-chan string + type FilterLimit struct + Max int + func (f *FilterLimit) Count(ctx context.Context, in <-chan int) <-chan int + func (f *FilterLimit) Select(ctx context.Context, in <-chan string) <-chan string + type FilterSkip struct + Skip int + func (f *FilterSkip) Count(ctx context.Context, in <-chan int) <-chan int + func (f *FilterSkip) Select(ctx context.Context, in <-chan string) <-chan string + type Range struct + First int + Last int + func ParseRange(s string) (r Range, err error) + func (r Range) Count() int
Go to main page