Documentation ¶
Index ¶
- Constants
- Variables
- type Buffer
- func (b *Buffer) Discard(n int)
- func (b *Buffer) IndexAny(chars string) (int, error)
- func (b *Buffer) Len() int
- func (b *Buffer) PeekN(n int) (out []byte, err error)
- func (b *Buffer) ReadLine() ([]byte, error)
- func (b *Buffer) ReadN(n int) (out []byte, err error)
- func (b *Buffer) Reset()
- func (b *Buffer) Truncate()
- func (b *Buffer) Write(skip int, data []byte) error
- type ErrLostData
- type Reader
- func (r *Reader) Close() error
- func (r *Reader) Discard(n int) (discarded int, err error)
- func (r *Reader) IndexAny(chars string) (pos int, err error)
- func (r *Reader) PeekN(n int) (out []byte, err error)
- func (r *Reader) Read(p []byte) (n int, err error)
- func (r *Reader) ReadLine() (out []byte, err error)
- func (r *Reader) ReadN(n int) (out []byte, err error)
- func (r *Reader) Reassembled(rs []tcpassembly.Reassembly)
- func (r *Reader) ReassemblyComplete()
- func (r *Reader) Reset()
- func (r *Reader) Truncate()
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
}
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 (*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()
Click to show internal directories.
Click to hide internal directories.