poll

type Config struct {
	Type        string `koanf:"type"`
	Concurrency int    `koanf:"concurrency"`
}

type LaunchConfig struct {
	Queues          []queue.Queue
	Poller          Poller
	Processor       process.Processor
	QueueCancelFunc context.CancelFunc
	TransformFunc   transform.TransformationFunc
	Concurrency     int
}

type Poller func(ctx context.Context, wg *sync.WaitGroup, queues []queue.Queue, proc process.Processor, trans transform.TransformationFunc)