redis

Documentation

Index

• Constants
• type Consumer
  • func NewConsumer(configName string, config config.Config) (consumer *Consumer, err error)
  • func (consumer *Consumer) Close() error
  • func (consumer *Consumer) Connect() (err error)
  • func (consumer *Consumer) Consume(task queue.TaskInfo, callback queue.ConsumeCallback) (err error)
  • func (consumer *Consumer) Start() error
  • func (consumer *Consumer) Unconsume(queue string)
• type Producer
  • func NewProducer(config config.Config, opts ...queue.Option) (m *Producer, err error)
  • func (p *Producer) BatchPush(ctx context.Context, key string, msgList ...queue.Message) error
  • func (c *Producer) Close() error
  • func (c *Producer) DelayPush(ctx context.Context, key string, msg queue.Message, delaySeconds int64) error
  • func (c *Producer) Push(ctx context.Context, key string, msg queue.Message) error
• type ProductOptions
• type QueueItem

Constants

const (
	Proto = "redis"
)

Types

type Consumer

type Consumer struct {
	EnableDeadLetter bool //开启死信队列
	DeadLetterQueue  string
	// contains filtered or unexported fields
}

Consumer Consumer

func NewConsumer

func NewConsumer(configName string, config config.Config) (consumer *Consumer, err error)

NewConsumerByConfig 创建新的Consumer

func (*Consumer) Close

func (consumer *Consumer) Close() error

Close 关闭当前连接

func (*Consumer) Connect

func (consumer *Consumer) Connect() (err error)

Connect 连接服务器

func (*Consumer) Consume

func (consumer *Consumer) Consume(task queue.TaskInfo, callback queue.ConsumeCallback) (err error)

Consume 注册消费信息

func (*Consumer) Start

func (consumer *Consumer) Start() error

Start 启动

func (*Consumer) Unconsume

func (consumer *Consumer) Unconsume(queue string)

UnConsume 取消注册消费

type Producer

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

Producer memcache配置文件

func NewProducer

func NewProducer(config config.Config, opts ...queue.Option) (m *Producer, err error)

NewProducerByConfig 根据配置文件创建一个redis连接

func (*Producer) BatchPush

func (p *Producer) BatchPush(ctx context.Context, key string, msgList ...queue.Message) error

func (*Producer) Close

func (c *Producer) Close() error

Close 释放资源

func (*Producer) DelayPush

func (c *Producer) DelayPush(ctx context.Context, key string, msg queue.Message, delaySeconds int64) error

Push 向存于 key 的列表的尾部插入所有指定的值

func (*Producer) Push

func (c *Producer) Push(ctx context.Context, key string, msg queue.Message) error

Push 向存于 key 的列表的尾部插入所有指定的值

type ProductOptions

type ProductOptions struct {
	DelayInterval int `json:"delay_interval" yaml:"delay_interval"`
}

type QueueItem

type QueueItem struct {
	QueueName    string
	Concurrency  int //等于0 ，代表不限制
	BlockTimeout int
	// contains filtered or unexported fields
}