workers

package

Go to main page

Versions in this module

v0

v0.46.0

Jun 14, 2024

Changes in this version

type GenericWorker

+ func (w *GenericWorker) CountEgressTraffic()

+ func (w *GenericWorker) CountIngressTraffic()

+ func (w *GenericWorker) SendDroppedTo(routes []chan dnsutils.DNSMessage, routesName []string, dm dnsutils.DNSMessage)

+ func (w *GenericWorker) SendForwardedTo(routes []chan dnsutils.DNSMessage, routesName []string, dm dnsutils.DNSMessage)

+ func (w *GenericWorker) SetMetrics(metrics *telemetry.PrometheusCollector)

type Worker

+ CountEgressTraffic func()

+ CountIngressTraffic func()

+ SetMetrics func(metrics *telemetry.PrometheusCollector)

v0.45.0

May 26, 2024

Changes in this version

+ func GetName(name string) string

+ func GetRoutes(routes []Worker) ([]chan dnsutils.DNSMessage, []string)

type DNSProcessor

+ func (w *DNSProcessor) StartCollect()

type DNSTapProcessor

+ func (w *DNSTapProcessor) GetDataChannel() chan []byte

+ func (w *DNSTapProcessor) StartCollect()

+ type GenericWorker struct

+ func GetWorkerForTest(bufferSize int) *GenericWorker

+ func NewGenericWorker(config *pkgconfig.Config, logger *logger.Logger, name string, descr string, ...) *GenericWorker

+ func (w *GenericWorker) AddDefaultRoute(wrk Worker)

+ func (w *GenericWorker) AddDroppedRoute(wrk Worker)

+ func (w *GenericWorker) CollectDone()

+ func (w *GenericWorker) GetConfig() *pkgconfig.Config

+ func (w *GenericWorker) GetDefaultRoutes() []Worker

+ func (w *GenericWorker) GetDroppedRoutes() []Worker

+ func (w *GenericWorker) GetInputChannel() chan dnsutils.DNSMessage

+ func (w *GenericWorker) GetInputChannelAsList() []chan dnsutils.DNSMessage

+ func (w *GenericWorker) GetLogger() *logger.Logger

+ func (w *GenericWorker) GetName() string

+ func (w *GenericWorker) GetOutputChannel() chan dnsutils.DNSMessage

+ func (w *GenericWorker) GetOutputChannelAsList() []chan dnsutils.DNSMessage

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

+ func (w *GenericWorker) LogFatal(v ...interface{})

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

+ func (w *GenericWorker) Loggers() ([]chan dnsutils.DNSMessage, []string)

+ func (w *GenericWorker) LoggingDone()

+ func (w *GenericWorker) Monitor()

+ func (w *GenericWorker) NewConfig() chan *pkgconfig.Config

+ func (w *GenericWorker) OnLoggerStopped() chan bool

+ func (w *GenericWorker) OnStop() chan bool

+ func (w *GenericWorker) ReadConfig()

+ func (w *GenericWorker) ReloadConfig(config *pkgconfig.Config)

+ func (w *GenericWorker) SendTo(routes []chan dnsutils.DNSMessage, routesName []string, dm dnsutils.DNSMessage)

+ func (w *GenericWorker) SetConfig(config *pkgconfig.Config)

+ func (w *GenericWorker) SetDefaultDropped(workers []Worker)

+ func (w *GenericWorker) SetDefaultRoutes(workers []Worker)

+ func (w *GenericWorker) SetLoggers(loggers []Worker)

+ func (w *GenericWorker) StartCollect()

+ func (w *GenericWorker) StartLogging()

+ func (w *GenericWorker) Stop()

+ func (w *GenericWorker) StopLogger()

+ func (w *GenericWorker) WorkerIsBusy(name string)

type PdnsProcessor

+ func (w *PdnsProcessor) GetDataChannel() chan []byte

+ func (w *PdnsProcessor) StartCollect()

+ type Worker interface

+ AddDefaultRoute func(wrk Worker)

+ AddDroppedRoute func(wrk Worker)

+ GetInputChannel func() chan dnsutils.DNSMessage

+ GetName func() string

+ ReadConfig func()

+ ReloadConfig func(config *pkgconfig.Config)

+ SetLoggers func(loggers []Worker)

+ StartCollect func()

+ Stop func()

v0.45.0-beta3

May 19, 2024

v0.45.0-beta2

May 17, 2024

v0.45.0-beta1

