loggers

Apr 11, 2024

Changes in this version

+ type ClickhouseClient struct

+ RoutingHandler pkgutils.RoutingHandler

+ func NewClickhouseClient(config *pkgconfig.Config, console *logger.Logger, name string) *ClickhouseClient

+ func (o *ClickhouseClient) AddDefaultRoute(wrk pkgutils.Worker)

+ func (o *ClickhouseClient) AddDroppedRoute(wrk pkgutils.Worker)

+ func (o *ClickhouseClient) Channel() chan dnsutils.DNSMessage

+ func (o *ClickhouseClient) GetInputChannel() chan dnsutils.DNSMessage

+ func (o *ClickhouseClient) GetName() string

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

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

+ func (o *ClickhouseClient) Process()

+ func (o *ClickhouseClient) ReadConfig()

+ func (o *ClickhouseClient) ReloadConfig(config *pkgconfig.Config)

+ func (o *ClickhouseClient) Run()

+ func (o *ClickhouseClient) SetLoggers(loggers []pkgutils.Worker)

+ func (o *ClickhouseClient) Stop()

+ type ClickhouseData struct

+ Family string

+ Identity string

+ Operation string

+ Protocol string

+ QName string

+ QType string

+ QueryIP string

+ RCode string

+ TimeNSec string

+ TimeStamp string

Mar 19, 2024

Changes in this version

+ type DevNull struct

+ RoutingHandler pkgutils.RoutingHandler

+ func NewDevNull(config *pkgconfig.Config, console *logger.Logger, name string) *DevNull

+ func (so *DevNull) AddDefaultRoute(wrk pkgutils.Worker)

+ func (so *DevNull) AddDroppedRoute(wrk pkgutils.Worker)

+ func (so *DevNull) GetInputChannel() chan dnsutils.DNSMessage

+ func (so *DevNull) GetName() string

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

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

+ func (so *DevNull) Process()

+ func (so *DevNull) ReadConfig()

+ func (so *DevNull) ReloadConfig(config *pkgconfig.Config)

+ func (so *DevNull) Run()

+ func (so *DevNull) SetLoggers(loggers []pkgutils.Worker)

+ func (so *DevNull) Stop()

type ElasticSearchClient

+ func (ec *ElasticSearchClient) ProcessDM()

type FluentdClient

+ func (fc *FluentdClient) ProcessDM()

type KafkaProducer

+ func (k *KafkaProducer) ProcessDM()

Jan 24, 2024

Changes in this version

type FakeLogger

+ func NewFakeLoggerWithBufferSize(bufferSize int) *FakeLogger

Jan 20, 2024

Changes in this version

+ func GetStreamGlobal(dm *dnsutils.DNSMessage) string

type DnstapSender

+ RoutingHandler pkgutils.RoutingHandler

+ func (ds *DnstapSender) AddDefaultRoute(wrk pkgutils.Worker)

+ func (ds *DnstapSender) AddDroppedRoute(wrk pkgutils.Worker)

+ func (ds *DnstapSender) GetInputChannel() chan dnsutils.DNSMessage

type ElasticSearchClient

+ RoutingHandler pkgutils.RoutingHandler

+ func (ec *ElasticSearchClient) AddDefaultRoute(wrk pkgutils.Worker)

+ func (ec *ElasticSearchClient) AddDroppedRoute(wrk pkgutils.Worker)

+ func (ec *ElasticSearchClient) GetInputChannel() chan dnsutils.DNSMessage

type FakeLogger

+ func (c *FakeLogger) AddDefaultRoute(wrk pkgutils.Worker)

+ func (c *FakeLogger) AddDroppedRoute(wrk pkgutils.Worker)

+ func (c *FakeLogger) GetInputChannel() chan dnsutils.DNSMessage

type FalcoClient

+ RoutingHandler pkgutils.RoutingHandler

+ func (fc *FalcoClient) AddDefaultRoute(wrk pkgutils.Worker)

+ func (fc *FalcoClient) AddDroppedRoute(wrk pkgutils.Worker)

+ func (fc *FalcoClient) GetInputChannel() chan dnsutils.DNSMessage

type FluentdClient

+ RoutingHandler pkgutils.RoutingHandler

+ func (fc *FluentdClient) AddDefaultRoute(wrk pkgutils.Worker)

+ func (fc *FluentdClient) AddDroppedRoute(wrk pkgutils.Worker)

+ func (fc *FluentdClient) GetInputChannel() chan dnsutils.DNSMessage

type InfluxDBClient

+ RoutingHandler pkgutils.RoutingHandler

+ func (ic *InfluxDBClient) AddDefaultRoute(wrk pkgutils.Worker)

+ func (ic *InfluxDBClient) AddDroppedRoute(wrk pkgutils.Worker)

+ func (ic *InfluxDBClient) GetInputChannel() chan dnsutils.DNSMessage

type KafkaProducer

