redis_mutex

Documentation

Index

• Constants
• type RedisMutex
  • func NewRedisMutex(client *redis.Client) *RedisMutex
  • func (r *RedisMutex) Lock(ctx context.Context, key string) error
  • func (r *RedisMutex) TryLock(ctx context.Context, key string) (bool, error)
  • func (r *RedisMutex) Unlock(ctx context.Context, key string) error
• type RedisRWMutex
  • func NewRedisRWMutex(client *redis.Client) *RedisRWMutex
  • func (r *RedisRWMutex) Lock(ctx context.Context, key string) error
  • func (r *RedisRWMutex) RLock(ctx context.Context, key string) error
  • func (r *RedisRWMutex) RUnlock(ctx context.Context, key string) error
  • func (r *RedisRWMutex) Unlock(ctx context.Context, key string) error

Constants

const (
	DefaultMutexTTL      = time.Second * 5
	DefaultCheckInterval = time.Millisecond * 20
)

const (
	WLockKeyPrefix string = "w-lock:"
	RLockKeyPrefix string = "r-lock:"
)

Types

type RedisMutex

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

func NewRedisMutex

func NewRedisMutex(client *redis.Client) *RedisMutex

func (*RedisMutex) Lock

func (r *RedisMutex) Lock(ctx context.Context, key string) error

func (*RedisMutex) TryLock

func (r *RedisMutex) TryLock(ctx context.Context, key string) (bool, error)

func (*RedisMutex) Unlock

func (r *RedisMutex) Unlock(ctx context.Context, key string) error

type RedisRWMutex

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

func NewRedisRWMutex

func NewRedisRWMutex(client *redis.Client) *RedisRWMutex

func (*RedisRWMutex) Lock

func (r *RedisRWMutex) Lock(ctx context.Context, key string) error

func (*RedisRWMutex) RLock

func (r *RedisRWMutex) RLock(ctx context.Context, key string) error

func (*RedisRWMutex) RUnlock

func (r *RedisRWMutex) RUnlock(ctx context.Context, key string) error

func (*RedisRWMutex) Unlock

func (r *RedisRWMutex) Unlock(ctx context.Context, key string) error