Function initResource

pkg/microservice/hubagent/server/server.go:98–147

()

}

func initResource() {
	token, err := login.GetInternalToken("hub-agent")
	if err != nil {
		log.Fatalf("failed to get internal token, err: %s", err)
	}
	client := aslan.NewExternal(config2.AslanBaseAddr(), token)

	scheduleWorkflow := config2.ScheduleWorkflow()
	if scheduleWorkflow == "" {
		log.Infof("failed to get scheduleWorkflow from env")
		scheduleWorkflow = "true"
	}
	schedule, err := strconv.ParseBool(scheduleWorkflow)
	if err != nil {
		log.Errorf("failed to parse scheduleWorkflow, err: %s", err)
		schedule = true
	}

	if schedule {
		ls, err := client.ListRegistries()
		if err != nil {
			log.Fatalf("failed to list registries from zadig server, error: %s", err)
		}

		regList := make([]*registrytool.RegistryInfoForDinDUpdate, 0)
		for _, reg := range ls {
			regItem := &registrytool.RegistryInfoForDinDUpdate{
				ID:      reg.ID,
				RegAddr: reg.RegAddr,
			}
			if reg.AdvancedSetting != nil {
				regItem.AdvancedSetting = &registrytool.RegistryAdvancedSetting{
					TLSEnabled: reg.AdvancedSetting.TLSEnabled,
					TLSCert:    reg.AdvancedSetting.TLSCert,
				}
			}
			regList = append(regList, regItem)
		}

		clientSet, err := clientmanager.NewKubeClientManager().GetKubernetesClientSet(setting.LocalClusterID)
		if err != nil {
			log.Fatalf("failed to create dynamic kubernetes clientset for clusterID: %s, the error is: %s", setting.LocalClusterID, err)
		}

		err = registrytool.PrepareDinD(clientSet, "koderover-agent", regList)
		if err != nil {
			log.Fatalf("failed to update dind, the error is: %s", err)
		}
	}
}