https://pulumi.com logo
Powered by
Title
s

sparse-nail-47035

01/04/2023, 8:02 PM
I'm trying to set up a simple K8s cluster script in Azure using Scala and I'm wondering what is the correct way to export a kubeconfig from my cluster definition. I have the following: 
val k8sCluster = new ManagedCluster(...)
I do not see any function in the ManagedCluster class that I can use to export the KubeConfig object. Is there any mechanism in the API that can be used to build a KubeConfig from a clsuer instance?
b

billowy-army-68599

01/04/2023, 8:05 PM
@sparse-nail-47035 I’m not familiar with scala, but in Java there’s a 
ctx.export
method: 
import com.pulumi.Context;


ctx.export("kubeconfig" ...)
m

many-telephone-49025

01/04/2023, 8:09 PM
Hi @sparse-nail-47035, In "vanilla" Java, I had to do this to get the 
kubeconfig
Output<String> kubeconfig = Output.all(minecraftGroup.name(), mc.name()).apply(values -> {
                try {
                    CompletableFuture<ListManagedClusterUserCredentialsResult> cred = ContainerserviceFunctions.listManagedClusterUserCredentials(ListManagedClusterUserCredentialsArgs.builder()
                            .resourceGroupName(values.get(0))
                            .resourceName(values.get(1)).build());
                    String kubeconfigString = cred.get().kubeconfigs().get(0).value();
                    byte[] decodedBytes = Base64.getDecoder().decode(kubeconfigString);
                    return Output.of(new String(decodedBytes));
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            });
I can't rewrite this "quickly" into Scala but should be similar at the end 😄 #jvm
s

sparse-nail-47035

01/04/2023, 8:14 PM
@billowy-army-68599 I don't think it works. I already have tried this!
@many-telephone-49025 Is that so complicated to export a KubeConfig?
m

many-telephone-49025

01/04/2023, 8:18 PM
yeah, Easier it is when you use the azure cli to get the kubeconfig
but not practical, when you want to use it to autodeploy
s

sparse-nail-47035

01/04/2023, 8:19 PM
Under what circumstances would I be needing to export KubeConfig from a Java or Scala code?
m

many-telephone-49025

01/04/2023, 8:19 PM
If you want to deploy k8s resources via Pulumi
In most aks tutorials you see: 1. Deploy 2. ??? 3. `az aks get-credential ...`` 4. Profit 😄
s

sparse-nail-47035

01/04/2023, 8:22 PM
Could you share that full source code
I could not make out what some of those variables stand for
As a sidenote, that piece of Java code is not pleasing to the eyes. My sinceere advice is to use Scala!
m

many-telephone-49025

01/04/2023, 8:23 PM
Yes -> https://github.com/dirien/pulumi-java-azure-kubernetes/blob/main/src/main/java/minecraft/App.java
s

sparse-nail-47035

01/04/2023, 8:23 PM
That returned a 404
m

many-telephone-49025

01/04/2023, 8:24 PM
Try again please, it was private somehow
s

sparse-nail-47035

01/04/2023, 8:24 PM
Yes, I will take a look, but thank you very much for the help!
m

many-telephone-49025

01/04/2023, 8:27 PM
If you manage it, would love to see the Scala code! So if you could share your results i would be very happy!
s

sparse-nail-47035

01/04/2023, 8:28 PM
I will sure do that! I'm hitting another problem now
I have the following as dependencies
libraryDependencies += "com.pulumi" % "pulumi" % "0.7.1",
libraryDependencies += "com.pulumi" % "azure" % "5.28.0",
libraryDependencies += "com.pulumi" % "command" % "4.5.0"
m

many-telephone-49025

01/04/2023, 8:29 PM
ah you are not using the native provider?
s

sparse-nail-47035

01/04/2023, 8:29 PM
I guess not
m

many-telephone-49025

01/04/2023, 8:29 PM
you should use the azure native provider
libraryDependencies += "com.pulumi" % "azure-native" % "1.90.0",
s

sparse-nail-47035

01/04/2023, 8:33 PM
Here is the project that I'm working on:
https://github.com/open-electrons/oprn-electrons-infra/blob/master/open-electrons-[…]c/main/scala/com/openelectrons/infra/k8s/CreateK8sCluster.scala
What is that cred.get?
I cannot find that
It is resolving not to a Future, but this
val cred: Output[ListManagedClusterUserCredentialsResult]
m

many-telephone-49025

01/04/2023, 8:38 PM
its a CompletableFuture<ListManagedClusterUserCredentialsResult>
From java.util.concurrent
s

sparse-nail-47035

01/04/2023, 8:39 PM
It does not resole to a future
If it does, I can get it into a Scala Future, but it resolved to Output[...]
m

many-telephone-49025

01/04/2023, 8:40 PM
hmm https://www.pulumi.com/registry/packages/azure-native/api-docs/containerservice/listmanagedclustermonitoringusercredentials/
docs state it's a Future
s

sparse-nail-47035

01/04/2023, 8:45 PM
Wierd, it won't resolve to a Future
I guess I'm calling one of the overloaded methods
This is what I see:
/**
 * The list of credential result response.
 * API Version: 2021-03-01.
 * 
 */
public static Output<ListManagedClusterMonitoringUserCredentialsResult> listManagedClusterMonitoringUserCredentials(ListManagedClusterMonitoringUserCredentialsArgs args) {
    return listManagedClusterMonitoringUserCredentials(args, InvokeOptions.Empty);
}
/**
 * The list of credential result response.
 * API Version: 2021-03-01.
 * 
 */
public static CompletableFuture<ListManagedClusterMonitoringUserCredentialsResult> listManagedClusterMonitoringUserCredentialsPlain(ListManagedClusterMonitoringUserCredentialsPlainArgs args) {
    return listManagedClusterMonitoringUserCredentialsPlain(args, InvokeOptions.Empty);
}
/**
 * The list of credential result response.
 * API Version: 2021-03-01.
 * 
 */
public static Output<ListManagedClusterMonitoringUserCredentialsResult> listManagedClusterMonitoringUserCredentials(ListManagedClusterMonitoringUserCredentialsArgs args, InvokeOptions options) {
    return Deployment.getInstance().invoke("azure-native:containerservice:listManagedClusterMonitoringUserCredentials", TypeShape.of(ListManagedClusterMonitoringUserCredentialsResult.class), args, Utilities.withVersion(options));
}
/**
 * The list of credential result response.
 * API Version: 2021-03-01.
 * 
 */
public static CompletableFuture<ListManagedClusterMonitoringUserCredentialsResult> listManagedClusterMonitoringUserCredentialsPlain(ListManagedClusterMonitoringUserCredentialsPlainArgs args, InvokeOptions options) {
    return Deployment.getInstance().invokeAsync("azure-native:containerservice:listManagedClusterMonitoringUserCredentials", TypeShape.of(ListManagedClusterMonitoringUserCredentialsResult.class), args, Utilities.withVersion(options));
}
m

many-telephone-49025

01/04/2023, 9:02 PM
unfortunately I am very basic in my Scala skills and would not much of a help.
s

sparse-nail-47035

01/04/2023, 9:13 PM
I'm trying to get that done!
https://github.com/open-electrons/oprn-electrons-infra/blob/master/open-electrons-[…]c/main/scala/com/openelectrons/infra/k8s/CreateK8sCluster.scala
That atleast compiles, but that way of calling get on Futures and Try is not idomatic
I will change that later
but thanks for the help!
#generalJoin Slack
Powered by