Function GetJobLogger

pkg/operator/operator/logging.go:138–150

(jobKey spec.JobKey)

}

func GetJobLogger(jobKey spec.JobKey) (*zap.SugaredLogger, error) {
	loggerCacheKey := fmt.Sprintf("apiName=%s,jobID=%s", jobKey.APIName, jobKey.ID)
	logger := getFromCacheOrNil(loggerCacheKey)
	if logger != nil {
		return logger, nil
	}

	return initializeLogger(loggerCacheKey, userconfig.InfoLogLevel, map[string]interface{}{
		"apiName": jobKey.APIName,
		"apiKind": jobKey.Kind.String(),
		"jobID":   jobKey.ID,
	})
}

func GetJobLoggerFromSpec(apiSpec *spec.API, jobKey spec.JobKey) (*zap.SugaredLogger, error) {
	loggerCacheKey := fmt.Sprintf("apiName=%s,jobID=%s", jobKey.APIName, jobKey.ID)