tcp

Sep 25, 2021

Changes in this version

+ type ConnectionReader interface

+ ReadStream func(r Stream, a, b gopacket.Flow)

+ type SavePointReader struct

+ func NewSavePointReader(r io.Reader) *SavePointReader

+ func (sp *SavePointReader) Read(p []byte) (read int, err error)

+ func (sp *SavePointReader) Reset()

+ func (sp *SavePointReader) Restore(discardSavePoint bool)

+ func (sp *SavePointReader) SavePoint()

+ type Stream interface

+ Read func(p []byte) (n int, err error)

+ Seen func() (time.Time, error)

+ type StreamFactory struct

+ Reader ConnectionReader

+ func (f *StreamFactory) New(a, b gopacket.Flow) tcpassembly.Stream

+ func (f *StreamFactory) Wait()

+ type TimeCaptureReader struct

+ func NewTimeCaptureReader(r Stream) *TimeCaptureReader

+ func (t *TimeCaptureReader) Read(p []byte) (read int, err error)

+ func (t *TimeCaptureReader) Reset()

+ func (t *TimeCaptureReader) Seen() []time.Time