(client TelemetryClient)
| 729 | } |
| 730 | |
| 731 | func (b *BasicTelemetryController) New(client TelemetryClient) { |
| 732 | b.Lock() |
| 733 | defer b.Unlock() |
| 734 | b.client = client |
| 735 | b.unavailable = false |
| 736 | b.logger.Debug(context.Background(), "new telemetry client connected to controller") |
| 737 | } |
| 738 | |
| 739 | func (b *BasicTelemetryController) SendTelemetryEvent(event *proto.TelemetryEvent) { |
| 740 | b.Lock() |