Function NewSet

decoder/decoder.go:33–71

NewSet creates a Set with all known decoders

(skipCacheSize int, monitor *cgroup.Monitor)

// NewSet creates a Set with all known decoders
func NewSet(skipCacheSize int, monitor *cgroup.Monitor) (*Set, error) {
	ksym, err := kallsyms.NewDecoder("/proc/kallsyms")
	if err != nil {
		return nil, fmt.Errorf("error creating ksym decoder: %w", err)
	}

	s := &Set{
		decoders: map[string]Decoder{
			"cgroup":       &CGroup{monitor},
			"dname":        &Dname{},
			"errno":        &Errno{},
			"hex":          &Hex{},
			"ifname":       &IfName{},
			"inet_ip":      &InetIP{},
			"kstack":       &KStack{ksym},
			"ksym":         &KSym{ksym},
			"majorminor":   &MajorMinor{},
			"pci_class":    &PCIClass{},
			"pci_device":   &PCIDevice{},
			"pci_subclass": &PCISubClass{},
			"pci_vendor":   &PCIVendor{},
			"regexp":       &Regexp{},
			"static_map":   &StaticMap{},
			"string":       &String{},
			"syscall":      &Syscall{},
			"uint":         &UInt{},
		},
		cache: map[string]map[string][]string{},
	}

	if skipCacheSize > 0 {
		skipCache, err := lru.New[string, struct{}](skipCacheSize)
		if err != nil {
			return nil, err
		}
		s.skipCache = skipCache
	}
	return s, nil
}

// decode transforms input byte field into a string according to configuration
func (s *Set) decode(in []byte, label config.Label) ([]byte, error) {