filesystem

Documentation

Index

• type FilenameFunc
  • func (f FilenameFunc) Filename([]byte) string
• type Filenamer
• type Reader
  • func NewReader(opts ReaderOptions) *Reader
  • func (r *Reader) Process(ctx context.Context, args selina.ProcessArgs) (err error)
• type ReaderOptions
• type Writer
  • func NewWriter(opts WriterOptions) *Writer
  • func (w Writer) Process(ctx context.Context, args selina.ProcessArgs) (err error)
• type WriterOptions

Types

type FilenameFunc

type FilenameFunc func() string

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

func (FilenameFunc) Filename

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

func NewReader(opts ReaderOptions) *Reader

func (*Reader) Process

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
	Hanlder   selina.ErrorHandler
}

type Writer

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

func NewWriter

func NewWriter(opts WriterOptions) *Writer

func (Writer) Process

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
	Hanlder    selina.ErrorHandler
}