kredis

Documentation

Index

• Variables
• func Close() error
• type Subscribe
  • func Init(ctx context.Context, client *redis.Client, ...) *Subscribe
  • 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 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) Sub

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

Sub 订阅