NewReader create a new reader with goven options.

NewWriter create a new writer with given options.

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.

ReaderOptions configuration for Reader worker.

WriterOptions configuration for a Writer worker.

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

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