UpdateAPI deploys or update a task api without triggering any task
(apiConfig *userconfig.API)
| 44 | |
| 45 | // UpdateAPI deploys or update a task api without triggering any task |
| 46 | func UpdateAPI(apiConfig *userconfig.API) (*spec.API, string, error) { |
| 47 | prevVirtualService, err := config.K8s.GetVirtualService(workloads.K8sName(apiConfig.Name)) |
| 48 | if err != nil { |
| 49 | return nil, "", err |
| 50 | } |
| 51 | |
| 52 | initialDeploymentTime := time.Now().UnixNano() |
| 53 | if prevVirtualService != nil && prevVirtualService.Labels["initialDeploymentTime"] != "" { |
| 54 | var err error |
| 55 | initialDeploymentTime, err = k8s.ParseInt64Label(prevVirtualService, "initialDeploymentTime") |
| 56 | if err != nil { |
| 57 | return nil, "", err |
| 58 | } |
| 59 | } |
| 60 | |
| 61 | api := spec.GetAPISpec(apiConfig, initialDeploymentTime, "", config.ClusterConfig.ClusterUID) // Deployment ID not needed for TaskAPI spec |
| 62 | |
| 63 | if prevVirtualService == nil { |
| 64 | if err := config.AWS.UploadJSONToS3(api, config.ClusterConfig.Bucket, api.Key); err != nil { |
| 65 | return nil, "", errors.Wrap(err, "upload api spec") |
| 66 | } |
| 67 | |
| 68 | err = applyK8sResources(api, prevVirtualService) |
| 69 | if err != nil { |
| 70 | routines.RunWithPanicHandler(func() { |
| 71 | deleteK8sResources(api.Name) |
| 72 | }) |
| 73 | return nil, "", err |
| 74 | } |
| 75 | |
| 76 | return api, fmt.Sprintf("created %s", api.Resource.UserString()), nil |
| 77 | } |
| 78 | |
| 79 | if prevVirtualService.Labels["specID"] != api.SpecID { |
| 80 | if err := config.AWS.UploadJSONToS3(api, config.ClusterConfig.Bucket, api.Key); err != nil { |
| 81 | return nil, "", errors.Wrap(err, "upload api spec") |
| 82 | } |
| 83 | |
| 84 | err = applyK8sResources(api, prevVirtualService) |
| 85 | if err != nil { |
| 86 | return nil, "", err |
| 87 | } |
| 88 | |
| 89 | return api, fmt.Sprintf("updated %s", api.Resource.UserString()), nil |
| 90 | } |
| 91 | |
| 92 | return api, fmt.Sprintf("%s is up to date", api.Resource.UserString()), nil |
| 93 | } |
| 94 | |
| 95 | // DeleteAPI deletes a task api |
| 96 | func DeleteAPI(apiName string, keepCache bool) error { |
no test coverage detected