source

Documentation

Index

• type Handle
• type PacketSourceManager
  • func NewPacketSourceManager(procfs string, interfaceName string, mtls bool, pods []v1.Pod, ...) (*PacketSourceManager, error)
  • func (m *PacketSourceManager) Close()
  • func (m *PacketSourceManager) Stats() (packetsReceived int, packetsDropped int, err error)
  • func (m *PacketSourceManager) UpdatePods(pods []v1.Pod, packets chan<- TcpPacketInfo)
• type PacketSourceManagerConfig
• type TcpPacketInfo
• type TcpPacketSource
  • func NewHostPacketSource(filename string, interfaceName string, packetCapture string) (*TcpPacketSource, error)
  • func NewTcpPacketSource(name, filename string, interfaceName string, packetCapture string) (*TcpPacketSource, error)
  • func (source *TcpPacketSource) Close()
  • func (source *TcpPacketSource) NewPcapHandle() error
  • func (source *TcpPacketSource) ReadPackets(packets chan<- TcpPacketInfo, dontClose bool, masterCapture bool)
  • func (source *TcpPacketSource) Stats() (packetsReceived uint, packetsDropped uint, err error)
  • func (source *TcpPacketSource) String() string

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)
	FileSize() (size int64, err error)
}

type PacketSourceManager

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

func NewPacketSourceManager

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

func (*PacketSourceManager) Close

func (m *PacketSourceManager) Close()

func (*PacketSourceManager) Stats

func (m *PacketSourceManager) Stats() (packetsReceived int, packetsDropped int, err error)

func (*PacketSourceManager) UpdatePods

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

type PacketSourceManagerConfig

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

type TcpPacketInfo

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

type TcpPacketSource

type TcpPacketSource struct {
	Handle Handle
	// contains filtered or unexported fields
}

func NewHostPacketSource

func NewHostPacketSource(filename string, interfaceName string, packetCapture string) (*TcpPacketSource, error)

func NewTcpPacketSource

func NewTcpPacketSource(name, filename string, interfaceName string, packetCapture string) (*TcpPacketSource, error)

func (*TcpPacketSource) Close

func (source *TcpPacketSource) Close()

func (*TcpPacketSource) NewPcapHandle

func (source *TcpPacketSource) NewPcapHandle() error

func (*TcpPacketSource) ReadPackets

func (source *TcpPacketSource) ReadPackets(
	packets chan<- TcpPacketInfo,
	dontClose bool,
	masterCapture bool,
)

func (*TcpPacketSource) Stats

func (source *TcpPacketSource) Stats() (packetsReceived uint, packetsDropped uint, err error)

func (*TcpPacketSource) String

func (source *TcpPacketSource) String() string