in datahub/binaryrecord.go [427:447]
func (serializer *binaryRecordContextSerializer) deserializeRecordHeader(reader *bytes.Reader) (*binaryRecordHeader, error) {
if reader.Len() < binaryRecordHeaderSize {
return nil, fmt.Errorf("data length is not enough for BinaryRecordHeader(%d)", binaryRecordHeaderSize)
}
header := &binaryRecordHeader{}
if err := binary.Read(reader, binary.LittleEndian, &header.encodeType); err != nil {
return nil, err
}
if err := binary.Read(reader, binary.LittleEndian, &header.schemaVersion); err != nil {
return nil, err
}
if err := binary.Read(reader, binary.LittleEndian, &header.totalSize); err != nil {
return nil, err
}
if err := binary.Read(reader, binary.LittleEndian, &header.attrOffset); err != nil {
return nil, err
}
return header, nil
}