type golang.org/x/pkgsite/internal/queue.inMemoryProcessFunc

3 uses

	golang.org/x/pkgsite/internal/queue (current package)
		queue.go#L39: func New(ctx context.Context, cfg *config.Config, queueName string, numWorkers int, expGetter middleware.ExperimentGetter, processFunc inMemoryProcessFunc) (Queue, error) {
		queue.go#L228: type inMemoryProcessFunc func(context.Context, string, string) (int, error)
		queue.go#L233: func NewInMemory(ctx context.Context, workerCount int, experiments []string, processFunc inMemoryProcessFunc) *InMemory {