Method writeHashEncodingEx

core/hash.go:381–437

(key string, hash map[string][]byte, expire map[string]int64, options ...interface{})

}

func (enc *Encoder) writeHashEncodingEx(key string, hash map[string][]byte, expire map[string]int64, options ...interface{}) error {
	err := enc.write([]byte{typeHashWithHfe})
	if err != nil {
		return err
	}
	err = enc.writeString(key)
	if err != nil {
		return err
	}
	// Hash with HFEs. min TTL at start (7.4+), 7.4RC not included
	// minExpire is the minimum non-zero expiration time across all fields,
	// used as a base for relative TTL encoding. Matches Redis hashTypeGetMinExpire().
	var minExpire int64 = EB_EXPIRE_TIME_INVALID
	for _, e := range expire {
		if e > 0 && e < minExpire {
			minExpire = e
		}
	}
	if minExpire == EB_EXPIRE_TIME_INVALID {
		// No field has expiration, use 0
		minExpire = 0
	}
	minExpireBytes := make([]byte, 8)
	binary.LittleEndian.PutUint64(minExpireBytes[:], uint64(minExpire))
	err = enc.write(minExpireBytes)
	if err != nil {
		return err
	}
	err = enc.writeLength(uint64(len(hash)))
	if err != nil {
		return err
	}
	for field, value := range hash {
		fieldExpire := expire[field]
		var ttl uint64
		if fieldExpire == 0 {
			// 0 indicates no TTL
			ttl = 0
		} else {
			// TTL is relative to minExpire (with +1 to avoid 0 that already taken)
			ttl = uint64(fieldExpire - minExpire + 1)
		}
		err = enc.writeLength(ttl)
		if err != nil {
			return err
		}
		err = enc.writeString(field)
		if err != nil {
			return err
		}
		err = enc.writeString(unsafeBytes2Str(value))
		if err != nil {
			return err
		}
	}
	return nil
}