type Sink struct { Config *config.Config Scheduled chan deps.Dep // Replies for the backend Replies chan deps.Reply }
Sink implements sink.Sink
func (sink *Sink) Connect(src <-chan deps.Dep) (err error)
Connect connects the sink and starts handling incoming deployments
func (sink *Sink) Init(conf *config.Config)
Init initializes the sink