May 13, 2024

v0.44.0

May 9, 2024

Changes in this version

+ const ExpectedBufferMsg1023

+ const ExpectedBufferMsg511

+ const ExpectedIdentity

+ const ExpectedQname

+ const ExpectedQname2

+ const SeverityError

+ const SeverityFatal

+ const SeverityFine

+ const SeverityFiner

+ const SeverityFinest

+ const SeverityInfo

+ const SeverityWarning

+ var ProtobufPowerDNSToDNSTap = map[string]string

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

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

+ func GetResolverIP(dm *dnsutils.DNSMessage) string

+ func GetStreamGlobal(dm *dnsutils.DNSMessage) string

+ func GetStreamID(dm *dnsutils.DNSMessage) string

+ func IsStdoutValidMode(mode string) bool

+ func IsValid(mode string) bool

+ func IsValidMode(mode string) bool

+ func SanitizeMetricName(metricName string) string

+ type AfpacketSniffer struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewAfpacketSniffer(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, ...) *AfpacketSniffer

+ func (w *AfpacketSniffer) Listen() error

+ func (w *AfpacketSniffer) StartCollect()

+ type ClickhouseClient struct

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

+ func (w *ClickhouseClient) StartCollect()

+ func (w *ClickhouseClient) StartLogging()

+ type ClickhouseData struct

+ Family string

+ Identity string

+ Operation string

+ Protocol string

+ QName string

+ QType string

+ QueryIP string

+ RCode string

+ TimeNSec string

+ TimeStamp string

+ type DNSMessage struct

+ func NewDNSMessage(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, ...) *DNSMessage

+ func (w *DNSMessage) GetInputChannel() chan dnsutils.DNSMessage

+ func (w *DNSMessage) LoadData(matchSource string, srcKind string) (MatchSource, error)

+ func (w *DNSMessage) LoadFromFile(filePath string, srcKind string) (MatchSource, error)

+ func (w *DNSMessage) LoadFromURL(matchSource string, srcKind string) (MatchSource, error)

+ func (w *DNSMessage) ReadConfig()

+ func (w *DNSMessage) ReadConfigMatching(value interface{})

+ func (w *DNSMessage) StartCollect()

+ type DNSProcessor struct

+ ConfigChan chan *pkgconfig.Config

+ RoutingHandler pkgutils.RoutingHandler

+ 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(defaultWorkers []pkgutils.Worker, droppedworkers []pkgutils.Worker)

+ func (d *DNSProcessor) Stop()

+ type DNSTapProcessor struct

+ ConfigChan chan *pkgconfig.Config

+ ConnID int

+ PeerName string

+ RoutingHandler pkgutils.RoutingHandler

+ func NewDNSTapProcessor(connID int, peerName string, config *pkgconfig.Config, logger *logger.Logger, ...) 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(defaultWorkers []pkgutils.Worker, droppedworkers []pkgutils.Worker)

+ func (d *DNSTapProcessor) Stop()

+ type DevNull struct

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

+ func (w *DevNull) StartCollect()

+ func (w *DevNull) StartLogging()

+ type DnstapProxifier struct

+ func NewDnstapProxifier(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, ...) *DnstapProxifier

+ func (w *DnstapProxifier) CheckConfig()

+ func (w *DnstapProxifier) HandleConn(conn net.Conn, connID uint64, forceClose chan bool, wg *sync.WaitGroup)

+ func (w *DnstapProxifier) HandleFrame(recvFrom chan []byte, sendTo []chan dnsutils.DNSMessage)

+ func (w *DnstapProxifier) StartCollect()

+ type DnstapSender struct

+ func NewDnstapSender(config *pkgconfig.Config, logger *logger.Logger, name string) *DnstapSender

+ func (w *DnstapSender) ConnectToRemote()

+ func (w *DnstapSender) Disconnect()

+ func (w *DnstapSender) FlushBuffer(buf *[]dnsutils.DNSMessage)

+ func (w *DnstapSender) ReadConfig()

+ func (w *DnstapSender) StartCollect()

+ func (w *DnstapSender) StartLogging()

+ type DnstapServer struct

+ func NewDnstapServer(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, ...) *DnstapServer

+ func (w *DnstapServer) CheckConfig()

+ func (w *DnstapServer) HandleConn(conn net.Conn, connID uint64, forceClose chan bool, wg *sync.WaitGroup)

+ func (w *DnstapServer) StartCollect()

