transformers

Dec 14, 2024

Changes in this version

+ type NewDomainTracker struct

+ func NewNewDomainTracker(ttl time.Duration, maxSize int, whitelist map[string]*regexp.Regexp, ...) (*NewDomainTracker, error)

+ func (ndt *NewDomainTracker) IsNewDomain(domain string) bool

+ func (ndt *NewDomainTracker) SaveCacheToDisk() error

+ type NewDomainTrackerTransform struct

+ func NewNewDomainTrackerTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) *NewDomainTrackerTransform

+ func (t *NewDomainTrackerTransform) GetTransforms() ([]Subtransform, error)

+ func (t *NewDomainTrackerTransform) LoadWhiteDomainsList() error

+ func (t *NewDomainTrackerTransform) ReloadConfig(config *pkgconfig.ConfigTransformers)

+ func (t *NewDomainTrackerTransform) Reset()

Sep 23, 2024

Changes in this version

type NormalizeTransform

+ func (t *NormalizeTransform) ReplaceNonprintable(dm *dnsutils.DNSMessage) (int, error)

+ type RewriteTransform struct

+ func NewRewriteTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) *RewriteTransform

+ func (t *RewriteTransform) GetTransforms() ([]Subtransform, error)

+ func (t *RewriteTransform) UpdateValues(dm *dnsutils.DNSMessage) (int, error)

May 26, 2024

Changes in this version

+ var ReturnKeep = 1

+ func HashIP(ip string, algo string) string

+ type ATagsTransform struct

+ func (t *ATagsTransform) GetTransforms() ([]Subtransform, error)

+ type ExtractTransform struct

+ func (t *ExtractTransform) GetTransforms() ([]Subtransform, error)

+ type FilteringTransform struct

+ func (t *FilteringTransform) GetTransforms() ([]Subtransform, error)

+ func (t *FilteringTransform) LoadDomainsList() error

+ func (t *FilteringTransform) LoadQueryIPList() error

+ func (t *FilteringTransform) LoadRcodes() error

+ func (t *FilteringTransform) LoadrDataIPList() error

+ type GenericTransformer struct

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

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

+ func NewTransformer(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) GenericTransformer

+ func (t *GenericTransformer) ReloadConfig(config *pkgconfig.ConfigTransformers)

+ func (t *GenericTransformer) Reset()

+ type GeoIPTransform struct

+ func (t *GeoIPTransform) Close()

+ func (t *GeoIPTransform) GetTransforms() ([]Subtransform, error)

+ func (t *GeoIPTransform) Lookup(ip string) (GeoRecord, error)

+ func (t *GeoIPTransform) Open() (err error)

+ func (t *GeoIPTransform) Reset()

+ type LatencyTransform struct

+ func (t *LatencyTransform) GetTransforms() ([]Subtransform, error)

+ type MlTransform struct

+ func (t *MlTransform) GetTransforms() ([]Subtransform, error)

+ type NormalizeTransform struct

+ func (t *NormalizeTransform) GetEffectiveTld(dm *dnsutils.DNSMessage) (int, error)

+ func (t *NormalizeTransform) GetEffectiveTldPlusOne(dm *dnsutils.DNSMessage) (int, error)

+ func (t *NormalizeTransform) GetTransforms() ([]Subtransform, error)

+ func (t *NormalizeTransform) QnameLowercase(dm *dnsutils.DNSMessage) (int, error)

+ func (t *NormalizeTransform) QuietText(dm *dnsutils.DNSMessage) (int, error)

+ func (t *NormalizeTransform) RRLowercase(dm *dnsutils.DNSMessage) (int, error)

+ type ReducerTransform struct

+ func (t *ReducerTransform) GetTransforms() ([]Subtransform, error)

+ func (t *ReducerTransform) ReloadConfig(config *pkgconfig.ConfigTransformers)

+ type RelabelTransform struct

+ RelabelingRules []dnsutils.RelabelingRule

