collectors

package
v0.43.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 11, 2024 License: MIT Imports: 44 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApplyBpfFilter 

func ApplyBpfFilter(filter []bpf.Instruction, fd int) (err error)

func ConvertIP4 added in v0.39.0 

func ConvertIP4(ip uint32) net.IP

func ConvertIP6 added in v0.39.0 

func ConvertIP6(ip [4]uint32) net.IP

func GetBPFFilterIngress added in v0.39.0 

func GetBPFFilterIngress(port int) []bpf.Instruction

func GetBpfFilter 

func GetBpfFilter(port int) []bpf.Instruction

func GetIPAddress added in v0.39.0 

func GetIPAddress[T uint32 | [4]uint32](ip T, mapper func(T) net.IP) net.IP

func Htons 

func Htons(v uint16) int

Convert a uint16 to host byte order (big endian)

func IsValidMode added in v0.26.0 

func IsValidMode(mode string) bool

func RemoveBpfFilter 

func RemoveBpfFilter(fd int) (err error)

Types

type AfpacketSniffer added in v0.27.0 

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

func NewAfpacketSniffer added in v0.27.0 

func NewAfpacketSniffer(loggers []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *AfpacketSniffer

func (*AfpacketSniffer) AddDefaultRoute added in v0.40.0 

func (c *AfpacketSniffer) AddDefaultRoute(wrk pkgutils.Worker)

func (*AfpacketSniffer) AddDroppedRoute added in v0.40.0 

func (c *AfpacketSniffer) AddDroppedRoute(wrk pkgutils.Worker)

func (*AfpacketSniffer) GetInputChannel added in v0.40.0 

func (c *AfpacketSniffer) GetInputChannel() chan dnsutils.DNSMessage

func (*AfpacketSniffer) GetName added in v0.27.0 

func (c *AfpacketSniffer) GetName() string

func (*AfpacketSniffer) Listen added in v0.27.0 

func (c *AfpacketSniffer) Listen() error

func (*AfpacketSniffer) LogError added in v0.27.0 

func (c *AfpacketSniffer) LogError(msg string, v ...interface{})

func (*AfpacketSniffer) LogInfo added in v0.27.0 

func (c *AfpacketSniffer) LogInfo(msg string, v ...interface{})

func (*AfpacketSniffer) Loggers added in v0.27.0 

func (c *AfpacketSniffer) Loggers() ([]chan dnsutils.DNSMessage, []string)

func (*AfpacketSniffer) ReadConfig added in v0.27.0 

func (c *AfpacketSniffer) ReadConfig()

func (*AfpacketSniffer) ReloadConfig added in v0.38.0 

func (c *AfpacketSniffer) ReloadConfig(config *pkgconfig.Config)

func (*AfpacketSniffer) Run added in v0.27.0 

func (c *AfpacketSniffer) Run()

func (*AfpacketSniffer) SetLoggers added in v0.27.0 

func (c *AfpacketSniffer) SetLoggers(loggers []pkgutils.Worker)

func (*AfpacketSniffer) Stop added in v0.27.0 

func (c *AfpacketSniffer) Stop()

type DNSMessage added in v0.40.0 

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

func NewDNSMessage added in v0.40.0 

func NewDNSMessage(loggers []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *DNSMessage

func (*DNSMessage) AddDefaultRoute added in v0.40.0 

func (c *DNSMessage) AddDefaultRoute(wrk pkgutils.Worker)

func (*DNSMessage) AddDroppedRoute added in v0.40.0 

func (c *DNSMessage) AddDroppedRoute(wrk pkgutils.Worker)

func (*DNSMessage) GetInputChannel added in v0.40.0 

func (c *DNSMessage) GetInputChannel() chan dnsutils.DNSMessage

func (*DNSMessage) GetName added in v0.40.0 

func (c *DNSMessage) GetName() string

func (*DNSMessage) LoadData added in v0.40.0 

func (c *DNSMessage) LoadData(matchSource string, srcKind string) (MatchSource, error)

func (*DNSMessage) LoadFromFile added in v0.40.0 

func (c *DNSMessage) LoadFromFile(filePath string, srcKind string) (MatchSource, error)

func (*DNSMessage) LoadFromURL added in v0.40.0 

func (c *DNSMessage) LoadFromURL(matchSource string, srcKind string) (MatchSource, error)

func (*DNSMessage) LogError added in v0.40.0 

func (c *DNSMessage) LogError(msg string, v ...interface{})

func (*DNSMessage) LogInfo added in v0.40.0 

func (c *DNSMessage) LogInfo(msg string, v ...interface{})

func (*DNSMessage) Loggers added in v0.40.0 

func (c *DNSMessage) Loggers() ([]chan dnsutils.DNSMessage, []string)

deprecated function

func (*DNSMessage) MonitorNextStanzas added in v0.40.2 

func (c *DNSMessage) MonitorNextStanzas()

func (*DNSMessage) ReadConfig added in v0.40.0 

func (c *DNSMessage) ReadConfig()

func (*DNSMessage) ReadConfigMatching added in v0.40.0 

func (c *DNSMessage) ReadConfigMatching(value interface{})

func (*DNSMessage) ReloadConfig added in v0.40.0 

func (c *DNSMessage) ReloadConfig(config *pkgconfig.Config)

func (*DNSMessage) Run added in v0.40.0 

func (c *DNSMessage) Run()

func (*DNSMessage) SetLoggers added in v0.40.0 

func (c *DNSMessage) SetLoggers(loggers []pkgutils.Worker)

deprecated function

func (*DNSMessage) Stop added in v0.40.0 

func (c *DNSMessage) Stop()

type Dnstap added in v0.3.0 

type Dnstap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDnstap added in v0.3.0 

func NewDnstap(loggers []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *Dnstap

func (*Dnstap) AddDefaultRoute added in v0.40.0 

func (c *Dnstap) AddDefaultRoute(wrk pkgutils.Worker)

func (*Dnstap) AddDroppedRoute added in v0.40.0 

func (c *Dnstap) AddDroppedRoute(wrk pkgutils.Worker)

func (*Dnstap) GetInputChannel added in v0.40.0 

func (c *Dnstap) GetInputChannel() chan dnsutils.DNSMessage

func (*Dnstap) GetName added in v0.22.0 

func (c *Dnstap) GetName() string

func (*Dnstap) HandleConn added in v0.3.0 

func (c *Dnstap) HandleConn(conn net.Conn)

func (*Dnstap) Listen added in v0.3.0 

func (c *Dnstap) Listen() error

func (*Dnstap) LogError added in v0.3.0 

func (c *Dnstap) LogError(msg string, v ...interface{})

func (*Dnstap) LogInfo added in v0.3.0 

func (c *Dnstap) LogInfo(msg string, v ...interface{})

func (*Dnstap) Loggers added in v0.3.0 

func (c *Dnstap) Loggers() ([]chan dnsutils.DNSMessage, []string)

func (*Dnstap) MonitorCollector added in v0.33.0 

func (c *Dnstap) MonitorCollector()

func (*Dnstap) ReadConfig added in v0.3.0 

func (c *Dnstap) ReadConfig()

func (*Dnstap) ReloadConfig added in v0.38.0 

func (c *Dnstap) ReloadConfig(config *pkgconfig.Config)

func (*Dnstap) Run added in v0.3.0 

func (c *Dnstap) Run()

func (*Dnstap) SetLoggers added in v0.22.0 

func (c *Dnstap) SetLoggers(loggers []pkgutils.Worker)

func (*Dnstap) Stop added in v0.3.0 

func (c *Dnstap) Stop()

type DnstapProxifier added in v0.26.0 

type DnstapProxifier struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewDnstapProxifier added in v0.26.0 

func NewDnstapProxifier(loggers []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *DnstapProxifier

func (*DnstapProxifier) AddDefaultRoute added in v0.40.0 

func (c *DnstapProxifier) AddDefaultRoute(wrk pkgutils.Worker)

func (*DnstapProxifier) AddDroppedRoute added in v0.40.0 

func (c *DnstapProxifier) AddDroppedRoute(wrk pkgutils.Worker)

func (*DnstapProxifier) GetInputChannel added in v0.40.0 

func (c *DnstapProxifier) GetInputChannel() chan dnsutils.DNSMessage

func (*DnstapProxifier) GetName added in v0.26.0 

func (c *DnstapProxifier) GetName() string

func (*DnstapProxifier) HandleConn added in v0.26.0 

func (c *DnstapProxifier) HandleConn(conn net.Conn)

func (*DnstapProxifier) HandleFrame added in v0.26.0 

func (c *DnstapProxifier) HandleFrame(recvFrom chan []byte, sendTo []chan dnsutils.DNSMessage)

func (*DnstapProxifier) Listen added in v0.26.0 

func (c *DnstapProxifier) Listen() error

func (*DnstapProxifier) LogError added in v0.26.0 

func (c *DnstapProxifier) LogError(msg string, v ...interface{})

func (*DnstapProxifier) LogInfo added in v0.26.0 

func (c *DnstapProxifier) LogInfo(msg string, v ...interface{})

func (*DnstapProxifier) Loggers added in v0.26.0 

func (c *DnstapProxifier) Loggers() []chan dnsutils.DNSMessage

func (*DnstapProxifier) ReadConfig added in v0.26.0 

func (c *DnstapProxifier) ReadConfig()

func (*DnstapProxifier) ReloadConfig added in v0.38.0 

func (c *DnstapProxifier) ReloadConfig(config *pkgconfig.Config)

func (*DnstapProxifier) Run added in v0.26.0 

func (c *DnstapProxifier) Run()

func (*DnstapProxifier) SetLoggers added in v0.26.0 

func (c *DnstapProxifier) SetLoggers(loggers []pkgutils.Worker)

func (*DnstapProxifier) Stop added in v0.26.0 

func (c *DnstapProxifier) Stop()

type FileIngestor added in v0.26.0 

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

func NewFileIngestor added in v0.26.0 

func NewFileIngestor(loggers []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *FileIngestor

func (*FileIngestor) AddDefaultRoute added in v0.40.0 

func (c *FileIngestor) AddDefaultRoute(wrk pkgutils.Worker)

func (*FileIngestor) AddDroppedRoute added in v0.40.0 

func (c *FileIngestor) AddDroppedRoute(wrk pkgutils.Worker)

func (*FileIngestor) GetInputChannel added in v0.40.0 

func (c *FileIngestor) GetInputChannel() chan dnsutils.DNSMessage

func (*FileIngestor) GetName added in v0.26.0 

func (c *FileIngestor) GetName() string

func (*FileIngestor) LogError added in v0.26.0 

func (c *FileIngestor) LogError(msg string, v ...interface{})

func (*FileIngestor) LogInfo added in v0.26.0 

func (c *FileIngestor) LogInfo(msg string, v ...interface{})

func (*FileIngestor) Loggers added in v0.26.0 

func (c *FileIngestor) Loggers() ([]chan dnsutils.DNSMessage, []string)

func (*FileIngestor) ProcessDnstap added in v0.26.0 

func (c *FileIngestor) ProcessDnstap(filePath string) error

func (*FileIngestor) ProcessFile added in v0.26.0 

func (c *FileIngestor) ProcessFile(filePath string)

func (*FileIngestor) ProcessPcap added in v0.26.0 

func (c *FileIngestor) ProcessPcap(filePath string)

func (*FileIngestor) ReadConfig added in v0.26.0 

func (c *FileIngestor) ReadConfig()

func (*FileIngestor) RegisterEvent added in v0.26.0 

func (c *FileIngestor) RegisterEvent(filePath string)

func (*FileIngestor) ReloadConfig added in v0.38.0 

func (c *FileIngestor) ReloadConfig(config *pkgconfig.Config)

func (*FileIngestor) RemoveEvent added in v0.26.0 

func (c *FileIngestor) RemoveEvent(filePath string)

func (*FileIngestor) Run added in v0.26.0 

func (c *FileIngestor) Run()

func (*FileIngestor) SetLoggers added in v0.26.0 

func (c *FileIngestor) SetLoggers(loggers []pkgutils.Worker)

func (*FileIngestor) Stop added in v0.26.0 

func (c *FileIngestor) Stop()

type MatchSource added in v0.40.0 

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

type ProtobufPowerDNS added in v0.17.0 

type ProtobufPowerDNS struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewProtobufPowerDNS added in v0.17.0 

func NewProtobufPowerDNS(loggers []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *ProtobufPowerDNS

func (*ProtobufPowerDNS) AddDefaultRoute added in v0.40.0 

func (c *ProtobufPowerDNS) AddDefaultRoute(wrk pkgutils.Worker)

func (*ProtobufPowerDNS) AddDroppedRoute added in v0.40.0 

func (c *ProtobufPowerDNS) AddDroppedRoute(wrk pkgutils.Worker)

func (*ProtobufPowerDNS) GetInputChannel added in v0.40.0 

func (c *ProtobufPowerDNS) GetInputChannel() chan dnsutils.DNSMessage

func (*ProtobufPowerDNS) GetName added in v0.22.0 

func (c *ProtobufPowerDNS) GetName() string

func (*ProtobufPowerDNS) HandleConn added in v0.17.0 

func (c *ProtobufPowerDNS) HandleConn(conn net.Conn)

func (*ProtobufPowerDNS) Listen added in v0.17.0 

func (c *ProtobufPowerDNS) Listen() error

func (*ProtobufPowerDNS) LogError added in v0.17.0 

func (c *ProtobufPowerDNS) LogError(msg string, v ...interface{})

func (*ProtobufPowerDNS) LogInfo added in v0.17.0 

func (c *ProtobufPowerDNS) LogInfo(msg string, v ...interface{})

func (*ProtobufPowerDNS) Loggers added in v0.17.0 

func (c *ProtobufPowerDNS) Loggers() ([]chan dnsutils.DNSMessage, []string)

func (*ProtobufPowerDNS) MonitorCollector added in v0.33.0 

func (c *ProtobufPowerDNS) MonitorCollector()

func (*ProtobufPowerDNS) ReadConfig added in v0.17.0 

func (c *ProtobufPowerDNS) ReadConfig()

func (*ProtobufPowerDNS) ReloadConfig added in v0.38.0 

func (c *ProtobufPowerDNS) ReloadConfig(config *pkgconfig.Config)

func (*ProtobufPowerDNS) Run added in v0.17.0 

func (c *ProtobufPowerDNS) Run()

func (*ProtobufPowerDNS) SetLoggers added in v0.22.0 

func (c *ProtobufPowerDNS) SetLoggers(loggers []pkgutils.Worker)

func (*ProtobufPowerDNS) Stop added in v0.17.0 

func (c *ProtobufPowerDNS) Stop()

type TZSPSniffer added in v0.39.0 

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

func NewTZSP added in v0.39.0 

func NewTZSP(loggers []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *TZSPSniffer

func (*TZSPSniffer) AddDefaultRoute added in v0.40.0 

func (c *TZSPSniffer) AddDefaultRoute(wrk pkgutils.Worker)

func (*TZSPSniffer) AddDroppedRoute added in v0.40.0 

func (c *TZSPSniffer) AddDroppedRoute(wrk pkgutils.Worker)

func (*TZSPSniffer) GetInputChannel added in v0.40.0 

func (c *TZSPSniffer) GetInputChannel() chan dnsutils.DNSMessage

func (*TZSPSniffer) GetName added in v0.39.0 

func (c *TZSPSniffer) GetName() string

func (*TZSPSniffer) Listen added in v0.39.0 

func (c *TZSPSniffer) Listen() error

func (*TZSPSniffer) LogError added in v0.39.0 

func (c *TZSPSniffer) LogError(msg string, v ...interface{})

func (*TZSPSniffer) LogInfo added in v0.39.0 

func (c *TZSPSniffer) LogInfo(msg string, v ...interface{})

func (*TZSPSniffer) Loggers added in v0.39.0 

func (c *TZSPSniffer) Loggers() ([]chan dnsutils.DNSMessage, []string)

func (*TZSPSniffer) ReadConfig added in v0.39.0 

func (c *TZSPSniffer) ReadConfig()

func (*TZSPSniffer) ReloadConfig added in v0.39.0 

func (c *TZSPSniffer) ReloadConfig(config *pkgconfig.Config)

func (*TZSPSniffer) Run added in v0.39.0 

func (c *TZSPSniffer) Run()

func (*TZSPSniffer) SetLoggers added in v0.39.0 

func (c *TZSPSniffer) SetLoggers(loggers []pkgutils.Worker)

func (*TZSPSniffer) Stop added in v0.39.0 

func (c *TZSPSniffer) Stop()

type Tail added in v0.5.0 

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

func NewTail added in v0.5.0 

func NewTail(loggers []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *Tail

func (*Tail) AddDefaultRoute added in v0.40.0 

func (c *Tail) AddDefaultRoute(wrk pkgutils.Worker)

func (*Tail) AddDroppedRoute added in v0.40.0 

func (c *Tail) AddDroppedRoute(wrk pkgutils.Worker)

func (*Tail) Follow added in v0.5.0 

func (c *Tail) Follow() error

func (*Tail) GetInputChannel added in v0.40.0 

func (c *Tail) GetInputChannel() chan dnsutils.DNSMessage

func (*Tail) GetName added in v0.22.0 

func (c *Tail) GetName() string

func (*Tail) LogError added in v0.5.0 

func (c *Tail) LogError(msg string, v ...interface{})

func (*Tail) LogInfo added in v0.5.0 

func (c *Tail) LogInfo(msg string, v ...interface{})

func (*Tail) Loggers added in v0.5.0 

func (c *Tail) Loggers() []chan dnsutils.DNSMessage

func (*Tail) ReadConfig added in v0.5.0 

func (c *Tail) ReadConfig()

func (*Tail) ReloadConfig added in v0.38.0 

func (c *Tail) ReloadConfig(config *pkgconfig.Config)

func (*Tail) Run added in v0.5.0 

func (c *Tail) Run()

func (*Tail) SetLoggers added in v0.22.0 

func (c *Tail) SetLoggers(loggers []pkgutils.Worker)

func (*Tail) Stop added in v0.5.0 

func (c *Tail) Stop()

type XDPSniffer added in v0.39.0 

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

func NewXDPSniffer added in v0.39.0 

func NewXDPSniffer(loggers []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *XDPSniffer

func (*XDPSniffer) AddDefaultRoute added in v0.40.0 

func (c *XDPSniffer) AddDefaultRoute(wrk pkgutils.Worker)

func (*XDPSniffer) AddDroppedRoute added in v0.40.0 

func (c *XDPSniffer) AddDroppedRoute(wrk pkgutils.Worker)

func (*XDPSniffer) GetInputChannel added in v0.40.0 

func (c *XDPSniffer) GetInputChannel() chan dnsutils.DNSMessage

func (*XDPSniffer) GetName added in v0.39.0 

func (c *XDPSniffer) GetName() string

func (*XDPSniffer) LogError added in v0.39.0 

func (c *XDPSniffer) LogError(msg string, v ...interface{})

func (*XDPSniffer) LogInfo added in v0.39.0 

func (c *XDPSniffer) LogInfo(msg string, v ...interface{})

func (*XDPSniffer) Loggers added in v0.39.0 

func (c *XDPSniffer) Loggers() ([]chan dnsutils.DNSMessage, []string)

func (*XDPSniffer) ReadConfig added in v0.39.0 

func (c *XDPSniffer) ReadConfig()

func (*XDPSniffer) ReloadConfig added in v0.39.0 

func (c *XDPSniffer) ReloadConfig(config *pkgconfig.Config)

func (*XDPSniffer) Run added in v0.39.0 

func (c *XDPSniffer) Run()

func (*XDPSniffer) SetLoggers added in v0.39.0 

func (c *XDPSniffer) SetLoggers(loggers []pkgutils.Worker)

func (*XDPSniffer) Stop added in v0.39.0 

func (c *XDPSniffer) Stop()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.