+ type ElasticSearchClient struct

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

+ func (w *ElasticSearchClient) ReadConfig()

+ func (w *ElasticSearchClient) StartCollect()

+ func (w *ElasticSearchClient) StartLogging()

+ type EpsCounters struct

+ Eps uint64

+ EpsMax uint64

+ TotalAA float64

+ TotalAD float64

+ TotalBytes int

+ TotalBytesReceived int

+ TotalBytesSent int

+ TotalDNSMessages float64

+ TotalEvents uint64

+ TotalEventsPrev uint64

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

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

+ func (w *FalcoClient) StartCollect()

+ func (w *FalcoClient) StartLogging()

+ type FileIngestor struct

+ func NewFileIngestor(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, ...) *FileIngestor

+ func (w *FileIngestor) CheckConfig()

+ func (w *FileIngestor) ProcessDnstap(filePath string) error

+ func (w *FileIngestor) ProcessFile(filePath string)

+ func (w *FileIngestor) ProcessPcap(filePath string)

+ func (w *FileIngestor) RegisterEvent(filePath string)

+ func (w *FileIngestor) RemoveEvent(filePath string)

+ func (w *FileIngestor) StartCollect()

+ type FluentdClient struct

+ func NewFluentdClient(config *pkgconfig.Config, logger *logger.Logger, name string) *FluentdClient

+ func (w *FluentdClient) ConnectToRemote()

+ func (w *FluentdClient) Disconnect()

+ func (w *FluentdClient) FlushBuffer(buf *[]dnsutils.DNSMessage)

+ func (w *FluentdClient) ReadConfig()

+ func (w *FluentdClient) StartCollect()

+ func (w *FluentdClient) StartLogging()

+ 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.TransformSuspicious

+ type InfluxDBClient struct

+ func NewInfluxDBClient(config *pkgconfig.Config, logger *logger.Logger, name string) *InfluxDBClient

+ func (w *InfluxDBClient) StartCollect()

+ func (w *InfluxDBClient) StartLogging()

+ type KafkaProducer struct

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

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

+ func (w *KafkaProducer) Disconnect()

+ func (w *KafkaProducer) FlushBuffer(buf *[]dnsutils.DNSMessage)

+ func (w *KafkaProducer) ReadConfig()

+ func (w *KafkaProducer) StartCollect()

+ func (w *KafkaProducer) StartLogging()

+ type KeyHit struct

+ Hit int

+ Key string

+ type LogFile struct

+ func NewLogFile(config *pkgconfig.Config, logger *logger.Logger, name string) *LogFile

+ func (w *LogFile) Cleanup() error

+ func (w *LogFile) CompressFile()

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

+ func (w *LogFile) FlushWriters()

+ func (w *LogFile) GetMaxSize() int64

+ func (w *LogFile) OpenFile() error

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

+ func (w *LogFile) ReadConfig()

+ func (w *LogFile) RotateFile() error

+ func (w *LogFile) StartCollect()

+ func (w *LogFile) StartLogging()

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

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

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

+ type LokiClient struct

+ func NewLokiClient(config *pkgconfig.Config, logger *logger.Logger, name string) *LokiClient

+ func (w *LokiClient) ReadConfig()

+ func (w *LokiClient) SendEntries(buf []byte)

+ func (w *LokiClient) StartCollect()

+ func (w *LokiClient) StartLogging()

+ type LokiStream struct

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

+ func (w *LokiStream) Init()

+ func (w *LokiStream) ResetEntries()

+ type MatchSource struct

+ type PdnsProcessor struct

+ ConfigChan chan *pkgconfig.Config

+ ConnID int

+ PeerName string

+ RoutingHandler pkgutils.RoutingHandler

+ func NewPdnsProcessor(connID int, peerName string, config *pkgconfig.Config, logger *logger.Logger, ...) 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) MonitorLoggers()

+ func (p *PdnsProcessor) Run(defaultWorkers []pkgutils.Worker, droppedworkers []pkgutils.Worker)

+ func (p *PdnsProcessor) Stop()

+ type PdnsServer struct

+ func NewPdnsServer(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, ...) *PdnsServer

+ func (w *PdnsServer) CheckConfig()

+ func (w *PdnsServer) HandleConn(conn net.Conn, connID uint64, forceClose chan bool, wg *sync.WaitGroup)

+ func (w *PdnsServer) StartCollect()

+ type PromCounterCatalogueContainer struct

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

