* use cns logger lib

* use cns logger lib

* fix linter issues

* add [Azure CNS]

* remove [Azure CNS] log
This commit is contained in:
Paul Yu 2024-11-21 14:05:20 -05:00 коммит произвёл GitHub
Родитель b30cdc3c7b
Коммит bf080b93ae
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: B5690EEEBB952194
1 изменённых файлов: 8 добавлений и 8 удалений

Просмотреть файл

@ -365,9 +365,9 @@ func init() {
// Wait until receiving a signal.
select {
case sig := <-sigCh:
log.Errorf("caught exit signal %v, exiting", sig)
logger.Errorf("caught exit signal %v, exiting", sig)
case err := <-rootErrCh:
log.Errorf("unhandled error %v, exiting", err)
logger.Errorf("unhandled error %v, exiting", err)
}
cancel()
}()
@ -428,7 +428,7 @@ func sendRegisterNodeRequest(ctx context.Context, httpClient httpDoer, httpRestS
var body bytes.Buffer
err := json.NewEncoder(&body).Encode(nodeRegisterRequest)
if err != nil {
log.Errorf("[Azure CNS] Failed to register node while encoding json failed with non-retryable err %v", err)
logger.Errorf("Failed to register node while encoding json failed with non-retryable err %v", err)
return errors.Wrap(retry.Unrecoverable(err), "failed to sendRegisterNodeRequest")
}
@ -454,7 +454,7 @@ func sendRegisterNodeRequest(ctx context.Context, httpClient httpDoer, httpRestS
var req cns.SetOrchestratorTypeRequest
err = json.NewDecoder(response.Body).Decode(&req)
if err != nil {
log.Errorf("[Azure CNS] decoding Node Register response json failed with err %v", err)
logger.Errorf("decoding Node Register response json failed with err %v", err)
return errors.Wrap(err, "failed to sendRegisterNodeRequest")
}
httpRestService.SetNodeOrchestrator(&req)
@ -469,7 +469,7 @@ func startTelemetryService(ctx context.Context) {
tb := telemetry.NewTelemetryBuffer(nil)
err := tb.CreateAITelemetryHandle(config, false, false, false)
if err != nil {
log.Errorf("AI telemetry handle creation failed..:%w", err)
logger.Errorf("AI telemetry handle creation failed: %v", err)
return
}
@ -478,9 +478,9 @@ func startTelemetryService(ctx context.Context) {
tbtemp.Cleanup(telemetry.FdName)
err = tb.StartServer()
log.Printf("Telemetry service for CNI started")
logger.Printf("Telemetry service for CNI started")
if err != nil {
log.Errorf("Telemetry service failed to start: %w", err)
logger.Errorf("Telemetry service failed to start: %v", err)
return
}
tb.PushData(ctx)
@ -1484,7 +1484,7 @@ func InitializeCRDState(ctx context.Context, httpRestService cns.HTTPService, cn
// this false and the NNC Reconciler stuck/failed, log and retry.
nncReadyCtx, cancel := context.WithTimeout(ctx, 15*time.Minute) //nolint // it will time out and not leak
if started, err := nncReconciler.Started(nncReadyCtx); !started {
log.Errorf("NNC reconciler has not started, does the NNC exist? err: %v", err)
logger.Errorf("NNC reconciler has not started, does the NNC exist? err: %v", err)
nncReconcilerStartFailures.Inc()
continue
}