(s ...services.Service)
| 137 | } |
| 138 | |
| 139 | func (q *Querier) RegisterSubservices(s ...services.Service) error { |
| 140 | var err error |
| 141 | q.subservices, err = services.NewManager(s...) |
| 142 | q.subservicesWatcher = services.NewFailureWatcher() |
| 143 | q.subservicesWatcher.WatchManager(q.subservices) |
| 144 | return err |
| 145 | } |
| 146 | |
| 147 | func (q *Querier) starting(ctx context.Context) error { |
| 148 | if q.subservices != nil { |
no outgoing calls
no test coverage detected