mutex

Mar 9, 2025

Changes in this version

+ func InitCluster(ctx context.Context)

+ func IsMaster() bool

+ type ClusterMutex struct

+ func NewClusterMutex(ctx context.Context, cli *redis.Client, name string) *ClusterMutex

+ func (m *ClusterMutex) IsMaster() bool

+ type RedisLocker struct

+ func NewRedisLocker(rds *redis.Client, name string, timeout time.Duration) *RedisLocker

+ func (l *RedisLocker) Lock()

+ func (l *RedisLocker) Unlock()