redlock

Documentation

Index

• type RedLock
  • func NewRedLock(redis connectors.DBConnector[*redis.Client, *types.RedisTx], ...) (*RedLock, error)
  • func (rl *RedLock) DoUnderLock(ctx context.Context, key string, f func(ctx context.Context) error) error
• type RedLockOption
  • func WithExpireOption(expire time.Duration) RedLockOption
  • func WithRetryCountOption(retryCount int) RedLockOption
  • func WithRetryDelayOption(delay time.Duration) RedLockOption

Types

type RedLock

type RedLock struct {
	// contains filtered or unexported fields
}

func NewRedLock

func NewRedLock(
	redis connectors.DBConnector[*redis.Client, *types.RedisTx],
	opts ...RedLockOption,
) (*RedLock, error)

func (*RedLock) DoUnderLock

func (rl *RedLock) DoUnderLock(ctx context.Context, key string, f func(ctx context.Context) error) error

type RedLockOption

type RedLockOption func(rl *RedLock)

func WithExpireOption

func WithExpireOption(expire time.Duration) RedLockOption

func WithRetryCountOption

func WithRetryCountOption(retryCount int) RedLockOption

func WithRetryDelayOption

func WithRetryDelayOption(delay time.Duration) RedLockOption