lazyio

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 21, 2020 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BufferWriter

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

func (*BufferWriter) Buffer

func (b *BufferWriter) Buffer(path string) *bytes.Buffer

func (*BufferWriter) Buffers

func (b *BufferWriter) Buffers() []string

func (*BufferWriter) Open

func (b *BufferWriter) Open(path string) (io.WriteCloser, error)

type CSV

type CSV struct {
	Path   string
	Opener OutputOpener
	// contains filtered or unexported fields
}

func (*CSV) Close

func (f *CSV) Close() error

func (*CSV) Error

func (f *CSV) Error() error

func (*CSV) Flush

func (f *CSV) Flush()

func (*CSV) Write

func (f *CSV) Write(row ...string) error

type FileReader

type FileReader struct {
	Dir string
}

func (*FileReader) Open

func (fr *FileReader) Open(path string) (io.ReadCloser, error)

func (*FileReader) Walk

func (fr *FileReader) Walk(fn func(string) error) error

type FileWriter

type FileWriter struct {
	Dir string
}

func (*FileWriter) Open

func (fw *FileWriter) Open(path string) (io.WriteCloser, error)

type Input

type Input struct {
	Path   string
	Opener InputOpener
	// contains filtered or unexported fields
}

func (*Input) Close

func (i *Input) Close() error

func (*Input) Open

func (i *Input) Open() (io.Reader, error)

func (*Input) StripExt

func (i *Input) StripExt() string

type InputOpener

type InputOpener interface {
	Open(path string) (io.ReadCloser, error)
}

type InputWalker

type InputWalker interface {
	Walk(fn func(path string) error) error
}

type OutputOpener

type OutputOpener interface {
	Open(path string) (io.WriteCloser, error)
}

type S3Reader

type S3Reader struct {
	Bucket     string
	Prefix     string
	Downloader *s3.S3
}

func NewS3Reader

func NewS3Reader(io *sys.IO, uri string) (*S3Reader, error)

func (*S3Reader) Open

func (r *S3Reader) Open(path string) (io.ReadCloser, error)

func (*S3Reader) Walk

func (r *S3Reader) Walk(fn func(string) error) error

type S3Writer

type S3Writer struct {
	Bucket   string
	Prefix   string
	Uploader *s3manager.Uploader
}

func NewS3Writer

func NewS3Writer(io *sys.IO, uri string) (*S3Writer, error)

func (*S3Writer) Open

func (o *S3Writer) Open(path string) (io.WriteCloser, error)

type TXT

type TXT struct {
	Path   string
	Opener OutputOpener
	// contains filtered or unexported fields
}

func (*TXT) Close

func (f *TXT) Close() error

func (*TXT) Write

func (f *TXT) Write(line string) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL