redisqueue

Documentation

Index

• func UserExport(ctx context.Context, appProvider *deps.AppProvider, task *redisqueue.Task) (output json.RawMessage, err error)
• func UserImport(ctx context.Context, appProvider *deps.AppProvider, task *redisqueue.Task) (output json.RawMessage, err error)
• func UserReindex(ctx context.Context, appProvider *deps.AppProvider, task *redisqueue.Task) (output json.RawMessage, err error)
• type Consumer
  • func NewConsumer(ctx context.Context, queueName string, ...) *Consumer
  • func (c *Consumer) DisplayName() string
  • func (c *Consumer) Start(ctx context.Context, _ *log.Logger)
  • func (c *Consumer) Start0(ctx context.Context)
  • func (c *Consumer) Stop(ctx context.Context, _ *log.Logger) error
  • func (c *Consumer) Stop0(ctx context.Context)
• type TaskProcessor

Functions

func UserExport

func UserExport(ctx context.Context, appProvider *deps.AppProvider, task *redisqueue.Task) (output json.RawMessage, err error)

func UserImport

func UserImport(ctx context.Context, appProvider *deps.AppProvider, task *redisqueue.Task) (output json.RawMessage, err error)

func UserReindex

func UserReindex(ctx context.Context, appProvider *deps.AppProvider, task *redisqueue.Task) (output json.RawMessage, err error)

Types

type Consumer

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

func NewConsumer

func NewConsumer(ctx context.Context, queueName string, rateLimitConfig config.RateLimitsEnvironmentConfigEntry, rootProvider *deps.RootProvider, configSourceController *configsource.Controller, taskProcessor TaskProcessor) *Consumer

func (*Consumer) DisplayName

func (c *Consumer) DisplayName() string

func (*Consumer) Start

func (c *Consumer) Start(ctx context.Context, _ *log.Logger)

func (*Consumer) Start0

func (c *Consumer) Start0(ctx context.Context)

Start starts draining the queue and blocks indefinitely. It should be called with go.

func (*Consumer) Stop

func (c *Consumer) Stop(ctx context.Context, _ *log.Logger) error

func (*Consumer) Stop0

func (c *Consumer) Stop0(ctx context.Context)

type TaskProcessor

type TaskProcessor func(ctx context.Context, appProvider *deps.AppProvider, task *redisqueue.Task) (output json.RawMessage, err error)