Pilot #

若无特别说明，本文是根据 Istio 1.6.5 进行分析。

pilot discovery #

函数调用栈 #

• NewServer
  • initConfigController
    • makeKubeConfigController
      • (add schema) collections.Pilot.All()
      • NewClient
      • NewController
        • (add stores for CRD kinds) addInformer
          • newCacheHandler
            • informer := cache.NewSharedIndexInformer(…)
            • informer.AddEventHandler
              • queue.Push(onEvent)
    • s.ConfigStores = append(s.ConfigStores, configController)
    • aggregateConfigController, err := configaggregate.MakeCache(s.ConfigStores)
    • s.configController = aggregateConfigController
    • addStartFunc
  • initServiceControllers
    • NewServiceDiscovery
      • RegisterEventHandler: 注册 serviceEntryKind 与 workloadEntryKind 的 handler
  • initDiscoveryService
    • initEventHandlers
      • 定义 handler
        • s.EnvoyXdsServer.ConfigUpdate(pushReq): 真正做的事情，更新 envoy xds 配置
      • 添加 handler
• discoveryServer.Start(stop)
  • (crd controller) Run
    • informer.Run(stop)
    • cache.WaitForCacheSync(stop, c.HasSynced): 等待 Informer 完成一次本地缓存的数据同步操作
    • c.queue.Run(stop): 执行 queue.tasks，即 cacheHandler.onEvent
      • 执行 handlers