Method CreateSecret

runner/utils/driver/istio/secrets.go:20–53

CreateSecret is used to upsert secret

(ctx context.Context, projectID string, secretObj *model.Secret)

// CreateSecret is used to upsert secret
func (i *Istio) CreateSecret(ctx context.Context, projectID string, secretObj *model.Secret) error {
	// check whether the oldSecret type is correct!
	if secretObj.Type != model.FileType && secretObj.Type != model.EnvType && secretObj.Type != model.DockerType {
		return helpers.Logger.LogError(helpers.GetRequestID(ctx), fmt.Sprintf("Invalid old secret type (%s) provided", secretObj.Type), nil, nil)
	}

	oldSecret, err := i.kube.CoreV1().Secrets(projectID).Get(ctx, secretObj.ID, metav1.GetOptions{})
	if kubeErrors.IsNotFound(err) {
		// Create a new Secret
		helpers.Logger.LogDebug(helpers.GetRequestID(ctx), fmt.Sprintf("Creating secret (%s)", secretObj.ID), nil)
		newSecret, err := generateSecret(ctx, projectID, secretObj)
		if err != nil {
			return err
		}

		_, err = i.kube.CoreV1().Secrets(projectID).Create(ctx, newSecret, metav1.CreateOptions{})
		return err

	} else if err == nil {
		// oldSecret already exists...update it!
		helpers.Logger.LogDebug(helpers.GetRequestID(ctx), fmt.Sprintf("Updating secret (%s)", secretObj.ID), nil)
		oldSecretType := oldSecret.Annotations["secretType"]
		if oldSecret.Annotations["secretType"] != secretObj.Type {
			return helpers.Logger.LogError(helpers.GetRequestID(ctx), fmt.Sprintf("Secret type mismatch. Wanted - %s; Got - %s", oldSecretType, secretObj.Type), nil, nil)
		}
		newSecret, err := generateSecret(ctx, projectID, secretObj)
		if err != nil {
			return err
		}
		_, err = i.kube.CoreV1().Secrets(projectID).Update(ctx, newSecret, metav1.UpdateOptions{})
		return err
	}
	return helpers.Logger.LogError(helpers.GetRequestID(ctx), fmt.Sprintf("Failed to create secret (%s)", secretObj.ID), err, nil)
}

// ListSecrets lists all the secrets in the provided name-space!
func (i *Istio) ListSecrets(ctx context.Context, projectID string) ([]*model.Secret, error) {