InstallAzurite will set up Azurite in defined namespace and creates service
( ctx context.Context, crudClient client.Client, namespace string, )
| 110 | |
| 111 | // InstallAzurite will set up Azurite in defined namespace and creates service |
| 112 | func InstallAzurite( |
| 113 | ctx context.Context, |
| 114 | crudClient client.Client, |
| 115 | namespace string, |
| 116 | ) error { |
| 117 | azuriteDeployment := getAzuriteDeployment(namespace) |
| 118 | err := crudClient.Create(ctx, &azuriteDeployment) |
| 119 | if err != nil { |
| 120 | return err |
| 121 | } |
| 122 | // Wait for the Azurite pod to be ready |
| 123 | deploymentNamespacedName := types.NamespacedName{ |
| 124 | Namespace: namespace, |
| 125 | Name: "azurite", |
| 126 | } |
| 127 | deployment := &appsv1.Deployment{} |
| 128 | err = crudClient.Get(ctx, deploymentNamespacedName, deployment) |
| 129 | if err != nil { |
| 130 | return err |
| 131 | } |
| 132 | err = deployments.WaitForReady(ctx, crudClient, deployment, 300) |
| 133 | if err != nil { |
| 134 | return err |
| 135 | } |
| 136 | azuriteService := getAzuriteService(namespace) |
| 137 | err = crudClient.Create(ctx, &azuriteService) |
| 138 | return err |
| 139 | } |
| 140 | |
| 141 | // InstallAzCli will install Az cli |
| 142 | func InstallAzCli( |