Using API toolkit to list flux custom resources ..

[talha9251]

Hi all ..

I am bit new to fluxcd and go-lang in general . I am using go-lang dynamic client with helmchart api ( Source-controller ) using unstructured method. I want to get similar output as ( kubectl get helmcharts.source.toolkit.fluxcd.io -A , required fields NAMESPACE NAME CHART VERSION SOURCE KIND SOURCE NAME AGE READY STATUS
I was checking supported types from https://github.com/fluxcd/source-controller/blob/main/api/v1beta1/helmchart_types.go . Please advise.
Thanks.
--- go-program.--------

package main

import (
        "context"
        "flag"
        "fmt"
        "os"
        "path/filepath"
        "log/slog"
        "k8s.io/client-go/dynamic"
//      "k8s.io/client-go/kubernetes"
        "k8s.io/client-go/rest"
        "k8s.io/client-go/tools/clientcmd"
        "k8s.io/client-go/util/homedir"
        metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
        "k8s.io/apimachinery/pkg/runtime/schema"
        sourcev1beta1 "github.com/fluxcd/source-controller/api/v1beta1"
        "k8s.io/apimachinery/pkg/runtime"
        "github.com/fatih/color"
)

func main() {

         //cGreen := "\033[32m"
        var kubeconfig *string
        if home := homedir.HomeDir(); home != "" {
                kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "absolute path to the kubeconfig file")
        } else {
                kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
        }
        flag.Parse()

        // Load Kubernetes configuration
        config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
        if err != nil {
                config, err = rest.InClusterConfig()
                if err != nil {
                        fmt.Printf("Error building config: %v\n", err)
                        os.Exit(1)
                }
        }

        dynamicClient, err := dynamic.NewForConfig(config)
        if err != nil {
                fmt.Printf("Error creating dynamic client: %v\n", err)
                os.Exit(1)
        }

       crList5, err := dynamicClient.Resource(schema.GroupVersionResource{
                Group:    "source.toolkit.fluxcd.io",    // specify the API group of the custom resource
                Version:  "v1beta1",  // specify the API version of the custom resource
                Resource: "helmcharts", // specify the resource name
         }).List(context.Background(), metav1.ListOptions{})
        if err != nil {
                fmt.Printf("Error listing custom resources: %v\n", err)
                os.Exit(1)
        }

        // Print the list of Custom Resources
        color.Yellow("HelmCharts Custom Resources:")
        for _, cr := range crList5.Items {
                fmt.Printf(" - %s\n", cr.GetName())
                fmt.Printf(" NameSpace - %s\n", cr.GetNamespace())
        j := &sourcev1beta1.HelmChart{}
        err = runtime.DefaultUnstructuredConverter.FromUnstructured(cr.UnstructuredContent(), &j)
        if err != nil {
                fmt.Printf("error %s, converting unstructured type", err.Error())

                 slog.Info("Details  %v\n", j.Status.Conditions)
                 slog.Info("Details  %v\n", j.Spec.Chart)
                 slog.Info("Details  %v\n", j.Labels)
                  slog.Info("Details  %v\n", j.Spec.URL)
               fmt.Printf("Details  %s\n", &j)
         }
 }
}


----------------output -------------

#  go run tiny.go
HelmCharts Custom Resources:
 - sandbox-ns1-busybox
 NameSpace - sandbox-ns1
 - sandbox-ns2-busybox
 NameSpace - sandbox-ns2

------------ Desired output ------------------

 kubectl get helmcharts.source.toolkit.fluxcd.io -A
NAMESPACE     NAME                  CHART     VERSION           SOURCE KIND      SOURCE NAME       AGE     READY   STATUS
sandbox-ns1   sandbox-ns1-busybox   busybox   >=0.1.1           HelmRepository   helm-repository   6h30m   True    pulled 'busybox' chart with version '0.1.4'
sandbox -ns2   sandbox-ns2-busybox   busybox   >=0.1.1 <=0.1.4   HelmRepository   helm-repository   6h30m   True    pulled 'busybox' chart with version '0.1.4'

[stefanprodan]

Please see here the docs on how to use the Flux APIs in Go https://fluxcd.io/flux/gitops-toolkit/packages/

[talha9251]

Thanks for your feedback . I have started looking at gitops-toolkit package. i think it will be much straight forward.
looks like i cannot query all names/namespace likes of
kubectl get helmreleases.helm.toolkit.fluxcd.io -A or --all-namespaces. or these field cannot be empty or use wildcard ?? please advise.

types
}
namespacedName := types.NamespacedName{
Namespace: "sandbox-ns",
Name: "test",
}

[stefanprodan]

That's for selecting a single object, there is a List type you can use, the namespace would be string empty to list all. Example here https://github.com/fluxcd/notification-controller/blob/e73db32382a1f60646d2540e8525eaa55ec66f5c/internal/server/event_handlers.go#L94-L98

[talha9251]

Thanks a lot for your help . just wondering how i can get controller version 2.2.x information from api toolkit . checked the types.go files with no luck .

[stefanprodan]

Not sure what you are asking for? What kind of information?

[talha9251]

I am looking for output like flux version command , need flux and controller version as well .

[stefanprodan]

Read the CLI code, all is open source https://github.com/fluxcd/flux2/blob/main/cmd/flux/version.go