+ RoutingHandler pkgutils.RoutingHandler

+ func (k *KafkaProducer) AddDefaultRoute(wrk pkgutils.Worker)

+ func (k *KafkaProducer) AddDroppedRoute(wrk pkgutils.Worker)

+ func (k *KafkaProducer) GetInputChannel() chan dnsutils.DNSMessage

type LogFile

+ RoutingHandler pkgutils.RoutingHandler

+ func (lf *LogFile) AddDefaultRoute(wrk pkgutils.Worker)

+ func (lf *LogFile) AddDroppedRoute(wrk pkgutils.Worker)

+ func (lf *LogFile) GetInputChannel() chan dnsutils.DNSMessage

type LokiClient

+ RoutingHandler pkgutils.RoutingHandler

+ func (c *LokiClient) AddDefaultRoute(wrk pkgutils.Worker)

+ func (c *LokiClient) AddDroppedRoute(wrk pkgutils.Worker)

+ func (c *LokiClient) GetInputChannel() chan dnsutils.DNSMessage

type Prometheus

+ RoutingHandler pkgutils.RoutingHandler

+ func (c *Prometheus) AddDefaultRoute(wrk pkgutils.Worker)

+ func (c *Prometheus) AddDroppedRoute(wrk pkgutils.Worker)

+ func (c *Prometheus) GetInputChannel() chan dnsutils.DNSMessage

type RedisPub

+ RoutingHandler pkgutils.RoutingHandler

+ func (c *RedisPub) AddDefaultRoute(wrk pkgutils.Worker)

+ func (c *RedisPub) AddDroppedRoute(wrk pkgutils.Worker)

+ func (c *RedisPub) GetInputChannel() chan dnsutils.DNSMessage

type RestAPI

+ RoutingHandler pkgutils.RoutingHandler

+ func (c *RestAPI) AddDefaultRoute(wrk pkgutils.Worker)

+ func (c *RestAPI) AddDroppedRoute(wrk pkgutils.Worker)

+ func (c *RestAPI) GetInputChannel() chan dnsutils.DNSMessage

type ScalyrClient

+ RoutingHandler pkgutils.RoutingHandler

+ func (c *ScalyrClient) AddDefaultRoute(wrk pkgutils.Worker)

+ func (c *ScalyrClient) AddDroppedRoute(wrk pkgutils.Worker)

+ func (c *ScalyrClient) GetInputChannel() chan dnsutils.DNSMessage

type StatsdClient

+ RoutingHandler pkgutils.RoutingHandler

+ func (c *StatsdClient) AddDefaultRoute(wrk pkgutils.Worker)

+ func (c *StatsdClient) AddDroppedRoute(wrk pkgutils.Worker)

+ func (c *StatsdClient) GetInputChannel() chan dnsutils.DNSMessage

type StdOut

+ RoutingHandler pkgutils.RoutingHandler

+ func (so *StdOut) AddDefaultRoute(wrk pkgutils.Worker)

+ func (so *StdOut) AddDroppedRoute(wrk pkgutils.Worker)

+ func (so *StdOut) GetInputChannel() chan dnsutils.DNSMessage

type Syslog

+ RoutingHandler pkgutils.RoutingHandler

+ func (s *Syslog) AddDefaultRoute(wrk pkgutils.Worker)

+ func (s *Syslog) AddDroppedRoute(wrk pkgutils.Worker)

+ func (s *Syslog) GetInputChannel() chan dnsutils.DNSMessage

type TCPClient

+ RoutingHandler pkgutils.RoutingHandler

+ func (c *TCPClient) AddDefaultRoute(wrk pkgutils.Worker)

+ func (c *TCPClient) AddDroppedRoute(wrk pkgutils.Worker)

+ func (c *TCPClient) GetInputChannel() chan dnsutils.DNSMessage

Dec 16, 2023

Changes in this version

type EpsCounters

+ TotalDNSMessages float64

type RestAPI

+ func (c *RestAPI) RecordDNSMessage(dm dnsutils.DNSMessage)

type StatsdClient

+ func (c *StatsdClient) RecordDNSMessage(dm dnsutils.DNSMessage)

type Syslog

+ func (s *Syslog) FlushBuffer(buf *[]dnsutils.DNSMessage)

+ type TCPClient struct

+ func NewTCPClient(config *pkgconfig.Config, logger *logger.Logger, name string) *TCPClient

+ func (c *TCPClient) Channel() chan dnsutils.DNSMessage

+ func (c *TCPClient) ConnectToRemote()

+ func (c *TCPClient) Disconnect()

+ func (c *TCPClient) FlushBuffer(buf *[]dnsutils.DNSMessage)

+ func (c *TCPClient) GetName() string

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

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

+ func (c *TCPClient) Process()

+ func (c *TCPClient) ReadConfig()

+ func (c *TCPClient) ReadFromConnection()

+ func (c *TCPClient) ReloadConfig(config *pkgconfig.Config)

