redispkg

Documentation

Index

• func IsNilErr(err error) bool
• func NewDB(conf *Config) (db redis.UniversalClient, err error)
• func NewLocker(redisCC redis.UniversalClient, opts ...redsync.Option) lockerpkg.Locker
• type Config
• type Locker
  • func (s *Locker) Mutex(ctx context.Context, lockName string) (locker lockerpkg.Unlocker, err error)
  • func (s *Locker) Once(ctx context.Context, lockName string) (locker lockerpkg.Unlocker, err error)

Functions

func IsNilErr

func IsNilErr(err error) bool

func NewDB

func NewDB(conf *Config) (db redis.UniversalClient, err error)

NewDB redis db

func NewLocker

func NewLocker(redisCC redis.UniversalClient, opts ...redsync.Option) lockerpkg.Locker

NewLocker ..

Types

type Config

type Config struct {
	Addresses    []string
	Username     string
	Password     string
	Db           uint32
	DialTimeout  *durationpb.Duration
	ReadTimeout  *durationpb.Duration
	WriteTimeout *durationpb.Duration
	// ConnMaxActive 连接的最大数量
	ConnMaxActive uint32
	// ConnMaxLifetime 连接可复用的最大时间
	ConnMaxLifetime *durationpb.Duration
	// ConnMaxIdle 连接池中空闲连接的最大数量
	ConnMaxIdle uint32
	ConnMinIdle uint32
	// ConnMaxIdleTime 设置连接空闲的最长时间
	ConnMaxIdleTime *durationpb.Duration
}

Config redis config

type Locker

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

Locker 锁

func (*Locker) Mutex

func (s *Locker) Mutex(ctx context.Context, lockName string) (locker lockerpkg.Unlocker, err error)

Mutex ...

func (*Locker) Once

func (s *Locker) Once(ctx context.Context, lockName string) (locker lockerpkg.Unlocker, err error)

Once ...