Export labels

exporter/metric/cloudmonitoring.go

@@ -83,3 +83,8 @@ func NewRawExporter(opts ...Option) (*Exporter, error) {
 func (e *Exporter) Export(ctx context.Context, cps export.CheckpointSet) error {
 	return e.metricExporter.ExportMetrics(ctx, cps)
 }
+
+// ExportMonitoredResLabels exports the labels of monitored resources.
+func (e *Exporter) ExportMonitoredResLabels() map[string]string {
+	return e.metricExporter.ExportMonitoredResLabels()
+}

exporter/metric/metric.go

@@ -45,6 +45,7 @@ const (
 
 var (
 	errBlankProjectID = errors.New("expecting a non-blank ProjectID")
+	monitoredResLabelMap = make(map[string]string)
 )
 
 type errUnsupportedAggregation struct {
@@ -127,6 +128,7 @@ func InstallNewPipeline(opts []Option, popts ...push.Option) (*push.Controller,
 // chaining a NewRawExporter into the recommended selectors and integrators.
 func NewExportPipeline(opts []Option, popts ...push.Option) (*push.Controller, error) {
 	selector := simple.NewWithExactDistribution()
+	extractResourceLabels(popts...)
 	exporter, err := NewRawExporter(opts...)
 	if err != nil {
 		return nil, err
@@ -256,6 +258,30 @@ func (me *metricExporter) recordToTspb(r *export.Record, res *resource.Resource)
 	}, nil
 }
 
+// extractResourceLabels extracts resources from the construction option
+func extractResourceLabels(popts ...push.Option) {
+	for _, popt := range popts {
+		var config push.Config
+		popt.Apply(&config)
+		if config.Resource.Len() > 0 {
+			for _, ele := range config.Resource.Attributes() {
+				monitoredResLabelMap[string(ele.Key)] = ele.Value.AsString()
+			}
+		}
+	}
+}
+
+
+// ExportMonitoredResLabels exports the map of monitored resources labels
+func (me *metricExporter) ExportMonitoredResLabels() map[string]string {
+	outputMap :=  make(map[string]string)
+	// Do deep copy to protect the label map
+	for k,v := range monitoredResLabelMap {
+		outputMap[k] = v
+	}
+	return outputMap
+}
+
 // descToMetricType converts descriptor to MetricType proto type.
 // Basically this returns default value ("custom.googleapis.com/opentelemetry/[metric type]")
 func (me *metricExporter) descToMetricType(desc *apimetric.Descriptor) string {

exporter/trace/trace_proto.go

@@ -84,7 +84,7 @@ func protoFromSpanData(s *export.SpanData, projectID string) *tracepb.Span {
 		SameProcessAsParentSpan: &wrapperspb.BoolValue{Value: !s.HasRemoteParent},
 	}
 	if s.ParentSpanID != s.SpanContext.SpanID && s.ParentSpanID.IsValid() {
-		sp.ParentSpanId = fmt.Sprintf("%.16x", s.ParentSpanID)
+		sp.ParentSpanId = s.ParentSpanID.String()
 	}
 	if s.StatusCode != codes.OK {
 		sp.Status = &statuspb.Status{Code: int32(s.StatusCode)}