Method decodeData

netflow/v9/decoder.go:318–372

(tr TemplateRecord)

}

func (d *Decoder) decodeData(tr TemplateRecord) ([]DecodedField, error) {
	var (
		fields []DecodedField
		err    error
		b      []byte
	)

	r := d.reader

	for i := 0; i < len(tr.ScopeFieldSpecifiers); i++ {
		b, err = r.Read(int(tr.ScopeFieldSpecifiers[i].Length))
		if err != nil {
			return nil, err
		}

		m, ok := ipfix.InfoModel[ipfix.ElementKey{
			0,
			tr.ScopeFieldSpecifiers[i].ElementID,
		}]

		if !ok {
			return nil, nonfatalError(fmt.Errorf("Netflow element key (%d) not exist (scope)",
				tr.ScopeFieldSpecifiers[i].ElementID))
		}

		fields = append(fields, DecodedField{
			ID:    m.FieldID,
			Value: ipfix.Interpret(&b, m.Type),
		})
	}

	for i := 0; i < len(tr.FieldSpecifiers); i++ {
		b, err = r.Read(int(tr.FieldSpecifiers[i].Length))
		if err != nil {
			return nil, err
		}

		m, ok := ipfix.InfoModel[ipfix.ElementKey{
			0,
			tr.FieldSpecifiers[i].ElementID,
		}]

		if !ok {
			return nil, nonfatalError(fmt.Errorf("Netflow element key (%d) not exist",
				tr.FieldSpecifiers[i].ElementID))
		}

		fields = append(fields, DecodedField{
			ID:    m.FieldID,
			Value: ipfix.Interpret(&b, m.Type),
		})
	}

	return fields, nil
}

// NewDecoder constructs a decoder
func NewDecoder(raddr net.IP, b []byte) *Decoder {