Function DescribeAPIByName

pkg/operator/resources/asyncapi/api.go:312–353

(deployedResource *operator.DeployedResource)

}

func DescribeAPIByName(deployedResource *operator.DeployedResource) ([]schema.APIResponse, error) {
	var apiDeployment *kapps.Deployment

	apiDeployment, err := config.K8s.GetDeployment(workloads.K8sName(deployedResource.Name))
	if err != nil {
		return nil, err
	}

	if apiDeployment == nil {
		return nil, errors.ErrorUnexpected("unable to find api deployment", deployedResource.Name)
	}

	apiStatus := status.FromDeployment(apiDeployment)
	apiMetadata, err := spec.MetadataFromDeployment(apiDeployment)
	if err != nil {
		return nil, errors.ErrorUnexpected("unable to obtain metadata", deployedResource.Name)
	}

	apiPods, err := config.K8s.ListPodsByLabels(map[string]string{
		"apiName": apiDeployment.Labels["apiName"],
	})
	if err != nil {
		return nil, err
	}
	apiStatus.ReplicaCounts = GetReplicaCounts(apiDeployment, apiPods)

	apiEndpoint, err := operator.APIEndpointFromResource(deployedResource)
	if err != nil {
		return nil, err
	}

	dashboardURL := pointer.String(getDashboardURL(deployedResource.Name))

	return []schema.APIResponse{
		{
			Metadata:     apiMetadata,
			Status:       apiStatus,
			Endpoint:     &apiEndpoint,
			DashboardURL: dashboardURL,
		},
	}, nil
}

func UpdateAPIMetricsCron(apiDeployment *kapps.Deployment) error {
	apiName := apiDeployment.Labels["apiName"]