go_delay_driver_redis

README

go-delay-driver-redis

how to use

https://github.com/wsqun/go-delay-queue

Documentation

Index

• type Dredis
  • func NewDredis(addr, pwd string, opt ...OptFn) (dr *Dredis, err error)
  • func (dr *Dredis) PublishMsg(topic string, msg []byte) (err error)
  • func (dr *Dredis) SubscribeMsg(topic string, dealFn func([]byte) (err error)) (err error)
• type OptFn

Types

type Dredis

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

func NewDredis

func NewDredis(addr, pwd string, opt ...OptFn) (dr *Dredis, err error)

func (*Dredis) PublishMsg

func (dr *Dredis) PublishMsg(topic string, msg []byte) (err error)

func (*Dredis) SubscribeMsg

func (dr *Dredis) SubscribeMsg(topic string, dealFn func([]byte) (err error)) (err error)

type OptFn

type OptFn func(cfg *redis.Options)