redismq

Documentation

Index

• type Option
  • func WithRedisGroup(group string) Option
• type Options
• type Queue
  • func New(topic string, opts ...Option) *Queue
  • func (q *Queue) Consume(ctx context.Context) (string, error)
  • func (q *Queue) Produce(ctx context.Context, messages []string) error

Types

type Option

type Option func(*Options)

func WithRedisGroup

func WithRedisGroup(group string) Option

type Options

type Options struct {
	Group string
}

type Queue

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

func New

func New(topic string, opts ...Option) *Queue

func (*Queue) Consume

func (q *Queue) Consume(ctx context.Context) (string, error)

Consume 消费队列中的信息.

func (*Queue) Produce

func (q *Queue) Produce(ctx context.Context, messages []string) error

Produce 生产消息到队列.