package redisx

import (
	"context"

	"github.com/redis/go-redis/v9"
)

// 管道与事务

func Pipeline(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error) {
	pipe := getClient().Pipeline()
	err := fn(pipe)
	if err != nil {
		return nil, err
	}
	return pipe.Exec(ctx)
}