+ func (t *RelabelTransform) AddRules(dm *dnsutils.DNSMessage) (int, error)

+ func (t *RelabelTransform) GetTransforms() ([]Subtransform, error)

+ func (t *RelabelTransform) Precompile() string

+ type Subtransform struct

type SuspiciousTransform

+ func (t *SuspiciousTransform) GetTransforms() ([]Subtransform, error)

+ type TransformEntry struct

+ type Transformation interface

+ GetTransforms func() ([]Subtransform, error)

+ ReloadConfig func(config *pkgconfig.ConfigTransformers)

+ Reset func()

+ type UserPrivacyTransform struct

+ func (t *UserPrivacyTransform) GetTransforms() ([]Subtransform, error)

Apr 11, 2024

Changes in this version

type ATagsProcessor

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

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

+ func NewATagsTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) ATagsProcessor

type ExtractProcessor

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

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

+ func NewExtractTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) ExtractProcessor

type FilteringProcessor

+ func NewFilteringTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) FilteringProcessor

type GeoIPProcessor

+ func NewDNSGeoIPTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) GeoIPProcessor

type LatencyProcessor

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

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

+ func NewLatencyTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) *LatencyProcessor

type MlProcessor

+ func NewMachineLearningTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) MlProcessor

type NormalizeProcessor

+ func NewNormalizeTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) NormalizeProcessor

+ func (p *NormalizeProcessor) QnameLowercase(dm *dnsutils.DNSMessage) int

+ func (p *NormalizeProcessor) RRLowercase(dm *dnsutils.DNSMessage) int

type ReducerProcessor

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

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

+ func NewReducerTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) *ReducerProcessor

+ type RelabelProcessor struct

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

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

+ RelabelingRules []dnsutils.RelabelingRule

+ func NewRelabelTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) RelabelProcessor

+ func (p *RelabelProcessor) InitDNSMessage(dm *dnsutils.DNSMessage)

+ func (p *RelabelProcessor) IsEnabled() bool

+ func (p *RelabelProcessor) Precompile()

+ func (p *RelabelProcessor) ReloadConfig(config *pkgconfig.ConfigTransformers)

type SuspiciousTransform

+ func NewSuspiciousTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) SuspiciousTransform

type Transforms

+ RelabelTransform RelabelProcessor

type UserPrivacyProcessor

+ func NewUserPrivacyTransform(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) UserPrivacyProcessor

Jan 20, 2024

Changes in this version

+ type ATagsProcessor struct

+ func NewATagsSubprocessor(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) ATagsProcessor

+ func (p *ATagsProcessor) AddTags(dm *dnsutils.DNSMessage) int

+ func (p *ATagsProcessor) InitDNSMessage(dm *dnsutils.DNSMessage)

+ func (p *ATagsProcessor) IsEnabled() bool

+ func (p *ATagsProcessor) ReloadConfig(config *pkgconfig.ConfigTransformers)

type Transforms

+ ATagsTransform ATagsProcessor

type UserPrivacyProcessor

+ func (s *UserPrivacyProcessor) LogError(msg string, v ...interface{})

+ func (s *UserPrivacyProcessor) LogInfo(msg string, v ...interface{})

+ func (s *UserPrivacyProcessor) ReadConfig()

Dec 16, 2023

Changes in this version

+ var DNSQr = map[string]string

+ var ReturnDrop = 2

+ var ReturnError = 3

+ var ReturnSuccess = 1

type ExtractProcessor

+ func (p *ExtractProcessor) InitDNSMessage(dm *dnsutils.DNSMessage)

type FilteringProcessor

+ func (p *FilteringProcessor) DropQueryIPFilter(dm *dnsutils.DNSMessage) bool

+ func (p *FilteringProcessor) InitDNSMessage(dm *dnsutils.DNSMessage)

+ func (p *FilteringProcessor) LoadQueryIPList()

+ func (p *FilteringProcessor) LoadrDataIPList()

+ type GeoIPProcessor struct

