ohio

Documentation

Index

• Variables
• func CopyWithPrefixOnDelim(delim byte, prefix string, dst io.Writer, src io.Reader) (n int64, err error)
• func ErrExhaustedFuncSetStringersGetString(in error) (ok bool, v string)
• func ErrExhaustedFuncSetStringersWithDelim(in error, delim byte) (out error)
• func GetPoolBufioWriter() schnittstellen.Pool[bufio.Writer, *bufio.Writer]
• func IsErrExhaustedFuncSetStringers(err error) bool
• func MakeDelimReader(delim byte, r io.Reader) (dr *delimReader)
• func MakeLineReaderIgnoreErrors(in schnittstellen.FuncSetString) schnittstellen.FuncSetString
• func MakeLineReaderIterate(rffs ...schnittstellen.FuncSetString) schnittstellen.FuncSetString
• func MakeLineReaderIterateStrict(rffs ...schnittstellen.FuncSetString) schnittstellen.FuncSetString
• func MakeLineReaderKeyValue(key string, valueReader schnittstellen.FuncSetString) schnittstellen.FuncSetString
• func MakeLineReaderKeyValues(dict map[string]schnittstellen.FuncSetString) schnittstellen.FuncSetString
• func MakeLineReaderNop() schnittstellen.FuncSetString
• func MakeLineReaderRepeat(in schnittstellen.FuncSetString) schnittstellen.FuncSetString
• func PutDelimReader(dr *delimReader)
• func ReadAllOrDieTrying(r io.Reader, b []byte) (n int, err error)
• func ReadInt64(r io.Reader) (n int64, read int, err error)
• func ReadInt8(r io.Reader) (n int8, read int, err error)
• func ReadUint16(r io.Reader) (n uint16, err error)
• func ReadUint8(r io.Reader) (n uint8, read int, err error)
• func WriteAllOrDieTrying(w io.Writer, b []byte) (n int, err error)
• func WriteInt64(w io.Writer, n int64) (written int, err error)
• func WriteInt8(w io.Writer, n int8) (written int, err error)
• func WriteKeySpaceValueNewline(w io.Writer, key string, value []byte) (n int64, err error)
• func WriteKeySpaceValueNewlineString(w io.Writer, key, value string) (n int, err error)
• func WriteKeySpaceValueNewlineWritersTo(w io.Writer, key, value io.WriterTo) (n int64, err error)
• func WriteLine(w io.Writer, s string) (n int64, err error)
• func WriteSeq[T any](w1 io.Writer, e T, seq ...schnittstellen.FuncWriterElementInterface[T]) (n int64, err error)
• func WriteStrings(w io.Writer, ss ...string) (n int, err error)
• func WriteUint16(w io.Writer, n uint16) (written int, err error)
• func WriteUint8(w io.Writer, n uint8) (written int, err error)
• type DelimReader
• type ErrExhaustedFuncSetStringersLine
  • func (e ErrExhaustedFuncSetStringersLine) Error() string
  • func (e ErrExhaustedFuncSetStringersLine) Is(target error) (ok bool)
• type PipedReaderFrom
  • func MakePipedReaderFrom(r io.ReaderFrom) PipedReaderFrom

Variables

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 (e ErrExhaustedFuncSetStringersLine) Error() string

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