processors

Feb 20, 2024

Changes in this version

type DNSTapProcessor

+ PeerName string

type PdnsProcessor

+ PeerName string

Jan 27, 2024

Changes in this version

+ const ExpectedQname2

Jan 24, 2024

Changes in this version

+ const ExpectedBufferMsg1023

+ const ExpectedBufferMsg511

+ const ExpectedIdentity

+ const ExpectedQname

Jan 20, 2024

Changes in this version

type DNSProcessor

+ RoutingHandler pkgutils.RoutingHandler

type DNSTapProcessor

+ RoutingHandler pkgutils.RoutingHandler

type PdnsProcessor

+ RoutingHandler pkgutils.RoutingHandler

Dec 16, 2023

Changes in this version

+ var ProtobufPowerDNSToDNSTap = map[string]string

+ func GetFakeDNS() ([]byte, error)

+ func GetFakeDNSTap(dnsquery []byte) *dnstap.Dnstap

+ type DNSProcessor struct

+ ConfigChan chan *pkgconfig.Config

+ func NewDNSProcessor(config *pkgconfig.Config, logger *logger.Logger, name string, size int) DNSProcessor

+ func (d *DNSProcessor) GetChannel() chan dnsutils.DNSMessage

+ func (d *DNSProcessor) GetChannelList() []chan dnsutils.DNSMessage

+ func (d *DNSProcessor) LogError(msg string, v ...interface{})

+ func (d *DNSProcessor) LogInfo(msg string, v ...interface{})

+ func (d *DNSProcessor) MonitorLoggers()

+ func (d *DNSProcessor) Run(loggersChannel []chan dnsutils.DNSMessage, loggersName []string)

+ func (d *DNSProcessor) Stop()

+ type DNSTapProcessor struct

+ ConfigChan chan *pkgconfig.Config

+ ConnID int

+ func NewDNSTapProcessor(connID int, config *pkgconfig.Config, logger *logger.Logger, name string, ...) DNSTapProcessor

+ func (d *DNSTapProcessor) GetChannel() chan []byte

+ func (d *DNSTapProcessor) LogError(msg string, v ...interface{})

+ func (d *DNSTapProcessor) LogInfo(msg string, v ...interface{})

+ func (d *DNSTapProcessor) MonitorLoggers()

+ func (d *DNSTapProcessor) Run(loggersChannel []chan dnsutils.DNSMessage, loggersName []string)

+ func (d *DNSTapProcessor) Stop()

type PdnsProcessor

+ ConnID int

Nov 17, 2023

Changes in this version

+ var PROTOBUF_PDNS_TO_DNSTAP = map[string]string

type DnsProcessor

+ ConfigChan chan *dnsutils.Config

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

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

+ func (d *DnsProcessor) MonitorLoggers()

type DnstapProcessor

+ ConfigChan chan *dnsutils.Config

+ ConnId int

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

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

+ func (d *DnstapProcessor) MonitorLoggers()

+ type PdnsProcessor struct

+ ConfigChan chan *dnsutils.Config

+ ConnId int

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

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

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

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

+ func (d *PdnsProcessor) MonitorLoggers()

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

+ func (d *PdnsProcessor) Stop()

Aug 8, 2021

Changes in this version

+ const DnsLen

+ var Rcodes = map[int]string

+ var Rdatatypes = map[int]string

+ func DecodeAnswer(ancount int, start_offset int, payload []byte) ([]dnsutils.DnsAnswer, error)

+ func DecodeDns(payload []byte) (int, int, int, int, int, error)

+ func DecodeQuestion(payload []byte) (string, int, int, error)

+ func GetFakeDns() ([]byte, error)

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

+ func ParseA(r []byte) string

+ func ParseAAAA(rdata []byte) string

+ func ParseLabels(offset int, payload []byte) (string, int, error)

+ func ParseRdata(rdatatype string, rdata []byte) string

+ func RcodeToString(rcode int) string

+ func RdatatypeToString(rrtype int) string

+ type DnsProcessor struct

+ func NewDnsProcessor(logger *logger.Logger) DnsProcessor

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

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

+ func (d *DnsProcessor) Run(send_to []chan dnsutils.DnsMessage)

+ func (d *DnsProcessor) Stop()

+ type DnstapProcessor struct

+ func NewDnstapProcessor(logger *logger.Logger) DnstapProcessor

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

+ func (d *DnstapProcessor) Run(send_to []chan dnsutils.DnsMessage)

+ func (d *DnstapProcessor) Stop()