feat: ErrLockReleased

Author: wolfogre

modules/globallock/globallock.go

@@ -5,6 +5,7 @@ package globallock
 
 import (
 	"context"
+	"fmt"
 )
 
 type Locker interface {
@@ -13,3 +14,6 @@ type Locker interface {
 }
 
 type ReleaseFunc func() context.Context
+
+// ErrLockReleased is used as context cause when a lock is released
+var ErrLockReleased = fmt.Errorf("lock released")

modules/globallock/memory_locker.go

@@ -5,7 +5,6 @@ package globallock
 
 import (
 	"context"
-	"fmt"
 	"sync"
 	"time"
 )
@@ -29,7 +28,7 @@ func (l *memoryLocker) Lock(ctx context.Context, key string) (context.Context, R
 		return ctx, func() context.Context {
 			releaseOnce.Do(func() {
 				l.locks.Delete(key)
-				cancel(fmt.Errorf("release"))
+				cancel(ErrLockReleased)
 			})
 			return originalCtx
 		}, nil
@@ -48,7 +47,7 @@ func (l *memoryLocker) Lock(ctx context.Context, key string) (context.Context, R
 				return ctx, func() context.Context {
 					releaseOnce.Do(func() {
 						l.locks.Delete(key)
-						cancel(fmt.Errorf("release"))
+						cancel(ErrLockReleased)
 					})
 					return originalCtx
 				}, nil
@@ -65,7 +64,7 @@ func (l *memoryLocker) TryLock(ctx context.Context, key string) (bool, context.C
 		releaseOnce := sync.Once{}
 		return true, ctx, func() context.Context {
 			releaseOnce.Do(func() {
-				cancel(fmt.Errorf("release"))
+				cancel(ErrLockReleased)
 				l.locks.Delete(key)
 			})
 			return originalCtx

modules/globallock/redis_locker.go

@@ -6,7 +6,6 @@ package globallock
 import (
 	"context"
 	"errors"
-	"fmt"
 	"sync"
 	"time"
 
@@ -96,7 +95,7 @@ func (l *redisLocker) lock(ctx context.Context, key string, tries int) (context.
 			// Do not call mutex.UnlockContext(ctx) here, or it will fail to release when ctx has timed out.
 			_, _ = mutex.Unlock()
 
-			cancel(fmt.Errorf("release"))
+			cancel(ErrLockReleased)
 		})
 		return originalCtx
 	}, nil