+ func (c *TCPClient) Run()

+ func (c *TCPClient) SetLoggers(loggers []dnsutils.Worker)

+ func (c *TCPClient) Stop()

Nov 17, 2023

Changes in this version

type DnstapSender

+ func (o *DnstapSender) ReloadConfig(config *dnsutils.Config)

type ElasticSearchClient

+ func (o *ElasticSearchClient) ReloadConfig(config *dnsutils.Config)

type FakeLogger

+ func (o *FakeLogger) ReloadConfig(config *dnsutils.Config)

type FalcoClient

+ func (c *FalcoClient) ReloadConfig(config *dnsutils.Config)

type FluentdClient

+ func (o *FluentdClient) ReadFromConnection()

+ func (o *FluentdClient) ReloadConfig(config *dnsutils.Config)

type InfluxDBClient

+ func (o *InfluxDBClient) ReloadConfig(config *dnsutils.Config)

type KafkaProducer

+ func (o *KafkaProducer) ReloadConfig(config *dnsutils.Config)

type LogFile

+ func (o *LogFile) ReloadConfig(config *dnsutils.Config)

type LokiClient

+ func (o *LokiClient) ReloadConfig(config *dnsutils.Config)

type Prometheus

+ func (o *Prometheus) ReloadConfig(config *dnsutils.Config)

type RedisPub

+ func (o *RedisPub) ReloadConfig(config *dnsutils.Config)

type RestAPI

+ func (o *RestAPI) ReloadConfig(config *dnsutils.Config)

type ScalyrClient

+ func (o *ScalyrClient) ReloadConfig(config *dnsutils.Config)

type StatsdClient

+ func (o *StatsdClient) ReloadConfig(config *dnsutils.Config)

type StdOut

+ func (o *StdOut) ReloadConfig(config *dnsutils.Config)

+ func (o *StdOut) SetPcapWriter(w io.Writer)

+ func (o *StdOut) SetTextWriter(b *bytes.Buffer)

type Syslog

+ func (o *Syslog) ReloadConfig(config *dnsutils.Config)

type TcpClient

+ func (o *TcpClient) ReadFromConnection()

+ func (o *TcpClient) ReloadConfig(config *dnsutils.Config)

Oct 18, 2023

Changes in this version

type RedisPub

+ func (o *RedisPub) ReadFromConnection()

type Syslog

+ func (o *Syslog) ConnectToRemote()

Aug 31, 2023

Changes in this version

+ func GetResolverIP(dm *dnsutils.DnsMessage) string

+ func GetStreamID(dm *dnsutils.DnsMessage) string

type ElasticSearchClient

+ func (o *ElasticSearchClient) FlushBuffer(buf *[]dnsutils.DnsMessage)

+ type PromCounterCatalogueContainer struct

+ func CreateSystemCatalogue(prom *Prometheus) ([]string, *PromCounterCatalogueContainer)

+ func NewPromCounterCatalogueContainer(p *Prometheus, sel_labels []string, l map[string]string) *PromCounterCatalogueContainer

+ func (c *PromCounterCatalogueContainer) GetAllCounterSets() []*PrometheusCountersSet

+ func (c *PromCounterCatalogueContainer) GetCountersSet(dm *dnsutils.DnsMessage) PrometheusCountersCatalogue

+ type PrometheusCountersCatalogue interface

+ GetCountersSet func(*dnsutils.DnsMessage) PrometheusCountersCatalogue

+ type PrometheusCountersSet struct

+ func (c *PrometheusCountersSet) Describe(ch chan<- *prometheus.Desc)

+ func (c *PrometheusCountersSet) GetCountersSet(dm *dnsutils.DnsMessage) PrometheusCountersCatalogue

+ func (c *PrometheusCountersSet) Record(dm dnsutils.DnsMessage)

+ func (o *PrometheusCountersSet) Collect(ch chan<- prometheus.Metric)

+ func (o *PrometheusCountersSet) ComputeEventsPerSecond()

Jul 28, 2023

Changes in this version

type Prometheus

+ func (o *Prometheus) Collect(ch chan<- prometheus.Metric)

+ func (o *Prometheus) ComputeEventsPerSecond()

+ func (o *Prometheus) Describe(ch chan<- *prometheus.Desc)

Jun 15, 2023

Changes in this version

+ func IsStdoutValidMode(mode string) bool

type DnstapSender

+ func (o *DnstapSender) Process()

type ElasticSearchClient

+ func (o *ElasticSearchClient) Process()

type EpsCounters

+ TotalAA float64

+ TotalAD float64

+ TotalBytes int

+ TotalBytesReceived int

+ TotalBytesSent int

+ TotalDnsMessages float64

+ TotalFragmented float64

+ TotalIPProtocol map[string]float64

+ TotalIPVersion map[string]float64

+ TotalMalformed float64

+ TotalQtypes map[string]float64

