Function GetAPIByName

pkg/operator/resources/job/batchapi/api.go:194–267

(deployedResource *operator.DeployedResource)

}

func GetAPIByName(deployedResource *operator.DeployedResource) ([]schema.APIResponse, error) {
	metadata, err := spec.MetadataFromVirtualService(deployedResource.VirtualService)
	if err != nil {
		return nil, err
	}

	api, err := operator.DownloadAPISpec(deployedResource.Name, metadata.APIID)
	if err != nil {
		return nil, err
	}

	ctx := context.Background()
	batchJobList := batch.BatchJobList{}
	if err = config.K8s.List(
		ctx, &batchJobList,
		client.InNamespace(config.K8s.Namespace),
		client.MatchingLabels{"apiName": deployedResource.Name},
	); err != nil {
		return nil, err
	}

	endpoint, err := operator.APIEndpoint(api)
	if err != nil {
		return nil, err
	}

	var jobStatuses []status.BatchJobStatus
	jobIDSet := strset.New()
	for _, batchJob := range batchJobList.Items {
		jobStatus, err := getJobStatusFromBatchJob(batchJob)
		if err != nil {
			return nil, err
		}
		jobStatuses = append(jobStatuses, *jobStatus)
		jobIDSet.Add(batchJob.Name)
	}

	if len(jobStatuses) < 10 {
		jobStates, err := job.GetMostRecentlySubmittedJobStates(deployedResource.Name, 10+len(jobStatuses), userconfig.BatchAPIKind)
		if err != nil {
			return nil, err
		}
		for _, jobState := range jobStates {
			if jobIDSet.Has(jobState.ID) {
				continue
			}
			jobIDSet.Add(jobState.ID)

			jobStatus, err := getJobStatusFromJobState(jobState)
			if err != nil {
				return nil, err
			}

			if jobStatus != nil {
				jobStatuses = append(jobStatuses, *jobStatus)
				if len(jobStatuses) == 10 {
					break
				}