redis

Documentation

Index

• type Redis
  • func New(rs *pipeline.Redis) (r *Redis, err error)
  • func (r *Redis) Close() error
  • func (r *Redis) Send(msg *message2.Message) (ok bool, err error)

Types

type Redis

type Redis struct {
	Redis  *pipeline.Redis
	Client *redis.Client
}

Reids send message to Redis

func New

func New(rs *pipeline.Redis) (r *Redis, err error)

New returns a new Reids instance

func (*Redis) Close

func (r *Redis) Close() error

func (*Redis) Send

func (r *Redis) Send(msg *message2.Message) (ok bool, err error)

Send loginc and control