+ TotalQueries int

+ TotalRA float64

+ TotalRcodes map[string]float64

+ TotalReasembled float64

+ TotalReplies int

+ TotalTC float64

type FalcoClient

+ func (f *FalcoClient) Process()

type FluentdClient

+ func (o *FluentdClient) Process()

type InfluxDBClient

+ func (o *InfluxDBClient) Process()

type KafkaProducer

+ func (o *KafkaProducer) Process()

type LogFile

+ func (l *LogFile) Process()

type LokiClient

+ func (o *LokiClient) Process()

type Prometheus

+ func (o *Prometheus) ComputeMetrics()

+ func (s *Prometheus) Process()

type RedisPub

+ func (o *RedisPub) Process()

type RestAPI

+ func (s *RestAPI) Process()

type ScalyrClient

+ func (c *ScalyrClient) Process()

type StatsdClient

+ func (o *StatsdClient) Process()

type StdOut

+ func (o *StdOut) Process()

type Syslog

+ func (o *Syslog) Process()

type TcpClient

+ func (o *TcpClient) Process()

May 23, 2023

Changes in this version

+ type FalcoClient struct

+ func NewFalcoClient(config *dnsutils.Config, console *logger.Logger, name string) *FalcoClient

+ func (c *FalcoClient) GetName() string

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

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

+ func (c *FalcoClient) ReadConfig()

+ func (c *FalcoClient) SetLoggers(loggers []dnsutils.Worker)

+ func (f *FalcoClient) Channel() chan dnsutils.DnsMessage

+ func (f *FalcoClient) Run()

+ func (f *FalcoClient) Stop()

+ type KafkaProducer struct

+ func NewKafkaProducer(config *dnsutils.Config, logger *logger.Logger, name string) *KafkaProducer

+ func (c *KafkaProducer) GetName() string

+ func (c *KafkaProducer) SetLoggers(loggers []dnsutils.Worker)

+ func (o *KafkaProducer) Channel() chan dnsutils.DnsMessage

+ func (o *KafkaProducer) ConnectToKafka(ctx context.Context, readyTimer *time.Timer)

+ func (o *KafkaProducer) Disconnect()

+ func (o *KafkaProducer) FlushBuffer(buf *[]dnsutils.DnsMessage)

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

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

+ func (o *KafkaProducer) ReadConfig()

+ func (o *KafkaProducer) Run()

+ func (o *KafkaProducer) Stop()

+ type KeyHit struct

+ Hit int

+ Key string

type RestAPI

+ func (s *RestAPI) DeleteResetHandler(w http.ResponseWriter, r *http.Request)

Apr 22, 2023

Changes in this version

+ const SeverityError

+ const SeverityFatal

+ const SeverityFine

+ const SeverityFiner

+ const SeverityFinest

+ const SeverityInfo

+ const SeverityWarning

type DnstapSender

+ func (o *DnstapSender) ConnectToRemote()

+ func (o *DnstapSender) Disconnect()

+ func (o *DnstapSender) FlushBuffer(buf *[]dnsutils.DnsMessage)

type FluentdClient

+ func (o *FluentdClient) ConnectToRemote()

+ func (o *FluentdClient) Disconnect()

+ func (o *FluentdClient) FlushBuffer(buf *[]dnsutils.DnsMessage)

+ type RedisPub struct

+ func NewRedisPub(config *dnsutils.Config, logger *logger.Logger, name string) *RedisPub

+ func (c *RedisPub) GetName() string

+ func (c *RedisPub) SetLoggers(loggers []dnsutils.Worker)

+ func (o *RedisPub) Channel() chan dnsutils.DnsMessage

+ func (o *RedisPub) ConnectToRemote()

+ func (o *RedisPub) Disconnect()

+ func (o *RedisPub) FlushBuffer(buf *[]dnsutils.DnsMessage)

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

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

+ func (o *RedisPub) ReadConfig()

+ func (o *RedisPub) Run()

+ func (o *RedisPub) Stop()

+ type ScalyrClient struct

+ func NewScalyrClient(config *dnsutils.Config, console *logger.Logger, name string) *ScalyrClient

+ func (c *ScalyrClient) Channel() chan dnsutils.DnsMessage

+ func (c *ScalyrClient) GetName() string

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

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

+ func (c *ScalyrClient) ReadConfig()

+ func (c *ScalyrClient) Run()

+ func (c *ScalyrClient) SetLoggers(loggers []dnsutils.Worker)

+ func (c ScalyrClient) Stop()

type TcpClient

+ func (o *TcpClient) ConnectToRemote()

+ func (o *TcpClient) Disconnect()

+ func (o *TcpClient) FlushBuffer(buf *[]dnsutils.DnsMessage)

Feb 8, 2023

Changes in this version

type RestAPI

+ Streams map[string]int

+ func (s *RestAPI) GetSearchHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetStreamsHandler(w http.ResponseWriter, r *http.Request)

