func (d *Discovery) Run(ctx context.Context, in chan<- []*confgroup.Group) {
    d.Info("instance is started")
    defer func() { d.Info("instance is stopped") }()

    select {