locker

Oct 17, 2024

Changes in this version

+ var WaitInteval time.Duration = 50 * time.Millisecond

type Locker

+ WaitForLocker func(ctx context.Context, resource string, maxWait time.Duration, ...) (Release, error)

type RedisLocker

+ func (r *RedisLocker) WaitForLocker(ctx context.Context, resource string, maxWait time.Duration, ...) (Release, error)

Sep 5, 2024

Changes in this version

+ const LockerPrefix

+ var MaxLockerDuration time.Duration = 30 * time.Minute

Jun 11, 2024

Changes in this version

type Locker

+ func InitRedisLocker(logger *zap.Logger, client *redis.Client) Locker

+ type RedisLocker struct

+ Logger *zap.Logger

+ Maxtry uint

+ Timeout time.Duration

+ func (r *RedisLocker) Lock(ctx context.Context, resource string) (Release, error)

+ func (r *RedisLocker) LockWithtimeout(ctx context.Context, resource string, timeout time.Duration) (Release, error)

Nov 11, 2023

Changes in this version

+ type LocalLocker struct

+ func (ml *LocalLocker) Lock(ctx context.Context, resource string) (Release, error)

+ func (ml *LocalLocker) LockWithtimeout(ctx context.Context, resource string, timeout time.Duration) (Release, error)

+ type Locker interface

+ Lock func(ctx context.Context, resource string) (Release, error)

+ LockWithtimeout func(ctx context.Context, resource string, timeout time.Duration) (Release, error)

+ func InitLocalLocker() Locker

+ type Release func(context.Context) error