Function Delete

cli/cluster/delete.go:32–57

(operatorConfig OperatorConfig, apiName string, keepCache bool, force bool)

)

func Delete(operatorConfig OperatorConfig, apiName string, keepCache bool, force bool) (schema.DeleteResponse, error) {
	if !force {
		readyReplicas := getReadyRealtimeAPIReplicasOrNil(operatorConfig, apiName)
		if readyReplicas != nil && *readyReplicas > 2 {
			prompt.YesOrExit(fmt.Sprintf("are you sure you want to delete %s (which has %d live replicas)?", apiName, *readyReplicas), "", "")
		}
	}

	params := map[string]string{
		"apiName":   apiName,
		"keepCache": s.Bool(keepCache),
	}

	httpRes, err := HTTPDelete(operatorConfig, "/delete/"+apiName, params)
	if err != nil {
		return schema.DeleteResponse{}, err
	}

	var deleteRes schema.DeleteResponse
	err = json.Unmarshal(httpRes, &deleteRes)
	if err != nil {
		return schema.DeleteResponse{}, errors.Wrap(err, "/delete", string(httpRes))
	}

	return deleteRes, nil
}

func getReadyRealtimeAPIReplicasOrNil(operatorConfig OperatorConfig, apiName string) *int32 {
	httpRes, err := HTTPGet(operatorConfig, "/get/"+apiName)