throttle

Documentation

Index

• type Exec
  • func NewExec(input io.Reader) *Exec
  • func (ex *Exec) Start(ctx context.Context, interval <-chan time.Time, ...)
  • func (ex *Exec) Wait() <-chan struct{}

Types

type Exec

type Exec struct {
	// contains filtered or unexported fields
}

func NewExec

func NewExec(input io.Reader) *Exec

func (*Exec) Start

func (ex *Exec) Start(ctx context.Context, interval <-chan time.Time, flushCallback func(ctx context.Context, output string) error, doneCallback func(ctx context.Context, output string) error)

func (*Exec) Wait

func (ex *Exec) Wait() <-chan struct{}