net

Documentation

Index

• func Walk(fn WalkFunc, list ...string) error
• func Watch(ctx context.Context, tick time.Duration, fn WatchFunc, list ...string) error
• func WatchEventString(ev WatchEvent) string
• type NifDiag
  • func (n *NifDiag) Capture(ifName string, filters ...string) error
• type NifList
  • func (n *NifList) FindAddr(name string) (pcap.Interface, error)
  • func (n *NifList) FindIf(name string) (pcap.Interface, error)
  • func (n *NifList) Len() int
  • func (n *NifList) Refresh() error
• type StatsStream
  • func (s *StatsStream) Reassembled(reassemblies []tcpassembly.Reassembly)
  • func (s *StatsStream) ReassemblyComplete()
• type StatsStreamFactory
  • func (factory *StatsStreamFactory) New(net, transport gopacket.Flow) tcpassembly.Stream
• type WalkFunc
• type WatchEvent
• type WatchFunc

Functions

func Walk

func Walk(fn WalkFunc, list ...string) error

func Watch

func Watch(ctx context.Context, tick time.Duration, fn WatchFunc, list ...string) error

func WatchEventString

func WatchEventString(ev WatchEvent) string

Types

type NifDiag

type NifDiag struct{}

func (*NifDiag) Capture

func (n *NifDiag) Capture(ifName string, filters ...string) error

type NifList

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

func (*NifList) FindAddr

func (n *NifList) FindAddr(name string) (pcap.Interface, error)

func (*NifList) FindIf

func (n *NifList) FindIf(name string) (pcap.Interface, error)

func (*NifList) Len

func (n *NifList) Len() int

func (*NifList) Refresh

func (n *NifList) Refresh() error

type StatsStream

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

statsStream will handle the actual decoding of stats requests.

func (*StatsStream) Reassembled

func (s *StatsStream) Reassembled(reassemblies []tcpassembly.Reassembly)

Reassembled is called whenever new packet data is available for reading. Reassembly objects contain stream data IN ORDER.

func (*StatsStream) ReassemblyComplete

func (s *StatsStream) ReassemblyComplete()

ReassemblyComplete is called when the TCP assembler believes a stream has finished.

type StatsStreamFactory

type StatsStreamFactory struct{}

simpleStreamFactory implements tcpassembly.StreamFactory

func (*StatsStreamFactory) New

func (factory *StatsStreamFactory) New(net, transport gopacket.Flow) tcpassembly.Stream

New creates a new stream. It's called whenever the assembler sees a stream it isn't currently following.

type WalkFunc

type WalkFunc func(net.Interface, error) error

type WatchEvent

type WatchEvent uint

const (
	EventNull WatchEvent = iota
	EventCreate
	EventModify
	EventDelete
)

type WatchFunc

type WatchFunc func(string, WatchEvent, error) error