collector

Documentation

Overview

Package collector repeatedly queries the netlink socket to discover measurement data about open TCP connections and sends that data down a channel.

Index

• func OneType(inetType uint8) ([]*syscall.NetlinkMessage, error)
• func Run(ctx context.Context, reps int, svrChan chan<- netlink.MessageBlock, ...) (localCount, errCount int)

Functions

func OneType

func OneType(inetType uint8) ([]*syscall.NetlinkMessage, error)

OneType handles the request and response for a single type, e.g. INET or INET6 TODO maybe move this to top level?

func Run

func Run(ctx context.Context, reps int, svrChan chan<- netlink.MessageBlock, cl saver.CacheLogger, skipLocal bool) (localCount, errCount int)

Run the collector, either for the specified number of loops, or, if the number specified is infinite, run forever.