(ctx context.Context)
| 44 | } |
| 45 | |
| 46 | func (r *ringServiceDiscovery) starting(ctx context.Context) error { |
| 47 | r.subservicesWatcher.WatchService(r.ringClient) |
| 48 | |
| 49 | return errors.Wrap(services.StartAndAwaitRunning(ctx, r.ringClient), "failed to start ring client") |
| 50 | } |
| 51 | |
| 52 | func (r *ringServiceDiscovery) stopping(_ error) error { |
| 53 | return errors.Wrap(services.StopAndAwaitTerminated(context.Background(), r.ringClient), "failed to stop ring client") |
nothing calls this directly
no test coverage detected