subscribe

Documentation

Index

• func NewRedisSubscribe()
• type RedisSubscribe
  • func (s *RedisSubscribe) Publish(channel string, message any) error
  • func (s *RedisSubscribe) Subscribe(channel string, callback handler.SubscribeCallback)
• type SubPub

Functions

func NewRedisSubscribe

func NewRedisSubscribe()

Types

type RedisSubscribe

type RedisSubscribe struct {
}

func (*RedisSubscribe) Publish

func (s *RedisSubscribe) Publish(channel string, message any) error

Publish 发布数据

func (*RedisSubscribe) Subscribe

func (s *RedisSubscribe) Subscribe(channel string, callback handler.SubscribeCallback)

Subscribe 订阅消息

type SubPub

type SubPub interface {
	// Subscribe 订阅消息
	Subscribe(channel string, callback handler.SubscribeCallback)
	// Publish 发布消息
	Publish(channel string, message any) error
}

SubPub 消息发布定义

var SubscribeHandler SubPub