filter

Documentation

Index

• type FileFilter
  • func (f *FileFilter) Start(ctx context.Context, wg *sync.WaitGroup) (*os.File, error)

Types

type FileFilter

type FileFilter struct {
	To io.Writer

	Filter func([]byte) bool
	// contains filtered or unexported fields
}

FileFilter filter *os.File with a defined filter function.

func (*FileFilter) Start

func (f *FileFilter) Start(ctx context.Context, wg *sync.WaitGroup) (*os.File, error)

Start create a goroutine to listen->filter->redirect output. It is return *os.File to replace it with other *os.File types. Safe to call more than once to get filtered *os.File.