gcpqueue

Documentation

Overview

Package gcpqueue provides a GCP queue implementation that can be used for asynchronous scheduling of fetch actions.

Index

• func New(ctx context.Context, cfg *config.Config, queueName string, numWorkers int, ...) (queue.Queue, error)

Functions

func New

func New(ctx context.Context, cfg *config.Config, queueName string, numWorkers int, expGetter middleware.ExperimentGetter, processFunc queue.InMemoryProcessFunc) (queue.Queue, error)

New creates a new Queue with name queueName based on the configuration in cfg. When running locally, Queue uses numWorkers concurrent workers.