loader

Documentation

Index

• func NewNoopWatcher() *noopWatcher
• type KvPair
• type LoadOptions
• type Loader
  • func NewLoader(decoderFactory decoder.DecoderFactory, metricsProvider stats.MetricsProvider) Loader
• type MapEntry
• type MapWatcher
• type ParsedELF
• type WatchedMap
• type WatchedMapOptions

Functions

func NewNoopWatcher

func NewNoopWatcher() *noopWatcher

Types

type KvPair

type KvPair struct {
	Key   map[string]string
	Value string
	Hash  uint64
}

type LoadOptions

type LoadOptions struct {
	ParsedELF *ParsedELF
	Watcher   MapWatcher
	PinMaps   string
	PinProgs  string
}

type Loader

type Loader interface {
	Parse(ctx context.Context, reader io.ReaderAt) (*ParsedELF, error)
	Load(ctx context.Context, opts *LoadOptions) error
	WatchMaps(ctx context.Context, watchedMaps map[string]WatchedMap, watchedMapOptions map[string]WatchedMapOptions, coll map[string]*ebpf.Map, watcher MapWatcher) error
}

func NewLoader

func NewLoader(
	decoderFactory decoder.DecoderFactory,
	metricsProvider stats.MetricsProvider,
) Loader

type MapEntry

type MapEntry struct {
	Name  string
	Entry KvPair
}

type MapWatcher

type MapWatcher interface {
	NewRingBuf(name string, keys []string)
	NewHashMap(name string, keys []string)
	SendEntry(entry MapEntry)
	Close()
}

type ParsedELF

type ParsedELF struct {
	Spec              *ebpf.CollectionSpec
	WatchedMaps       map[string]WatchedMap
	WatchedMapOptions map[string]WatchedMapOptions
}

type WatchedMap

type WatchedMap struct {
	Name   string
	Labels []string
	// contains filtered or unexported fields
}

type WatchedMapOptions

type WatchedMapOptions struct {
	HistValueKey string
	HistBuckets  []float64
}