Function initializeLogger

pkg/operator/operator/logging.go:78–102

(key string, level userconfig.LogLevel, fields map[string]interface{})

}

func initializeLogger(key string, level userconfig.LogLevel, fields map[string]interface{}) (*zap.SugaredLogger, error) {
	loggerConfig := logging.DefaultZapConfig(level, fields)

	disableJSONLogging := strings.ToLower(os.Getenv("CORTEX_DISABLE_JSON_LOGGING"))
	if disableJSONLogging == "true" {
		loggerConfig.Encoding = "console"
	}

	logger, err := loggerConfig.Build()
	if err != nil {
		return nil, errors.WithStack(err)
	}

	sugarLogger := logger.Sugar()

	_loggerCache.Lock()
	defer _loggerCache.Unlock()

	_loggerCache.m[key] = &cachedLogger{
		lastAccess: time.Now(),
		value:      sugarLogger,
	}

	return sugarLogger, nil
}

func GetRealtimeAPILogger(apiName string, apiID string) (*zap.SugaredLogger, error) {
	loggerCacheKey := fmt.Sprintf("apiName=%s,apiID=%s", apiName, apiID)