sync

Documentation

Index

• type MutexRedis
  • func MutexWrap(c redis.Client) *MutexRedis
  • func (m *MutexRedis) Expire(ctx context.Context, key string, expiration time.Duration) *goredis.BoolCmd
  • func (m *MutexRedis) Get(ctx context.Context, key string) *goredis.StringCmd
  • func (m *MutexRedis) Persist(ctx context.Context, key string) *goredis.BoolCmd
  • func (m *MutexRedis) SAdd(ctx context.Context, key string, values ...interface{}) *goredis.IntCmd
  • func (m *MutexRedis) SMembers(ctx context.Context, key string) *goredis.StringSliceCmd
  • func (m *MutexRedis) Set(ctx context.Context, key string, value any, expiration time.Duration) *goredis.StatusCmd

Types

type MutexRedis

type MutexRedis struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func MutexWrap

func MutexWrap(c redis.Client) *MutexRedis

func (*MutexRedis) Expire

func (m *MutexRedis) Expire(ctx context.Context, key string, expiration time.Duration) *goredis.BoolCmd

func (*MutexRedis) Get

func (m *MutexRedis) Get(ctx context.Context, key string) *goredis.StringCmd

func (*MutexRedis) Persist

func (m *MutexRedis) Persist(ctx context.Context, key string) *goredis.BoolCmd

func (*MutexRedis) SAdd

func (m *MutexRedis) SAdd(ctx context.Context, key string, values ...interface{}) *goredis.IntCmd

func (*MutexRedis) SMembers

func (m *MutexRedis) SMembers(ctx context.Context, key string) *goredis.StringSliceCmd

func (*MutexRedis) Set

func (m *MutexRedis) Set(ctx context.Context, key string, value any, expiration time.Duration) *goredis.StatusCmd