+ func NewDNSGeoIPProcessor(config *pkgconfig.ConfigTransformers, logger *logger.Logger, name string, ...) GeoIPProcessor

+ func (p *GeoIPProcessor) Close()

+ func (p *GeoIPProcessor) InitDNSMessage(dm *dnsutils.DNSMessage)

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

+ func (p *GeoIPProcessor) ReloadConfig(config *pkgconfig.ConfigTransformers)

type HashQueries

+ func (mp *HashQueries) SetTTL(ttl time.Duration)

type MapQueries

+ func (mp *MapQueries) SetTTL(ttl time.Duration)

type MapTraffic

+ func (mp *MapTraffic) SetTTL(ttl time.Duration)

type MlProcessor

+ func (p *MlProcessor) InitDNSMessage(dm *dnsutils.DNSMessage)

type NormalizeProcessor

+ func (p *NormalizeProcessor) InitDNSMessage(dm *dnsutils.DNSMessage)

+ func (p *NormalizeProcessor) ProcessDNSMessage(dm *dnsutils.DNSMessage) int

type ReducerProcessor

+ func (p *ReducerProcessor) InitDNSMessage(dm *dnsutils.DNSMessage)

+ func (p *ReducerProcessor) ProcessDNSMessage(dm *dnsutils.DNSMessage) int

type SuspiciousTransform

+ func (p *SuspiciousTransform) InitDNSMessage(dm *dnsutils.DNSMessage)

type Transforms

+ func (p *Transforms) InitDNSMessageFormat(dm *dnsutils.DNSMessage)

Nov 17, 2023

Changes in this version

type ExtractProcessor

+ func (p *ExtractProcessor) ReloadConfig(config *dnsutils.ConfigTransformers)

type FilteringProcessor

+ func (p *FilteringProcessor) ReloadConfig(config *dnsutils.ConfigTransformers)

type GeoIpProcessor

+ func (p *GeoIpProcessor) ReloadConfig(config *dnsutils.ConfigTransformers)

type HashQueries

+ func (mp *HashQueries) SetTtl(ttl time.Duration)

type LatencyProcessor

+ func (s *LatencyProcessor) ReloadConfig(config *dnsutils.ConfigTransformers)

type MapQueries

+ func (mp *MapQueries) SetTtl(ttl time.Duration)

type MapTraffic

+ func (mp *MapTraffic) SetTtl(ttl time.Duration)

type MlProcessor

+ func (p *MlProcessor) ReloadConfig(config *dnsutils.ConfigTransformers)

type NormalizeProcessor

+ func (p *NormalizeProcessor) ReloadConfig(config *dnsutils.ConfigTransformers)

type ReducerProcessor

+ func (p *ReducerProcessor) ReloadConfig(config *dnsutils.ConfigTransformers)

type SuspiciousTransform

+ func (s *SuspiciousTransform) ReloadConfig(config *dnsutils.ConfigTransformers)

type Transforms

+ func (p *Transforms) ReloadConfig(config *dnsutils.ConfigTransformers)

type UserPrivacyProcessor

+ func (s *UserPrivacyProcessor) ReloadConfig(config *dnsutils.ConfigTransformers)

Sep 25, 2023

Changes in this version

type FilteringProcessor

+ func (p *FilteringProcessor) DropQueryIpFilter(dm *dnsutils.DnsMessage) bool

Aug 31, 2023

Changes in this version

type FilteringProcessor

+ func (p *FilteringProcessor) LoadrDataIpList()

+ type MlProcessor struct

+ func NewMachineLearningSubprocessor(config *dnsutils.ConfigTransformers, logger *logger.Logger, name string, ...) MlProcessor

+ func (p *MlProcessor) AddFeatures(dm *dnsutils.DnsMessage)

+ func (p *MlProcessor) InitDnsMessage(dm *dnsutils.DnsMessage)

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

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

type Transforms

+ MachineLearningTransform MlProcessor

May 23, 2023

Changes in this version

type ReducerProcessor

