2b85b0d1df
Update k8s client and the dependencies ACI client change for Mocking Add ACI Provider Mock Tests Add the Windows development environment Add UT for Default Resource Requests Enable the make test in Docker file Update the vendors
70 lines
2.1 KiB
Go
70 lines
2.1 KiB
Go
package aci
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"errors"
|
|
"fmt"
|
|
"net/http"
|
|
"net/url"
|
|
|
|
"github.com/virtual-kubelet/virtual-kubelet/providers/azure/client/api"
|
|
)
|
|
|
|
// CreateContainerGroup creates a new Azure Container Instance with the
|
|
// provided properties.
|
|
// From: https://docs.microsoft.com/en-us/rest/api/container-instances/containergroups/createorupdate
|
|
func (c *Client) CreateContainerGroup(resourceGroup, containerGroupName string, containerGroup ContainerGroup) (*ContainerGroup, error) {
|
|
urlParams := url.Values{
|
|
"api-version": []string{apiVersion},
|
|
}
|
|
|
|
// Create the url.
|
|
uri := api.ResolveRelative(c.auth.ResourceManagerEndpoint, containerGroupURLPath)
|
|
uri += "?" + url.Values(urlParams).Encode()
|
|
|
|
// Create the body for the request.
|
|
b := new(bytes.Buffer)
|
|
if err := json.NewEncoder(b).Encode(containerGroup); err != nil {
|
|
return nil, fmt.Errorf("Encoding create container group body request failed: %v", err)
|
|
}
|
|
|
|
// Create the request.
|
|
req, err := http.NewRequest("PUT", uri, b)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("Creating create/update container group uri request failed: %v", err)
|
|
}
|
|
|
|
// Add the parameters to the url.
|
|
if err := api.ExpandURL(req.URL, map[string]string{
|
|
"subscriptionId": c.auth.SubscriptionID,
|
|
"resourceGroup": resourceGroup,
|
|
"containerGroupName": containerGroupName,
|
|
}); err != nil {
|
|
return nil, fmt.Errorf("Expanding URL with parameters failed: %v", err)
|
|
}
|
|
|
|
// Send the request.
|
|
resp, err := c.hc.Do(req)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("Sending create container group request failed: %v", err)
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
// 200 (OK) and 201 (Created) are a successful responses.
|
|
if err := api.CheckResponse(resp); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Decode the body from the response.
|
|
if resp.Body == nil {
|
|
return nil, errors.New("Create container group returned an empty body in the response")
|
|
}
|
|
var cg ContainerGroup
|
|
if err := json.NewDecoder(resp.Body).Decode(&cg); err != nil {
|
|
return nil, fmt.Errorf("Decoding create container group response body failed: %v", err)
|
|
}
|
|
|
|
return &cg, nil
|
|
}
|