+ func NewPromCounterCatalogueContainer(w *Prometheus, selLabels []string, l map[string]string) *PromCounterCatalogueContainer

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

+ func (w *PromCounterCatalogueContainer) GetCountersSet(dm *dnsutils.DNSMessage) PrometheusCountersCatalogue

+ type Prometheus struct

+ func NewPrometheus(config *pkgconfig.Config, logger *logger.Logger, name string) *Prometheus

+ func (w *Prometheus) ComputeEventsPerSecond()

+ func (w *Prometheus) InitProm()

+ func (w *Prometheus) ListenAndServe()

+ func (w *Prometheus) ReadConfig()

+ func (w *Prometheus) Record(dm dnsutils.DNSMessage)

+ func (w *Prometheus) StartCollect()

+ func (w *Prometheus) StartLogging()

+ type PrometheusCountersCatalogue interface

+ GetCountersSet func(*dnsutils.DNSMessage) PrometheusCountersCatalogue

+ type PrometheusCountersSet struct

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

+ func (w *PrometheusCountersSet) ComputeEventsPerSecond()

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

+ func (w *PrometheusCountersSet) GetCountersSet(dm *dnsutils.DNSMessage) PrometheusCountersCatalogue

+ func (w *PrometheusCountersSet) Record(dm dnsutils.DNSMessage)

+ type RedisPub struct

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

+ func (w *RedisPub) ConnectToRemote()

+ func (w *RedisPub) Disconnect()

+ func (w *RedisPub) FlushBuffer(buf *[]dnsutils.DNSMessage)

+ func (w *RedisPub) ReadConfig()

+ func (w *RedisPub) ReadFromConnection()

+ func (w *RedisPub) StartCollect()

+ func (w *RedisPub) StartLogging()

+ type RestAPI struct

+ HitsStream HitsStream

+ HitsUniq HitsUniq

+ Streams map[string]int

+ TopClients *topmap.TopMap

+ TopNonExistent *topmap.TopMap

+ TopQnames *topmap.TopMap

+ TopServFail *topmap.TopMap

+ TopTLDs *topmap.TopMap

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (w *RestAPI) ListenAndServe()

+ func (w *RestAPI) ReadConfig()

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

+ func (w *RestAPI) StartCollect()

+ func (w *RestAPI) StartLogging()

+ type ScalyrClient struct

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

+ func (w *ScalyrClient) ReadConfig()

+ func (w *ScalyrClient) StartCollect()

+ func (w *ScalyrClient) StartLogging()

+ type SearchBy struct

+ Clients map[string]*HitsRecord

+ Domains map[string]*HitsRecord

+ type StatsPerStream struct

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

+ Stats StreamStats

+ func NewStatsdClient(config *pkgconfig.Config, logger *logger.Logger, name string) *StatsdClient

+ func (w *StatsdClient) ReadConfig()

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

+ func (w *StatsdClient) StartCollect()

+ func (w *StatsdClient) StartLogging()

+ type StdOut struct

+ func NewStdOut(config *pkgconfig.Config, console *logger.Logger, name string) *StdOut

+ func (w *StdOut) ReadConfig()

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

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

+ func (w *StdOut) StartCollect()

+ func (w *StdOut) StartLogging()

+ type StreamStats struct

+ Streams map[string]*StatsPerStream

+ type Syslog struct

+ func NewSyslog(config *pkgconfig.Config, console *logger.Logger, name string) *Syslog

+ func (w *Syslog) ConnectToRemote()

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

+ func (w *Syslog) ReadConfig()

+ func (w *Syslog) StartCollect()

+ func (w *Syslog) StartLogging()

+ type TCPClient struct

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

+ func (w *TCPClient) ConnectToRemote()

+ func (w *TCPClient) Disconnect()

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

+ func (w *TCPClient) ReadConfig()

+ func (w *TCPClient) ReadFromConnection()

+ func (w *TCPClient) StartCollect()

+ func (w *TCPClient) StartLogging()

+ type TZSPSniffer struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewTZSP(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, ...) *TZSPSniffer

+ func (w *TZSPSniffer) Listen() error

+ func (w *TZSPSniffer) StartCollect()

+ type Tail struct

+ func NewTail(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, ...) *Tail

+ func (w *Tail) Follow() error

+ func (w *Tail) StartCollect()

+ type XDPSniffer struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewXDPSniffer(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, ...) *XDPSniffer

+ func (w *XDPSniffer) StartCollect()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL