io

package
v0.65.0 Latest Latest
Warning

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

Go to latest
Published: Jul 31, 2025 License: Apache-2.0 Imports: 4 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Copy added in v0.65.0

func Copy(ctx context.Context, dst io.Writer, src io.Reader) (int64, error)

Copy copies from src to dst until either EOF is reached on src or the context is canceled. It returns the number of bytes copied and the first error encountered while copying, if any.

Note: This implementation wraps the reader with a context check, which means it won't benefit from WriterTo optimization in io.Copy if the source implements it. This is a trade-off for being able to cancel the operation on context cancellation.

Types

type CountingReader added in v0.62.0

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

CountingReader wraps an io.Reader and counts the number of bytes read. Note: This implementation is NOT thread-safe. It should not be used concurrently from multiple goroutines.

func NewCountingReader added in v0.62.0

func NewCountingReader(r io.Reader) *CountingReader

NewCountingReader creates a new CountingReader that wraps the provided io.Reader.

func (*CountingReader) BytesRead added in v0.62.0

func (c *CountingReader) BytesRead() int64

BytesRead returns the number of bytes read.

func (*CountingReader) Read added in v0.62.0

func (c *CountingReader) Read(p []byte) (int, error)

Read reads data from the underlying reader and counts the number of bytes read.

type ReadSeekCloserAt added in v0.50.0

type ReadSeekCloserAt interface {
	io.ReadSeekCloser
	io.ReaderAt
}

func NopCloser

func NopCloser(r ReadSeekerAt) ReadSeekCloserAt

NopCloser returns a ReadSeekCloserAt with a no-op Close method wrapping the provided Reader r.

type ReadSeekerAt added in v0.50.0

type ReadSeekerAt interface {
	io.ReadSeeker
	io.ReaderAt
}

func NewReadSeekerAt added in v0.45.0

func NewReadSeekerAt(r io.Reader) (ReadSeekerAt, error)

func NewReadSeekerAtWithSize added in v0.50.0

func NewReadSeekerAtWithSize(r io.Reader) (ReadSeekerAt, int64, error)

Jump to

Keyboard shortcuts

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