Dec 10, 2022

Changes in this version

+ func IsValidMode(mode string) bool

type LogFile

+ func (l *LogFile) CompressFile()

+ func (l *LogFile) FlushWriters()

+ func (l *LogFile) RotateFile() error

+ func (l *LogFile) WriteToDnstap(data []byte)

+ func (l *LogFile) WriteToPcap(dm dnsutils.DnsMessage, pkt []gopacket.SerializableLayer)

+ func (l *LogFile) WriteToPlain(data []byte)

+ func (o *LogFile) GetMaxSize() int64

Nov 20, 2022

Changes in this version

+ type HitsRecord struct

+ Hits map[string]int

+ TotalHits int

+ type HitsStream struct

+ Streams map[string]SearchBy

+ type HitsUniq struct

+ Clients map[string]int

+ Domains map[string]int

+ NxDomains map[string]int

+ PublicSuffixes map[string]int

+ SfDomains map[string]int

+ Suspicious map[string]dnsutils.Suspicious

+ type RestAPI struct

+ HitsStream HitsStream

+ HitsUniq HitsUniq

+ TopClients *topmap.TopMap

+ TopNonExistent *topmap.TopMap

+ TopQnames *topmap.TopMap

+ TopServFail *topmap.TopMap

+ TopTLDs *topmap.TopMap

+ func NewRestAPI(config *dnsutils.Config, logger *logger.Logger, version string, name string) *RestAPI

+ func (c *RestAPI) GetName() string

+ func (c *RestAPI) SetLoggers(loggers []dnsutils.Worker)

+ func (o *RestAPI) BasicAuth(w http.ResponseWriter, r *http.Request) bool

+ func (o *RestAPI) Channel() chan dnsutils.DnsMessage

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

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

+ func (o *RestAPI) ReadConfig()

+ func (o *RestAPI) Stop()

+ func (s *RestAPI) GetClientsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetDomainsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetNxDomainsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetSfDomainsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetSuspiciousHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetTLDsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetTopClientsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetTopDomainsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetTopNxDomainsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetTopSfDomainsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) GetTopTLDsHandler(w http.ResponseWriter, r *http.Request)

+ func (s *RestAPI) ListenAndServe()

+ func (s *RestAPI) RecordDnsMessage(dm dnsutils.DnsMessage)

+ func (s *RestAPI) Run()

+ func (s *RestAPI) SearchHandler(w http.ResponseWriter, r *http.Request)

+ type SearchBy struct

+ Clients map[string]*HitsRecord

+ Domains map[string]*HitsRecord

type StatsPerStream

+ Clients map[string]int

+ Domains map[string]int

+ IPproto map[string]int

+ Nxdomains map[string]int

+ Operations map[string]int

+ RRtypes map[string]int

+ Rcodes map[string]int

+ TopIPproto *topmap.TopMap

+ TopOperations *topmap.TopMap

+ TopRRtypes *topmap.TopMap

+ TopRcodes *topmap.TopMap

+ TopTransport *topmap.TopMap

+ TotalPackets int

+ TotalReceivedBytes int

+ TotalSentBytes int

+ Transports map[string]int

type StatsdClient

+ Stats StreamStats

+ func (o *StatsdClient) RecordDnsMessage(dm dnsutils.DnsMessage)

+ type StreamStats struct

+ Streams map[string]*StatsPerStream

Sep 19, 2022

Changes in this version

+ type ElasticSearchClient struct

+ func NewElasticSearchClient(config *dnsutils.Config, console *logger.Logger, name string) *ElasticSearchClient

+ func (c *ElasticSearchClient) GetName() string

+ func (c *ElasticSearchClient) ReadConfig()

+ func (c *ElasticSearchClient) SetLoggers(loggers []dnsutils.Worker)

+ func (o *ElasticSearchClient) Channel() chan dnsutils.DnsMessage

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

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

+ func (o *ElasticSearchClient) Run()

+ func (o *ElasticSearchClient) Stop()

+ type ElasticSearchData struct

+ Family string

+ Identity string

+ Operation string

+ Protocol string

+ QName string

+ QType string

+ QueryIP string

+ RCode string

+ TimeStamp int64

Aug 1, 2022

Changes in this version

+ func SanitizeMetricName(metricName string) string

type DnstapSender

+ func (c *DnstapSender) GetName() string

+ func (c *DnstapSender) SetLoggers(loggers []dnsutils.Worker)

+ type EpsCounters struct

+ Eps uint64

+ EpsMax uint64

+ TotalEvents uint64

+ TotalEventsPrev uint64

type FakeLogger

+ func (c *FakeLogger) GetName() string

+ func (c *FakeLogger) SetLoggers(loggers []dnsutils.Worker)

type FluentdClient

+ func (c *FluentdClient) GetName() string

+ func (c *FluentdClient) SetLoggers(loggers []dnsutils.Worker)

