Documentation ¶
Index ¶
- Variables
- func GetFakeDNS() ([]byte, error)
- func GetFakeDNSTap(dnsquery []byte) *dnstap.Dnstap
- type 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) Run(defaultWorkers []pkgutils.Worker, droppedworkers []pkgutils.Worker)
- func (d *DNSProcessor) Stop()
- type 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) Run(defaultWorkers []pkgutils.Worker, droppedworkers []pkgutils.Worker)
- func (d *DNSTapProcessor) Stop()
- type PdnsProcessor
- func (p *PdnsProcessor) GetChannel() chan []byte
- func (p *PdnsProcessor) LogError(msg string, v ...interface{})
- func (p *PdnsProcessor) LogInfo(msg string, v ...interface{})
- func (p *PdnsProcessor) Run(defaultWorkers []pkgutils.Worker, droppedworkers []pkgutils.Worker)
- func (p *PdnsProcessor) Stop()
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ProtobufPowerDNSToDNSTap = map[string]string{
"DNSQueryType": "CLIENT_QUERY",
"DNSResponseType": "CLIENT_RESPONSE",
"DNSOutgoingQueryType": "RESOLVER_QUERY",
"DNSIncomingResponseType": "RESOLVER_RESPONSE",
}
)
Functions ¶
func GetFakeDNS ¶ added in v0.39.0
func GetFakeDNSTap ¶ added in v0.39.0
func GetFakeDNSTap(dnsquery []byte) *dnstap.Dnstap
Types ¶
type DNSProcessor ¶ added in v0.39.0
type DNSProcessor struct { ConfigChan chan *pkgconfig.Config RoutingHandler pkgutils.RoutingHandler // contains filtered or unexported fields }
func NewDNSProcessor ¶ added in v0.39.0
func NewDNSProcessor(config *pkgconfig.Config, logger *logger.Logger, name string, size int) DNSProcessor
func (*DNSProcessor) GetChannel ¶ added in v0.39.0
func (d *DNSProcessor) GetChannel() chan dnsutils.DNSMessage
func (*DNSProcessor) GetChannelList ¶ added in v0.39.0
func (d *DNSProcessor) GetChannelList() []chan dnsutils.DNSMessage
func (*DNSProcessor) LogError ¶ added in v0.39.0
func (d *DNSProcessor) LogError(msg string, v ...interface{})
func (*DNSProcessor) LogInfo ¶ added in v0.39.0
func (d *DNSProcessor) LogInfo(msg string, v ...interface{})
func (*DNSProcessor) Run ¶ added in v0.39.0
func (d *DNSProcessor) Run(defaultWorkers []pkgutils.Worker, droppedworkers []pkgutils.Worker)
func (*DNSProcessor) Stop ¶ added in v0.39.0
func (d *DNSProcessor) Stop()
type DNSTapProcessor ¶ added in v0.39.0
type DNSTapProcessor struct { ConnID int ConfigChan chan *pkgconfig.Config RoutingHandler pkgutils.RoutingHandler // contains filtered or unexported fields }
func NewDNSTapProcessor ¶ added in v0.39.0
func (*DNSTapProcessor) GetChannel ¶ added in v0.39.0
func (d *DNSTapProcessor) GetChannel() chan []byte
func (*DNSTapProcessor) LogError ¶ added in v0.39.0
func (d *DNSTapProcessor) LogError(msg string, v ...interface{})
func (*DNSTapProcessor) LogInfo ¶ added in v0.39.0
func (d *DNSTapProcessor) LogInfo(msg string, v ...interface{})
func (*DNSTapProcessor) Run ¶ added in v0.39.0
func (d *DNSTapProcessor) Run(defaultWorkers []pkgutils.Worker, droppedworkers []pkgutils.Worker)
func (*DNSTapProcessor) Stop ¶ added in v0.39.0
func (d *DNSTapProcessor) Stop()
type PdnsProcessor ¶ added in v0.38.0
type PdnsProcessor struct { ConnID int ConfigChan chan *pkgconfig.Config RoutingHandler pkgutils.RoutingHandler // contains filtered or unexported fields }
func NewPdnsProcessor ¶ added in v0.38.0
func (*PdnsProcessor) GetChannel ¶ added in v0.38.0
func (p *PdnsProcessor) GetChannel() chan []byte
func (*PdnsProcessor) LogError ¶ added in v0.38.0
func (p *PdnsProcessor) LogError(msg string, v ...interface{})
func (*PdnsProcessor) LogInfo ¶ added in v0.38.0
func (p *PdnsProcessor) LogInfo(msg string, v ...interface{})
func (*PdnsProcessor) Run ¶ added in v0.38.0
func (p *PdnsProcessor) Run(defaultWorkers []pkgutils.Worker, droppedworkers []pkgutils.Worker)
func (*PdnsProcessor) Stop ¶ added in v0.38.0
func (p *PdnsProcessor) Stop()
Click to show internal directories.
Click to hide internal directories.