云原生CI/CDDevOps后端【免费下载链接】pipelineA cloud-native Pipeline resource.项目地址https://gitcode.com/gh_mirrors/pipelin/pipeline点击查看免费下载本文聚焦 Tekton Pipelinepipelin/pipeline 仓库的 Cluster Resolver它如何通过cluster类型解析同一 Kubernetes 集群中其他命名空间下的 Task、Pipeline 与 StepAction 资源。读完本篇你将掌握 Cluster Resolver 的全部请求参数、cache缓存模式、命名空间访问控制allowed/blocked-namespaces的配置方法、启用所需的功能开关以及ResolutionRequest.Status.RefSource中uri与digest的生成原理——这些内容均可在仓库源码中逐条验证。Resolver 类型与工作机制Cluster Resolver 响应 resolver 类型为cluster的请求。从源码结构看其核心实现位于 pkg/resolution/resolver/cluster/resolver.go通过GetSelector返回resolution.tekton.dev/type: cluster的标签选择器来认领对应的ResolutionRequest资源// GetSelector returns the labels that resource requests are required to have for // the cluster resolver to process them. func (r *Resolver) GetSelector(_ context.Context) map[string]string { return map[string]string{ common.LabelKeyResolverType: LabelValueClusterResolverType, } }其中LabelValueClusterResolverType的值就是字符串cluster见 pkg/remoteresolution/resolver/cluster/resolver.go。此外还支持一个名为Cluster的 resolver 名ClusterResolverName配置名称固定为cluster-resolver-config。解析的实际工作由ResolveFromParams完成它先校验功能开关与参数再按kind分派到task、pipeline、stepaction三种取数路径每种路径都通过 Tekton 版本化 clientset 从目标命名空间执行Getswitch params[KindParam] { case stepaction: stepaction, err : pipelineClientSet.TektonV1beta1().StepActions(params[NamespaceParam]).Get(ctx, params[NameParam], metav1.GetOptions{}) ... case task: task, err : pipelineClientSet.TektonV1().Tasks(params[NamespaceParam]).Get(ctx, params[NameParam], metav1.GetOptions{}) ... case pipeline: pipeline, err : pipelineClientSet.TektonV1().Pipelines(params[NamespaceParam]).Get(ctx, params[NameParam], metav1.GetOptions{}) ... }也就是说Cluster Resolver 本质上是“用 clientset 跨命名空间拉取 Tekton 资源”并把资源整体序列化为 YAML 返回。请求参数参数名说明示例值kind要获取的资源类型。task、pipeline、stepactionname要获取的资源名称。some-pipeline、some-tasknamespace集群中包含该资源的命名空间。default、other-namespacecache可选的解析器缓存模式。always、never、auto参数名常量定义在 pkg/resolution/resolver/cluster/params.gokind、name、namespace三个参数中name始终必填kind与namespace可以缺省——缺省时回退到cluster-resolver-configConfigMap 中的default-kind/default-namespace。参数补全逻辑在populateParamsWithDefaults中if pKind, ok : paramsMap[KindParam]; !ok || pKind.StringVal { if kindVal, ok : conf[DefaultKindKey]; !ok { missingParams append(missingParams, KindParam) } else { params[KindParam] kindVal } } else { params[KindParam] pKind.StringVal } if kindVal, ok : params[KindParam]; ok !isSupportedKind(kindVal) { return nil, fmt.Errorf(unknown or unsupported resource kind %s, kindVal) }其中isSupportedKind依据白名单supportedKinds [task, pipeline, stepaction]做校验pkg/resolution/resolver/cluster/resolver.go#L53传入其他 kind 会直接得到unknown or unsupported resource kind错误。若namespace补全后仍为空白字符串会被视为缺失并报错missing required cluster resolver params。缓存参数 cache 的语义cache参数控制 Cluster Resolver 是否缓存解析结果缓存模式说明always无论解析结果是否具有不可变引用始终缓存。never从不缓存解析结果。autoCluster Resolver 的行为从不缓存集群资源没有不可变引用。不指定默认行为从不缓存对 Cluster Resolver 等同于auto。注意Cluster Resolver 只有在显式指定cache: always时才会缓存。原因是集群资源Task、Pipeline 等不像 Git 提交哈希或 bundle digest 那样拥有不可变引用自动缓存并不可靠。这一点在远程解析框架的实现中得到了印证——IsImmutable恒返回falsepkg/remoteresolution/resolver/cluster/resolver.go#L81-L87// IsImmutable implements ImmutabilityChecker.IsImmutable // Returns false because cluster resources dont have immutable references func (r *Resolver) IsImmutable([]v1.Param) bool { // Cluster resources (Tasks, Pipelines, etc.) dont have immutable references // like Git commit hashes or bundle digests, so we always return false return false }而在Resolve中只有当cache.ShouldUse判定应走缓存路径时才会调用cache.Get(ctx).GetCachedOrResolveFromRemote先查缓存、未命中再回源解析否则直接调用clusterresolution.ResolveFromParamspkg/remoteresolution/resolver/cluster/resolver.go#L89-L103。全局缓存配置解析器缓存可通过resolver-cache-configConfigMap 全局配置该 ConfigMap 对所有 resolver 生效控制缓存规模与条目存活时间TTL。仓库中随附的默认配置见 config/resolvers/resolver-cache-config.yaml配置项说明默认值示例取值max-size缓存最大条目数1000500、2000ttl缓存条目存活时间5m10m、1hdata: # Maximum number of entries in the resolver cache max-size: 1000 # Time-to-live for cache entries (examples: 5m, 10m, 1h) ttl: 5m该 ConfigMap 的名称可通过环境变量RESOLVER_CACHE_CONFIG_MAP_NAME自定义未设置时默认为resolver-cache-config。这一环境变量常量在缓存配置存储实现中定义resolverCacheConfigMapNameEnv RESOLVER_CACHE_CONFIG_MAP_NAMEpkg/remoteresolution/resolver/framework/cache/configstore.go。通过 default-cache-mode 覆盖默认缓存行为你还可以在cluster-resolver-configConfigMap 中增加default-cache-mode选项为 Cluster Resolver 设定默认的缓存模式覆盖系统默认值auto配置项说明合法取值默认值default-cache-mode未指定cache参数时的默认缓存行为always、never、autoauto仓库随附的 config/resolvers/cluster-resolver-config.yaml 中已给出该项的注释说明默认被注释掉即保持autodata: # The default kind to fetch. default-kind: task # The default namespace to look for resources in. default-namespace: # An optional comma-separated list of namespaces which the resolver is allowed to access. Defaults to empty, meaning all namespaces are allowed. allowed-namespaces: # An optional comma-separated list of namespaces which the resolver is blocked from accessing. Defaults to empty, meaning all namespaces are allowed. blocked-namespaces: # Optional: Default cache mode for this resolver. Valid values: always, never, auto (default: auto) # always - Always cache resolved resources # never - Never cache resolved resources (recommended for cluster resolver since resources are mutable) # auto - Never cache for cluster resolver (same as never) # default-cache-mode: auto示例——显式关闭默认缓存apiVersion: v1 kind: ConfigMap metadata: name: cluster-resolver-config namespace: tekton-pipelines-resolvers data: default-cache-mode: never # Never cache by default (since cluster resources are mutable)启用要求运行 Tekton Pipeline v0.41.0 或更高版本的集群。已安装内置的远程 resolverremote resolvers。tekton-pipelines-resolvers命名空间下resolvers-feature-flagsConfigMap 中的enable-cluster-resolver功能开关设置为true。已启用 Beta 特性。功能开关的校验逻辑在源码中非常直接ResolveFromParams与ValidateParams都会先调用isDisabled(ctx)未开启时立即返回错误const disabledError cannot handle resolution request, enable-cluster-resolver feature flag not true func isDisabled(ctx context.Context) bool { cfg : resolverconfig.FromContextOrDefaults(ctx) return !cfg.FeatureFlags.EnableClusterResolver }见 pkg/resolution/resolver/cluster/resolver.go#L40 与 pkg/resolution/resolver/cluster/resolver.go#L293-L305。关于该开关属于 Beta 特性的说明参见 docs/additional-configs.md。配置项cluster-resolver-config该 resolver 使用ConfigMap承载其设置。随仓库发布的默认值见上文引用的 config/resolvers/cluster-resolver-config.yaml各配置项的常量键名定义在 pkg/resolution/resolver/cluster/config.go配置项说明示例取值default-kind参数未指定 kind 时默认获取的资源类型。task、pipeline、stepactiondefault-namespace参数未指定命名空间时默认从中获取资源的命名空间。default、some-namespaceallowed-namespaces可选逗号分隔的命名空间白名单限定 resolver 允许访问的命名空间。默认为空表示允许所有命名空间。default,some-namespace、空blocked-namespaces可选逗号分隔的命名空间黑名单阻止 resolver 访问其中命名空间。取值*时拒绝所有命名空间且必须通过allowed-namespaces显式列出允许的命名空间。默认为空表示允许所有命名空间。default,other-namespace、*、空命名空间访问控制的判定顺序populateParamsWithDefaults中实现了完整的访问控制判定其执行顺序值得注意pkg/resolution/resolver/cluster/resolver.go#L263-L279if conf[BlockedNamespacesKey] ! isInCommaSeparatedList(params[NamespaceParam], conf[BlockedNamespacesKey]) { return nil, fmt.Errorf(access to specified namespace %s is blocked, params[NamespaceParam]) } if conf[AllowedNamespacesKey] ! isInCommaSeparatedList(params[NamespaceParam], conf[AllowedNamespacesKey]) { return params, nil } if conf[BlockedNamespacesKey] ! isInCommaSeparatedList(*, conf[BlockedNamespacesKey]) { return nil, errors.New(only explicit allowed access to namespaces is allowed) } if conf[AllowedNamespacesKey] ! !isInCommaSeparatedList(params[NamespaceParam], conf[AllowedNamespacesKey]) { return nil, fmt.Errorf(access to specified namespace %s is not allowed, params[NamespaceParam]) }可以推断其语义为黑名单命中直接拒绝 → 白名单命中直接放行 →blocked-namespaces为*时要求显式白名单否则报only explicit allowed access to namespaces is allowed→ 白名单非空但未命中则报access to specified namespace %s is not allowed。列表比较时会对每个条目做TrimSpaceKubernetes 命名空间名本身不含空白这使得配置中a, b与a,b等价。使用示例Task 解析apiVersion: tekton.dev/v1beta1 kind: TaskRun metadata: name: remote-task-reference spec: taskRef: resolver: cluster params: - name: kind value: task - name: name value: some-task - name: namespace value: namespace-containing-task带缓存的 Task 解析apiVersion: tekton.dev/v1beta1 kind: TaskRun metadata: name: remote-task-reference-cached spec: taskRef: resolver: cluster params: - name: kind value: task - name: name value: some-task - name: namespace value: namespace-containing-task - name: cache value: always不带缓存的 Task 解析apiVersion: tekton.dev/v1beta1 kind: TaskRun metadata: name: remote-task-reference-no-cache spec: taskRef: resolver: cluster params: - name: kind value: task - name: name value: some-task - name: namespace value: namespace-containing-task - name: cache value: neverStepAction 解析在 Task 的 step 中通过ref引用集群中的 StepAction此处按合法 YAML 缩进整理apiVersion: tekton.dev/v1beta1 kind: Task metadata: name: remote-stepaction-reference spec: steps: - name: step-action-example ref: resolver: cluster params: - name: kind value: stepaction - name: name value: some-stepaction - name: namespace value: namespace-containing-stepactionPipeline 解析apiVersion: tekton.dev/v1beta1 kind: PipelineRun metadata: name: remote-pipeline-reference spec: pipelineRef: resolver: cluster params: - name: kind value: pipeline - name: name value: some-pipeline - name: namespace value: namespace-containing-pipelineResolutionRequest.Status.RefSource解析来源如何记录ResolutionRequest.Status.RefSource字段记录远程资源的来源包含三个子字段url、digest、entrypointurl资源在集群中的唯一完整标识符格式为resource uriuid。Resource URI 部分为命名空间作用域 URI即/apis/GROUP/VERSION/namespaces/NAMESPACE/RESOURCETYPE/NAMEKubernetes Resource URI 概念可参考 Kubernetes API 文档。digest集群内资源spec 字段内容的 hex 编码 sha256 校验和。之所以只对 spec 做校验和而非整个对象是因为集群内资源的 metadata如 annotations可能被合法地修改只要 spec 内容的校验和不变源校验器source verifiers就能判断资源没有被恶意篡改——即便 metadata 出于善意目的被修改过。entrypoint为空因为路径信息已经包含在 url 字段中。源码中该标识符的构造与文档描述完全一致pkg/resolution/resolver/cluster/resolver.go#L157-L165return ResolvedClusterResource{ Content: data, Spec: spec, Name: params[NameParam], Namespace: params[NamespaceParam], Identifier: fmt.Sprintf(/apis/%s/namespaces/%s/%s/%s%s, groupVersion, params[NamespaceParam], params[KindParam], params[NameParam], uid), Checksum: sha256Checksum, }, nilResolvedClusterResource.RefSource()则把Identifier填入URI、把校验和填入Digest的sha256键func (r ResolvedClusterResource) RefSource() *pipelinev1.RefSource { return pipelinev1.RefSource{ URI: r.Identifier, Digest: map[string]string{ sha256: hex.EncodeToString(r.Checksum), }, } }每种 kind 的校验和都由各自的Checksum()方法计算Task/Pipeline 用pipelinev1版本StepAction 用pipelinev1beta1版本随后资源整体被补齐Kind与APIVersion后序列化为 YAML 作为Content返回。示例TaskRun 触发解析后的 ResolutionRequestapiVersion: tekton.dev/v1beta1 kind: TaskRun metadata: name: cluster-demo spec: taskRef: resolver: cluster params: - name: kind value: task - name: name value: a-simple-task - name: namespace value: default对应的ResolutionRequestapiVersion: resolution.tekton.dev/v1beta1 kind: ResolutionRequest metadata: labels: resolution.tekton.dev/type: cluster name: cluster-7a04be6baa3eeedd232542036b7f3b2d namespace: default ownerReferences: ... spec: params: - name: kind value: task - name: name value: a-simple-task - name: namespace value: default status: annotations: ... conditions: ... data: xxx refSource: digest: sha256: 245b1aa918434cc8195b4d4d026f2e43df09199e2ed31d4dfd9c2cbea1c7ce54 uri: /apis/tekton.dev/v1beta1/namespaces/default/task/a-simple-task3b82d8c4-f89e-47ea-a49d-3be0dca4c038可见uri由资源 URI/apis/tekton.dev/v1beta1/namespaces/default/task/a-simple-task加上与资源 UID 组成digest.sha256即该 Task spec 内容的校验和——这与ResolveFromParams中fmt.Sprintf(/apis/%s/namespaces/%s/%s/%s%s, ...)的拼接逻辑一一对应。小结与延伸阅读Cluster Resolver 是“集群内”资源解析器kind 白名单仅task、pipeline、stepaction三种解析产物天然带有uri资源 URI UID与digestspec 的 sha256两类来源证据服务于可信资源trusted resources校验场景。缓存默认关闭且auto对 Cluster Resolver 恒等于never只有显式cache: always才会进入resolver-cache-config约束max-size/ttl的缓存路径。安全边界由allowed-namespaces/blocked-namespaces双重控制blocked-namespaces: *可切换为“仅显式白名单”模式。相关仓库路径便于继续深入参数常量pkg/resolution/resolver/cluster/params.go配置键常量pkg/resolution/resolver/cluster/config.go随附默认配置config/resolvers/cluster-resolver-config.yaml、config/resolvers/resolver-cache-config.yaml远程解析框架入口含缓存分支pkg/remoteresolution/resolver/cluster/resolver.go安装与远程解析开启说明docs/install.md、Beta 特性开关说明docs/additional-configs.md赞分享云原生CI/CDDevOps后端【免费下载链接】pipelineA cloud-native Pipeline resource.项目地址https://gitcode.com/gh_mirrors/pipelin/pipeline点击查看免费下载相关推荐InsForge监控与日志10个必备的系统健康检查与故障排查技巧InsForge监控与日志10个必备的系统健康检查与故障排查技巧 InsForge作为一站式开源后端平台为开发者提供了强大的监控与日志系统让系统健康检查与云原生CI/CDDevOps后端Tekton Pipeline Bundles Resolver从 OCI 镜像包中解析 Task 与 Pipeline 的配置与实践Tekton Pipeline Bundles Resolver从 OCI 镜像包中解析 Task 与 Pipeline 的配置与实践 本文围绕 Tekton云原生CI/CDDevOps后端Tekton Pipeline 的 Tekton Bundle Contract 详解OCI 镜像中 Task/Pipeline 的分发契约与实现验证Tekton Pipeline 的 Tekton Bundle Contract 详解OCI 镜像中 Task/Pipeline 的分发契约与实现验证 本指南云原生CI/CDDevOps后端上一篇如何轻松搞定网站反向代理3个高效配置秘诀让你告别命令行下一篇FedPFT 一次性联邦学习基线详解基于 Foundation Model 的参数化特征迁移Flower 实现与复现创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考