type InfluxDBClient

+ func (c *InfluxDBClient) GetName() string

+ func (c *InfluxDBClient) SetLoggers(loggers []dnsutils.Worker)

type LogFile

+ func (c *LogFile) GetName() string

+ func (c *LogFile) SetLoggers(loggers []dnsutils.Worker)

type LokiClient

+ func (c *LokiClient) GetName() string

+ func (c *LokiClient) SetLoggers(loggers []dnsutils.Worker)

type PcapWriter

+ func (c *PcapWriter) GetName() string

+ func (c *PcapWriter) SetLoggers(loggers []dnsutils.Worker)

type Prometheus

+ func (c *Prometheus) GetName() string

+ func (c *Prometheus) SetLoggers(loggers []dnsutils.Worker)

+ func (o *Prometheus) ComputeEps()

type StatsdClient

+ func (c *StatsdClient) GetName() string

+ func (c *StatsdClient) SetLoggers(loggers []dnsutils.Worker)

type StdOut

+ func (c *StdOut) GetName() string

+ func (c *StdOut) SetLoggers(loggers []dnsutils.Worker)

type Syslog

+ func (c *Syslog) GetName() string

+ func (c *Syslog) SetLoggers(loggers []dnsutils.Worker)

type TcpClient

+ func (c *TcpClient) GetName() string

+ func (c *TcpClient) SetLoggers(loggers []dnsutils.Worker)

type Webserver

+ func (c *Webserver) GetName() string

+ func (c *Webserver) SetLoggers(loggers []dnsutils.Worker)

Jul 12, 2022

Changes in this version

+ type Counters struct

+ AuthenticData int

+ AuthoritativeAnswer int

+ Latency0_1 uint64

+ Latency1000_inf uint64

+ Latency100_500 uint64

+ Latency10_50 uint64

+ Latency1_10 uint64

+ Latency500_1000 uint64

+ Latency50_100 uint64

+ LatencyMax float64

+ LatencyMin float64

+ Packets uint64

+ PacketsMalformed uint64

+ PacketsPrev uint64

+ Pps uint64

+ PpsMax uint64

+ QnameLength0_10 int

+ QnameLength100_Inf int

+ QnameLength10_20 int

+ QnameLength20_40 int

+ QnameLength40_60 int

+ QnameLength60_100 int

+ QnameLengthMax int

+ QnameLengthMin int

+ Qps uint64

+ QpsMax uint64

+ Queries uint64

+ QueriesPrev uint64

+ QueryLength0_50 int

+ QueryLength100_250 int

+ QueryLength250_500 int

+ QueryLength500_Inf int

+ QueryLength50_100 int

+ QueryLengthMax int

+ QueryLengthMin int

+ ReceivedBytesTotal int

+ RecursionAvailable int

+ ReplyLength0_50 int

+ ReplyLength100_250 int

+ ReplyLength250_500 int

+ ReplyLength500_Inf int

+ ReplyLength50_100 int

+ ReplyLengthMax int

+ ReplyLengthMin int

+ SentBytesTotal int

+ Truncated int

+ type StatsPerStream struct

+ CommonQtypes []string

+ ListTopAS *topmap.TopMap

+ MapAS map[string]string

+ MapHitAS map[string]int

+ ThresholdPacketLen int

+ ThresholdQnameLen int

+ ThresholdSlow float64

+ TopMaxItems int

+ func NewStatsPerStream(config *dnsutils.Config, name string, topmaxitems int, maxqnamelen int, ...) *StatsPerStream

+ func (c *StatsPerStream) Compute()

+ func (c *StatsPerStream) GetAS() (ret map[string]string)

+ func (c *StatsPerStream) GetClients() (ret map[string]int)

+ func (c *StatsPerStream) GetCounters() (ret Counters)

+ func (c *StatsPerStream) GetDomains() (ret map[string]int)

+ func (c *StatsPerStream) GetHitAS() (ret map[string]int)

+ func (c *StatsPerStream) GetTopAS() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopClients() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopEffectiveTLDPlusOne() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopFirstLevelDomains() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopIpProto() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopNxdomains() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopOperations() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopPublicSuffix() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopQnames() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopRcodes() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopRrtypes() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopSlowdomains() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopSuspiciousClients() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopSuspiciousdomains() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTopTransports() (ret []topmap.TopMapItem)

+ func (c *StatsPerStream) GetTotalAS() (ret int)

+ func (c *StatsPerStream) GetTotalClients() (ret int)

+ func (c *StatsPerStream) GetTotalDomains() (ret int)

+ func (c *StatsPerStream) GetTotalEffectiveTLDPlusOne() (ret int)

+ func (c *StatsPerStream) GetTotalFirstLevelDomains() (ret int)

+ func (c *StatsPerStream) GetTotalNxdomains() (ret int)

+ func (c *StatsPerStream) GetTotalPublicSuffix() (ret int)

