maps

Documentation

Index

• func CountEntries(id ebpf.MapID) (int, error)
• func FormatBytes(format DisplayFormat, value []byte) string
• func IsLookupSupported(mt ebpf.MapType) bool
• func IsPerCPU(mt ebpf.MapType) bool
• func RestoreBytes(format DisplayFormat, value string, expectedSize uint32) ([]byte, error)
• type DisplayFormat
• type MapEntries
  • func GetEntries(id ebpf.MapID, sort bool) (*MapEntries, error)
• type MapEntry
• type MapExportConfiguration
  • func ParseMapExportConfiguration(config string) (*MapExportConfiguration, error)
  • func (c *MapExportConfiguration) MatchMap(id ebpf.MapID, name string) bool
• type MapInfo
• type MapsWatcher
  • func NewWatcher(logger zerolog.Logger, bpfDir string) MapsWatcher
• type WatcherOpts

Functions

func CountEntries

func CountEntries(id ebpf.MapID) (int, error)

func FormatBytes

func FormatBytes(format DisplayFormat, value []byte) string

func IsLookupSupported

func IsLookupSupported(mt ebpf.MapType) bool

func IsPerCPU

func IsPerCPU(mt ebpf.MapType) bool

func RestoreBytes

func RestoreBytes(format DisplayFormat, value string, expectedSize uint32) ([]byte, error)

Types

type DisplayFormat

type DisplayFormat = string

const (
	DisplayFormatHex    DisplayFormat = "hex"
	DisplayFormatString DisplayFormat = "string"
	DisplayFormatNumber DisplayFormat = "number"
)

type MapEntries

type MapEntries struct {
	Entries []*MapEntry
}

func GetEntries

func GetEntries(id ebpf.MapID, sort bool) (*MapEntries, error)

type MapEntry

type MapEntry struct {
	Key       []byte
	CPUValues [][]byte
	Value     []byte
}

type MapExportConfiguration

type MapExportConfiguration struct {
	StartID          int
	EndID            int
	MetricNameRegexp regexp.Regexp
	KeyFormat        DisplayFormat
}

func ParseMapExportConfiguration

func ParseMapExportConfiguration(config string) (*MapExportConfiguration, error)

func (*MapExportConfiguration) MatchMap

func (c *MapExportConfiguration) MatchMap(id ebpf.MapID, name string) bool

type MapInfo

type MapInfo struct {
	ID         ebpf.MapID
	Error      error
	Name       string
	Type       ebpf.MapType
	Flags      uint32
	Pins       []string
	KeySize    uint32
	ValueSize  uint32
	MaxEntries uint32
}

type MapsWatcher

type MapsWatcher interface {
	Run(ctx context.Context, refreshInterval time.Duration)
	GetMaps() ([]*MapInfo, error)
	GetMap(id ebpf.MapID) (*MapInfo, error)
	RegisterMetrics(registry *prometheus.Registry)
	AddExportConfig(config *MapExportConfiguration)
	PinMap(id ebpf.MapID, path string) error
	UpdateMapValue(id ebpf.MapID, key string, cpu *int, value string, keyFormat DisplayFormat, mapsFormat DisplayFormat) error
	CreateMapValue(id ebpf.MapID, key string, values []string, keyFormat DisplayFormat, mapsFormat DisplayFormat) error
	DeleteMapValue(id ebpf.MapID, key string, keyFormat DisplayFormat) error
}

func NewWatcher

func NewWatcher(logger zerolog.Logger, bpfDir string) MapsWatcher

type WatcherOpts

type WatcherOpts struct {
	RefreshInterval time.Duration
}