exporter/ocagent/transform_stats_to_metrics.go

27 	metricspb "github.com/census-instrumentation/opencensus-proto/gen-go/metrics/v1"  packageName
36 func viewDataToMetric(vd *view.Data) (*metricspb.Metric, error) {
51 	metric := &metricspb.Metric{
58 func viewToMetricDescriptor(v *view.View) (*metricspb.MetricDescriptor, error) {
66 	desc := &metricspb.MetricDescriptor{
102 func aggregationToMetricDescriptorType(v *view.View) metricspb.MetricDescriptor_Type {
104 		return metricspb.MetricDescriptor_UNSPECIFIED
107 		return metricspb.MetricDescriptor_UNSPECIFIED
113 		return metricspb.MetricDescriptor_CUMULATIVE_INT64
117 		return metricspb.MetricDescriptor_CUMULATIVE_DISTRIBUTION
123 			return metricspb.MetricDescriptor_GAUGE_DOUBLE
125 			return metricspb.MetricDescriptor_GAUGE_INT64
132 			return metricspb.MetricDescriptor_CUMULATIVE_DOUBLE
134 			return metricspb.MetricDescriptor_CUMULATIVE_INT64
139 	return metricspb.MetricDescriptor_UNSPECIFIED
142 func tagKeysToLabelKeys(tagKeys []tag.Key) []*metricspb.LabelKey {
143 	labelKeys := make([]*metricspb.LabelKey, 0, len(tagKeys))
145 		labelKeys = append(labelKeys, &metricspb.LabelKey{
152 func viewDataToTimeseries(vd *view.Data) ([]*metricspb.TimeSeries, error) {
165 	timeseries := make([]*metricspb.TimeSeries, 0, len(vd.Rows))
171 		timeseries = append(timeseries, &metricspb.TimeSeries{
174 			Points:         []*metricspb.Point{point},
193 …*view.View, row *view.Row, endTimestamp *timestamp.Timestamp, mType measureType) *metricspb.Point {
194 	pt := &metricspb.Point{
200 		pt.Value = &metricspb.Point_Int64Value{Int64Value: data.Value}
203 		pt.Value = &metricspb.Point_DistributionValue{
204 			DistributionValue: &metricspb.DistributionValue{
209 				BucketOptions: &metricspb.DistributionValue_BucketOptions{
210 					Type: &metricspb.DistributionValue_BucketOptions_Explicit_{
211 						Explicit: &metricspb.DistributionValue_BucketOptions_Explicit{
231 func setPointValue(pt *metricspb.Point, value float64, mType measureType) {
233 		pt.Value = &metricspb.Point_Int64Value{Int64Value: int64(value)}
235 		pt.Value = &metricspb.Point_DoubleValue{DoubleValue: value}
239 func bucketsToProtoBuckets(countPerBucket []int64) []*metricspb.DistributionValue_Bucket {
240 	distBuckets := make([]*metricspb.DistributionValue_Bucket, len(countPerBucket))
244 		distBuckets[i] = &metricspb.DistributionValue_Bucket{
252 func labelValuesFromTags(tags []tag.Tag) []*metricspb.LabelValue {
257 	labelValues := make([]*metricspb.LabelValue, 0, len(tags))
259 		labelValues = append(labelValues, &metricspb.LabelValue{