redisqueue

Documentation

Index

• type Consumer
  • func (c *Consumer) AddRegions(regions []vm.Region) error
  • func (c *Consumer) OnError(fn queue.ErrorHandler)
  • func (c *Consumer) RemoveRegions(regions []vm.Region) error
• type Item
  • func (i *Item) Ack(ctx context.Context) error
  • func (i *Item) Nack(ctx context.Context) error
  • func (i *Item) Region() vm.Region
  • func (i *Item) Request() vm.Request
• type Queue
  • func New(rdb redis.UniversalClient, taskMgr *task.Manager) *Queue
  • func (q *Queue) Add(ctx context.Context, request vm.Request) error
  • func (q *Queue) CreateConsumer(ctx context.Context, fn queue.ConsumerFunc) (queue.Consumer, error)

Types

type Consumer

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

func (*Consumer) AddRegions

func (c *Consumer) AddRegions(regions []vm.Region) error

func (*Consumer) OnError

func (c *Consumer) OnError(fn queue.ErrorHandler)

func (*Consumer) RemoveRegions

func (c *Consumer) RemoveRegions(regions []vm.Region) error

type Item

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

func (*Item) Ack

func (i *Item) Ack(ctx context.Context) error

func (*Item) Nack

func (i *Item) Nack(ctx context.Context) error

func (*Item) Region

func (i *Item) Region() vm.Region

func (*Item) Request

func (i *Item) Request() vm.Request

type Queue

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

func New

func New(rdb redis.UniversalClient, taskMgr *task.Manager) *Queue

func (*Queue) Add

func (q *Queue) Add(ctx context.Context, request vm.Request) error

func (*Queue) CreateConsumer

func (q *Queue) CreateConsumer(ctx context.Context, fn queue.ConsumerFunc) (queue.Consumer, error)