source

Documentation

Index

• type Handle
• type PacketSourceManager
  • func NewPacketSourceManager(procfs string, filename string, interfaceName string, mtls bool, pods []v1.Pod, ...) (*PacketSourceManager, error)
  • func (m *PacketSourceManager) Close()
  • func (m *PacketSourceManager) Stats() string
  • func (m *PacketSourceManager) UpdatePods(pods []v1.Pod, ipdefrag bool, packets chan<- TcpPacketInfo)
• type PacketSourceManagerConfig
• type TcpPacketInfo
• type TcpPacketSourceBehaviour

Types

type Handle

type Handle interface {
	NextPacket() (packet gopacket.Packet, err error)
	SetDecoder(decoder gopacket.Decoder, lazy bool, noCopy bool)
	SetBPF(expr string) (err error)
	LinkType() layers.LinkType
	Stats() (packetsReceived uint, packetsDropped uint, err error)
	Close() (err error)
}

type PacketSourceManager

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

func NewPacketSourceManager

func NewPacketSourceManager(procfs string, filename string, interfaceName string,
	mtls bool, pods []v1.Pod, behaviour TcpPacketSourceBehaviour, ipdefrag bool,
	packetCapture string, packets chan<- TcpPacketInfo) (*PacketSourceManager, error)

func (*PacketSourceManager) Close

func (m *PacketSourceManager) Close()

func (*PacketSourceManager) Stats

func (m *PacketSourceManager) Stats() string

func (*PacketSourceManager) UpdatePods

func (m *PacketSourceManager) UpdatePods(pods []v1.Pod, ipdefrag bool, packets chan<- TcpPacketInfo)

type PacketSourceManagerConfig

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

type TcpPacketInfo

type TcpPacketInfo struct {
	Packet gopacket.Packet
	Source *tcpPacketSource
}

type TcpPacketSourceBehaviour

type TcpPacketSourceBehaviour struct {
	SnapLength   int
	TargetSizeMb int
	Promisc      bool
	Tstype       string
	DecoderName  string
	Lazy         bool
	BpfFilter    string
}