苹果|OpenYurt 之 Yurthub 数据过滤框架解析 face id|全面屏|手机行业

OpenYurt 是业界首个非侵入的边缘计算云原生开源项目，通过边缘自治，云边协同，边缘单元化，边缘流量闭环等能力为用户提供云边一体化的使用体验。在 Openyurt 里边缘网络可以使用数据过滤框架在不同节点池里实现边缘流量闭环能力。
Yurthub 数据过滤框架解析 Yurthub 本质上是一层 kube-apiserver 的代理，在代理的基础上加了一层 cache ，一来保证边缘节点离线的情况下可以使用本地 cache 保证业务稳定性有效的解决了边缘自治的问题。二来可以降低大量的 listwatch 操作对云上 api 产生一定的负载。
Yurthub 的数据过滤通过节点上的 pod 以及 kubelet 的请求通过 Load Balancer 发送给 kube-apiserver ，代理接收到响应消息进行数据过滤处理，之后再将过滤后的数据返回给请求方。如果节点是边缘节点会根据请求类型对响应请求体中的资源进行本地缓存，如果是云端节点考虑到网络状态良好不进行本地缓存。
Yurthub 的过滤框架实现原理图：

Yurthub 目前包含四种过滤规则，通过 addons 请求的 user-agent ， resource ， verb 判断经过那个过滤器进行相应的数据过滤。
四种过滤规则功能及实现 ServiceTopologyFilter
主要针对 EndpointSlice 资源进行数据过滤但 Endpoint Slice 特性需要在 Kubernetes v1.18 或以上版本才能支持，如果在 1.18 版本以下建议使用 endpointsFilter 过滤器。当经过该过滤器首先通过 kubernetes.io/service-name 找到 endpointSlice 资源所对应的 services 资源，之后判断 servces 资源是否存在 openyurt.io/topologyKeys 这个 Annotations ，如果存在那么通过这个 Annotations 的值判断数据过滤规则，最后更新 response data 返回给 addons 。
Annotations 的值分为两大类：
1、kubernetes.io/hostname:只过滤出相同节点的 endpoint ip
2、openyurt.io/nodepool 或者 kubernetes.io/zone: 通过这个 Annotations 获取对应节点池，最后遍历 endpointSlice 资源，通过 endpointSlice 里的 topology 字段中的 kubernetes.io/hostname 字段在 endpointSlice 对象里找到对应的 Endpoints ，之后重组 endpointSlice 里的 Endpoints 后返回给 addons 。
代码实现：
func (fh *serviceTopologyFilterHandler) reassembleEndpointSlice(endpointSlice *discovery.EndpointSlice) *discovery.EndpointSlice { var serviceTopologyType string // get the service Topology type if svcName ok := endpointSlice.Labels[discovery.LabelServiceName
; ok { svc err := fh.serviceLister.Services(endpointSlice.Namespace).Get(svcName) if err != nil { klog.Infof(\"skip reassemble endpointSlice failed to get service %s/%s err: %v\" endpointSlice.Namespace svcName err) return endpointSliceif serviceTopologyType ok = svc.Annotations[AnnotationServiceTopologyKey
; !ok { klog.Infof(\"skip reassemble endpointSlice service %s/%s has no annotation %s\" endpointSlice.Namespace svcName AnnotationServiceTopologyKey) return endpointSlicevar newEps [
discovery.Endpoint // if type of service Topology is 'kubernetes.io/hostname' // filter the endpoint just on the local host if serviceTopologyType == AnnotationServiceTopologyValueNode { for i := range endpointSlice.Endpoints { if endpointSlice.Endpoints[i
.Topology[v1.LabelHostname
== fh.nodeName { newEps = append(newEps endpointSlice.Endpoints[i
)endpointSlice.Endpoints = newEpselse if serviceTopologyType == AnnotationServiceTopologyValueNodePool || serviceTopologyType == AnnotationServiceTopologyValueZone { // if type of service Topology is openyurt.io/nodepool // filter the endpoint just on the node which is in the same nodepool with current node currentNode err := fh.nodeGetter(fh.nodeName) if err != nil { klog.Infof(\"skip reassemble endpointSlice failed to get current node %s err: %v\" fh.nodeName err) return endpointSliceif nodePoolName ok := currentNode.Labels[nodepoolv1alpha1.LabelCurrentNodePool

苹果|OpenYurt 之 Yurthub 数据过滤框架解析

相关经验推荐

郑州生育第二胎产假有多长？郑州市二胎产假规定

什么面相女人不好惹？性格乖张做事决绝女人面相

上饶特产上饶特产的介绍

央视巨作《青山不墨》开播时间央视巨作《青山不墨》开播

倩女幽魂手游关联手机怎么取消绑定倩女幽魂手游关联手机怎么取消

笔记本|2025超越：英特尔表示摩尔定律回来了

马拉糕的材料和做法做马拉糕要什么材料

2022九江柴桑区购房补贴对象范围+补贴标准

维生素e乳可以直接涂在脸上吗维生素e去痘印方法

2021超好听男生励志qq昵称大全自己选的路跪着也要走完

2023年福州中考 2023福州中考成绩什么时候公布

开服嘉礼活动改名卡获取方法英雄联盟手游改名卡怎么获得

2023年绍兴大学生创业一次性社保补贴政策

苹果充电器有时能充有时充不了为什么苹果充电器有时能充有时充不了

知了几点从土里出来

表白说说文案可爱表白怎么发说说

南联盟有哪些国家组成南联盟由有哪些国家组成

英雄联盟11.14版本：虚空遁地兽（雷克塞）Q技能第一段基础伤害提升、Q技能第二段后几级基础伤害提升！

借款合同是否有效

高通骁龙|诚意满满！全新骁龙8+2K无级变帧屏+12GB+256GB，价格是否满意