Function GetAPIs

pkg/operator/resources/resources.go:256–361

()

}

func GetAPIs() ([]schema.APIResponse, error) {
	var deployments []kapps.Deployment
	var k8sTaskJobs []kbatch.Job
	var taskAPIPods []kcore.Pod
	var virtualServices []istioclientnetworking.VirtualService
	var batchJobList batch.BatchJobList

	err := parallel.RunFirstErr(
		func() error {
			var err error
			deployments, err = config.K8s.ListDeploymentsWithLabelKeys("apiName")
			return err
		},
		func() error {
			var err error
			taskAPIPods, err = config.K8s.ListPodsByLabel("apiKind", userconfig.TaskAPIKind.String())
			return err
		},
		func() error {
			var err error
			k8sTaskJobs, err = config.K8s.ListJobs(
				&kmeta.ListOptions{
					LabelSelector: klabels.SelectorFromSet(
						map[string]string{
							"apiKind": userconfig.TaskAPIKind.String(),
						},
					).String(),
				},
			)
			return err
		},
		func() error {
			var err error
			virtualServices, err = config.K8s.ListVirtualServicesWithLabelKeys("apiName")
			return err
		},
		func() error {
			return config.K8s.List(context.Background(), &batchJobList)
		},
	)
	if err != nil {
		return nil, err
	}

	var realtimeAPIDeployments []kapps.Deployment
	var asyncAPIDeployments []kapps.Deployment
	for _, deployment := range deployments {
		switch deployment.Labels["apiKind"] {
		case userconfig.RealtimeAPIKind.String():
			realtimeAPIDeployments = append(realtimeAPIDeployments, deployment)
		case userconfig.AsyncAPIKind.String():
			asyncAPIDeployments = append(asyncAPIDeployments, deployment)
		}
	}

	var batchAPIVirtualServices []istioclientnetworking.VirtualService
	var taskAPIVirtualServices []istioclientnetworking.VirtualService
	var trafficSplitterVirtualServices []istioclientnetworking.VirtualService