mutex

Documentation

Index

• func InitCluster(ctx context.Context)
• func IsMaster() bool
• type ClusterMutex
  • func NewClusterMutex(ctx context.Context, cli *redis.Client, name string) *ClusterMutex
  • func (m *ClusterMutex) IsMaster() bool
• type RedisLocker
  • func NewRedisLocker(rds *redis.Client, name string, timeout time.Duration) *RedisLocker
  • func (l *RedisLocker) Lock()
  • func (l *RedisLocker) Unlock()

Functions

func InitCluster

func InitCluster(ctx context.Context)

func IsMaster

func IsMaster() bool

Types

type ClusterMutex

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

func NewClusterMutex

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

func (*ClusterMutex) IsMaster

func (m *ClusterMutex) IsMaster() bool

IsMaster 是否是主节点

type RedisLocker

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

RedisLocker .

func NewRedisLocker

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

NewRedisLocker TODO

func (*RedisLocker) Lock

func (l *RedisLocker) Lock()

Lock .

func (*RedisLocker) Unlock

func (l *RedisLocker) Unlock()

Unlock .