xredis

README

How to Use

• NewPreempt: Using redis to preempt locks and ensure uniqueness of execution tasks.

Documentation

Index

• Variables
• func Close() error
• type Preempt
  • func NewPreempt(ctx context.Context, db *eredis.Component, key string, ...) *Preempt
  • func (p *Preempt) Close()
• type Subscribe
  • func Init(ctx context.Context, client *redis.Client, ...) *Subscribe
  • func (s *Subscribe) Pub(ctx context.Context, channel string, message []byte) error
  • func (s *Subscribe) Sub(ctx context.Context, channel string) *redis.PubSub

Variables

var Subscribes = make([]*Subscribe, 0)

Functions

func Close

func Close() error

Close 消息订阅关闭

Types

type Preempt

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

func NewPreempt

func NewPreempt(ctx context.Context, db *eredis.Component, key string, startFunc, closeFunc func()) *Preempt

func (*Preempt) Close

func (p *Preempt) Close()

type Subscribe

type Subscribe struct {
	DbRedis *redis.Client
	// contains filtered or unexported fields
}

func Init

func Init(ctx context.Context, client *redis.Client, channels map[string]func(ctx context.Context, pubSub *redis.PubSub)) *Subscribe

Init 全局 Subscribe 初始化

func (*Subscribe) Pub

func (s *Subscribe) Pub(ctx context.Context, channel string, message []byte) error

Pub 发布

func (*Subscribe) Sub

func (s *Subscribe) Sub(ctx context.Context, channel string) *redis.PubSub

Sub 订阅