parsing

Documentation

Index

• type Config
• type Parser
  • func New(conf Config, resolverMap *stats.ResolverInfoMap, zoneStats *stats.ZoneStats, ...) *Parser
  • func (p *Parser) ComponentName() string
  • func (p *Parser) IsHealthy() error
  • func (p *Parser) Start(ctx context.Context, group *errgroup.Group)

Types

type Config

type Config struct {
	Zone                       string
	SocketPath                 string
	RecordRTTs                 bool
	PingMinQph                 int
	PrometheusMetricsFrequency time.Duration
}

Configuration variables for the Parser struct.

type Parser

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

Parser is the component in charge of reading and parsing dnstap from a UNIX socket and processing these messages to collect aggregate statistics.

func New

func New(conf Config,
	resolverMap *stats.ResolverInfoMap,
	zoneStats *stats.ZoneStats,
	messages chan *dnstap.Message,
	pingQueue chan<- *stats.ResolverInfo) *Parser

Creates and returns a new Parser component. One Parser is created for each configured DNS zone.

func (*Parser) ComponentName

func (p *Parser) ComponentName() string

func (*Parser) IsHealthy

func (p *Parser) IsHealthy() error

Reports whether this parser component is healthy. Whether the socket location is still present.

func (*Parser) Start

func (p *Parser) Start(ctx context.Context, group *errgroup.Group)

Start the Parser component:

1. Read the bytestream from the UNIX socket and parse into dnstap messages
2. Process dnstap messages from the message queue