// supportedTemplates 从mixer/pkg/template包获取所有注册的模板信息。
func supportedTemplates() map[string]template.Info {
	return generatedTmplRepo.SupportedTmplInfo
}
// supportedAdapters 从mixer/pkg/adapter包获取所有注册的适配器信息。
func supportedAdapters() []adptr.InfoFn {
	return adapter.Inventory()
}

func main() {
    // 构造cobra.Command实例，mixs server子命令设计在serverCmd中定义。
	rootCmd := cmd.GetRootCmd(os.Args[1:], supportedTemplates(), supportedAdapters(), shared.Printf, shared.Fatalf)

	if err := rootCmd.Execute(); err != nil {
		os.Exit(-1)
	}
}

func serverCmd(info map[string]template.Info, adapters []adapter.InfoFn, printf, fatalf shared.FormatFn) *cobra.Command {
	...
	serverCmd := &cobra.Command{
		Use:   "server",
		Short: "Starts Mixer as a server",
		Run: func(cmd *cobra.Command, args []string) {
            // 用户执行mixs server命令时，启动mixer gRPC server
			runServer(sa, printf, fatalf) 
		},
	}
    ...
}

// runServer函数启动mixer gRPC server
func runServer(sa *server.Args, printf, fatalf shared.FormatFn) {
	s, err := server.New(sa)
	...
	s.Run()
    ...
}

func newServer(a *Args, p *patchTable) (*Server, error) {
	...
	s := &Server{}
    // 初始化API worker线程池
	s.gp = pool.NewGoroutinePool(apiPoolSize, a.SingleThreaded)
	s.gp.AddWorkers(apiPoolSize)
    // 初始化adapter worker线程池
	s.adapterGP = pool.NewGoroutinePool(adapterPoolSize, a.SingleThreaded)
	s.adapterGP.AddWorkers(adapterPoolSize)

    // 构造存放Mixer模板仓库
	tmplRepo := template.NewRepository(a.Templates)
    // 构造存放adapter的map
	adapterMap := config.AdapterInfoMap(a.Adapters, tmplRepo.SupportsTemplate)
    ...
    // 构造Mixer runtime实例。runtime实例是Mixer运行时环境的主要入口。
    // 它会监听配置变更，配置变更时会动态构造新的handler实例和dispatcher实例。
    // dispatcher会基于配置和attributes对请求进行调度，调用相应的adapters处理请求。
	rt = p.newRuntime(st, templateMap, adapterMap, a.ConfigIdentityAttribute, a.ConfigDefaultNamespace,
		s.gp, s.adapterGP, a.TracingOptions.TracingEnabled())
    // runtime实例开始监听配置变更，一旦配置变更，runtime实例会构造新的dispatcher。
	p.runtimeListen(rt)
	s.dispatcher = rt.Dispatcher()
    ...
    // 注册Mixer gRPC server
	mixerpb.RegisterMixerServer(s.server, api.NewGRPCServer(s.dispatcher, s.gp))
    // 启动ControlZ监听器，ControlZ提供了Istio的内省功能。Mixer与ctrlz集成时，会启动一个
    // web service监听器用于展示Mixer的环境变量、参数版本信息、内存信息、进程信息、metrics等。
	go ctrlz.Run(a.IntrospectionOptions, nil)

	return s, nil
}

func NewGRPCServer(dispatcher dispatcher.Dispatcher, gp *pool.GoroutinePool) mixerpb.MixerServer {
    // 从globalList拷贝出list切片，list形如[]string{"source.ip","source.port","request.id"...}
	list := attribute.GlobalList()
    // 将以attribute.name作为key，index作为value，构造map。形如:map[string][int]{"source.ip":1, "source.port":2, "request.id":3...}
	globalDict := make(map[string]int32, len(list))
	for i := 0; i < len(list); i++ {
		globalDict[list[i]] = int32(i)
	}

	return &grpcServer{
		dispatcher:     dispatcher,
		gp:             gp,
		globalWordList: list,
		globalDict:     globalDict,
	}
}

