collectors

Documentation

Index

• type DNSSniffer
  • func NewDNSSniffer(resolver ipresolver.IPResolver, isRunningOnAWS bool) *DNSSniffer
  • func (s *DNSSniffer) CreateDNSPacketStream() (chan gopacket.Packet, error)
  • func (s *DNSSniffer) CreatePacketChannelForInterface(iface net.Interface) (result chan gopacket.Packet, err error)
  • func (s *DNSSniffer) GetTimeTilNextRefresh() time.Duration
  • func (s *DNSSniffer) HandlePacket(packet gopacket.Packet)
  • func (s *DNSSniffer) RefreshHostsMapping() error
• type NetworkCollector
  • func (c *NetworkCollector) CollectResults() []mapperclient.RecordedDestinationsForSrc
• type PacketChannelCombiner
  • func NewPacketChannelCombiner(channels []chan gopacket.Packet) *PacketChannelCombiner
  • func (p *PacketChannelCombiner) Packets() chan gopacket.Packet
• type SocketScanner
  • func NewSocketScanner() *SocketScanner
  • func (s *SocketScanner) ScanProcDir() error
• type TCPSniffer
  • func NewTCPSniffer(resolver ipresolver.IPResolver, isRunningOnAWS bool) *TCPSniffer
  • func (s *TCPSniffer) CreateTCPPacketStream() (chan gopacket.Packet, error)
  • func (s *TCPSniffer) GetTimeTilNextRefresh() time.Duration
  • func (s *TCPSniffer) HandlePacket(packet gopacket.Packet)
  • func (s *TCPSniffer) RefreshHostsMapping() error
• type TimeAndTTL
• type UniqueRequest

Types

type DNSSniffer

type DNSSniffer struct {
	NetworkCollector
	// contains filtered or unexported fields
}

func NewDNSSniffer

func NewDNSSniffer(resolver ipresolver.IPResolver, isRunningOnAWS bool) *DNSSniffer

func (*DNSSniffer) CreateDNSPacketStream

func (s *DNSSniffer) CreateDNSPacketStream() (chan gopacket.Packet, error)

func (*DNSSniffer) CreatePacketChannelForInterface

func (s *DNSSniffer) CreatePacketChannelForInterface(iface net.Interface) (result chan gopacket.Packet, err error)

func (*DNSSniffer) GetTimeTilNextRefresh

func (s *DNSSniffer) GetTimeTilNextRefresh() time.Duration

func (*DNSSniffer) HandlePacket

func (s *DNSSniffer) HandlePacket(packet gopacket.Packet)

func (*DNSSniffer) RefreshHostsMapping

func (s *DNSSniffer) RefreshHostsMapping() error

type NetworkCollector

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

func (*NetworkCollector) CollectResults

func (c *NetworkCollector) CollectResults() []mapperclient.RecordedDestinationsForSrc

type PacketChannelCombiner

type PacketChannelCombiner struct {
	Channels []chan gopacket.Packet
	// contains filtered or unexported fields
}

func NewPacketChannelCombiner

func NewPacketChannelCombiner(channels []chan gopacket.Packet) *PacketChannelCombiner

func (*PacketChannelCombiner) Packets

func (p *PacketChannelCombiner) Packets() chan gopacket.Packet

type SocketScanner

type SocketScanner struct {
	NetworkCollector
}

func NewSocketScanner

func NewSocketScanner() *SocketScanner

func (*SocketScanner) ScanProcDir

func (s *SocketScanner) ScanProcDir() error

type TCPSniffer

type TCPSniffer struct {
	NetworkCollector
	// contains filtered or unexported fields
}

func NewTCPSniffer

func NewTCPSniffer(resolver ipresolver.IPResolver, isRunningOnAWS bool) *TCPSniffer

func (*TCPSniffer) CreateTCPPacketStream

func (s *TCPSniffer) CreateTCPPacketStream() (chan gopacket.Packet, error)

func (*TCPSniffer) GetTimeTilNextRefresh

func (s *TCPSniffer) GetTimeTilNextRefresh() time.Duration

func (*TCPSniffer) HandlePacket

func (s *TCPSniffer) HandlePacket(packet gopacket.Packet)

func (*TCPSniffer) RefreshHostsMapping

func (s *TCPSniffer) RefreshHostsMapping() error

type TimeAndTTL

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

type UniqueRequest

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