collectors

package
v0.44.0-beta1 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2024 License: MIT Imports: 42 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsValidMode added in v0.26.0 

func IsValidMode(mode string) bool

Types

type AfpacketSniffer added in v0.27.0 

type AfpacketSniffer struct {
	*pkgutils.Collector
	// contains filtered or unexported fields
}

func NewAfpacketSniffer added in v0.27.0 

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

func (*AfpacketSniffer) Listen added in v0.27.0 

func (c *AfpacketSniffer) Listen() error

func (*AfpacketSniffer) Run added in v0.27.0 

func (c *AfpacketSniffer) Run()

type DNSMessage added in v0.40.0 

type DNSMessage struct {
	*pkgutils.Collector
	// contains filtered or unexported fields
}

func NewDNSMessage added in v0.40.0 

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

func (*DNSMessage) GetInputChannel added in v0.40.0 

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

func (*DNSMessage) LoadData added in v0.40.0 

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

func (*DNSMessage) LoadFromFile added in v0.40.0 

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

func (*DNSMessage) LoadFromURL added in v0.40.0 

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

func (*DNSMessage) ReadConfig added in v0.40.0 

func (c *DNSMessage) ReadConfig()

func (*DNSMessage) ReadConfigMatching added in v0.40.0 

func (c *DNSMessage) ReadConfigMatching(value interface{})

func (*DNSMessage) Run added in v0.40.0 

func (c *DNSMessage) Run()

type Dnstap added in v0.3.0 

type Dnstap struct {
	*pkgutils.Collector
	// contains filtered or unexported fields
}

func NewDnstap added in v0.3.0 

func NewDnstap(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *Dnstap

func (*Dnstap) CheckConfig 

func (c *Dnstap) CheckConfig()

func (*Dnstap) HandleConn added in v0.3.0 

func (c *Dnstap) HandleConn(conn net.Conn, connID uint64, forceClose chan bool, wg *sync.WaitGroup)

func (*Dnstap) Run added in v0.3.0 

func (c *Dnstap) Run()

type DnstapProxifier added in v0.26.0 

type DnstapProxifier struct {
	*pkgutils.Collector
	// contains filtered or unexported fields
}

func NewDnstapProxifier added in v0.26.0 

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

func (*DnstapProxifier) CheckConfig 

func (c *DnstapProxifier) CheckConfig()

func (*DnstapProxifier) HandleConn added in v0.26.0 

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

func (*DnstapProxifier) HandleFrame added in v0.26.0 

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

func (*DnstapProxifier) Run added in v0.26.0 

func (c *DnstapProxifier) Run()

type FileIngestor added in v0.26.0 

type FileIngestor struct {
	*pkgutils.Collector
	// contains filtered or unexported fields
}

func NewFileIngestor added in v0.26.0 

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

func (*FileIngestor) CheckConfig 

func (c *FileIngestor) CheckConfig()

func (*FileIngestor) ProcessDnstap added in v0.26.0 

func (c *FileIngestor) ProcessDnstap(filePath string) error

func (*FileIngestor) ProcessFile added in v0.26.0 

func (c *FileIngestor) ProcessFile(filePath string)

func (*FileIngestor) ProcessPcap added in v0.26.0 

func (c *FileIngestor) ProcessPcap(filePath string)

func (*FileIngestor) RegisterEvent added in v0.26.0 

func (c *FileIngestor) RegisterEvent(filePath string)

func (*FileIngestor) RemoveEvent added in v0.26.0 

func (c *FileIngestor) RemoveEvent(filePath string)

func (*FileIngestor) Run added in v0.26.0 

func (c *FileIngestor) Run()

type MatchSource added in v0.40.0 

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

type ProtobufPowerDNS added in v0.17.0 

type ProtobufPowerDNS struct {
	*pkgutils.Collector
	// contains filtered or unexported fields
}

func NewProtobufPowerDNS added in v0.17.0 

func NewProtobufPowerDNS(next []pkgutils.Worker, config *pkgconfig.Config, logger *logger.Logger, name string) *ProtobufPowerDNS

func (*ProtobufPowerDNS) CheckConfig 

func (c *ProtobufPowerDNS) CheckConfig()

func (*ProtobufPowerDNS) HandleConn added in v0.17.0 

func (c *ProtobufPowerDNS) HandleConn(conn net.Conn, connID uint64, forceClose chan bool, wg *sync.WaitGroup)

func (*ProtobufPowerDNS) Run added in v0.17.0 

func (c *ProtobufPowerDNS) Run()

type TZSPSniffer added in v0.39.0 

type TZSPSniffer struct {
	*pkgutils.Collector
	// contains filtered or unexported fields
}

func NewTZSP added in v0.39.0 

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

func (*TZSPSniffer) Listen added in v0.39.0 

func (c *TZSPSniffer) Listen() error

func (*TZSPSniffer) Run added in v0.39.0 

func (c *TZSPSniffer) Run()

type Tail added in v0.5.0 

type Tail struct {
	*pkgutils.Collector
	// contains filtered or unexported fields
}

func NewTail added in v0.5.0 

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

func (*Tail) Follow added in v0.5.0 

func (c *Tail) Follow() error

func (*Tail) Run added in v0.5.0 

func (c *Tail) Run()

type XDPSniffer added in v0.39.0 

type XDPSniffer struct {
	*pkgutils.Collector
}

func NewXDPSniffer added in v0.39.0 

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

func (*XDPSniffer) Run added in v0.39.0 

func (c *XDPSniffer) Run()

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.