filesystem

type FilenameFunc ¶

type FilenameFunc func() string

FilenameFunc provide a wrapper to implement a Filenamer with just a func()string

func (f FilenameFunc) Filename([]byte) string

type Filenamer ¶

type Filenamer interface {
	Filename(msg []byte) string
}

Filenamer is used to provide an easy way to generate dynamic files name to reader/writer msg is readed from input chanel in Process

type Reader ¶

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

Reader for every message received it call Filenamer.Filename(msg) to get a filename to open a given file, then read it until eof or context is cancelled

func NewReader(opts ReaderOptions) *Reader

func (r *Reader) Process(ctx context.Context, args selina.ProcessArgs) (err error)

type ReaderOptions ¶

type ReaderOptions struct {
	Fs        afero.Fs
	SplitFunc bufio.SplitFunc
	Filename  Filenamer
	Handler   selina.ErrorHandler
}

ReaderOptions configuration for Reader worker

type Writer ¶

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

func NewWriter(opts WriterOptions) *Writer

func (w Writer) Process(ctx context.Context, args selina.ProcessArgs) (err error)

type WriterOptions ¶

type WriterOptions struct {
	Filename   Filenamer
	Fs         afero.Fs
	AddNewLine bool
	BufferSize int
	Mode       os.FileMode
	Handler    selina.ErrorHandler
}

WriterOptions configuration for a Writer worker