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)
}