loggers

package
v0.41.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 20, 2024 License: MIT Imports: 57 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SeverityFinest scalyrSeverity = iota
	SeverityFiner
	SeverityFine
	SeverityInfo
	SeverityWarning
	SeverityError
	SeverityFatal
)

Variables

This section is empty.

Functions

func GetPriority 

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

func GetResolverIP added in v0.35.0 

func GetResolverIP(dm *dnsutils.DNSMessage) string

func GetStreamGlobal added in v0.40.0 

func GetStreamGlobal(dm *dnsutils.DNSMessage) string

Selectors

func GetStreamID added in v0.35.0 

func GetStreamID(dm *dnsutils.DNSMessage) string

func IsStdoutValidMode added in v0.33.0 

func IsStdoutValidMode(mode string) bool

func IsValidMode added in v0.26.0 

func IsValidMode(mode string) bool

func SanitizeMetricName added in v0.22.0 

func SanitizeMetricName(metricName string) string

OpenMetrics and the Prometheus exposition format require the metric name to consist only of alphanumericals and "_", ":" and they must not start with digits.

Types

type DnstapSender 

type DnstapSender struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewDnstapSender 

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

func (*DnstapSender) AddDefaultRoute added in v0.40.0 

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

func (*DnstapSender) AddDroppedRoute added in v0.40.0 

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

func (*DnstapSender) ConnectToRemote added in v0.31.0 

func (ds *DnstapSender) ConnectToRemote()

func (*DnstapSender) Disconnect added in v0.31.0 

func (ds *DnstapSender) Disconnect()

func (*DnstapSender) FlushBuffer added in v0.31.0 

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

func (*DnstapSender) GetInputChannel added in v0.40.0 

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

func (*DnstapSender) GetName added in v0.22.0 

func (ds *DnstapSender) GetName() string

func (*DnstapSender) LogError 

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

func (*DnstapSender) LogInfo 

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

func (*DnstapSender) Process added in v0.33.0 

func (ds *DnstapSender) Process()

func (*DnstapSender) ReadConfig 

func (ds *DnstapSender) ReadConfig()

func (*DnstapSender) ReloadConfig added in v0.38.0 

func (ds *DnstapSender) ReloadConfig(config *pkgconfig.Config)

func (*DnstapSender) Run 

func (ds *DnstapSender) Run()

func (*DnstapSender) SetLoggers added in v0.22.0 

func (ds *DnstapSender) SetLoggers(loggers []pkgutils.Worker)

func (*DnstapSender) Stop 

func (ds *DnstapSender) Stop()

type ElasticSearchClient added in v0.23.0 

type ElasticSearchClient struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewElasticSearchClient added in v0.23.0 

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

func (*ElasticSearchClient) AddDefaultRoute added in v0.40.0 

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

func (*ElasticSearchClient) AddDroppedRoute added in v0.40.0 

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

func (*ElasticSearchClient) FlushBuffer added in v0.35.0 

func (ec *ElasticSearchClient) FlushBuffer(buf *[]dnsutils.DNSMessage)

func (*ElasticSearchClient) GetInputChannel added in v0.40.0 

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

func (*ElasticSearchClient) GetName added in v0.23.0 

func (ec *ElasticSearchClient) GetName() string

func (*ElasticSearchClient) LogError added in v0.23.0 

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

func (*ElasticSearchClient) LogInfo added in v0.23.0 

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

func (*ElasticSearchClient) Process added in v0.33.0 

func (ec *ElasticSearchClient) Process()

func (*ElasticSearchClient) ReadConfig added in v0.23.0 

func (ec *ElasticSearchClient) ReadConfig()

func (*ElasticSearchClient) ReloadConfig added in v0.38.0 

func (ec *ElasticSearchClient) ReloadConfig(config *pkgconfig.Config)

func (*ElasticSearchClient) Run added in v0.23.0 

func (ec *ElasticSearchClient) Run()

func (*ElasticSearchClient) SetLoggers added in v0.23.0 

