Method getSetFromDB

structure/set.go:375–401

GetSetFromDB retrieves a set from database given a key. If createIfNotExist is true, a new set will be created if the key is not found. It returns the file sets and any write error encountered.

(key []byte, createIfNotExist bool)

// GetSetFromDB retrieves a set from database given a key. If createIfNotExist is true,
// a new set will be created if the key is not found. It returns the file sets and any write error encountered.
func (s *SetStructure) getSetFromDB(key []byte, createIfNotExist bool) (*FSets, int64, error) {
	if s.db == nil {
		return nil, 0, ErrSetNotInitialized
	}
	var zSetValueWithTTL FSetWithTTL
	dbData, err := s.db.Get(key)

	// If key is not found, return nil for both; otherwise return the error.
	if err != nil {
		if errors.Is(err, _const.ErrKeyNotFound) && createIfNotExist {
			return &FSets{}, 0, nil
		}
		return nil, 0, err
	} else {
		err = encoding.NewMessagePackDecoder(dbData).Decode(&zSetValueWithTTL) // Decode the value along with TTL
		if err != nil {
			return nil, 0, err
		}

		expiration := zSetValueWithTTL.TTL
		if expiration != 0 && expiration < time.Now().UnixNano() {
			return nil, -1, _const.ErrKeyIsExpired
		}

		return zSetValueWithTTL.ZSet, zSetValueWithTTL.TTL, nil // Return the zSetValue and TTL
	}
}

type FSetWithTTL struct {
	ZSet *FSets