rdb

Documentation

Overview

Package rdb Redis工具.

Index

• Variables
• type InstanceNum
  • func NewInstanceNum(client redis.Cmdable) *InstanceNum
  • func NewInstanceNumByKey(client redis.Cmdable, key string) *InstanceNum
  • func (p *InstanceNum) Num() int
  • func (p *InstanceNum) Register(observer chan<- uint64)
  • func (p *InstanceNum) Run()
• type Locker
  • func NewLocker(client redis.Cmdable, times ...time.Duration) *Locker
  • func (p *Locker) Lock(key string, yield func() error) error

Examples

• Locker

Variables

var (
	ErrLock   = errors.New("is lock")
	ErrExpire = errors.New("expire time too long")
)

Types

type InstanceNum

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

InstanceNum 实例数量.

func NewInstanceNum

func NewInstanceNum(client redis.Cmdable) *InstanceNum

NewInstanceNum 新建实例数量.

func NewInstanceNumByKey

func NewInstanceNumByKey(client redis.Cmdable, key string) *InstanceNum

func (*InstanceNum) Num

func (p *InstanceNum) Num() int

Num 实例数量.

func (*InstanceNum) Register

func (p *InstanceNum) Register(observer chan<- uint64)

Register 订阅主题.

func (*InstanceNum) Run

func (p *InstanceNum) Run()

Run 运行.

使用 redis INCR 命令计算一秒内增加的数量得出实例数量.

type Locker

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

Locker 分布式锁.

Example

nolint: testableexamples

client := redis.NewClient(&redis.Options{
	Addr:     "192.168.1.11:6379",
	Password: "",
	DB:       0,
})
locker := rdb.NewLocker(client)

_ = locker.Lock("test", func() error {
	// do something
	return nil
})

func NewLocker

func NewLocker(client redis.Cmdable, times ...time.Duration) *Locker

NewLocker 新建分布式锁. times[0] 锁时间, times[1] 续期间隔.

func (*Locker) Lock

func (p *Locker) Lock(key string, yield func() error) error

Lock 锁成功则执行，执行完毕解锁.