sink

type Sink interface {
	Init(conf *config.Config)

	// Connect starts handling tasks in the queue
	// the Sink must close when the src channel closes
	// must not block
	Connect(src <-chan deps.Dep) (err error)
}