collectors

Documentation

Index

• func ApplyBpfFilter(filter []bpf.Instruction, fd int) (err error)
• func GetBpfFilter(port int) []bpf.Instruction
• func Htons(v uint16) int
• func RemoveBpfFilter(fd int) (err error)
• type DnsSniffer
  • func NewDnsSniffer(loggers []dnsutils.Worker, config *dnsutils.Config, logger *logger.Logger) *DnsSniffer
  • func (c *DnsSniffer) Channel() chan dnsutils.DnsMessage
  • func (c *DnsSniffer) Listen() error
  • func (c *DnsSniffer) LogError(msg string, v ...interface{})
  • func (c *DnsSniffer) LogInfo(msg string, v ...interface{})
  • func (c *DnsSniffer) Loggers() []chan dnsutils.DnsMessage
  • func (c *DnsSniffer) ReadConfig()
  • func (c *DnsSniffer) Run()
  • func (c *DnsSniffer) Stop()
• type Dnstap
  • func NewDnstap(loggers []dnsutils.Worker, config *dnsutils.Config, logger *logger.Logger) *Dnstap
  • func (c *Dnstap) Channel() chan dnsutils.DnsMessage
  • func (c *Dnstap) HandleConn(conn net.Conn)
  • func (c *Dnstap) Listen() error
  • func (o *Dnstap) LogError(msg string, v ...interface{})
  • func (o *Dnstap) LogInfo(msg string, v ...interface{})
  • func (c *Dnstap) Loggers() []chan dnsutils.DnsMessage
  • func (c *Dnstap) ReadConfig()
  • func (c *Dnstap) Run()
  • func (c *Dnstap) Stop()
• type Tail
  • func NewTail(loggers []dnsutils.Worker, config *dnsutils.Config, logger *logger.Logger) *Tail
  • func (c *Tail) Channel() chan dnsutils.DnsMessage
  • func (c *Tail) Follow() error
  • func (o *Tail) LogError(msg string, v ...interface{})
  • func (o *Tail) LogInfo(msg string, v ...interface{})
  • func (c *Tail) Loggers() []chan dnsutils.DnsMessage
  • func (c *Tail) ReadConfig()
  • func (c *Tail) Run()
  • func (c *Tail) Stop()

Functions

func ApplyBpfFilter

func ApplyBpfFilter(filter []bpf.Instruction, fd int) (err error)

func GetBpfFilter

func GetBpfFilter(port int) []bpf.Instruction

func Htons

func Htons(v uint16) int

Convert a uint16 to host byte order (big endian)

func RemoveBpfFilter

func RemoveBpfFilter(fd int) (err error)

Types

type DnsSniffer

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

func NewDnsSniffer

func NewDnsSniffer(loggers []dnsutils.Worker, config *dnsutils.Config, logger *logger.Logger) *DnsSniffer

func (*DnsSniffer) Channel

func (c *DnsSniffer) Channel() chan dnsutils.DnsMessage

func (*DnsSniffer) Listen

func (c *DnsSniffer) Listen() error

func (*DnsSniffer) LogError

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

func (*DnsSniffer) LogInfo

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

func (*DnsSniffer) Loggers

func (c *DnsSniffer) Loggers() []chan dnsutils.DnsMessage

func (*DnsSniffer) ReadConfig

func (c *DnsSniffer) ReadConfig()

func (*DnsSniffer) Run

func (c *DnsSniffer) Run()

func (*DnsSniffer) Stop

func (c *DnsSniffer) Stop()

type Dnstap

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

func NewDnstap

func NewDnstap(loggers []dnsutils.Worker, config *dnsutils.Config, logger *logger.Logger) *Dnstap

func (*Dnstap) Channel

func (c *Dnstap) Channel() chan dnsutils.DnsMessage

func (*Dnstap) HandleConn

func (c *Dnstap) HandleConn(conn net.Conn)

func (*Dnstap) Listen

func (c *Dnstap) Listen() error

func (*Dnstap) LogError

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

func (*Dnstap) LogInfo

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

func (*Dnstap) Loggers

func (c *Dnstap) Loggers() []chan dnsutils.DnsMessage

func (*Dnstap) ReadConfig

func (c *Dnstap) ReadConfig()

func (*Dnstap) Run

func (c *Dnstap) Run()

func (*Dnstap) Stop

func (c *Dnstap) Stop()

type Tail

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

func NewTail

func NewTail(loggers []dnsutils.Worker, config *dnsutils.Config, logger *logger.Logger) *Tail

func (*Tail) Channel

func (c *Tail) Channel() chan dnsutils.DnsMessage

func (*Tail) Follow

func (c *Tail) Follow() error

func (*Tail) LogError

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

func (*Tail) LogInfo

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

func (*Tail) Loggers

func (c *Tail) Loggers() []chan dnsutils.DnsMessage

func (*Tail) ReadConfig

func (c *Tail) ReadConfig()

func (*Tail) Run

func (c *Tail) Run()

func (*Tail) Stop

func (c *Tail) Stop()