redis_subscribe

package

v0.0.7 Latest Latest Go to latest Published: Dec 31, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewSubscribe(redis *redis.Client) *Subscribe

func (s *Subscribe) Pub(ctx context.Context, topic string, payload string) error

func (s *Subscribe) Sub(ctx context.Context, topic string, r chan string) error

Sub 订阅消息 TODO 未验证 redis 断线重连，不确定有没有问题