func()

in datahub/binaryrecord.go [556:587]

• 29 lines of code
• 5 McCabe index (conditional complexity)

func (serializer *binaryRecordContextSerializer) binaryRecord2DhRecord(bRecord *binaryRecord, meta *respMeta, schema *RecordSchema) (IRecord, error) {
	var record IRecord
	var err error

	if schema != nil {
		record, err = serializer.binary2TupleRecord(bRecord, schema)
		if err != nil {
			return nil, err
		}
	} else {
		record, err = serializer.binary2BlobRecord(bRecord)
		if err != nil {
			return nil, err
		}
	}

	baseRecord := BaseRecord{
		ShardId:    serializer.shardId,
		SystemTime: meta.systemTime,
		Sequence:   meta.sequence,
		Cursor:     meta.cursor,
		NextCursor: meta.nextCursor,
		Serial:     meta.serial,
	}
	attributes := bRecord.getAttributes()
	for key, val := range attributes {
		baseRecord.SetAttribute(key, val)
	}
	record.SetBaseRecord(baseRecord)

	return record, nil
}