+ func (c *StatsPerStream) GetTotalSlowdomains() (ret int)

+ func (c *StatsPerStream) GetTotalSuspiciousClients() (ret int)

+ func (c *StatsPerStream) GetTotalSuspiciousdomains() (ret int)

+ func (c *StatsPerStream) ReadConfig()

+ func (c *StatsPerStream) Record(dm dnsutils.DnsMessage)

+ func (c *StatsPerStream) Reset()

+ type StatsStreams struct

+ func NewStreamsStats(config *dnsutils.Config, version string, prom string, topmaxitems int, ...) *StatsStreams

+ func (c *StatsStreams) Compute()

+ func (c *StatsStreams) GetAS(identity string) (ret map[string]string)

+ func (c *StatsStreams) GetClients(identity string) (ret map[string]int)

+ func (c *StatsStreams) GetCounters(identity string) (ret Counters)

+ func (c *StatsStreams) GetDomains(identity string) (ret map[string]int)

+ func (c *StatsStreams) GetHitAS(identity string) (ret map[string]int)

+ func (c *StatsStreams) GetTopAS(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopClients(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopEffectiveTLDPlusOne(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopFirstLevelDomains(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopIpProto(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopNxdomains(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopOperations(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopPublicSuffix(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopQnames(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopRcodes(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopRrtypes(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopSlowdomains(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopSuspiciousClients(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopSuspiciousdomains(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTopTransports(identity string) (ret []topmap.TopMapItem)

+ func (c *StatsStreams) GetTotalAS(identity string) (ret int)

+ func (c *StatsStreams) GetTotalClients(identity string) (ret int)

+ func (c *StatsStreams) GetTotalDomains(identity string) (ret int)

+ func (c *StatsStreams) GetTotalEffectiveTLDPlusOne(identity string) (ret int)

+ func (c *StatsStreams) GetTotalFirstLevelDomains(identity string) (ret int)

+ func (c *StatsStreams) GetTotalNxdomains(identity string) (ret int)

+ func (c *StatsStreams) GetTotalPublicSuffix(identity string) (ret int)

+ func (c *StatsStreams) GetTotalSlowdomains(identity string) (ret int)

+ func (c *StatsStreams) GetTotalSuspiciousClients(identity string) (ret int)

+ func (c *StatsStreams) GetTotalSuspiciousdomains(identity string) (ret int)

+ func (c *StatsStreams) Record(dm dnsutils.DnsMessage)

+ func (c *StatsStreams) Reset(identity string)

+ func (c *StatsStreams) Streams() []string

+ func (s *StatsStreams) GetMetrics(w http.ResponseWriter, r *http.Request)

Mar 17, 2022

Changes in this version

type LogFile

+ func (o *LogFile) CompressPostRotateCommand(filename string)

type LokiClient

+ func (o *LokiClient) SendEntriesOld(buf []byte) error

+ type LokiStream struct

+ func (o *LokiStream) Encode2Proto() ([]byte, error)

+ func (o *LokiStream) Init()

+ func (o *LokiStream) ResetEntries()

Feb 25, 2022

Changes in this version

type FakeLogger

+ func (o *FakeLogger) ReadConfig()

type Prometheus

+ func (o *Prometheus) ReadConfig()

Jan 21, 2022

Changes in this version

+ type Prometheus struct

+ func NewPrometheus(config *dnsutils.Config, logger *logger.Logger, version string) *Prometheus

+ func (o *Prometheus) BasicAuth(w http.ResponseWriter, r *http.Request) bool

+ func (o *Prometheus) Channel() chan dnsutils.DnsMessage

+ func (o *Prometheus) InitProm()

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

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

+ func (o *Prometheus) Record(dm dnsutils.DnsMessage)

+ func (o *Prometheus) Stop()

+ func (s *Prometheus) ListenAndServe()

+ func (s *Prometheus) Run()

+ type TopMaps struct

Dec 28, 2021

Changes in this version

+ type StatsdClient struct

+ func NewStatsdClient(config *dnsutils.Config, logger *logger.Logger, version string) *StatsdClient

+ func (o *StatsdClient) Channel() chan dnsutils.DnsMessage

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

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

+ func (o *StatsdClient) ReadConfig()

+ func (o *StatsdClient) Run()

+ func (o *StatsdClient) Stop()

Dec 16, 2021

Changes in this version

+ type InfluxDBClient struct

+ func NewInfluxDBClient(config *dnsutils.Config, logger *logger.Logger) *InfluxDBClient

+ func (o *InfluxDBClient) Channel() chan dnsutils.DnsMessage

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

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

+ func (o *InfluxDBClient) ReadConfig()

+ func (o *InfluxDBClient) Run()

+ func (o *InfluxDBClient) Stop()

+ type LokiClient struct

+ func NewLokiClient(config *dnsutils.Config, logger *logger.Logger) *LokiClient

+ func (o *LokiClient) Channel() chan dnsutils.DnsMessage

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

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

+ func (o *LokiClient) ProtoEncode() ([]byte, error)

+ func (o *LokiClient) ReadConfig()

+ func (o *LokiClient) ResetEntries()

+ func (o *LokiClient) Run()

+ func (o *LokiClient) SendEntries(buf []byte) error

+ func (o *LokiClient) Stop()

Aug 29, 2021

Changes in this version

type LogFile

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

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

+ func (o *LogFile) Cleanup() error

+ func (o *LogFile) Compress()

+ func (o *LogFile) PostRotateCommand(filename string)

type PcapWriter

+ func (o *PcapWriter) Cleanup() error

+ func (o *PcapWriter) Compress()

+ func (o *PcapWriter) PostRotateCommand(filename string)

Aug 22, 2021

Changes in this version

+ func GetPriority(facility string) (syslog.Priority, error)

+ type DnstapSender struct

+ func NewDnstapSender(config *dnsutils.Config, logger *logger.Logger) *DnstapSender

+ func (o *DnstapSender) Channel() chan dnsutils.DnsMessage

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

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

+ func (o *DnstapSender) ReadConfig()

+ func (o *DnstapSender) Run()

+ func (o *DnstapSender) Stop()

+ type FakeLogger struct

+ func NewFakeLogger() *FakeLogger

+ func (o *FakeLogger) Channel() chan dnsutils.DnsMessage

+ func (o *FakeLogger) Run()

+ func (o *FakeLogger) Stop()

+ type FluentdClient struct

+ func NewFluentdClient(config *dnsutils.Config, logger *logger.Logger) *FluentdClient

+ func (o *FluentdClient) Channel() chan dnsutils.DnsMessage

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

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

+ func (o *FluentdClient) ReadConfig()

+ func (o *FluentdClient) Run()

+ func (o *FluentdClient) Stop()

+ type LogFile struct

+ func NewLogFile(config *dnsutils.Config, logger *logger.Logger) *LogFile

+ func (c *LogFile) ReadConfig()

+ func (o *LogFile) Channel() chan dnsutils.DnsMessage

+ func (o *LogFile) Flush()

+ func (o *LogFile) MaxSize() int64

+ func (o *LogFile) OpenFile(fpath string) error

+ func (o *LogFile) Rotate() error

+ func (o *LogFile) Run()

+ func (o *LogFile) Stop()

+ func (o *LogFile) Write(d []byte)

+ type PcapWriter struct

+ func NewPcapFile(config *dnsutils.Config, console *logger.Logger) *PcapWriter

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

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

+ func (c *PcapWriter) ReadConfig()

+ func (o *PcapWriter) Channel() chan dnsutils.DnsMessage

+ func (o *PcapWriter) GetIpPort(dm *dnsutils.DnsMessage) (string, int, string, int)

+ func (o *PcapWriter) MaxSize() int64

+ func (o *PcapWriter) OpenFile() error

+ func (o *PcapWriter) Rotate() error

+ func (o *PcapWriter) Run()

+ func (o *PcapWriter) SetBuffer(b *bytes.Buffer)

+ func (o *PcapWriter) Stop()

+ func (o *PcapWriter) Write(dm dnsutils.DnsMessage, pkt []gopacket.SerializableLayer)

+ type StdOut struct

+ func NewStdOut(config *dnsutils.Config, console *logger.Logger) *StdOut

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

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

+ func (c *StdOut) ReadConfig()

+ func (o *StdOut) Channel() chan dnsutils.DnsMessage

+ func (o *StdOut) Print(dm dnsutils.DnsMessage)

+ func (o *StdOut) Run()

+ func (o *StdOut) SetBuffer(b *bytes.Buffer)

+ func (o *StdOut) Stop()

+ type Syslog struct

+ func NewSyslog(config *dnsutils.Config, console *logger.Logger) *Syslog

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

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

+ func (c *Syslog) ReadConfig()

+ func (o *Syslog) Channel() chan dnsutils.DnsMessage

+ func (o *Syslog) Run()

+ func (o *Syslog) Stop()

+ type TcpClient struct

+ func NewTcpClient(config *dnsutils.Config, logger *logger.Logger) *TcpClient

+ func (o *TcpClient) Channel() chan dnsutils.DnsMessage

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

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

+ func (o *TcpClient) ReadConfig()

+ func (o *TcpClient) Run()

+ func (o *TcpClient) Stop()

+ type Webserver struct

+ func NewWebserver(config *dnsutils.Config, logger *logger.Logger) *Webserver

+ func (c *Webserver) ReadConfig()

+ func (o *Webserver) BasicAuth(w http.ResponseWriter, r *http.Request) bool

+ func (o *Webserver) Channel() chan dnsutils.DnsMessage

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

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

+ func (o *Webserver) Stop()

+ func (s *Webserver) ListenAndServe()

+ func (s *Webserver) Run()