INNER CODE UNIT · Go

createNginxManager

nginx/kubernetes-ingress · cmd/nginx-ingress/main.go:595

func createNginxManager(ctx context.Context, managerCollector collectors.ManagerCollector, licenseReporter *license_reporting.LicenseReporter, deploymentMetadata *metadata.Metadata) (nginx.Manager, bool) {
	useFakeNginxManager := *proxyURL != ""
	timeout := time.Duration(*nginxReloadTimeout) * time.Millisecond
	var nginxManager nginx.Manager
	switch {
	case useFakeNginxManager:
		nginxManager = nginx.NewFakeManager("/etc/nginx")
	case *enableConfigSafety:
		nginxManager = nginx.NewConfigRollbackManager(ctx, "/etc/nginx/", *nginxDebug, managerCollector, licenseReporter, deploymentMetadata, timeout, *nginxPlus)
	default:
		nginxManager = nginx.NewLocalManager(ctx, "/etc/nginx/", *nginxDebug, managerCollector, licenseReporter, deploymentMetadata, timeout, *nginxPlus)
	}
	return nginxManager, useFakeNginxManager
}

func getNginxVersionInfo(ctx context.Context, nginxManager nginx.Manager) nginx.Version {
	l := nl.LoggerFromContext(ctx)
	nginxInfo := nginxManager.Version()

View source record →