+ func (p *ReducerProcessor) InitDnsMessage(dm *dnsutils.DnsMessage)

Apr 22, 2023

Changes in this version

+ type ExtractProcessor struct

+ func NewExtractSubprocessor(config *dnsutils.ConfigTransformers) ExtractProcessor

+ func (p *ExtractProcessor) InitDnsMessage(dm *dnsutils.DnsMessage)

+ func (s *ExtractProcessor) AddBase64Payload(dm *dnsutils.DnsMessage) []byte

+ func (s *ExtractProcessor) IsEnabled() bool

+ type MapTraffic struct

+ func NewMapTraffic(ttl time.Duration, channels []chan dnsutils.DnsMessage) MapTraffic

+ func (mp *MapTraffic) Delete(key uint64)

+ func (mp *MapTraffic) Exists(key uint64) (ok bool)

+ func (mp *MapTraffic) ProcessExpiredKeys()

+ func (mp *MapTraffic) Run()

+ func (mp *MapTraffic) Set(key uint64, dm *dnsutils.DnsMessage)

type NormalizeProcessor

+ func (p *NormalizeProcessor) LoadActiveProcessors()

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

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

+ func (p *NormalizeProcessor) LowercaseQname(dm *dnsutils.DnsMessage) int

+ func (p *NormalizeProcessor) ProcessDnsMessage(dm *dnsutils.DnsMessage) int

+ type ReducerProcessor struct

+ func NewReducerSubprocessor(config *dnsutils.ConfigTransformers, logger *logger.Logger, name string, ...) *ReducerProcessor

+ func (p *ReducerProcessor) LoadActiveReducers()

+ func (p *ReducerProcessor) RepetitiveTrafficDetector(dm *dnsutils.DnsMessage) int

+ func (s *ReducerProcessor) ProcessDnsMessage(dm *dnsutils.DnsMessage) int

type Transforms

+ ExtractProcessor ExtractProcessor

+ ReducerTransform *ReducerProcessor

Mar 28, 2023

Changes in this version

+ type HashQueries struct

+ func NewHashQueries(ttl time.Duration) HashQueries

+ func (mp *HashQueries) Delete(key uint64)

+ func (mp *HashQueries) Get(key uint64) (value float64, ok bool)

+ func (mp *HashQueries) Set(key uint64, value float64)

+ type LatencyProcessor struct

+ func NewLatencySubprocessor(config *dnsutils.ConfigTransformers, logger *logger.Logger, name string, ...) *LatencyProcessor

+ func (s *LatencyProcessor) DetectEvictedTimeout(dm *dnsutils.DnsMessage)

+ func (s *LatencyProcessor) MeasureLatency(dm *dnsutils.DnsMessage)

+ type MapQueries struct

+ func NewMapQueries(ttl time.Duration, channels []chan dnsutils.DnsMessage) MapQueries

+ func (mp *MapQueries) Delete(key uint64)

+ func (mp *MapQueries) Exists(key uint64) (ok bool)

+ func (mp *MapQueries) Set(key uint64, dm dnsutils.DnsMessage)

type Transforms

+ LatencyTransform *LatencyProcessor

Feb 26, 2023

Changes in this version

type GeoIpProcessor

+ func (p *GeoIpProcessor) InitDnsMessage(dm *dnsutils.DnsMessage)

type NormalizeProcessor

+ func (p *NormalizeProcessor) InitDnsMessage(dm *dnsutils.DnsMessage)

type SuspiciousTransform

+ func (p *SuspiciousTransform) InitDnsMessage(dm *dnsutils.DnsMessage)

type Transforms

+ func (p *Transforms) InitDnsMessageFormat(dm *dnsutils.DnsMessage)

Dec 18, 2022

Changes in this version

type UserPrivacyProcessor

+ func (s *UserPrivacyProcessor) HashIP(ip string) string

Dec 10, 2022

Changes in this version

+ var DnsQr = map[string]string

+ var DnstapMessage = map[string]string

