Method SFDecode

sflow/decoder.go:95–135

SFDecode decodes sFlow data

()

// SFDecode decodes sFlow data
func (d *SFDecoder) SFDecode() (*SFDatagram, error) {
	datagram, err := d.sfHeaderDecode()
	if err != nil {
		return nil, err
	}

	datagram.Samples = []Sample{}
	datagram.Counters = []Counter{}

	for i := uint32(0); i < datagram.SamplesNo; i++ {
		sfTypeFormat, sfDataLength, err := d.getSampleInfo()
		if err != nil {
			return nil, err
		}

		if m := d.isFilterMatch(sfTypeFormat); m {
			d.reader.Seek(int64(sfDataLength), 1)
			continue
		}

		switch sfTypeFormat {
		case DataFlowSample:
			d, err := decodeFlowSample(d.reader)
			if err != nil {
				return datagram, err
			}
			datagram.Samples = append(datagram.Samples, d)
		case DataCounterSample:
			d, err := decodeFlowCounter(d.reader)
			if err != nil {
				return datagram, err
			}
			datagram.Counters = append(datagram.Counters, d)
		default:
			d.reader.Seek(int64(sfDataLength), 1)
		}

	}

	return datagram, nil
}

func (d *SFDecoder) sfHeaderDecode() (*SFDatagram, error) {
	var (