ioutil

Documentation

Index

• func BytesSliceReader(bytes [][]byte) io.Reader
• func DataReader(reader io.Reader, URL string) (io.ReadCloser, error)
• func NewHttpClientProvider(concurrency int, timeout time.Duration, dnsResolver string) func(baseURL string, options ...storage.Option) (*http.Client, error)
• func OpenURL(ctx context.Context, fs afs.Service, URL string, options ...storage.Option) (io.ReadCloser, error)
• type Flusher
• type ReadCloser
  • func (c *ReadCloser) Close() error
• type WriterCloser
  • func (w WriterCloser) Close() error

Functions

func BytesSliceReader

func BytesSliceReader(bytes [][]byte) io.Reader

BytesSliceReader creates a new byte slice reader

func DataReader

func DataReader(reader io.Reader, URL string) (io.ReadCloser, error)

DataReader returns uncompress data reader

func NewHttpClientProvider

func NewHttpClientProvider(concurrency int, timeout time.Duration, dnsResolver string) func(baseURL string, options ...storage.Option) (*http.Client, error)

NewHttpClientProvider crates custom HTTP client provider overcoming Cloud Function default DNS restriction.

func OpenURL

func OpenURL(ctx context.Context, fs afs.Service, URL string, options ...storage.Option) (io.ReadCloser, error)

OpenURL returns uncompressed data reader

Types

type Flusher

type Flusher interface {
	Flush() error
}

Flusher represents io flusher

type ReadCloser

type ReadCloser struct {
	Origin io.ReadCloser
	io.ReadCloser
}

ReadCloser represents a reader closer wrapper of original and wrapper reader

func (*ReadCloser) Close

func (c *ReadCloser) Close() error

Stop closes readers

type WriterCloser

type WriterCloser struct {
	Origin io.WriteCloser
	io.WriteCloser
}

WriterCloser represents a writer closer wrapper of original and wrapper

func (WriterCloser) Close

func (w WriterCloser) Close() error

Stop closes writers