Method CheckAndSetReference

pkg/cache/redis/reference.go:52–105

(new, old *plumbing.Reference)

}

func (r *ReferenceStorage) CheckAndSetReference(new, old *plumbing.Reference) error {
	if new == nil {
		return errors.New("new reference cannot be nil")
	}

	key := withNamespace(r.namespacePrefix, referencePrefix, new.Name().String())

	// The transaction function. It will be retried if the watched keys change.
	txnFunc := func(tx *redis.Tx) error {
		// Get the current reference data.
		data, err := tx.Get(ctx, key).Bytes()
		if err != nil && err != redis.Nil {
			return err
		}

		// If old reference is provided, ensure the current reference matches.
		if old != nil {
			if err == redis.Nil {
				return storage.ErrReferenceHasChanged // Reference was expected but not found.
			}

			currentRef, err := jsonToReference(data)
			if err != nil {
				return err
			}

			if currentRef.Hash() != old.Hash() {
				return storage.ErrReferenceHasChanged // Hash mismatch indicates concurrent update.
			}
		}

		// If the reference was found or no old reference was provided, proceed to set the new reference.
		newRefMap, err := referenceToMap(new)
		if err != nil {
			return err
		}

		newData, err := json.Marshal(newRefMap)
		if err != nil {
			return err
		}

		// Set the new reference data inside the transaction.
		_, err = tx.Pipelined(ctx, func(pipe redis.Pipeliner) error {
			pipe.Set(ctx, key, newData, 0)
			return nil
		})

		return err
	}

	// Execute the transaction.
	return r.client.Watch(ctx, txnFunc, key)
}

// PackRefs implements storage.Storer.
func (s *ReferenceStorage) PackRefs() error {