safeio

Documentation

Overview

Package safeio provides functions similar to utilities in built-in io package but with safety nets.

Index

• func ContextualWriter(ctx context.Context, writer io.Writer) io.Writer
• func ConvertIOError(err error) (newErr error)
• func CopyDataWithContext(ctx context.Context, src io.Reader, dst io.Writer) (copied int64, err error)
• func CopyNWithContext(ctx context.Context, src io.Reader, dst io.Writer, n int64) (copied int64, err error)
• func NewByteReader(ctx context.Context, someBytes []byte) io.Reader
• func NewContextualReader(ctx context.Context, reader io.Reader) io.Reader
• func NewContextualReaderFrom(ctx context.Context, reader io.ReaderFrom) io.ReaderFrom
• func ReadAll(ctx context.Context, src io.Reader) ([]byte, error)
• func ReadAtMost(ctx context.Context, src io.Reader, max int64, bufferCapacity int64) (content []byte, err error)
• func WriteString(ctx context.Context, dst io.Writer, s string) (n int, err error)

Functions

func ContextualWriter

func ContextualWriter(ctx context.Context, writer io.Writer) io.Writer

ContextualWriter returns a writer which is context aware. Context state is checked BEFORE every Write.

func ConvertIOError

func ConvertIOError(err error) (newErr error)

ConvertIOError converts an I/O error into common errors.

func CopyDataWithContext

func CopyDataWithContext(ctx context.Context, src io.Reader, dst io.Writer) (copied int64, err error)

CopyDataWithContext copies from src to dst similarly to io.Copy but with context control to stop when asked to.

func CopyNWithContext

func CopyNWithContext(ctx context.Context, src io.Reader, dst io.Writer, n int64) (copied int64, err error)

CopyNWithContext copies n bytes from src to dst similarly to io.CopyN but with context control to stop when asked to.

func NewByteReader

func NewByteReader(ctx context.Context, someBytes []byte) io.Reader

NewByteReader return a byte reader which is context aware.

func NewContextualReader

func NewContextualReader(ctx context.Context, reader io.Reader) io.Reader

NewContextualReader returns a reader which is context aware. Context state is checked BEFORE every Read.

func NewContextualReaderFrom

func NewContextualReaderFrom(ctx context.Context, reader io.ReaderFrom) io.ReaderFrom

NewContextualReaderFrom returns a io.ReaderFrom which is context aware. Context state is checked BEFORE every Read, Write, Copy.

func ReadAll

func ReadAll(ctx context.Context, src io.Reader) ([]byte, error)

ReadAll reads the whole content of src similarly to io.ReadAll but with context control to stop when asked to.

func ReadAtMost

func ReadAtMost(ctx context.Context, src io.Reader, max int64, bufferCapacity int64) (content []byte, err error)

ReadAtMost reads the content of src and at most max bytes. It provides a functionality close to io.ReadAtLeast but with a different goal. if bufferCapacity is not set i.e. set to a negative value, it will be set by default to max if max is set to a negative value, the entirety of the reader will be read

func WriteString

func WriteString(ctx context.Context, dst io.Writer, s string) (n int, err error)

WriteString writes a string to dst similarly to io.WriteString but with context control to stop when asked to.