reader

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: Jan 23, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const (
	BufferSize = 32 * 1024
)

Variables

View Source
var (
	// ErrShortRead is returned if there is insufficient data in the buffer.
	ErrShortRead = fmt.Errorf("Insufficient data to complete read")
)

Functions

This section is empty.

Types

type Buffer added in v1.5.0

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

func NewBuffer added in v1.5.0

func NewBuffer(cap int) *Buffer

func (*Buffer) Discard added in v1.5.0

func (b *Buffer) Discard(n int)

func (*Buffer) IndexAny added in v1.5.0

func (b *Buffer) IndexAny(chars string) (int, error)

func (*Buffer) Len added in v1.5.0

func (b *Buffer) Len() int

func (*Buffer) PeekN added in v1.5.0

func (b *Buffer) PeekN(n int) (out []byte, err error)

func (*Buffer) ReadLine added in v1.5.0

func (b *Buffer) ReadLine() ([]byte, error)

func (*Buffer) ReadN added in v1.5.0

func (b *Buffer) ReadN(n int) (out []byte, err error)

func (*Buffer) Reset added in v1.5.0

func (b *Buffer) Reset()

func (*Buffer) Truncate added in v1.5.0

func (b *Buffer) Truncate()

Truncate discards any pending data in this buffer. It does not reset 'discard', which is pending data yet to arrive that is still behind the conceptual read cursor. That (pending) data still needs to be read and discarded.

func (*Buffer) Write added in v1.5.0

func (b *Buffer) Write(skip int, data []byte) error

type ErrLostData

type ErrLostData struct {
	Lost int
}

ErrLostData is returned when there is a gap in the TCP stream due to missing or late packets. It is returned only once for each gap. Successive read attempts will proceed, returning the next available data.

func (ErrLostData) Error

func (e ErrLostData) Error() string

type Reader added in v1.5.0

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

Reader implements the model.ConsumerSource interface using a Buffer.

func New

func New() *Reader

func (*Reader) Close added in v1.5.0

func (r *Reader) Close() error

func (*Reader) Discard added in v1.5.0

func (r *Reader) Discard(n int) (discarded int, err error)

func (*Reader) IndexAny added in v1.5.0

func (r *Reader) IndexAny(chars string) (pos int, err error)

func (*Reader) PeekN added in v1.5.0

func (r *Reader) PeekN(n int) (out []byte, err error)

func (*Reader) Read added in v1.5.0

func (r *Reader) Read(p []byte) (n int, err error)

func (*Reader) ReadLine added in v1.5.0

func (r *Reader) ReadLine() (out []byte, err error)

func (*Reader) ReadN added in v1.5.0

func (r *Reader) ReadN(n int) (out []byte, err error)

func (*Reader) Reassembled added in v1.5.0

func (r *Reader) Reassembled(rs []tcpassembly.Reassembly)

func (*Reader) ReassemblyComplete added in v1.5.0

func (r *Reader) ReassemblyComplete()

func (*Reader) Reset added in v1.5.0

func (r *Reader) Reset()

func (*Reader) Truncate added in v1.5.0

func (r *Reader) Truncate()

Jump to

Keyboard shortcuts

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