lock

Documentation

Index

• type Locker
  • func GetLocker(rdb redis.UniversalClient) *Locker
  • func (l *Locker) Obtain(ctx context.Context, key string, ttl int, opt ...*redislock.Options) (*redislock.Lock, error)
  • func (l *Locker) ObtainWaitExponentialRetry(ctx context.Context, key string, ttl int, maxWaitTime int) (*redislock.Lock, error)
  • func (l *Locker) ObtainWaitRetry(ctx context.Context, key string, ttl int, retryCount int) (*redislock.Lock, error)

Types

type Locker

type Locker struct {
	Locker *redislock.Client
}

func GetLocker

func GetLocker(rdb redis.UniversalClient) *Locker

func (*Locker) Obtain

func (l *Locker) Obtain(ctx context.Context, key string, ttl int, opt ...*redislock.Options) (*redislock.Lock, error)

func (*Locker) ObtainWaitExponentialRetry

func (l *Locker) ObtainWaitExponentialRetry(ctx context.Context, key string, ttl int, maxWaitTime int) (*redislock.Lock, error)

func (*Locker) ObtainWaitRetry

func (l *Locker) ObtainWaitRetry(ctx context.Context, key string, ttl int, retryCount int) (*redislock.Lock, error)