func determineESCredentialsSecret()

in internal/stackdiag.go [495:510]


func determineESCredentialsSecret(k *Kubectl, ns, esName string) (secretName, secretKey string, err error) {
	diagnosticUserSecretName := fmt.Sprintf("%s-es-internal-users", esName)
	secret, err := k.CoreV1().Secrets(ns).Get(context.Background(), diagnosticUserSecretName, metav1.GetOptions{})
	if err == nil {
		if _, ok := secret.Data[diagnosticsUsername]; ok {
			return diagnosticUserSecretName, diagnosticsUsername, nil
		}
	}

	elasticSecretName := fmt.Sprintf("%s-es-elastic-user", esName)
	if _, err := k.CoreV1().Secrets(ns).Get(context.Background(), elasticSecretName, metav1.GetOptions{}); err == nil {
		return elasticSecretName, "elastic", nil
	}

	return "", "", fmt.Errorf("no credentials secret found for Elasticsearch %s", esName)
}