collectors

package
v0.32.0 Latest Latest
Warning

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

 Go to latest Published: May 23, 2023 License: MIT Imports: 40 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PROTOBUF_PDNS_TO_DNSTAP = map[string]string{
		"DNSQueryType":            "CLIENT_QUERY",
		"DNSResponseType":         "CLIENT_RESPONSE",
		"DNSOutgoingQueryType":    "RESOLVER_QUERY",
		"DNSIncomingResponseType": "RESOLVER_RESPONSE",
	}
)

Functions

func ApplyBpfFilter 

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

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 GetBpfFilter 

func GetBpfFilter(port int) []bpf.Instruction

func GetBpfFilter_Ingress added in v0.27.0 

func GetBpfFilter_Ingress(port int) []bpf.Instruction

func GetFakeDns added in v0.21.0 

func GetFakeDns() ([]byte, error)

func GetFakeDnstap added in v0.21.0 

func GetFakeDnstap(dnsquery []byte) *dnstap.Dnstap

func GetIpAddress added in v0.27.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 *dnsutils.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) 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 DnsProcessor added in v0.21.0 

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

func NewDnsProcessor added in v0.21.0 

func NewDnsProcessor(config *dnsutils.Config, logger *logger.Logger, name string, size int) DnsProcessor

func (*DnsProcessor) Following added in v0.32.0 

func (d *DnsProcessor) Following()

func (*DnsProcessor) GetChannel added in v0.21.0 

func (d *DnsProcessor) GetChannel() chan dnsutils.DnsMessage

func (*DnsProcessor) GetChannelList added in v0.21.0 

func (d *DnsProcessor) GetChannelList() []chan dnsutils.DnsMessage

func (*DnsProcessor) LogError added in v0.21.0 

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

func (*DnsProcessor) LogInfo added in v0.21.0 

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

func (*DnsProcessor) ReadConfig added in v0.21.0 

func (d *DnsProcessor) ReadConfig()

func (*DnsProcessor) Run added in v0.21.0 

func (d *DnsProcessor) Run(loggersChannel []chan dnsutils.DnsMessage, loggersName []string)

func (*DnsProcessor) Stop added in v0.21.0 

func (d *DnsProcessor) 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) DropsFollowing added in v0.32.0 

func (c *Dnstap) DropsFollowing()

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) ReadConfig added in v0.3.0 

func (c *Dnstap) ReadConfig()

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 DnstapProcessor added in v0.21.0 

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

func NewDnstapProcessor added in v0.21.0 

func NewDnstapProcessor(connId int, config *dnsutils.Config, logger *logger.Logger, name string, size int) DnstapProcessor

func (*DnstapProcessor) Following added in v0.32.0 

func (d *DnstapProcessor) Following()

func (*DnstapProcessor) GetChannel added in v0.21.0 

func (d *DnstapProcessor) GetChannel() chan []byte

func (*DnstapProcessor) LogError added in v0.21.0 

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

func (*DnstapProcessor) LogInfo added in v0.21.0 

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

func (*DnstapProcessor) ReadConfig added in v0.21.0 

func (d *DnstapProcessor) ReadConfig()

func (*DnstapProcessor) Run added in v0.21.0 

func (d *DnstapProcessor) Run(loggersChannel []chan dnsutils.DnsMessage, loggersName []string)

func (*DnstapProcessor) Stop added in v0.21.0 

func (d *DnstapProcessor) 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) 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) 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 PdnsProcessor added in v0.21.0 

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

func NewPdnsProcessor added in v0.21.0 

func NewPdnsProcessor(connId int, config *dnsutils.Config, logger *logger.Logger, name string, size int) PdnsProcessor

func (*PdnsProcessor) Following added in v0.32.0 

func (d *PdnsProcessor) Following()

func (*PdnsProcessor) GetChannel added in v0.21.0 

func (d *PdnsProcessor) GetChannel() chan []byte

func (*PdnsProcessor) LogError added in v0.21.0 

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

func (*PdnsProcessor) LogInfo added in v0.21.0 

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

func (*PdnsProcessor) ReadConfig added in v0.21.0 

func (c *PdnsProcessor) ReadConfig()

func (*PdnsProcessor) Run added in v0.21.0 

func (d *PdnsProcessor) Run(loggersChannel []chan dnsutils.DnsMessage, loggersName []string)

func (*PdnsProcessor) Stop added in v0.21.0 

func (d *PdnsProcessor) 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) FollowChannel added in v0.32.0 

func (c *ProtobufPowerDNS) FollowChannel()

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) ReadConfig added in v0.17.0 

func (c *ProtobufPowerDNS) ReadConfig()

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) 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 NewTzsp added in v0.29.0 

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

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) Listen added in v0.29.0 

func (c *TzspSniffer) Listen() error

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, []string)

func (*TzspSniffer) ReadConfig added in v0.29.0 

func (c *TzspSniffer) ReadConfig()

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