tcpasm

Documentation

Index

• type Assembler
  • func (a *Assembler) Assemble(ctx context.Context, r io.Reader) error
  • func (a *Assembler) New(netFlow, tcpFlow gopacket.Flow) tcpassembly.Stream
• type Endpoint
  • func NewEndpoint(net, tcp gopacket.Endpoint) (Endpoint, error)
  • func (e Endpoint) PortString() string
  • func (e Endpoint) String() string
• type StreamCreated

Types

type Assembler

type Assembler struct {
	Warn    *log.Logger
	Decoder gopacket.Decoder
	Created StreamCreated

	// FlushInterval is interval to calls
	// tcpassembly.Assembler.FlushWithOptions() repeatedly.
	// Defailt is 5min.
	FlushInterval time.Duration
}

func (*Assembler) Assemble

func (a *Assembler) Assemble(ctx context.Context, r io.Reader) error

func (*Assembler) New

func (a *Assembler) New(netFlow, tcpFlow gopacket.Flow) tcpassembly.Stream

type Endpoint

type Endpoint struct {
	Address string
	Port    uint16
}

func NewEndpoint

func NewEndpoint(net, tcp gopacket.Endpoint) (Endpoint, error)

func (Endpoint) PortString

func (e Endpoint) PortString() string

func (Endpoint) String

func (e Endpoint) String() string

type StreamCreated

type StreamCreated func(src, dst Endpoint, r io.ReadCloser) error