ioextensions

Documentation

Index

• func CreateFileWith(filePath string, content io.Reader) error
• func NewReaderWithRetry(getReader func() (io.ReadCloser, error), retryAttempts int) io.ReadCloser
• type Flusher
• type MultiCloser
  • func NewMultiCloser(closers []io.Closer) *MultiCloser
  • func (m *MultiCloser) Close() error
• type NamedReader
• type NamedReaderImpl
  • func NewNamedReaderImpl(reader io.Reader, name string) *NamedReaderImpl
  • func (reader *NamedReaderImpl) Name() string
• type OnCloseFlusher
  • func NewOnCloseFlusher(writeCloser io.WriteCloser, flusher Flusher) *OnCloseFlusher
  • func (cf OnCloseFlusher) Close() error
• type ReadCascadeCloser
• type ReadSeekCloser
• type ReadSeekCloserImpl
• type ReaderWithRetry
  • func (r *ReaderWithRetry) Close() error
  • func (r *ReaderWithRetry) Read(p []byte) (int, error)
• type ZeroReader
  • func (z *ZeroReader) Read(p []byte) (int, error)

Functions

func CreateFileWith

func CreateFileWith(filePath string, content io.Reader) error

func NewReaderWithRetry

func NewReaderWithRetry(getReader func() (io.ReadCloser, error), retryAttempts int) io.ReadCloser

Types

type Flusher

type Flusher interface {
	Flush() error
}

type MultiCloser

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

func NewMultiCloser

func NewMultiCloser(closers []io.Closer) *MultiCloser

func (*MultiCloser) Close

func (m *MultiCloser) Close() error

type NamedReader

type NamedReader interface {
	io.Reader
	Name() string
}

type NamedReaderImpl

type NamedReaderImpl struct {
	io.Reader
	// contains filtered or unexported fields
}

func NewNamedReaderImpl

func NewNamedReaderImpl(reader io.Reader, name string) *NamedReaderImpl

func (*NamedReaderImpl) Name

func (reader *NamedReaderImpl) Name() string

type OnCloseFlusher

type OnCloseFlusher struct {
	io.WriteCloser
	Flusher
}

func NewOnCloseFlusher

func NewOnCloseFlusher(writeCloser io.WriteCloser, flusher Flusher) *OnCloseFlusher

func (OnCloseFlusher) Close

func (cf OnCloseFlusher) Close() error

type ReadCascadeCloser

type ReadCascadeCloser struct {
	io.Reader
	io.Closer
}

ReadCascadeCloser composes io.ReadCloser from two parts

type ReadSeekCloser

type ReadSeekCloser interface {
	io.Reader
	io.Seeker
	io.Closer
}

type ReadSeekCloserImpl

type ReadSeekCloserImpl struct {
	io.Reader
	io.Seeker
	io.Closer
}

type ReaderWithRetry

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

func (*ReaderWithRetry) Close

func (r *ReaderWithRetry) Close() error

func (*ReaderWithRetry) Read

func (r *ReaderWithRetry) Read(p []byte) (int, error)

type ZeroReader

type ZeroReader struct{}

ZeroReader generates a slice of zeroes. Used to pad tar in cases where length of file changes.

func (*ZeroReader) Read

func (z *ZeroReader) Read(p []byte) (int, error)