allow unknown records for sFlow (#155)

netsampler · Apr 16, 2023 · 958109e · 958109e
1 parent 5d47e60
commit 958109e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/decoders/sflow/packet.go b/decoders/sflow/packet.go
@@ -60,17 +60,13 @@ type RecordHeader struct {
 
 type FlowRecord struct {
 	Header RecordHeader
-	Data   interface{} // replace by FlowRecordData
+	Data   interface{}
 }
 
 type FlowRecordRaw struct {
 	Data []byte
 }
 
-type FlowRecordData interface {
-	GetBytes(offset int, length int, dst []byte) error
-}
-
 type CounterRecord struct {
 	Header RecordHeader
 	Data   interface{}

diff --git a/decoders/sflow/sflow.go b/decoders/sflow/sflow.go
@@ -94,7 +94,9 @@ func DecodeCounterRecord(header *RecordHeader, payload *bytes.Buffer) (CounterRe
 		}
 		counterRecord.Data = ethernetCounters
 	default:
-		return counterRecord, NewErrorDataFormat((*header).DataFormat)
+		counterRecord.Data = &FlowRecordRaw{
+			Data: payload.Next(int(header.Length)),
+		}
 	}
 
 	return counterRecord, nil