Function DeleteAPI

pkg/operator/resources/asyncapi/api.go:205–244

(apiName string, keepCache bool)

}

func DeleteAPI(apiName string, keepCache bool) error {
	err := parallel.RunFirstErr(
		func() error {
			vs, err := config.K8s.GetVirtualService(workloads.K8sName(apiName))
			if err != nil {
				return err
			}
			if vs != nil {
				initialDeploymentTime, err := k8s.ParseInt64Label(vs, "initialDeploymentTime")
				if err != nil {
					return err
				}
				queueURL, err := getQueueURL(apiName, initialDeploymentTime)
				if err != nil {
					return err
				}
				// best effort deletion
				_ = deleteQueueByURL(queueURL)
			}
			return nil
		},
		func() error {
			return deleteK8sResources(apiName)
		},
		func() error {
			if keepCache {
				return nil
			}
			// best effort deletion, swallow errors because there could be weird error messages
			_ = deleteBucketResources(apiName)
			return nil
		},
	)

	if err != nil {
		return err
	}

	return nil
}

func GetAllAPIs(deployments []kapps.Deployment) ([]schema.APIResponse, error) {
	asyncAPIs := make([]schema.APIResponse, 0)