collectors

package
v0.38.0 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2023 License: MIT Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertIp4 added in v0.27.0 

func ConvertIp4(ip uint32) net.IP

func ConvertIp6 added in v0.27.0 

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

func GetIpAddress added in v0.27.0 

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

func IsValidMode added in v0.26.0 

func IsValidMode(mode string) bool

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 *dnsutils.Config, logger *logger.Logger, name string) *AfpacketSniffer

workaround for macos, not yet supported

func NewTzsp added in v0.29.0 

func NewTzsp(loggers []dnsutils.Worker, config *dnsutils.Config, logger *logger.Logger, name string) *AfpacketSniffer

workaround for macos, not yet supported

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

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 *dnsutils.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 *dnsutils.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 *dnsutils.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 *dnsutils.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 *dnsutils.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 *dnsutils.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 *dnsutils.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 *dnsutils.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 *dnsutils.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 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 *dnsutils.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 *dnsutils.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 TzspSniffer added in v0.29.0 

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

func (*TzspSniffer) Channel added in v0.29.0 

func (c *TzspSniffer) Channel() chan dnsutils.DnsMessage

func (*TzspSniffer) GetName added in v0.29.0 

func (c *TzspSniffer) GetName() string

func (*TzspSniffer) LogError added in v0.29.0 

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

func (*TzspSniffer) LogInfo added in v0.29.0 

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

func (*TzspSniffer) Loggers added in v0.29.0 

func (c *TzspSniffer) Loggers() []chan dnsutils.DnsMessage

func (*TzspSniffer) ReadConfig added in v0.29.0 

func (c *TzspSniffer) ReadConfig()

func (*TzspSniffer) ReloadConfig added in v0.38.0 

func (c *TzspSniffer) ReloadConfig(config *dnsutils.Config)

func (*TzspSniffer) Run added in v0.29.0 

func (c *TzspSniffer) Run()

func (*TzspSniffer) SetLoggers added in v0.29.0 

func (c *TzspSniffer) SetLoggers(loggers []dnsutils.Worker)

func (*TzspSniffer) Stop added in v0.29.0 

func (c *TzspSniffer) Stop()

type XdpSniffer added in v0.27.0 

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

func NewXdpSniffer added in v0.27.0 

func NewXdpSniffer(loggers []dnsutils.Worker, config *dnsutils.Config, logger *logger.Logger, name string) *XdpSniffer

func (*XdpSniffer) Channel added in v0.27.0 

func (c *XdpSniffer) Channel() chan dnsutils.DnsMessage

func (*XdpSniffer) GetName added in v0.27.0 

func (c *XdpSniffer) GetName() string

func (*XdpSniffer) LogError added in v0.27.0 

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

func (*XdpSniffer) LogInfo added in v0.27.0 

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

func (*XdpSniffer) Loggers added in v0.27.0 

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

func (*XdpSniffer) ReadConfig added in v0.27.0 

func (c *XdpSniffer) ReadConfig()

func (*XdpSniffer) ReloadConfig added in v0.38.0 

func (c *XdpSniffer) ReloadConfig(config *dnsutils.Config)

func (*XdpSniffer) Run added in v0.27.0 

func (c *XdpSniffer) Run()

func (*XdpSniffer) SetLoggers added in v0.27.0 

func (c *XdpSniffer) SetLoggers(loggers []dnsutils.Worker)

func (*XdpSniffer) Stop added in v0.27.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.