Ingress2Gateway 代码实现原理深入理解转换引擎的工作机制【免费下载链接】ingress2gatewayConvert Ingress resources to Gateway API resources项目地址: https://gitcode.com/gh_mirrors/in/ingress2gatewayIngress2Gateway 是一个强大的 Kubernetes 工具专门用于将传统的 Ingress 资源和各种 Ingress 控制器特定的自定义资源CRDs转换为现代化的 Gateway API 资源。作为 Kubernetes SIG-Network 子项目的一部分这个工具在 Ingress NGINX 退役后变得尤为重要为开发者提供了从传统 Ingress 向 Gateway API 平滑迁移的完整解决方案。转换引擎的核心架构Ingress2Gateway 采用三层架构设计实现了高度模块化和可扩展的转换机制1. 提供者层Provider Layer提供者层负责读取和理解不同 Ingress 控制器的特定配置。每个支持的 Ingress 控制器都有一个对应的提供者实现例如ingress-nginx提供者pkg/i2gw/providers/ingressnginx/Kong提供者pkg/i2gw/providers/kong/Traefik提供者pkg/i2gw/providers/traefik/每个提供者都实现了i2gw.Provider接口主要包含三个关键方法type Provider interface { ReadResourcesFromCluster(ctx context.Context) error ReadResourcesFromFile(ctx context.Context, reader io.Reader) error ToIR() (emitterir.EmitterIR, field.ErrorList) }2. 中间表示层Intermediate Representation这是转换引擎的核心创新点提供者将读取到的 Ingress 资源转换为一个统一的中间表示IR这个中间表示包含了所有必要的信息但又保持了与具体实现无关的特性。中间表示层定义在 pkg/i2gw/provider_intermediate/intermediate_representation.go 中主要结构包括type ProviderIR struct { Gateways map[types.NamespacedName]GatewayContext HTTPRoutes map[types.NamespacedName]HTTPRouteContext Services map[types.NamespacedName]ProviderSpecificServiceIR // ... 其他资源类型 }3. 发射器层Emitter Layer发射器层负责将中间表示转换为最终的 Gateway API 资源。目前支持多种发射器standard发射器pkg/i2gw/emitters/standard/ - 输出标准的 Gateway API 资源envoy-gateway发射器pkg/i2gw/emitters/envoygateway/ - 输出 Envoy Gateway 特定的资源gce发射器pkg/i2gw/emitters/gce/ - 输出 Google Cloud Engine 特定的资源转换引擎的工作流程详解步骤1资源读取阶段转换引擎首先从 Kubernetes 集群或文件中读取 Ingress 资源。这个过程由ToGatewayAPIResources函数在 pkg/i2gw/ingress2gateway.go 中协调func ToGatewayAPIResources(ctx context.Context, namespace string, reader io.Reader, providers []string, emitterName string, providerSpecificFlags map[string]map[string]string, allowExperimentalGatewayAPI bool, noColor bool) ([]GatewayResources, *notifications.Report, error) { // 构建提供者实例 providerByName, err : constructProviders(ProviderConf{ Client: clusterClient, Namespace: namespace, ProviderSpecificFlags: providerSpecificFlags, Report: report, }, providers) // 读取资源 if reader ! nil { readProviderResourcesFromFile(ctx, providerByName, reader) } else { readProviderResourcesFromCluster(ctx, providerByName) } }步骤2转换为中间表示每个提供者将其特定的 Ingress 配置转换为统一的中间表示。以 ingress-nginx 提供者为例在 pkg/i2gw/providers/ingressnginx/ingressnginx.go 中func (p *Provider) ToIR() (emitterir.EmitterIR, field.ErrorList) { pIR, errs : p.resourcesToIRConverter.convert(p.notify, p.storage) eIR : providerir.ToEmitterIR(pIR) // 应用各种转换规则 applyRewriteTargetToEmitterIR(p.storage.Ingresses.List(), pIR, eIR) p.applyIPRangeControlToEmitterIR(pIR, eIR) p.applyTimeoutsToEmitterIR(pIR, eIR) p.applyCorsToEmitterIR(pIR, eIR) p.applyBodySizeToEmitterIR(pIR, eIR) p.addSSLAndTrailingSlashRedirects(p.storage.Ingresses.List(), pIR, eIR) errs append(errs, p.addWWWRedirect(pIR, eIR)...) return eIR, errs }步骤3中间表示转换提供者特定的中间表示通过ToEmitterIR函数转换为通用的发射器中间表示func ToEmitterIR(pIR ProviderIR) emitterir.EmitterIR { eIR : emitterir.EmitterIR{ Gateways: make(map[types.NamespacedName]emitterir.GatewayContext), HTTPRoutes: make(map[types.NamespacedName]emitterir.HTTPRouteContext), // ... 初始化所有字段 } // 转换各个资源类型 for k, v : range pIR.Gateways { ctx : emitterir.GatewayContext{Gateway: v.Gateway} if v.ProviderSpecificIR.Gce ! nil { ctx.Gce v.ProviderSpecificIR.Gce } eIR.Gateways[k] ctx } // ... 其他资源的转换 return eIR }步骤4最终资源生成发射器将中间表示转换为最终的 Gateway API 资源。标准发射器的实现在 pkg/i2gw/emitters/standard/standard.gofunc (e *Emitter) Emit(ir emitterir.EmitterIR) (i2gw.GatewayResources, field.ErrorList) { utils.LogUnparsedErrors(ir, e.notify) e.notify(notifications.WarningNotification, Gateway API does not support configuring URL normalization...) resources, err : utils.ToGatewayResources(ir) return resources, err }关键转换逻辑深度解析Ingress 字段到 Gateway API 的映射转换引擎实现了完整的字段映射机制Ingress 字段Gateway API 对应配置ingressClassNameGateway 的gatewayClassNamedefaultBackend无 hostname 的 Gateway Listener 通配 HTTPRoutetls[].hostsHTTPS Listener (端口 443协议 HTTPS)tls[].secretNameListener 的tls.certificateRefsrules[].host独立的 Gateway HTTP Listenerrules[].http.paths[].pathHTTPRoute 的rules[].matches[].path.valuerules[].http.paths[].pathTypeHTTPRoute 的rules[].matches[].path.type冲突解决机制Ingress2Gateway 实现了智能的冲突解决策略创建时间排序按照 Ingress 资源的最早创建时间排序命名空间/名称排序如果创建时间相同按命名空间和名称排序错误报告对后排序的冲突规则生成错误报告这种策略确保了转换结果的确定性和一致性。注解支持与扩展性转换引擎能够处理各种 Ingress 控制器特定的注解nginx.ingress.kubernetes.io/rewrite-target重写目标路径nginx.ingress.kubernetes.io/cors-allow-originCORS 配置nginx.ingress.kubernetes.io/proxy-body-size请求体大小限制nginx.ingress.kubernetes.io/ssl-redirectSSL 重定向架构优势与设计理念模块化设计Ingress2Gateway 的模块化架构使得添加新的 Ingress 控制器支持变得非常简单。只需要实现新的提供者即可无需修改核心转换逻辑。可扩展性通过中间表示层系统可以轻松支持新的 Gateway API 实现。每个新的 Gateway API 实现只需要提供自己的发射器。错误处理与报告转换引擎包含完善的错误处理和通知系统在 pkg/i2gw/notifications/ 中实现type Report struct { notifications map[NotificationType][]Notification noColor bool } func (r *Report) Notifier(component string) NotifyFunc { return func(typ NotificationType, msg string, args ...any) { // 记录转换过程中的所有通知和警告 } }向后兼容性转换引擎支持渐进式迁移允许用户部分转换只转换部分 Ingress 资源验证模式只验证不实际应用转换差异报告显示转换前后的差异实际应用场景与最佳实践迁移工作流程评估阶段使用ingress2gateway print命令预览转换结果测试阶段在测试环境中应用转换后的 Gateway API 资源验证阶段使用通知系统检查所有警告和错误生产阶段逐步将 Ingress 资源迁移到 Gateway API性能优化转换引擎经过优化能够批量处理一次性转换多个命名空间的所有 Ingress 资源内存效率使用流式处理减少内存占用缓存机制对重复的转换操作进行缓存监控与调试Ingress2Gateway 提供了丰富的调试信息详细日志记录每个转换步骤统计信息显示转换成功率和不支持的功能资源映射显示 Ingress 资源到 Gateway API 资源的映射关系未来发展方向Ingress2Gateway 项目正在不断演进未来的发展方向包括更多提供者支持扩展支持更多的 Ingress 控制器智能转换建议基于使用模式提供优化建议自动化迁移工具提供一键式迁移解决方案云原生集成与 CI/CD 管道深度集成通过深入了解 Ingress2Gateway 的代码实现原理开发者可以更好地利用这个强大的工具实现从传统 Ingress 到现代 Gateway API 的平滑迁移享受 Gateway API 带来的标准化、可扩展性和更好的可观测性优势。无论你是 Kubernetes 新手还是经验丰富的运维专家Ingress2Gateway 都能帮助你轻松应对 Ingress NGINX 退役带来的挑战开启 Gateway API 的新时代【免费下载链接】ingress2gatewayConvert Ingress resources to Gateway API resources项目地址: https://gitcode.com/gh_mirrors/in/ingress2gateway创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考