go wait.Until(func() { c.serviceQueueWorker(logger) }, c.workerLoopPeriod, ctx.Done())
	}
	logger.V(2).Info("Starting topology queue worker threads", "total", 1)
	go wait.Until(func() { c.topologyQueueWorker(logger) }, c.workerLoopPeriod, ctx.Done())

	<-ctx.Done()
}

// serviceQueueWorker runs a worker thread that just dequeues items, processes