service Mixer {
  // Check 基于活动配置和Envoy提供的attributes，执行前置条件检查和配额管理。
  rpc Check(CheckRequest) returns (CheckResponse) {}

  // Reports 基于活动配置和Envoy提供的attribues上报遥测数据（如logs和metrics）。
  rpc Report(ReportRequest) returns (ReportResponse) {}
}

func (s *grpcServer) Check(legacyCtx legacyContext.Context, req *mixerpb.CheckRequest) (*mixerpb.CheckResponse, error) {
	// 构造基于proto的属性包protoBag。protoBag提供了对一组attributes进行访问、修改的机制。
	protoBag := attribute.NewProtoBag(&req.Attributes, s.globalDict, s.globalWordList)
    defer protoBag.Done()

	// 构造可变的（执行check方法后会变化）属性包checkBag 
	checkBag := attribute.GetMutableBag(protoBag)
	defer checkBag.Done()
    // 执行dispatcher的预处理过程，s.dispatcher为runtime实例impl。
    // impl的Preprocess方法会调度生成属性相关的adapter，比如kubernetes adapter。
	s.dispatcher.Preprocess(legacyCtx, protoBag, checkBag);
    // 获取属性包中被引用的属性快照snapApa，snapApa能在每次check和quota处理中重复使用。
	snapApa := protoBag.SnapshotReferencedAttributes()
    // 执行dispatcher的前置条件检查，Check方法内部会计算被引用的属性并同步到protoBag中。
	cr, err := s.dispatcher.Check(legacyCtx, checkBag)
	...
    // 构造Check rpc response实例
	resp := &mixerpb.CheckResponse{
		Precondition: mixerpb.CheckResponse_PreconditionResult{
			ValidDuration:        cr.ValidDuration,
			ValidUseCount:        cr.ValidUseCount,
			Status:               cr.Status,
			ReferencedAttributes: protoBag.GetReferencedAttributes(s.globalDict, globalWordCount),
		},
	}

    // 如果前置条件检查通过且配额表总数大于0，则计算新的配额
	if status.IsOK(resp.Precondition.Status) && len(req.Quotas) > 0 {
		resp.Quotas = make(map[string]mixerpb.CheckResponse_QuotaResult, len(req.Quotas))
        // 遍历配额表，计算每个配额是否为引用配额
		for name, param := range req.Quotas {
			qma := &dispatcher.QuotaMethodArgs{
				Quota:           name,
				Amount:          param.Amount,
				DeduplicationID: req.DeduplicationId + name,
				BestEffort:      param.BestEffort,
			}

			protoBag.RestoreReferencedAttributes(snapApa)
			crqr := mixerpb.CheckResponse_QuotaResult{}
			var qr *adapter.QuotaResult
            // 执行dispacher的配额处理方法。istio/mixer/pkg/runtime/dispatcher/dispatcher.go#func (d *Impl) Quota(）
			qr, err = s.dispatcher.Quota(legacyCtx, checkBag, qma)
			if err != nil {
				err = fmt.Errorf("performing quota alloc failed: %v", err)
				log.Errora("Quota failure:", err.Error())
			} else if qr == nil {
				crqr.ValidDuration = defaultValidDuration
				crqr.GrantedAmount = qma.Amount
			} else {
				if !status.IsOK(qr.Status) {
					log.Debugf("Quota denied: %v", qr.Status)
				}
				crqr.ValidDuration = qr.ValidDuration
				crqr.GrantedAmount = qr.Amount
			}
            // 根据全局attribute字典来计算被引用的attributes
			crqr.ReferencedAttributes = protoBag.GetReferencedAttributes(s.globalDict, globalWordCount)
			resp.Quotas[name] = crqr
		}
	}
    // 返回Check gRPC相应结果
	return resp, nil
}