rds

Documentation

Index

• func Ins(id ...string) redis.Conn
• type Subscriber
  • func NewSubscriber(conn redis.Conn, topic string) (*Subscriber, error)
  • func (s *Subscriber) Close()
  • func (s *Subscriber) Subscribe(cb func([]byte)) error

Functions

func Ins

func Ins(id ...string) redis.Conn

返回 redis 的一个连接

Types

type Subscriber

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

func NewSubscriber

func NewSubscriber(conn redis.Conn, topic string) (*Subscriber, error)

func (*Subscriber) Close

func (s *Subscriber) Close()

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(cb func([]byte)) error