|
|
@@ -30,7 +30,10 @@ func init() {
|
|
|
}
|
|
|
|
|
|
func createACIContainers(ctx context.Context, aciContext store.AciContext, groupDefinition containerinstance.ContainerGroup) (c containerinstance.ContainerGroup, err error) {
|
|
|
- containerGroupsClient := getContainerGroupsClient(aciContext.SubscriptionID)
|
|
|
+ containerGroupsClient, err := getContainerGroupsClient(aciContext.SubscriptionID)
|
|
|
+ if err != nil {
|
|
|
+ return c, errors.Wrapf(err, "cannot get container group client")
|
|
|
+ }
|
|
|
|
|
|
// Check if the container group already exists
|
|
|
_, err = containerGroupsClient.Get(ctx, aciContext.ResourceGroup, *groupDefinition.Name)
|
|
|
@@ -94,7 +97,10 @@ func createACIContainers(ctx context.Context, aciContext store.AciContext, group
|
|
|
}
|
|
|
|
|
|
func execACIContainer(ctx context.Context, aciContext store.AciContext, command, containerGroup string, containerName string) (c containerinstance.ContainerExecResponse, err error) {
|
|
|
- containerClient := getContainerClient(aciContext.SubscriptionID)
|
|
|
+ containerClient, err := getContainerClient(aciContext.SubscriptionID)
|
|
|
+ if err != nil {
|
|
|
+ return c, errors.Wrapf(err, "cannot get container client")
|
|
|
+ }
|
|
|
rows, cols := getTermSize()
|
|
|
containerExecRequest := containerinstance.ContainerExecRequest{
|
|
|
Command: to.StringPtr(command),
|
|
|
@@ -199,7 +205,10 @@ func exec(ctx context.Context, address string, password string, reader io.Reader
|
|
|
}
|
|
|
|
|
|
func getACIContainerLogs(ctx context.Context, aciContext store.AciContext, containerGroupName, containerName string) (string, error) {
|
|
|
- containerClient := getContainerClient(aciContext.SubscriptionID)
|
|
|
+ containerClient, err := getContainerClient(aciContext.SubscriptionID)
|
|
|
+ if err != nil {
|
|
|
+ return "", errors.Wrapf(err, "cannot get container client")
|
|
|
+ }
|
|
|
|
|
|
logs, err := containerClient.ListLogs(ctx, aciContext.ResourceGroup, containerGroupName, containerName, nil)
|
|
|
if err != nil {
|
|
|
@@ -208,16 +217,22 @@ func getACIContainerLogs(ctx context.Context, aciContext store.AciContext, conta
|
|
|
return *logs.Content, err
|
|
|
}
|
|
|
|
|
|
-func getContainerGroupsClient(subscriptionID string) containerinstance.ContainerGroupsClient {
|
|
|
- auth, _ := auth.NewAuthorizerFromCLI()
|
|
|
+func getContainerGroupsClient(subscriptionID string) (containerinstance.ContainerGroupsClient, error) {
|
|
|
+ auth, err := auth.NewAuthorizerFromCLI()
|
|
|
+ if err != nil {
|
|
|
+ return containerinstance.ContainerGroupsClient{}, err
|
|
|
+ }
|
|
|
containerGroupsClient := containerinstance.NewContainerGroupsClient(subscriptionID)
|
|
|
containerGroupsClient.Authorizer = auth
|
|
|
- return containerGroupsClient
|
|
|
+ return containerGroupsClient, nil
|
|
|
}
|
|
|
|
|
|
-func getContainerClient(subscriptionID string) containerinstance.ContainerClient {
|
|
|
- auth, _ := auth.NewAuthorizerFromCLI()
|
|
|
+func getContainerClient(subscriptionID string) (containerinstance.ContainerClient, error) {
|
|
|
+ auth, err := auth.NewAuthorizerFromCLI()
|
|
|
+ if err != nil {
|
|
|
+ return containerinstance.ContainerClient{}, err
|
|
|
+ }
|
|
|
containerClient := containerinstance.NewContainerClient(subscriptionID)
|
|
|
containerClient.Authorizer = auth
|
|
|
- return containerClient
|
|
|
+ return containerClient, nil
|
|
|
}
|