package gcpqueue

import "golang.org/x/pkgsite/internal/queue/gcpqueue"

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, expGetter middleware.ExperimentGetter, processFunc queue.InMemoryProcessFunc) (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.

Source Files ¶

queue.go