collectors

package
v0.40.0-alpha3 Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2024 License: MIT Imports: 39 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 []dnsutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *AfpacketSniffer

func (*AfpacketSniffer) Channel added in v0.27.0 

func (c *AfpacketSniffer) Channel() 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 []dnsutils.Worker)

func (*AfpacketSniffer) Stop added in v0.27.0 

func (c *AfpacketSniffer) 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 []dnsutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *Dnstap

func (*Dnstap) Channel added in v0.3.0 

func (c *Dnstap) Channel() 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) LogConnError added in v0.33.0 

func (c *Dnstap) LogConnError(connID int, msg string, v ...interface{})

func (*Dnstap) LogConnInfo added in v0.33.0 

func (c *Dnstap) LogConnInfo(connID int, msg string, v ...interface{})

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 []dnsutils.Worker)

func (*Dnstap) Stop added in v0.3.0 

func (c *Dnstap) Stop()

type DnstapProxifier added in v0.26.0 

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

func NewDnstapProxifier added in v0.26.0 

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

func (*DnstapProxifier) Channel added in v0.26.0 

func (c *DnstapProxifier) Channel() 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 []dnsutils.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 []dnsutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *FileIngestor

func (*FileIngestor) Channel added in v0.26.0 

func (c *FileIngestor) Channel() 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 []dnsutils.Worker)

func (*FileIngestor) Stop added in v0.26.0 

func (c *FileIngestor) Stop()

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 []dnsutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *ProtobufPowerDNS

func (*ProtobufPowerDNS) Channel added in v0.17.0 

func (c *ProtobufPowerDNS) Channel() 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) LogConnError added in v0.33.0 

func (c *ProtobufPowerDNS) LogConnError(connID int, msg string, v ...interface{})

func (*ProtobufPowerDNS) LogConnInfo added in v0.33.0 

func (c *ProtobufPowerDNS) LogConnInfo(connID int, msg string, v ...interface{})

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 []dnsutils.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 []dnsutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *TZSPSniffer

func (*TZSPSniffer) Channel added in v0.39.0 

func (c *TZSPSniffer) Channel() 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 []dnsutils.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 []dnsutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *Tail

func (*Tail) Channel added in v0.5.0 

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

func (*Tail) Follow added in v0.5.0 

func (c *Tail) Follow() error

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 []dnsutils.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 []dnsutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *XDPSniffer

func (*XDPSniffer) Channel added in v0.39.0 

func (c *XDPSniffer) Channel() 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 []dnsutils.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.