func (ec *ElasticSearchClient) SetLoggers(loggers []pkgutils.Worker)

func (*ElasticSearchClient) Stop added in v0.23.0 

func (ec *ElasticSearchClient) Stop()

type EpsCounters added in v0.22.0 

type EpsCounters struct {
	Eps             uint64
	EpsMax          uint64
	TotalEvents     uint64
	TotalEventsPrev uint64

	TotalRcodes        map[string]float64
	TotalQtypes        map[string]float64
	TotalIPVersion     map[string]float64
	TotalIPProtocol    map[string]float64
	TotalDNSMessages   float64
	TotalQueries       int
	TotalReplies       int
	TotalBytesSent     int
	TotalBytesReceived int
	TotalBytes         int

	TotalTC         float64
	TotalAA         float64
	TotalRA         float64
	TotalAD         float64
	TotalMalformed  float64
	TotalFragmented float64
	TotalReasembled float64
}

EpsCounters (Events Per Second) - is a set of metrics we calculate on per-second basis. For others we rely on averaging by collector

type FalcoClient added in v0.32.0 

type FalcoClient struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewFalcoClient added in v0.32.0 

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

func (*FalcoClient) AddDefaultRoute added in v0.40.0 

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

func (*FalcoClient) AddDroppedRoute added in v0.40.0 

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

func (*FalcoClient) GetInputChannel added in v0.40.0 

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

func (*FalcoClient) GetName added in v0.32.0 

func (fc *FalcoClient) GetName() string

func (*FalcoClient) LogError added in v0.32.0 

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

func (*FalcoClient) LogInfo added in v0.32.0 

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

func (*FalcoClient) Process added in v0.33.0 

func (fc *FalcoClient) Process()

func (*FalcoClient) ReadConfig added in v0.32.0 

func (fc *FalcoClient) ReadConfig()

func (*FalcoClient) ReloadConfig added in v0.38.0 

func (fc *FalcoClient) ReloadConfig(config *pkgconfig.Config)

func (*FalcoClient) Run added in v0.32.0 

func (fc *FalcoClient) Run()

func (*FalcoClient) SetLoggers added in v0.32.0 

func (fc *FalcoClient) SetLoggers(loggers []pkgutils.Worker)

func (*FalcoClient) Stop added in v0.32.0 

func (fc *FalcoClient) Stop()

type FluentdClient 

type FluentdClient struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewFluentdClient 

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

func (*FluentdClient) AddDefaultRoute added in v0.40.0 

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

func (*FluentdClient) AddDroppedRoute added in v0.40.0 

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

func (*FluentdClient) ConnectToRemote added in v0.31.0 

func (fc *FluentdClient) ConnectToRemote()

func (*FluentdClient) Disconnect added in v0.31.0 

func (fc *FluentdClient) Disconnect()

func (*FluentdClient) FlushBuffer added in v0.31.0 

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

func (*FluentdClient) GetInputChannel added in v0.40.0 

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

func (*FluentdClient) GetName added in v0.22.0 

func (fc *FluentdClient) GetName() string

func (*FluentdClient) LogError 

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

func (*FluentdClient) LogInfo 

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

func (*FluentdClient) Process added in v0.33.0 

func (fc *FluentdClient) Process()

func (*FluentdClient) ReadConfig 

func (fc *FluentdClient) ReadConfig()

func (*FluentdClient) ReloadConfig added in v0.38.0 

func (fc *FluentdClient) ReloadConfig(config *pkgconfig.Config)

func (*FluentdClient) Run 

func (fc *FluentdClient) Run()

func (*FluentdClient) SetLoggers added in v0.22.0 

func (fc *FluentdClient) SetLoggers(loggers []pkgutils.Worker)

func (*FluentdClient) Stop 

func (fc *FluentdClient) Stop()

type HitsRecord added in v0.25.0 

type HitsRecord struct {
	TotalHits int            `json:"total-hits"`
	Hits      map[string]int `json:"hits"`
}

type HitsStream added in v0.25.0 

type HitsStream struct {
	Streams map[string]SearchBy
}

