Function GetRealtimeAPILoggerFromSpec

pkg/operator/operator/logging.go:124–136

(apiSpec *spec.API)

}

func GetRealtimeAPILoggerFromSpec(apiSpec *spec.API) (*zap.SugaredLogger, error) {
	loggerCacheKey := fmt.Sprintf("apiName=%s,apiID=%s", apiSpec.Name, apiSpec.ID)
	logger := getFromCacheOrNil(loggerCacheKey)
	if logger != nil {
		return logger, nil
	}

	return initializeLogger(loggerCacheKey, userconfig.InfoLogLevel, map[string]interface{}{
		"apiName": apiSpec.Name,
		"apiKind": apiSpec.Kind.String(),
		"apiID":   apiSpec.ID,
	})
}

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