ohio

package
v0.0.0-...-381c4e2 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrBoundaryNotFound      = errors.New("boundary not found")
	ErrExpectedContentRead   = errors.New("expected content read")
	ErrExpectedBoundaryRead  = errors.New("expected boundary read")
	ErrReadFromSmallOverflow = errors.New(
		"reader provided more bytes than max int",
	)
	ErrInvalidBoundaryReaderState = errors.New("invalid boundary reader state")
)

Functions

func CopyWithPrefixOnDelim

func CopyWithPrefixOnDelim(
	delim byte,
	prefix string,
	dst io.Writer,
	src io.Reader,
) (n int64, err error)

func ErrExhaustedFuncSetStringersGetString

func ErrExhaustedFuncSetStringersGetString(in error) (ok bool, v string)

func ErrExhaustedFuncSetStringersWithDelim

func ErrExhaustedFuncSetStringersWithDelim(in error, delim byte) (out error)

func GetPoolBufioWriter

func GetPoolBufioWriter() schnittstellen.Pool[bufio.Writer, *bufio.Writer]

func IsErrExhaustedFuncSetStringers

func IsErrExhaustedFuncSetStringers(err error) bool

func MakeDelimReader

func MakeDelimReader(
	delim byte,
	r io.Reader,
) (dr *delimReader)

func MakeLineReaderIgnoreErrors

func MakeLineReaderIgnoreErrors(
	in schnittstellen.FuncSetString,
) schnittstellen.FuncSetString

func MakeLineReaderIterate

func MakeLineReaderIterate(
	rffs ...schnittstellen.FuncSetString,
) schnittstellen.FuncSetString

func MakeLineReaderIterateStrict

func MakeLineReaderIterateStrict(
	rffs ...schnittstellen.FuncSetString,
) schnittstellen.FuncSetString

func MakeLineReaderKeyValue

func MakeLineReaderKeyValue(
	key string,
	valueReader schnittstellen.FuncSetString,
) schnittstellen.FuncSetString

func MakeLineReaderKeyValues

func MakeLineReaderKeyValues(
	dict map[string]schnittstellen.FuncSetString,
) schnittstellen.FuncSetString

func MakeLineReaderNop

func MakeLineReaderNop() schnittstellen.FuncSetString

func MakeLineReaderRepeat

func MakeLineReaderRepeat(
	in schnittstellen.FuncSetString,
) schnittstellen.FuncSetString

func PutDelimReader

func PutDelimReader(dr *delimReader)

func ReadAllOrDieTrying

func ReadAllOrDieTrying(r io.Reader, b []byte) (n int, err error)

func ReadInt64

func ReadInt64(r io.Reader) (n int64, read int, err error)

func ReadInt8

func ReadInt8(r io.Reader) (n int8, read int, err error)

func ReadUint16

func ReadUint16(r io.Reader) (n uint16, err error)

func ReadUint8

func ReadUint8(r io.Reader) (n uint8, read int, err error)

func WriteAllOrDieTrying

func WriteAllOrDieTrying(w io.Writer, b []byte) (n int, err error)

func WriteInt64

func WriteInt64(w io.Writer, n int64) (written int, err error)

func WriteInt8

func WriteInt8(w io.Writer, n int8) (written int, err error)

func WriteKeySpaceValueNewline

func WriteKeySpaceValueNewline(
	w io.Writer,
	key string, value []byte,
) (n int64, err error)

func WriteKeySpaceValueNewlineString

func WriteKeySpaceValueNewlineString(
	w io.Writer,
	key, value string,
) (n int, err error)

func WriteKeySpaceValueNewlineWritersTo

func WriteKeySpaceValueNewlineWritersTo(
	w io.Writer,
	key, value io.WriterTo,
) (n int64, err error)

func WriteLine

func WriteLine(w io.Writer, s string) (n int64, err error)

TODO-P4 check performance of this

func WriteSeq

func WriteSeq[T any](
	w1 io.Writer,
	e T,
	seq ...schnittstellen.FuncWriterElementInterface[T],
) (n int64, err error)

func WriteStrings

func WriteStrings(
	w io.Writer,
	ss ...string,
) (n int, err error)

func WriteUint16

func WriteUint16(w io.Writer, n uint16) (written int, err error)

func WriteUint8

func WriteUint8(w io.Writer, n uint8) (written int, err error)

Types

type DelimReader

type DelimReader interface {
	io.Reader
	N() int64
	Segments() int64
	IsEOF() bool
	ResetWith(dr delimReader)
	Reset()
	ReadOneString() (str string, err error)
	ReadOneKeyValue(sep string) (key, val string, err error)
}

Not safe for parallel use

type ErrExhaustedFuncSetStringersLine

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

func (ErrExhaustedFuncSetStringersLine) Error

func (ErrExhaustedFuncSetStringersLine) Is

func (e ErrExhaustedFuncSetStringersLine) Is(target error) (ok bool)

type PipedReaderFrom

type PipedReaderFrom interface {
	Close() (n int64, err error)
	io.Writer
}

func MakePipedReaderFrom

func MakePipedReaderFrom(r io.ReaderFrom) PipedReaderFrom

Jump to

Keyboard shortcuts

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