type HitsUniq added in v0.25.0 

type HitsUniq struct {
	Clients        map[string]int
	Domains        map[string]int
	NxDomains      map[string]int
	SfDomains      map[string]int
	PublicSuffixes map[string]int
	Suspicious     map[string]*dnsutils.TransformSuspicious
}

type InfluxDBClient added in v0.13.0 

type InfluxDBClient struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewInfluxDBClient added in v0.13.0 

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

func (*InfluxDBClient) AddDefaultRoute added in v0.40.0 

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

func (*InfluxDBClient) AddDroppedRoute added in v0.40.0 

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

func (*InfluxDBClient) GetInputChannel added in v0.40.0 

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

func (*InfluxDBClient) GetName added in v0.22.0 

func (ic *InfluxDBClient) GetName() string

func (*InfluxDBClient) LogError added in v0.13.0 

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

func (*InfluxDBClient) LogInfo added in v0.13.0 

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

func (*InfluxDBClient) Process added in v0.33.0 

func (ic *InfluxDBClient) Process()

func (*InfluxDBClient) ReadConfig added in v0.13.0 

func (ic *InfluxDBClient) ReadConfig()

func (*InfluxDBClient) ReloadConfig added in v0.38.0 

func (ic *InfluxDBClient) ReloadConfig(config *pkgconfig.Config)

func (*InfluxDBClient) Run added in v0.13.0 

func (ic *InfluxDBClient) Run()

func (*InfluxDBClient) SetLoggers added in v0.22.0 

func (ic *InfluxDBClient) SetLoggers(loggers []pkgutils.Worker)

func (*InfluxDBClient) Stop added in v0.13.0 

func (ic *InfluxDBClient) Stop()

type KafkaProducer added in v0.32.0 

type KafkaProducer struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewKafkaProducer added in v0.32.0 

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

func (*KafkaProducer) AddDefaultRoute added in v0.40.0 

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

func (*KafkaProducer) AddDroppedRoute added in v0.40.0 

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

func (*KafkaProducer) ConnectToKafka added in v0.32.0 

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

func (*KafkaProducer) Disconnect added in v0.32.0 

func (k *KafkaProducer) Disconnect()

func (*KafkaProducer) FlushBuffer added in v0.32.0 

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

func (*KafkaProducer) GetInputChannel added in v0.40.0 

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

func (*KafkaProducer) GetName added in v0.32.0 

func (k *KafkaProducer) GetName() string

func (*KafkaProducer) LogError added in v0.32.0 

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

func (*KafkaProducer) LogInfo added in v0.32.0 

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

func (*KafkaProducer) Process added in v0.33.0 

func (k *KafkaProducer) Process()

func (*KafkaProducer) ReadConfig added in v0.32.0 

func (k *KafkaProducer) ReadConfig()

func (*KafkaProducer) ReloadConfig added in v0.38.0 

func (k *KafkaProducer) ReloadConfig(config *pkgconfig.Config)

func (*KafkaProducer) Run added in v0.32.0 

func (k *KafkaProducer) Run()

func (*KafkaProducer) SetLoggers added in v0.32.0 

func (k *KafkaProducer) SetLoggers(loggers []pkgutils.Worker)

func (*KafkaProducer) Stop added in v0.32.0 

func (k *KafkaProducer) Stop()

type KeyHit added in v0.32.0 

type KeyHit struct {
	Key string `json:"key"`
	Hit int    `json:"hit"`
}

type LogFile 

type LogFile struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewLogFile 

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

func (*LogFile) AddDefaultRoute added in v0.40.0 

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

func (*LogFile) AddDroppedRoute added in v0.40.0 

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

func (*LogFile) Cleanup added in v0.5.0 

func (lf *LogFile) Cleanup() error

func (*LogFile) CompressFile added in v0.26.0 

func (lf *LogFile) CompressFile()

func (*LogFile) CompressPostRotateCommand added in v0.17.0 

func (lf *LogFile) CompressPostRotateCommand(filename string)