+ var IPversion = map[string]string

+ var Rcodes = map[string]string

type NormalizeProcessor

+ func (s *NormalizeProcessor) GetEffectiveTld(qname string) (string, error)

+ func (s *NormalizeProcessor) GetEffectiveTldPlusOne(qname string) (string, error)

+ func (s *NormalizeProcessor) QuietText(dm *dnsutils.DnsMessage)

Nov 20, 2022

Changes in this version

+ var RETURN_DROP = 2

+ var RETURN_ERROR = 3

+ var RETURN_SUCCESS = 1

type FilteringProcessor

+ func (p *FilteringProcessor) LoadActiveFilters()

+ type NormalizeProcessor struct

+ func NewNormalizeSubprocessor(config *dnsutils.ConfigTransformers) NormalizeProcessor

+ func (s *NormalizeProcessor) IsEnabled() bool

+ func (s *NormalizeProcessor) Lowercase(qname string) string

+ type PublicSuffixProcessor struct

+ func NewPublicSuffixSubprocessor(config *dnsutils.ConfigTransformers) PublicSuffixProcessor

+ func (s *PublicSuffixProcessor) GetEffectiveTld(qname string) (string, error)

+ func (s *PublicSuffixProcessor) GetEffectiveTldPlusOne(qname string) (string, error)

+ func (s *PublicSuffixProcessor) IsEnabled() bool

+ type SuspiciousTransform struct

+ CommonQtypes map[string]bool

+ func NewSuspiciousSubprocessor(config *dnsutils.ConfigTransformers, logger *logger.Logger, name string) SuspiciousTransform

+ func (p *SuspiciousTransform) CheckIfSuspicious(dm *dnsutils.DnsMessage)

+ func (p *SuspiciousTransform) IsEnabled() bool

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

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

+ func (p *SuspiciousTransform) ReadConfig()

+ type Transforms struct

+ FilteringTransform FilteringProcessor

+ GeoipTransform GeoIpProcessor

+ NormalizeTransform NormalizeProcessor

+ PublicSuffixTransform PublicSuffixProcessor

+ SuspiciousTransform SuspiciousTransform

+ UserPrivacyTransform UserPrivacyProcessor

+ func NewTransforms(config *dnsutils.ConfigTransformers, logger *logger.Logger, name string) Transforms

+ func (p *Transforms) GetEffectiveTld(dm *dnsutils.DnsMessage) int

+ func (p *Transforms) GetEffectiveTldPlusOne(dm *dnsutils.DnsMessage) int

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

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

+ func (p *Transforms) Prepare() error

+ func (p *Transforms) ProcessMessage(dm *dnsutils.DnsMessage) int

+ func (p *Transforms) Reset()

+ type UserPrivacyProcessor struct

+ func NewUserPrivacySubprocessor(config *dnsutils.ConfigTransformers) UserPrivacyProcessor

+ func (s *UserPrivacyProcessor) AnonymizeIP(ip string) string

+ func (s *UserPrivacyProcessor) MinimazeQname(qname string) string

Jul 12, 2022

Changes in this version

+ type FilteringProcessor struct

+ 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 struct

+ 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 struct

+ ASN string

+ ASO string

+ City string

+ Continent string

+ CountryISOCode string

+ type IpAnonymizerSubproc struct

+ func NewIpAnonymizerSubprocessor(config *dnsutils.Config) IpAnonymizerSubproc

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

+ func (s *IpAnonymizerSubproc) IsEnabled() bool

+ func (s *IpAnonymizerSubproc) ReadConfig()

+ type MaxminddbRecord struct

+ AutonomousSystemNumber int

+ AutonomousSystemOrganization string

+ City struct{ ... }

+ Continent struct{ ... }

+ Country struct{ ... }

+ type QnameReducer struct

+ func NewQnameReducerSubprocessor(config *dnsutils.Config) QnameReducer

+ func (s *QnameReducer) IsEnabled() bool

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

+ func (s *QnameReducer) ReadConfig()