instrument cloud/scope

Author: meobilivang

cloud/scope/clients.go

@@ -31,6 +31,7 @@ import (
 	"k8s.io/client-go/pkg/version"
 	"k8s.io/client-go/util/flowcontrol"
 	infrav1 "sigs.k8s.io/cluster-api-provider-gcp/api/v1beta1"
+	"sigs.k8s.io/cluster-api-provider-gcp/util/telemetry"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
@@ -89,6 +90,12 @@ func defaultClientOptions(ctx context.Context, credentialsRef *infrav1.ObjectRef
 }
 
 func newComputeService(ctx context.Context, credentialsRef *infrav1.ObjectReference, crClient client.Client) (*compute.Service, error) {
+
+	ctx, span := telemetry.Tracer().Start(
+		ctx, "cloud.clients.newComputeService",
+	)
+	defer span.End()
+
 	opts, err := defaultClientOptions(ctx, credentialsRef, crClient)
 	if err != nil {
 		return nil, fmt.Errorf("getting default gcp client options: %w", err)
@@ -103,6 +110,12 @@ func newComputeService(ctx context.Context, credentialsRef *infrav1.ObjectRefere
 }
 
 func newClusterManagerClient(ctx context.Context, credentialsRef *infrav1.ObjectReference, crClient client.Client) (*container.ClusterManagerClient, error) {
+
+	ctx, span := telemetry.Tracer().Start(
+		ctx, "cloud.clients.newClusterManagerClient",
+	)
+	defer span.End()
+
 	opts, err := defaultClientOptions(ctx, credentialsRef, crClient)
 	if err != nil {
 		return nil, fmt.Errorf("getting default gcp client options: %w", err)
@@ -117,6 +130,12 @@ func newClusterManagerClient(ctx context.Context, credentialsRef *infrav1.Object
 }
 
 func newIamCredentialsClient(ctx context.Context, credentialsRef *infrav1.ObjectReference, crClient client.Client) (*credentials.IamCredentialsClient, error) {
+
+	ctx, span := telemetry.Tracer().Start(
+		ctx, "cloud.clients.newIamCredentialsClient",
+	)
+	defer span.End()
+
 	opts, err := defaultClientOptions(ctx, credentialsRef, crClient)
 	if err != nil {
 		return nil, fmt.Errorf("getting default gcp client options: %w", err)
@@ -131,6 +150,12 @@ func newIamCredentialsClient(ctx context.Context, credentialsRef *infrav1.Object
 }
 
 func newInstanceGroupManagerClient(ctx context.Context, credentialsRef *infrav1.ObjectReference, crClient client.Client) (*computerest.InstanceGroupManagersClient, error) {
+
+	ctx, span := telemetry.Tracer().Start(
+		ctx, "cloud.clients.newInstanceGroupManagerClient",
+	)
+	defer span.End()
+
 	opts, err := defaultClientOptions(ctx, credentialsRef, crClient)
 	if err != nil {
 		return nil, fmt.Errorf("getting default gcp client options: %w", err)

cloud/scope/cluster.go

@@ -27,6 +27,7 @@ import (
 	"k8s.io/utils/pointer"
 	infrav1 "sigs.k8s.io/cluster-api-provider-gcp/api/v1beta1"
 	"sigs.k8s.io/cluster-api-provider-gcp/cloud"
+	"sigs.k8s.io/cluster-api-provider-gcp/util/telemetry"
 	clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
 	"sigs.k8s.io/cluster-api/util/patch"
 	"sigs.k8s.io/controller-runtime/pkg/client"
@@ -43,6 +44,12 @@ type ClusterScopeParams struct {
 // NewClusterScope creates a new Scope from the supplied parameters.
 // This is meant to be called for each reconcile iteration.
 func NewClusterScope(ctx context.Context, params ClusterScopeParams) (*ClusterScope, error) {
+
+	ctx, span := telemetry.Tracer().Start(
+		ctx, "cloud.clusterScope.NewClusterScope",
+	)
+	defer span.End()
+
 	if params.Cluster == nil {
 		return nil, errors.New("failed to generate new scope from nil Cluster")
 	}

cloud/scope/managedcluster.go

@@ -27,6 +27,7 @@ import (
 	infrav1 "sigs.k8s.io/cluster-api-provider-gcp/api/v1beta1"
 	"sigs.k8s.io/cluster-api-provider-gcp/cloud"
 	infrav1exp "sigs.k8s.io/cluster-api-provider-gcp/exp/api/v1beta1"
+	"sigs.k8s.io/cluster-api-provider-gcp/util/telemetry"
 	clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
 	"sigs.k8s.io/cluster-api/util/patch"
 	"sigs.k8s.io/controller-runtime/pkg/client"
@@ -44,6 +45,12 @@ type ManagedClusterScopeParams struct {
 // NewManagedClusterScope creates a new Scope from the supplied parameters.
 // This is meant to be called for each reconcile iteration.
 func NewManagedClusterScope(ctx context.Context, params ManagedClusterScopeParams) (*ManagedClusterScope, error) {
+
+	ctx, span := telemetry.Tracer().Start(
+		ctx, "cloud.managedClusterScope.NewManagedClusterScope",
+	)
+	defer span.End()
+
 	if params.Cluster == nil {
 		return nil, errors.New("failed to generate new scope from nil Cluster")
 	}

cloud/scope/managedcontrolplane.go

@@ -21,6 +21,7 @@ import (
 	"fmt"
 
 	"sigs.k8s.io/cluster-api-provider-gcp/util/location"
+	"sigs.k8s.io/cluster-api-provider-gcp/util/telemetry"
 
 	"sigs.k8s.io/cluster-api/util/conditions"
 
@@ -52,6 +53,12 @@ type ManagedControlPlaneScopeParams struct {
 // NewManagedControlPlaneScope creates a new Scope from the supplied parameters.
 // This is meant to be called for each reconcile iteration.
 func NewManagedControlPlaneScope(ctx context.Context, params ManagedControlPlaneScopeParams) (*ManagedControlPlaneScope, error) {
+
+	ctx, span := telemetry.Tracer().Start(
+		ctx, "cloud.managedControlPlaneScope.NewManagedControlPlaneScope",
+	)
+	defer span.End()
+
 	if params.Cluster == nil {
 		return nil, errors.New("failed to generate new scope from nil Cluster")
 	}

cloud/scope/managedmachinepool.go

@@ -22,6 +22,7 @@ import (
 
 	"sigs.k8s.io/cluster-api-provider-gcp/cloud"
 	"sigs.k8s.io/cluster-api-provider-gcp/util/location"
+	"sigs.k8s.io/cluster-api-provider-gcp/util/telemetry"
 
 	"sigs.k8s.io/cluster-api/util/conditions"
 
@@ -51,6 +52,12 @@ type ManagedMachinePoolScopeParams struct {
 // NewManagedMachinePoolScope creates a new Scope from the supplied parameters.
 // This is meant to be called for each reconcile iteration.
 func NewManagedMachinePoolScope(ctx context.Context, params ManagedMachinePoolScopeParams) (*ManagedMachinePoolScope, error) {
+
+	ctx, span := telemetry.Tracer().Start(
+		ctx, "cloud.managedMachinePoolScope.NewManagedMachinePoolScope",
+	)
+	defer span.End()
+
 	if params.Cluster == nil {
 		return nil, errors.New("failed to generate new scope from nil Cluster")
 	}