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() string
  • func (m *PacketSourceManager) UpdatePods(pods []v1.Pod, packets chan<- TcpPacketInfo)
• type PacketSourceManagerConfig
• type TcpPacketInfo
• type TcpPacketSource
  • func NewTcpPacketSource(name, filename string, interfaceName string, packetCapture string, ...) (*TcpPacketSource, error)
  • func (source *TcpPacketSource) ReadPackets(packets chan<- TcpPacketInfo)
  • 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)
}

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() string

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

	Origin api.Capture
	// contains filtered or unexported fields
}

func NewTcpPacketSource

func NewTcpPacketSource(name, filename string, interfaceName string, packetCapture string,
	origin api.Capture) (*TcpPacketSource, error)

func (*TcpPacketSource) ReadPackets

func (source *TcpPacketSource) ReadPackets(packets chan<- TcpPacketInfo)

func (*TcpPacketSource) Stats

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

func (*TcpPacketSource) String

func (source *TcpPacketSource) String() string