(ctx context.Context)
| 187 | } |
| 188 | |
| 189 | func (s *Server) publishTelemetry(ctx context.Context) { |
| 190 | go func() { |
| 191 | defer s.handlePanic("publishTelemetry") |
| 192 | |
| 193 | for { |
| 194 | select { |
| 195 | case <-ctx.Done(): |
| 196 | return |
| 197 | default: |
| 198 | time.Sleep(time.Second * 60) |
| 199 | _, _ = s.telemetry.Publish(ctx) |
| 200 | } |
| 201 | } |
| 202 | }() |
| 203 | } |
| 204 | |
| 205 | func (s *Server) handleRecovered(method string, recovered interface{}) bool { |
| 206 | if recovered != nil { |
no test coverage detected