func()

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
}