Documentation
¶
Overview ¶
Package gcpqueue provides a GCP queue implementation that can be used for asynchronous scheduling of fetch actions.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.