Unify ClusterProfiles provider implementation into cluster-inventory-api provider

Signed-off-by: Shingo Omura <[email protected]>

Author: everpeace

examples/clusterprofile/clusterprofile-provider-file.json renamed to examples/cluster-inventory-api/clusterprofile-provider-file.json

@@ -69,7 +69,10 @@ github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9G
 github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
 github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA=
 github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ=
+github.com/nxadm/tail v1.4.8 h1:nPr65rt6Y5JFSKQO7qToXr7pePgD6Gwiw05lkbyAQTE=
+github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU=
 github.com/onsi/ginkgo v1.16.5 h1:8xi0RTUf59SOSfEtZMvwTvXYMzG4gV23XVHOZiXNtnE=
+github.com/onsi/ginkgo v1.16.5/go.mod h1:+E8gABHa3K6zRBolWtd+ROzc/U5bkGt0FwiG042wbpU=
 github.com/onsi/ginkgo/v2 v2.22.0 h1:Yed107/8DjTr0lKCNt7Dn8yQ6ybuDRQoMGrNFKzMfHg=
 github.com/onsi/ginkgo/v2 v2.22.0/go.mod h1:7Du3c42kxCUegi0IImZ1wUQzMBVecgIHjR1C+NkhLQo=
 github.com/onsi/gomega v1.36.1 h1:bJDPBO7ibjxcbHMgSCoo4Yj18UWbKDlLwX1x9sybDcw=
@@ -158,6 +161,8 @@ gopkg.in/evanphx/json-patch.v4 v4.12.0 h1:n6jtcsulIzXPJaxegRbvFNNrZDjbij7ny3gmSP
 gopkg.in/evanphx/json-patch.v4 v4.12.0/go.mod h1:p8EYWUEYMpynmqDbY58zCKCFZw8pRWMG4EsWvDvM72M=
 gopkg.in/inf.v0 v0.9.1 h1:73M5CoZyi3ZLMOyDlQh031Cx6N9NDJ2Vvfl76EDAgDc=
 gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw=
+gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=
+gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 k8s.io/api v0.33.1 h1:tA6Cf3bHnLIrUK4IqEgb2v++/GYUtqiu9sRVk3iBXyw=

examples/cluster-inventory-api/go.sum

@@ -19,10 +19,12 @@ package main
 import (
 	"context"
 	"errors"
+	"flag"
 	"os"
 
 	"golang.org/x/sync/errgroup"
 	clusterinventoryv1alpha1 "sigs.k8s.io/cluster-inventory-api/apis/v1alpha1"
+	"sigs.k8s.io/cluster-inventory-api/pkg/credentials"
 
 	corev1 "k8s.io/api/core/v1"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
@@ -50,6 +52,9 @@ func init() {
 }
 
 func main() {
+	credentialsProviderFile := credentials.SetupProviderFileFlag()
+	flag.Parse()
+
 	ctrllog.SetLogger(zap.New(zap.UseDevMode(true)))
 	entryLog := ctrllog.Log.WithName("entrypoint")
 	ctx := signals.SetupSignalHandler()
@@ -61,13 +66,25 @@ func main() {
 		os.Exit(1)
 	}
 
-	// Create the provider against the local manager.
+	// Load credential providers from configuration file
+	credentialsProvider, err := credentials.NewFromFile(*credentialsProviderFile)
+	if err != nil {
+		entryLog.Error(err, "Got error reading credentials providers")
+		os.Exit(1)
+	}
+
+	// Create the provider.
 	provider, err := clusterinventoryapi.New(clusterinventoryapi.Options{
+		// Specifying the strategy how to fetch kubeconfig from ClusterProfile.
 		KubeconfigStrategyOption: kubeconfigstrategy.Option{
-			// Use the Secret strategy with a specific consumer name.
-			Secret: kubeconfigstrategy.SecretStrategyOption{
-				ConsumerName: "cluster-inventory-api-consumer",
+			CredentialsProvider: &kubeconfigstrategy.CredentialsProviderOption{
+				Provider: credentialsProvider,
 			},
+			// // Alternative:
+			// //   You can use the Secret strategy, but it is not recommended for production use.
+			// Secret: &kubeconfigstrategy.SecretStrategyOption{
+			// 	ConsumerName: "cluster-inventory-api-consumer",
+			// },
 		},
 	})
 	if err != nil {
@@ -76,7 +93,7 @@ func main() {
 	}
 
 	// Create a multi-cluster manager attached to the provider.
-	entryLog.Info("Setting up local manager")
+	entryLog.Info("Setting up manager")
 	mcMgr, err := mcmanager.New(cfg, provider, manager.Options{
 		LeaderElection: false,
 		Metrics: metricsserver.Options{