func (*LogFile) FlushWriters added in v0.26.0 

func (lf *LogFile) FlushWriters()

func (*LogFile) GetInputChannel added in v0.40.0 

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

func (*LogFile) GetMaxSize added in v0.26.0 

func (lf *LogFile) GetMaxSize() int64

func (*LogFile) GetName added in v0.22.0 

func (lf *LogFile) GetName() string

func (*LogFile) LogError added in v0.5.0 

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

func (*LogFile) LogInfo added in v0.5.0 

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

func (*LogFile) OpenFile 

func (lf *LogFile) OpenFile() error

func (*LogFile) PostRotateCommand added in v0.5.0 

func (lf *LogFile) PostRotateCommand(filename string)

func (*LogFile) Process added in v0.33.0 

func (lf *LogFile) Process()

func (*LogFile) ReadConfig 

func (lf *LogFile) ReadConfig()

func (*LogFile) ReloadConfig added in v0.38.0 

func (lf *LogFile) ReloadConfig(config *pkgconfig.Config)

func (*LogFile) RotateFile added in v0.26.0 

func (lf *LogFile) RotateFile() error

func (*LogFile) Run 

func (lf *LogFile) Run()

func (*LogFile) SetLoggers added in v0.22.0 

func (lf *LogFile) SetLoggers(loggers []pkgutils.Worker)

func (*LogFile) Stop 

func (lf *LogFile) Stop()

func (*LogFile) WriteToDnstap added in v0.26.0 

func (lf *LogFile) WriteToDnstap(data []byte)

func (*LogFile) WriteToPcap added in v0.26.0 

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

func (*LogFile) WriteToPlain added in v0.26.0 

func (lf *LogFile) WriteToPlain(data []byte)

type LokiClient added in v0.13.0 

type LokiClient struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewLokiClient added in v0.13.0 

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

func (*LokiClient) AddDefaultRoute added in v0.40.0 

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

func (*LokiClient) AddDroppedRoute added in v0.40.0 

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

func (*LokiClient) GetInputChannel added in v0.40.0 

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

func (*LokiClient) GetName added in v0.22.0 

func (c *LokiClient) GetName() string

func (*LokiClient) LogError added in v0.13.0 

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

func (*LokiClient) LogInfo added in v0.13.0 

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

func (*LokiClient) Process added in v0.33.0 

func (c *LokiClient) Process()

func (*LokiClient) ReadConfig added in v0.13.0 

func (c *LokiClient) ReadConfig()

func (*LokiClient) ReloadConfig added in v0.38.0 

func (c *LokiClient) ReloadConfig(config *pkgconfig.Config)

func (*LokiClient) Run added in v0.13.0 

func (c *LokiClient) Run()

func (*LokiClient) SendEntries added in v0.13.0 

func (c *LokiClient) SendEntries(buf []byte)

func (*LokiClient) SetLoggers added in v0.22.0 

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

func (*LokiClient) Stop added in v0.13.0 

func (c *LokiClient) Stop()

type LokiStream added in v0.17.0 

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

func (*LokiStream) Encode2Proto added in v0.17.0 

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

func (*LokiStream) Init added in v0.17.0 

func (o *LokiStream) Init()

func (*LokiStream) ResetEntries added in v0.17.0 

func (o *LokiStream) ResetEntries()

type PromCounterCatalogueContainer added in v0.35.0 

type PromCounterCatalogueContainer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

PromCounterCatalogueContainer is the implementation of PrometheusCountersCatalogue interface That maps a single label into other Containers or CounterSet The 'chain' of nested Containers keep track of labelNames requested by the config to figure out whether nested Container should be created, or, if all labels but the last one already considered at the upper levels, it is time to create individual CounterSet

func CreateSystemCatalogue added in v0.35.0 

func CreateSystemCatalogue(o *Prometheus) ([]string, *PromCounterCatalogueContainer)

This function checks the configuration, to determine which label dimensions were requested by configuration, and returns correct implementation of Catalogue.

func NewPromCounterCatalogueContainer added in v0.35.0 

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

