rename metrics.go to metrics_proto.go. (#107)

census-ecosystem · Mar 18, 2019 · 199f933 · 199f933
1 parent ed9eca6
commit 199f933
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/metrics.go → metrics_proto.go b/metrics.go → metrics_proto.go
@@ -43,7 +43,7 @@ import (
 
 var errNilMetric = errors.New("expecting a non-nil metric")
 
-type metricPayload struct {
+type metricProtoPayload struct {
 	node     *commonpb.Node
 	resource *resourcepb.Resource
 	metric   *metricspb.Metric
@@ -56,7 +56,7 @@ func (se *statsExporter) ExportMetricsProto(ctx context.Context, node *commonpb.
 	}
 
 	for _, metric := range metrics {
-		payload := &metricPayload{
+		payload := &metricProtoPayload{
 			metric:   metric,
 			resource: rsc,
 			node:     node,
@@ -67,7 +67,7 @@ func (se *statsExporter) ExportMetricsProto(ctx context.Context, node *commonpb.
 	return nil
 }
 
-func (se *statsExporter) handleMetricsUpload(payloads []*metricPayload) error {
+func (se *statsExporter) handleMetricsProtoUpload(payloads []*metricProtoPayload) error {
 	ctx, cancel := se.o.newContextWithTimeout()
 	defer cancel()
 

diff --git a/metrics_test.go → metrics_proto_test.go b/metrics_test.go → metrics_proto_test.go
diff --git a/stats.go b/stats.go
@@ -108,9 +108,9 @@ func newStatsExporter(o Options) (*statsExporter, error) {
 		vds := bundle.([]*view.Data)
 		e.handleUpload(vds...)
 	})
-	e.protoMetricsBundler = bundler.NewBundler((*metricPayload)(nil), func(bundle interface{}) {
-		payloads := bundle.([]*metricPayload)
-		e.handleMetricsUpload(payloads)
+	e.protoMetricsBundler = bundler.NewBundler((*metricProtoPayload)(nil), func(bundle interface{}) {
+		payloads := bundle.([]*metricProtoPayload)
+		e.handleMetricsProtoUpload(payloads)
 	})
 	if delayThreshold := e.o.BundleDelayThreshold; delayThreshold > 0 {
 		e.viewDataBundler.DelayThreshold = delayThreshold