Enable csi-lib metrics

Based on cert-manager/csi-lib#73

Signed-off-by: Jing Liu <jingliu@apple.com>
Signed-off-by: Richard Wall <richard.wall@cyberark.com>

Author: 7ing

cmd/app/app.go

@@ -24,16 +24,21 @@ import (
 	"encoding/pem"
 	"fmt"
 	"net/http"
+	"time"
 
+	"github.com/cert-manager/cert-manager/pkg/client/informers/externalversions"
 	"github.com/cert-manager/csi-lib/driver"
 	"github.com/cert-manager/csi-lib/manager"
 	"github.com/cert-manager/csi-lib/manager/util"
 	"github.com/cert-manager/csi-lib/metadata"
+	csimetrics "github.com/cert-manager/csi-lib/metrics"
 	"github.com/cert-manager/csi-lib/storage"
+	"github.com/prometheus/client_golang/prometheus"
 	"github.com/spf13/cobra"
 	"golang.org/x/sync/errgroup"
 	"k8s.io/utils/clock"
 	ctrl "sigs.k8s.io/controller-runtime"
+	ctrlmetrics "sigs.k8s.io/controller-runtime/pkg/metrics"
 	metricsserver "sigs.k8s.io/controller-runtime/pkg/metrics/server"
 
 	"github.com/cert-manager/csi-driver/cmd/app/options"
@@ -80,6 +85,16 @@ func NewCommand(ctx context.Context) *cobra.Command {
 				clientForMeta = util.ClientForMetadataTokenRequestEmptyAud(opts.RestConfig)
 			}
 
+			certRequestInformerFactory := externalversions.NewSharedInformerFactory(opts.CMClient, 5*time.Second)
+			certRequestInformer := certRequestInformerFactory.Certmanager().V1().CertificateRequests()
+			metricsHandler := csimetrics.New(
+				opts.NodeID,
+				&opts.Logr,
+				ctrlmetrics.Registry.(*prometheus.Registry),
+				store,
+				certRequestInformer.Lister(),
+			)
+
 			mngrlog := opts.Logr.WithName("manager")
 			d, err := driver.New(ctx, opts.Endpoint, opts.Logr.WithName("driver"), driver.Options{
 				DriverName:    opts.DriverName,
@@ -97,6 +112,7 @@ func NewCommand(ctx context.Context) *cobra.Command {
 					GenerateRequest:    requestgen.RequestForMetadata,
 					SignRequest:        signRequest,
 					WriteKeypair:       writer.WriteKeypair,
+					Metrics:            metricsHandler,
 				}),
 			})
 			if err != nil {
@@ -163,6 +179,12 @@ func NewCommand(ctx context.Context) *cobra.Command {
 				g.Go(func() error {
 					return metricsServer.Start(gCTX)
 				})
+
+				g.Go(func() error {
+					certRequestInformerFactory.Start(gCTX.Done())
+					certRequestInformerFactory.WaitForCacheSync(gCTX.Done())
+					return nil
+				})
 			}
 			return g.Wait()
 		},

go.mod

@@ -8,6 +8,7 @@ require (
 	github.com/go-logr/logr v1.4.3
 	github.com/onsi/ginkgo/v2 v2.27.3
 	github.com/onsi/gomega v1.38.3
+	github.com/prometheus/client_golang v1.23.2
 	github.com/spf13/cobra v1.10.2
 	github.com/spf13/pflag v1.0.10
 	github.com/stretchr/testify v1.11.1
@@ -70,7 +71,6 @@ require (
 	github.com/mxk/go-flowrate v0.0.0-20140419014527-cca7078d478f // indirect
 	github.com/peterbourgon/diskv v2.0.1+incompatible // indirect
 	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
-	github.com/prometheus/client_golang v1.23.2 // indirect
 	github.com/prometheus/client_model v0.6.2 // indirect
 	github.com/prometheus/common v0.66.1 // indirect
 	github.com/prometheus/procfs v0.17.0 // indirect