in pkg/telemetry/telemetry.go [299:310]
func (t *Telemetry) sendAll() {
records := t.collectAllRecords()
recordsNoSend, err := t.sendRecords(records)
if err != nil {
log.Debugf("Failed to send telemetry %v record(s). Re-queue records. %v", len(records), err)
// There might be possibility that new records might be archived during re-queue records.
// But as timer is set after records are send this will not happen
for _, record := range recordsNoSend {
t.add(record)
}
}
}