From 44ca97b7d0394a9f334158b53d678ed1874a645e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= Date: Thu, 20 Mar 2025 11:27:35 +0800 Subject: [PATCH] redis lock --- internal/pkg/lock/mutex.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/pkg/lock/mutex.go b/internal/pkg/lock/mutex.go index 1eb23d4..9df58f2 100644 --- a/internal/pkg/lock/mutex.go +++ b/internal/pkg/lock/mutex.go @@ -2,6 +2,7 @@ package lock import ( "context" + "fmt" "github.com/redis/go-redis/v9" "time" ) @@ -21,7 +22,7 @@ func (c *Mutex) Lock(ctx context.Context, resource string, callback func(ctx con l := c.locker.GetLock(resource) if err := l.Lock(ctx); err != nil { - return err + return fmt.Errorf("lock failed: %w", err) } defer func() { _ = l.Unlock(ctx)