transformers

Documentation

Index

• type FilteringProcessor
  • func NewFilteringProcessor(config *dnsutils.Config, logger *logger.Logger, name string) FilteringProcessor
  • func (p *FilteringProcessor) CheckIfDrop(dm *dnsutils.DnsMessage) bool
  • func (p *FilteringProcessor) LoadDomainsList()
  • func (p *FilteringProcessor) LoadQueryIpList()
  • func (p *FilteringProcessor) LoadRcodes()
  • func (p *FilteringProcessor) LogError(msg string, v ...interface{})
  • func (p *FilteringProcessor) LogInfo(msg string, v ...interface{})
  • func (p *FilteringProcessor) Run()
• type GeoIpProcessor
  • func NewDnsGeoIpProcessor(config *dnsutils.Config, logger *logger.Logger) GeoIpProcessor
  • func (p *GeoIpProcessor) Close()
  • func (p *GeoIpProcessor) IsEnabled() bool
  • func (p *GeoIpProcessor) LogError(msg string, v ...interface{})
  • func (p *GeoIpProcessor) LogInfo(msg string, v ...interface{})
  • func (p *GeoIpProcessor) Lookup(ip string) (GeoRecord, error)
  • func (p *GeoIpProcessor) Open() (err error)
• type GeoRecord
• type IpAnonymizerSubproc
  • func NewIpAnonymizerSubprocessor(config *dnsutils.Config) IpAnonymizerSubproc
  • func (s *IpAnonymizerSubproc) Anonymize(ip string) string
  • func (s *IpAnonymizerSubproc) IsEnabled() bool
  • func (s *IpAnonymizerSubproc) ReadConfig()
• type MaxminddbRecord
• type QnameReducer
  • func NewQnameReducerSubprocessor(config *dnsutils.Config) QnameReducer
  • func (s *QnameReducer) IsEnabled() bool
  • func (s *QnameReducer) Minimaze(qname string) string
  • func (s *QnameReducer) ReadConfig()

Types

type FilteringProcessor

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

func NewFilteringProcessor

func NewFilteringProcessor(config *dnsutils.Config, logger *logger.Logger, name string) FilteringProcessor

func (*FilteringProcessor) CheckIfDrop

func (p *FilteringProcessor) CheckIfDrop(dm *dnsutils.DnsMessage) bool

func (*FilteringProcessor) LoadDomainsList

func (p *FilteringProcessor) LoadDomainsList()

func (*FilteringProcessor) LoadQueryIpList

func (p *FilteringProcessor) LoadQueryIpList()

func (*FilteringProcessor) LoadRcodes

func (p *FilteringProcessor) LoadRcodes()

func (*FilteringProcessor) LogError

func (p *FilteringProcessor) LogError(msg string, v ...interface{})

func (*FilteringProcessor) LogInfo

func (p *FilteringProcessor) LogInfo(msg string, v ...interface{})

func (*FilteringProcessor) Run

func (p *FilteringProcessor) Run()

type GeoIpProcessor

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

func NewDnsGeoIpProcessor

func NewDnsGeoIpProcessor(config *dnsutils.Config, logger *logger.Logger) GeoIpProcessor

func (*GeoIpProcessor) Close

func (p *GeoIpProcessor) Close()

func (*GeoIpProcessor) IsEnabled

func (p *GeoIpProcessor) IsEnabled() bool

func (*GeoIpProcessor) LogError

func (p *GeoIpProcessor) LogError(msg string, v ...interface{})

func (*GeoIpProcessor) LogInfo

func (p *GeoIpProcessor) LogInfo(msg string, v ...interface{})

func (*GeoIpProcessor) Lookup

func (p *GeoIpProcessor) Lookup(ip string) (GeoRecord, error)

func (*GeoIpProcessor) Open

func (p *GeoIpProcessor) Open() (err error)

type GeoRecord

type GeoRecord struct {
	Continent      string
	CountryISOCode string
	City           string
	ASN            string
	ASO            string
}

type IpAnonymizerSubproc

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

func NewIpAnonymizerSubprocessor

func NewIpAnonymizerSubprocessor(config *dnsutils.Config) IpAnonymizerSubproc

func (*IpAnonymizerSubproc) Anonymize

func (s *IpAnonymizerSubproc) Anonymize(ip string) string

func (*IpAnonymizerSubproc) IsEnabled

func (s *IpAnonymizerSubproc) IsEnabled() bool

func (*IpAnonymizerSubproc) ReadConfig

func (s *IpAnonymizerSubproc) ReadConfig()

type MaxminddbRecord

type MaxminddbRecord struct {
	Continent struct {
		Code string `maxminddb:"code"`
	} `maxminddb:"continent"`
	Country struct {
		ISOCode string `maxminddb:"iso_code"`
	} `maxminddb:"country"`
	City struct {
		Names map[string]string `maxminddb:"names"`
	} `maxminddb:"city"`
	AutonomousSystemNumber       int    `maxminddb:"autonomous_system_number"`
	AutonomousSystemOrganization string `maxminddb:"autonomous_system_organization"`
}

type QnameReducer

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

func NewQnameReducerSubprocessor

func NewQnameReducerSubprocessor(config *dnsutils.Config) QnameReducer

func (*QnameReducer) IsEnabled

func (s *QnameReducer) IsEnabled() bool

func (*QnameReducer) Minimaze

func (s *QnameReducer) Minimaze(qname string) string

func (*QnameReducer) ReadConfig

func (s *QnameReducer) ReadConfig()