func (*PromCounterCatalogueContainer) GetAllCounterSets added in v0.35.0 

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

Returns a slice of all PrometheusCountersSet in a Container

func (*PromCounterCatalogueContainer) GetCountersSet added in v0.35.0 

func (c *PromCounterCatalogueContainer) GetCountersSet(dm *dnsutils.DNSMessage) PrometheusCountersCatalogue

Searches for an existing element for a label value, creating one if not found

type Prometheus added in v0.15.0 

type Prometheus struct {
	sync.Mutex

	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewPrometheus added in v0.15.0 

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

func (*Prometheus) AddDefaultRoute added in v0.40.0 

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

func (*Prometheus) AddDroppedRoute added in v0.40.0 

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

func (*Prometheus) ComputeEventsPerSecond added in v0.34.0 

func (c *Prometheus) ComputeEventsPerSecond()

func (*Prometheus) GetInputChannel added in v0.40.0 

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

func (*Prometheus) GetName added in v0.22.0 

func (c *Prometheus) GetName() string

func (*Prometheus) InitProm added in v0.15.0 

func (c *Prometheus) InitProm()

func (*Prometheus) ListenAndServe added in v0.15.0 

func (c *Prometheus) ListenAndServe()

func (*Prometheus) LogError added in v0.15.0 

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

func (*Prometheus) LogInfo added in v0.15.0 

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

func (*Prometheus) Process added in v0.33.0 

func (c *Prometheus) Process()

func (*Prometheus) ReadConfig added in v0.16.0 

func (c *Prometheus) ReadConfig()

func (*Prometheus) Record added in v0.15.0 

func (c *Prometheus) Record(dm dnsutils.DNSMessage)

func (*Prometheus) ReloadConfig added in v0.38.0 

func (c *Prometheus) ReloadConfig(config *pkgconfig.Config)

func (*Prometheus) Run added in v0.15.0 

func (c *Prometheus) Run()

func (*Prometheus) SetLoggers added in v0.22.0 

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

func (*Prometheus) Stop added in v0.15.0 

func (c *Prometheus) Stop()

type PrometheusCountersCatalogue added in v0.35.0 

type PrometheusCountersCatalogue interface {
	// Prometheus logger encapsulates stats counters (PrometheusCounterSet) inside
	// PromCounterCatalogueContainer's. For each label the logger creates a nested level
	// of containers.
	// Containers and CounterSets must implemnent PrometheusCountersCatalogue interface
	// to allow fetching a CounterSet by the list of metric/values by fetching values from
	// the DNS message it logs.
	// There is a schematic sample layout when there are 2 labels considered at the end of this file
	GetCountersSet(*dnsutils.DNSMessage) PrometheusCountersCatalogue
}

type PrometheusCountersSet added in v0.35.0 

type PrometheusCountersSet struct {
	sync.Mutex // Each PrometheusCountersSet locks independently
	// contains filtered or unexported fields
}

This type represents a set of counters for a unique set of label name=value pairs. By default, we create a set per setream_id for backward compatibility However, we can allow slicing and dicing data using more dimensions. Each CounterSet is registered with Prometheus collection independently (wrapping label values)

func (*PrometheusCountersSet) Collect added in v0.35.0 

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

func (*PrometheusCountersSet) ComputeEventsPerSecond added in v0.35.0 

func (c *PrometheusCountersSet) ComputeEventsPerSecond()

func (*PrometheusCountersSet) Describe added in v0.35.0 

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

each CounterSet has the same list of timeseries descriptors, so it uses descriptros from the Prometheus instance the set belongs to.

func (*PrometheusCountersSet) GetCountersSet added in v0.35.0 

func (c *PrometheusCountersSet) GetCountersSet(dm *dnsutils.DNSMessage) PrometheusCountersCatalogue

func (*PrometheusCountersSet) Record added in v0.35.0 

func (c *PrometheusCountersSet) Record(dm dnsutils.DNSMessage)

Updates all counters for a specific set of labelName=labelValue

type RedisPub added in v0.31.0 

type RedisPub struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewRedisPub added in v0.31.0 

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

func (*RedisPub) AddDefaultRoute added in v0.40.0 

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

func (*RedisPub) AddDroppedRoute added in v0.40.0 

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

func (*RedisPub) ConnectToRemote added in v0.31.0 

func (c *RedisPub) ConnectToRemote()

func (*RedisPub) Disconnect added in v0.31.0 

func (c *RedisPub) Disconnect()

func (*RedisPub) FlushBuffer added in v0.31.0 

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

func (*RedisPub) GetInputChannel added in v0.40.0 

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

func (*RedisPub) GetName added in v0.31.0 

func (c *RedisPub) GetName() string

func (*RedisPub) LogError added in v0.31.0 

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

func (*RedisPub) LogInfo added in v0.31.0 

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

func (*RedisPub) Process added in v0.33.0 

func (c *RedisPub) Process()

func (*RedisPub) ReadConfig added in v0.31.0 

func (c *RedisPub) ReadConfig()

func (*RedisPub) ReadFromConnection added in v0.37.0 

func (c *RedisPub) ReadFromConnection()

func (*RedisPub) ReloadConfig added in v0.38.0 

func (c *RedisPub) ReloadConfig(config *pkgconfig.Config)

func (*RedisPub) Run added in v0.31.0 

func (c *RedisPub) Run()

func (*RedisPub) SetLoggers added in v0.31.0 

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

func (*RedisPub) Stop added in v0.31.0 

func (c *RedisPub) Stop()

type RestAPI added in v0.25.0 

type RestAPI struct {
	RoutingHandler pkgutils.RoutingHandler

	HitsStream HitsStream
	HitsUniq   HitsUniq

	Streams map[string]int `json:"streams"`

	TopQnames      *topmap.TopMap
	TopClients     *topmap.TopMap
	TopTLDs        *topmap.TopMap
	TopNonExistent *topmap.TopMap
	TopServFail    *topmap.TopMap

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRestAPI added in v0.25.0 

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

func (*RestAPI) AddDefaultRoute added in v0.40.0 

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

func (*RestAPI) AddDroppedRoute added in v0.40.0 

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

func (*RestAPI) BasicAuth added in v0.25.0 

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

func (*RestAPI) DeleteResetHandler added in v0.32.0 

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

func (*RestAPI) GetClientsHandler added in v0.25.0 

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

func (*RestAPI) GetDomainsHandler added in v0.25.0 

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

func (*RestAPI) GetInputChannel added in v0.40.0 

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

func (*RestAPI) GetName added in v0.25.0 

func (c *RestAPI) GetName() string

func (*RestAPI) GetNxDomainsHandler added in v0.25.0 

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

func (*RestAPI) GetSearchHandler added in v0.28.0 

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

func (*RestAPI) GetSfDomainsHandler added in v0.25.0 

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

func (*RestAPI) GetStreamsHandler added in v0.28.0 

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

func (*RestAPI) GetSuspiciousHandler added in v0.25.0 

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

func (*RestAPI) GetTLDsHandler added in v0.25.0 

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

func (*RestAPI) GetTopClientsHandler added in v0.25.0 

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

func (*RestAPI) GetTopDomainsHandler added in v0.25.0 

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

func (*RestAPI) GetTopNxDomainsHandler added in v0.25.0 

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

func (*RestAPI) GetTopSfDomainsHandler added in v0.25.0 

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

func (*RestAPI) GetTopTLDsHandler added in v0.25.0 

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

func (*RestAPI) ListenAndServe added in v0.25.0 

func (c *RestAPI) ListenAndServe()

func (*RestAPI) LogError added in v0.25.0 

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

func (*RestAPI) LogInfo added in v0.25.0 

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

func (*RestAPI) Process added in v0.33.0 

func (c *RestAPI) Process()

func (*RestAPI) ReadConfig added in v0.25.0 

func (c *RestAPI) ReadConfig()

func (*RestAPI) RecordDNSMessage added in v0.39.0 

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

func (*RestAPI) ReloadConfig added in v0.38.0 

func (c *RestAPI) ReloadConfig(config *pkgconfig.Config)

func (*RestAPI) Run added in v0.25.0 

func (c *RestAPI) Run()

func (*RestAPI) SetLoggers added in v0.25.0 

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

func (*RestAPI) Stop added in v0.25.0 

func (c *RestAPI) Stop()

type ScalyrClient added in v0.31.0 

type ScalyrClient struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

ScalyrClient is a client for Scalyr(https://www.dataset.com/) This client is using the addEvents endpoint, described here: https://app.scalyr.com/help/api#addEvents

func NewScalyrClient added in v0.31.0 

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

func (*ScalyrClient) AddDefaultRoute added in v0.40.0 

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

func (*ScalyrClient) AddDroppedRoute added in v0.40.0 

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

func (*ScalyrClient) GetInputChannel added in v0.40.0 

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

func (*ScalyrClient) GetName added in v0.31.0 

func (c *ScalyrClient) GetName() string

func (*ScalyrClient) LogError added in v0.31.0 

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

func (*ScalyrClient) LogInfo added in v0.31.0 

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

func (*ScalyrClient) Process added in v0.33.0 

func (c *ScalyrClient) Process()

func (*ScalyrClient) ReadConfig added in v0.31.0 

func (c *ScalyrClient) ReadConfig()

func (*ScalyrClient) ReloadConfig added in v0.38.0 

func (c *ScalyrClient) ReloadConfig(config *pkgconfig.Config)

func (*ScalyrClient) Run added in v0.31.0 

func (c *ScalyrClient) Run()

func (*ScalyrClient) SetLoggers added in v0.31.0 

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

func (ScalyrClient) Stop added in v0.31.0 

func (c ScalyrClient) Stop()

type SearchBy added in v0.25.0 

type SearchBy struct {
	Clients map[string]*HitsRecord
	Domains map[string]*HitsRecord
}

type StatsPerStream added in v0.21.0 

type StatsPerStream struct {
	TotalPackets       int
	TotalSentBytes     int
	TotalReceivedBytes int

	Clients   map[string]int
	Domains   map[string]int
	Nxdomains map[string]int

	RRtypes    map[string]int
	Rcodes     map[string]int
	Operations map[string]int
	Transports map[string]int
	IPproto    map[string]int

	TopRcodes     *topmap.TopMap
	TopOperations *topmap.TopMap
	TopIPproto    *topmap.TopMap
	TopTransport  *topmap.TopMap
	TopRRtypes    *topmap.TopMap
}

type StatsdClient added in v0.14.0 

type StatsdClient struct {
	RoutingHandler pkgutils.RoutingHandler

	Stats StreamStats
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewStatsdClient added in v0.14.0 

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

func (*StatsdClient) AddDefaultRoute added in v0.40.0 

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

func (*StatsdClient) AddDroppedRoute added in v0.40.0 

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

func (*StatsdClient) GetInputChannel added in v0.40.0 

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

func (*StatsdClient) GetName added in v0.22.0 

func (c *StatsdClient) GetName() string

func (*StatsdClient) LogError added in v0.14.0 

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

func (*StatsdClient) LogInfo added in v0.14.0 

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

func (*StatsdClient) Process added in v0.33.0 

func (c *StatsdClient) Process()

func (*StatsdClient) ReadConfig added in v0.14.0 

func (c *StatsdClient) ReadConfig()

func (*StatsdClient) RecordDNSMessage added in v0.39.0 

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

func (*StatsdClient) ReloadConfig added in v0.38.0 

func (c *StatsdClient) ReloadConfig(config *pkgconfig.Config)

func (*StatsdClient) Run added in v0.14.0 

func (c *StatsdClient) Run()

func (*StatsdClient) SetLoggers added in v0.22.0 

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

func (*StatsdClient) Stop added in v0.14.0 

func (c *StatsdClient) Stop()

type StdOut 

type StdOut struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewStdOut 

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

func (*StdOut) AddDefaultRoute added in v0.40.0 

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

func (*StdOut) AddDroppedRoute added in v0.40.0 

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

func (*StdOut) GetInputChannel added in v0.40.0 

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

func (*StdOut) GetName added in v0.22.0 

func (so *StdOut) GetName() string

func (*StdOut) LogError 

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

func (*StdOut) LogInfo 

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

func (*StdOut) Process added in v0.33.0 

func (so *StdOut) Process()

func (*StdOut) ReadConfig 

func (so *StdOut) ReadConfig()

func (*StdOut) ReloadConfig added in v0.38.0 

func (so *StdOut) ReloadConfig(config *pkgconfig.Config)

func (*StdOut) Run 

func (so *StdOut) Run()

func (*StdOut) SetLoggers added in v0.22.0 

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

func (*StdOut) SetPcapWriter added in v0.38.0 

func (so *StdOut) SetPcapWriter(w io.Writer)

func (*StdOut) SetTextWriter added in v0.38.0 

func (so *StdOut) SetTextWriter(b *bytes.Buffer)

func (*StdOut) Stop 

func (so *StdOut) Stop()

type StreamStats added in v0.25.0 

type StreamStats struct {
	Streams map[string]*StatsPerStream
}

type Syslog 

type Syslog struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewSyslog 

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

func (*Syslog) AddDefaultRoute added in v0.40.0 

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

func (*Syslog) AddDroppedRoute added in v0.40.0 

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

func (*Syslog) ConnectToRemote added in v0.37.0 

func (s *Syslog) ConnectToRemote()

func (*Syslog) FlushBuffer added in v0.39.0 

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

func (*Syslog) GetInputChannel added in v0.40.0 

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

func (*Syslog) GetName added in v0.22.0 

func (s *Syslog) GetName() string

func (*Syslog) LogError 

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

func (*Syslog) LogInfo 

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

func (*Syslog) Process added in v0.33.0 

func (s *Syslog) Process()

func (*Syslog) ReadConfig 

func (s *Syslog) ReadConfig()

func (*Syslog) ReloadConfig added in v0.38.0 

func (s *Syslog) ReloadConfig(config *pkgconfig.Config)

func (*Syslog) Run 

func (s *Syslog) Run()

func (*Syslog) SetLoggers added in v0.22.0 

func (s *Syslog) SetLoggers(loggers []pkgutils.Worker)

func (*Syslog) Stop 

func (s *Syslog) Stop()

type TCPClient added in v0.39.0 

type TCPClient struct {
	RoutingHandler pkgutils.RoutingHandler
	// contains filtered or unexported fields
}

func NewTCPClient added in v0.39.0 

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

func (*TCPClient) AddDefaultRoute added in v0.40.0 

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

func (*TCPClient) AddDroppedRoute added in v0.40.0 

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

func (*TCPClient) ConnectToRemote added in v0.39.0 

func (c *TCPClient) ConnectToRemote()

func (*TCPClient) Disconnect added in v0.39.0 

func (c *TCPClient) Disconnect()

func (*TCPClient) FlushBuffer added in v0.39.0 

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

func (*TCPClient) GetInputChannel added in v0.40.0 

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

func (*TCPClient) GetName added in v0.39.0 

func (c *TCPClient) GetName() string

func (*TCPClient) LogError added in v0.39.0 

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

func (*TCPClient) LogInfo added in v0.39.0 

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

func (*TCPClient) Process added in v0.39.0 

func (c *TCPClient) Process()

func (*TCPClient) ReadConfig added in v0.39.0 

func (c *TCPClient) ReadConfig()

func (*TCPClient) ReadFromConnection added in v0.39.0 

func (c *TCPClient) ReadFromConnection()

func (*TCPClient) ReloadConfig added in v0.39.0 

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

func (*TCPClient) Run added in v0.39.0 

func (c *TCPClient) Run()

func (*TCPClient) SetLoggers added in v0.39.0 

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

func (*TCPClient) Stop added in v0.39.0 

func (c *TCPClient) Stop()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.