diff --git a/azure/clusters.go b/azure/clusters.go index 3dd2214..2fede89 100644 --- a/azure/clusters.go +++ b/azure/clusters.go @@ -18,16 +18,16 @@ func (a ClustersAPI) init(client DBClient) ClustersAPI { } // Create creates a new Spark cluster -func (a ClustersAPI) Create(cluster models.NewCluster) (models.ClusterInfo, error) { - var clusterInfo models.ClusterInfo - +func (a ClustersAPI) Create(cluster models.NewCluster) (models.NewClusterResponse, error) { + var clusterResp models.NewClusterResponse + resp, err := a.Client.performQuery(http.MethodPost, "/clusters/create", cluster, nil) if err != nil { - return clusterInfo, err + return clusterResp, err } - - err = json.Unmarshal(resp, &clusterInfo) - return clusterInfo, err + + err = json.Unmarshal(resp, &clusterResp) + return clusterResp, err } // Edit edits the configuration of a cluster to match the provided attributes and size diff --git a/azure/models/NewClusterResponse.go b/azure/models/NewClusterResponse.go new file mode 100644 index 0000000..c0f6949 --- /dev/null +++ b/azure/models/NewClusterResponse.go @@ -0,0 +1,5 @@ +package models + +type NewClusterResponse struct { + ClusterID string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"` +} \ No newline at end of file