fix(storage): monitored resource detection (#11197)

* fix(storage): populate monitored resource correctly

* refactor with additional integration tests

* refactor initialization of metricsContext

* remove exporter experimental option and add manual reader for tests

* go mod tidy

* dependency inject gcp detector for testing

* revert removal of metricExporter option

* revert changes to metricExporter option tests

* use struct embedding

* pass in resource correctly to exporter

* update test using resource value

* add tests checking resource values

* add option to disable exporter in unit tests

* address feedback

* use project-id not project_id...

Author: frankyn

storage/grpc_client.go

@@ -35,6 +35,7 @@ import (
 	"google.golang.org/api/iterator"
 	"google.golang.org/api/option"
 	"google.golang.org/api/option/internaloption"
+	"google.golang.org/api/transport"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/encoding"
@@ -118,6 +119,24 @@ type grpcStorageClient struct {
 	settings *settings
 }
 
+func enableClientMetrics(ctx context.Context, s *settings, config storageConfig) (*metricsContext, error) {
+	var project string
+	// TODO: use new auth client
+	c, err := transport.Creds(ctx, s.clientOption...)
+	if err == nil {
+		project = c.ProjectID
+	}
+	metricsContext, err := newGRPCMetricContext(ctx, metricsConfig{
+		project:      project,
+		interval:     config.metricInterval,
+		manualReader: config.manualReader},
+	)
+	if err != nil {
+		return nil, fmt.Errorf("gRPC Metrics: %w", err)
+	}
+	return metricsContext, nil
+}
+
 // newGRPCStorageClient initializes a new storageClient that uses the gRPC
 // Storage API.
 func newGRPCStorageClient(ctx context.Context, opts ...storageOption) (storageClient, error) {